gio/gdbusauth.c

   1 /* GDBus - GLib D-Bus Library
   2  *
   3  * Copyright (C) 2008-2010 Red Hat, Inc.
   4  *
   5  * This library is free software; you can redistribute it and/or
   6  * modify it under the terms of the GNU Lesser General Public
   7  * License as published by the Free Software Foundation; either
   8  * version 2 of the License, or (at your option) any later version.
   9  *
  10  * This library is distributed in the hope that it will be useful,
  11  * but WITHOUT ANY WARRANTY; without even the implied warranty of
  12  * MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE.  See the GNU
  13  * Lesser General Public License for more details.
  14  *
  15  * You should have received a copy of the GNU Lesser General
  16  * Public License along with this library; if not, write to the
  17  * Free Software Foundation, Inc., 59 Temple Place, Suite 330,
  18  * Boston, MA 02111-1307, USA.
  19  *
  20  * Author: David Zeuthen <davidz@redhat.com>
  21  */
  22
  23 #include "config.h"
  24
  25 #include "gdbusauth.h"
  26
  27 #include "gdbusauthmechanismanon.h"
  28 #include "gdbusauthmechanismexternal.h"
  29 #include "gdbusauthmechanismsha1.h"
  30 #include "gdbusauthobserver.h"
  31
  32 #include "gdbuserror.h"
  33 #include "gdbusutils.h"
  34 #include "gioenumtypes.h"
  35 #include "gcredentials.h"
  36 #include "gdbusprivate.h"
  37 #include "giostream.h"
  38 #include "gdatainputstream.h"
  39 #include "gdataoutputstream.h"
  40
  41 #ifdef G_OS_UNIX
  42 #include <sys/types.h>
  43 #include <sys/socket.h>
  44 #include "gunixconnection.h"
  45 #include "gunixcredentialsmessage.h"
  46 #endif
  47
  48 #include "glibintl.h"
  49
  50 static void
  51 debug_print (const gchar *message, ...)
  52 {
  53   if (G_UNLIKELY (_g_dbus_debug_authentication ()))
  54     {
  55       gchar *s;
  56       GString *str;
  57       va_list var_args;
  58       guint n;
  59
  60       _g_dbus_debug_print_lock ();
  61
  62       va_start (var_args, message);
  63       s = g_strdup_vprintf (message, var_args);
  64       va_end (var_args);
  65
  66       str = g_string_new (NULL);
  67       for (n = 0; s[n] != '\0'; n++)
  68         {
  69           if (G_UNLIKELY (s[n] == '\r'))
  70             g_string_append (str, "\\r");
  71           else if (G_UNLIKELY (s[n] == '\n'))
  72             g_string_append (str, "\\n");
  73           else
  74             g_string_append_c (str, s[n]);
  75         }
  76       g_print ("GDBus-debug:Auth: %s\n", str->str);
  77       g_string_free (str, TRUE);
  78       g_free (s);
  79
  80       _g_dbus_debug_print_unlock ();
  81     }
  82 }
  83
  84 typedef struct
  85 {
  86   const gchar *name;
  87   gint priority;
  88   GType gtype;
  89 } Mechanism;
  90
  91 static void mechanism_free (Mechanism *m);
  92
  93 struct _GDBusAuthPrivate
  94 {
  95   GIOStream *stream;
  96
  97   /* A list of available Mechanism, sorted according to priority  */
  98   GList *available_mechanisms;
  99 };
 100
 101 enum
 102 {
 103   PROP_0,
 104   PROP_STREAM
 105 };
 106
 107 G_DEFINE_TYPE (GDBusAuth, _g_dbus_auth, G_TYPE_OBJECT);
 108
 109 /* ---------------------------------------------------------------------------------------------------- */
 110
 111 static void
 112 _g_dbus_auth_finalize (GObject *object)
 113 {
 114   GDBusAuth *auth = G_DBUS_AUTH (object);
 115
 116   if (auth->priv->stream != NULL)
 117     g_object_unref (auth->priv->stream);
 118   g_list_foreach (auth->priv->available_mechanisms, (GFunc) mechanism_free, NULL);
 119   g_list_free (auth->priv->available_mechanisms);
 120
 121   if (G_OBJECT_CLASS (_g_dbus_auth_parent_class)->finalize != NULL)
 122     G_OBJECT_CLASS (_g_dbus_auth_parent_class)->finalize (object);
 123 }
 124
 125 static void
 126 _g_dbus_auth_get_property (GObject    *object,
 127                            guint       prop_id,
 128                            GValue     *value,
 129                            GParamSpec *pspec)
 130 {
 131   GDBusAuth *auth = G_DBUS_AUTH (object);
 132
 133   switch (prop_id)
 134     {
 135     case PROP_STREAM:
 136       g_value_set_object (value, auth->priv->stream);
 137       break;
 138
 139     default:
 140       G_OBJECT_WARN_INVALID_PROPERTY_ID (object, prop_id, pspec);
 141       break;
 142     }
 143 }
 144
 145 static void
 146 _g_dbus_auth_set_property (GObject      *object,
 147                            guint         prop_id,
 148                            const GValue *value,
 149                            GParamSpec   *pspec)
 150 {
 151   GDBusAuth *auth = G_DBUS_AUTH (object);
 152
 153   switch (prop_id)
 154     {
 155     case PROP_STREAM:
 156       auth->priv->stream = g_value_dup_object (value);
 157       break;
 158
 159     default:
 160       G_OBJECT_WARN_INVALID_PROPERTY_ID (object, prop_id, pspec);
 161       break;
 162     }
 163 }
 164
 165 static void
 166 _g_dbus_auth_class_init (GDBusAuthClass *klass)
 167 {
 168   GObjectClass *gobject_class;
 169
 170   g_type_class_add_private (klass, sizeof (GDBusAuthPrivate));
 171
 172   gobject_class = G_OBJECT_CLASS (klass);
 173   gobject_class->get_property = _g_dbus_auth_get_property;
 174   gobject_class->set_property = _g_dbus_auth_set_property;
 175   gobject_class->finalize     = _g_dbus_auth_finalize;
 176
 177   g_object_class_install_property (gobject_class,
 178                                    PROP_STREAM,
 179                                    g_param_spec_object ("stream",
 180                                                         P_("IO Stream"),
 181                                                         P_("The underlying GIOStream used for I/O"),
 182                                                         G_TYPE_IO_STREAM,
 183                                                         G_PARAM_READABLE |
 184                                                         G_PARAM_WRITABLE |
 185                                                         G_PARAM_CONSTRUCT_ONLY |
 186                                                         G_PARAM_STATIC_NAME |
 187                                                         G_PARAM_STATIC_BLURB |
 188                                                         G_PARAM_STATIC_NICK));
 189 }
 190
 191 static void
 192 mechanism_free (Mechanism *m)
 193 {
 194   g_free (m);
 195 }
 196
 197 static void
 198 add_mechanism (GDBusAuth *auth,
 199                GType      mechanism_type)
 200 {
 201   Mechanism *m;
 202
 203   m = g_new0 (Mechanism, 1);
 204   m->name = _g_dbus_auth_mechanism_get_name (mechanism_type);
 205   m->priority = _g_dbus_auth_mechanism_get_priority (mechanism_type);
 206   m->gtype = mechanism_type;
 207
 208   auth->priv->available_mechanisms = g_list_prepend (auth->priv->available_mechanisms, m);
 209 }
 210
 211 static gint
 212 mech_compare_func (Mechanism *a, Mechanism *b)
 213 {
 214   gint ret;
 215   /* ensure deterministic order */
 216   ret = b->priority - a->priority;
 217   if (ret == 0)
 218     ret = g_strcmp0 (b->name, a->name);
 219   return ret;
 220 }
 221
 222 static void
 223 _g_dbus_auth_init (GDBusAuth *auth)
 224 {
 225   auth->priv = G_TYPE_INSTANCE_GET_PRIVATE (auth, G_TYPE_DBUS_AUTH, GDBusAuthPrivate);
 226
 227   /* TODO: trawl extension points */
 228   add_mechanism (auth, G_TYPE_DBUS_AUTH_MECHANISM_ANON);
 229   add_mechanism (auth, G_TYPE_DBUS_AUTH_MECHANISM_SHA1);
 230   add_mechanism (auth, G_TYPE_DBUS_AUTH_MECHANISM_EXTERNAL);
 231
 232   auth->priv->available_mechanisms = g_list_sort (auth->priv->available_mechanisms,
 233                                                   (GCompareFunc) mech_compare_func);
 234 }
 235
 236 static GType
 237 find_mech_by_name (GDBusAuth *auth,
 238                    const gchar *name)
 239 {
 240   GType ret;
 241   GList *l;
 242
 243   ret = (GType) 0;
 244
 245   for (l = auth->priv->available_mechanisms; l != NULL; l = l->next)
 246     {
 247       Mechanism *m = l->data;
 248       if (g_strcmp0 (name, m->name) == 0)
 249         {
 250           ret = m->gtype;
 251           goto out;
 252         }
 253     }
 254
 255  out:
 256   return ret;
 257 }
 258
 259 GDBusAuth  *
 260 _g_dbus_auth_new (GIOStream *stream)
 261 {
 262   return g_object_new (G_TYPE_DBUS_AUTH,
 263                        "stream", stream,
 264                        NULL);
 265 }
 266
 267 /* ---------------------------------------------------------------------------------------------------- */
 268 /* like g_data_input_stream_read_line() but sets error if there's no content to read */
 269 static gchar *
 270 _my_g_data_input_stream_read_line (GDataInputStream  *dis,
 271                                    gsize             *out_line_length,
 272                                    GCancellable      *cancellable,
 273                                    GError           **error)
 274 {
 275   gchar *ret;
 276
 277   g_return_val_if_fail (error == NULL || *error == NULL, NULL);
 278
 279   ret = g_data_input_stream_read_line (dis,
 280                                        out_line_length,
 281                                        cancellable,
 282                                        error);
 283   if (ret == NULL && error != NULL && *error == NULL)
 284     {
 285       g_set_error_literal (error,
 286                            G_IO_ERROR,
 287                            G_IO_ERROR_FAILED,
 288                            _("Unexpected lack of content trying to read a line"));
 289     }
 290
 291   return ret;
 292 }
 293
 294 /* This function is to avoid situations like this
 295  *
 296  * BEGIN\r\nl\0\0\1...
 297  *
 298  * e.g. where we read into the first D-Bus message while waiting for
 299  * the final line from the client (TODO: file bug against gio for
 300  * this)
 301  */
 302 static gchar *
 303 _my_g_input_stream_read_line_safe (GInputStream  *i,
 304                                    gsize         *out_line_length,
 305                                    GCancellable  *cancellable,
 306                                    GError       **error)
 307 {
 308   GString *str;
 309   gchar c;
 310   gssize num_read;
 311   gboolean last_was_cr;
 312
 313   str = g_string_new (NULL);
 314
 315   last_was_cr = FALSE;
 316   while (TRUE)
 317     {
 318       num_read = g_input_stream_read (i,
 319                                       &c,
 320                                       1,
 321                                       cancellable,
 322                                       error);
 323       if (num_read == -1)
 324         goto fail;
 325       if (num_read == 0)
 326         {
 327           if (error != NULL && *error == NULL)
 328             {
 329               g_set_error_literal (error,
 330                                    G_IO_ERROR,
 331                                    G_IO_ERROR_FAILED,
 332                                    _("Unexpected lack of content trying to (safely) read a line"));
 333             }
 334           goto fail;
 335         }
 336
 337       g_string_append_c (str, (gint) c);
 338       if (last_was_cr)
 339         {
 340           if (c == 0x0a)
 341             {
 342               g_assert (str->len >= 2);
 343               g_string_set_size (str, str->len - 2);
 344               goto out;
 345             }
 346         }
 347       last_was_cr = (c == 0x0d);
 348     }
 349
 350  out:
 351   if (out_line_length != NULL)
 352     *out_line_length = str->len;
 353   return g_string_free (str, FALSE);
 354
 355  fail:
 356   g_assert (error == NULL || *error != NULL);
 357   g_string_free (str, TRUE);
 358   return NULL;
 359 }
 360
 361 /* ---------------------------------------------------------------------------------------------------- */
 362
 363 static void
 364 append_nibble (GString *s, gint val)
 365 {
 366   g_string_append_c (s, val >= 10 ? ('a' + val - 10) : ('0' + val));
 367 }
 368
 369 static gchar *
 370 hexdecode (const gchar  *str,
 371            gsize        *out_len,
 372            GError      **error)
 373 {
 374   gchar *ret;
 375   GString *s;
 376   guint n;
 377
 378   ret = NULL;
 379   s = g_string_new (NULL);
 380
 381   for (n = 0; str[n] != '\0'; n += 2)
 382     {
 383       gint upper_nibble;
 384       gint lower_nibble;
 385       guint value;
 386
 387       upper_nibble = g_ascii_xdigit_value (str[n]);
 388       lower_nibble = g_ascii_xdigit_value (str[n + 1]);
 389       if (upper_nibble == -1 || lower_nibble == -1)
 390         {
 391           g_set_error (error,
 392                        G_IO_ERROR,
 393                        G_IO_ERROR_FAILED,
 394                        "Error hexdecoding string `%s' around position %d",
 395                        str, n);
 396           goto out;
 397         }
 398       value = (upper_nibble<<4) | lower_nibble;
 399       g_string_append_c (s, value);
 400     }
 401
 402   ret = g_string_free (s, FALSE);
 403   s = NULL;
 404
 405  out:
 406   if (s != NULL)
 407     g_string_free (s, TRUE);
 408   return ret;
 409 }
 410
 411 /* TODO: take len */
 412 static gchar *
 413 hexencode (const gchar *str)
 414 {
 415   guint n;
 416   GString *s;
 417
 418   s = g_string_new (NULL);
 419   for (n = 0; str[n] != '\0'; n++)
 420     {
 421       gint val;
 422       gint upper_nibble;
 423       gint lower_nibble;
 424
 425       val = ((const guchar *) str)[n];
 426       upper_nibble = val >> 4;
 427       lower_nibble = val & 0x0f;
 428
 429       append_nibble (s, upper_nibble);
 430       append_nibble (s, lower_nibble);
 431     }
 432
 433   return g_string_free (s, FALSE);
 434 }
 435
 436 /* ---------------------------------------------------------------------------------------------------- */
 437
 438 static GDBusAuthMechanism *
 439 client_choose_mech_and_send_initial_response (GDBusAuth           *auth,
 440                                               GCredentials        *credentials_that_were_sent,
 441                                               const gchar* const  *supported_auth_mechs,
 442                                               GPtrArray           *attempted_auth_mechs,
 443                                               GDataOutputStream   *dos,
 444                                               GCancellable        *cancellable,
 445                                               GError             **error)
 446 {
 447   GDBusAuthMechanism *mech;
 448   GType auth_mech_to_use_gtype;
 449   guint n;
 450   guint m;
 451   gchar *initial_response;
 452   gsize initial_response_len;
 453   gchar *encoded;
 454   gchar *s;
 455
 456  again:
 457   mech = NULL;
 458
 459   debug_print ("CLIENT: Trying to choose mechanism");
 460
 461   /* find an authentication mechanism to try, if any */
 462   auth_mech_to_use_gtype = (GType) 0;
 463   for (n = 0; supported_auth_mechs[n] != NULL; n++)
 464     {
 465       gboolean attempted_already;
 466       attempted_already = FALSE;
 467       for (m = 0; m < attempted_auth_mechs->len; m++)
 468         {
 469           if (g_strcmp0 (supported_auth_mechs[n], attempted_auth_mechs->pdata[m]) == 0)
 470             {
 471               attempted_already = TRUE;
 472               break;
 473             }
 474         }
 475       if (!attempted_already)
 476         {
 477           auth_mech_to_use_gtype = find_mech_by_name (auth, supported_auth_mechs[n]);
 478           if (auth_mech_to_use_gtype != (GType) 0)
 479             break;
 480         }
 481     }
 482
 483   if (auth_mech_to_use_gtype == (GType) 0)
 484     {
 485       guint n;
 486       gchar *available;
 487       GString *tried_str;
 488
 489       debug_print ("CLIENT: Exhausted all available mechanisms");
 490
 491       available = g_strjoinv (", ", (gchar **) supported_auth_mechs);
 492
 493       tried_str = g_string_new (NULL);
 494       for (n = 0; n < attempted_auth_mechs->len; n++)
 495         {
 496           if (n > 0)
 497             g_string_append (tried_str, ", ");
 498           g_string_append (tried_str, attempted_auth_mechs->pdata[n]);
 499         }
 500       g_set_error (error,
 501                    G_IO_ERROR,
 502                    G_IO_ERROR_FAILED,
 503                    _("Exhausted all available authentication mechanisms (tried: %s) (available: %s)"),
 504                    tried_str->str,
 505                    available);
 506       g_string_free (tried_str, TRUE);
 507       g_free (available);
 508       goto out;
 509     }
 510
 511   /* OK, decided on a mechanism - let's do this thing */
 512   mech = g_object_new (auth_mech_to_use_gtype,
 513                        "stream", auth->priv->stream,
 514                        "credentials", credentials_that_were_sent,
 515                        NULL);
 516   debug_print ("CLIENT: Trying mechanism `%s'", _g_dbus_auth_mechanism_get_name (auth_mech_to_use_gtype));
 517   g_ptr_array_add (attempted_auth_mechs, (gpointer) _g_dbus_auth_mechanism_get_name (auth_mech_to_use_gtype));
 518
 519   /* the auth mechanism may not be supported
 520    * (for example, EXTERNAL only works if credentials were exchanged)
 521    */
 522   if (!_g_dbus_auth_mechanism_is_supported (mech))
 523     {
 524       debug_print ("CLIENT: Mechanism `%s' says it is not supported", _g_dbus_auth_mechanism_get_name (auth_mech_to_use_gtype));
 525       g_object_unref (mech);
 526       mech = NULL;
 527       goto again;
 528     }
 529
 530   initial_response_len = -1;
 531   initial_response = _g_dbus_auth_mechanism_client_initiate (mech,
 532                                                              &initial_response_len);
 533 #if 0
 534   g_printerr ("using auth mechanism with name `%s' of type `%s' with initial response `%s'\n",
 535               _g_dbus_auth_mechanism_get_name (auth_mech_to_use_gtype),
 536               g_type_name (G_TYPE_FROM_INSTANCE (mech)),
 537               initial_response);
 538 #endif
 539   if (initial_response != NULL)
 540     {
 541       //g_printerr ("initial_response = `%s'\n", initial_response);
 542       encoded = hexencode (initial_response);
 543       s = g_strdup_printf ("AUTH %s %s\r\n",
 544                            _g_dbus_auth_mechanism_get_name (auth_mech_to_use_gtype),
 545                            encoded);
 546       g_free (initial_response);
 547       g_free (encoded);
 548     }
 549   else
 550     {
 551       s = g_strdup_printf ("AUTH %s\r\n", _g_dbus_auth_mechanism_get_name (auth_mech_to_use_gtype));
 552     }
 553   debug_print ("CLIENT: writing `%s'", s);
 554   if (!g_data_output_stream_put_string (dos, s, cancellable, error))
 555     {
 556       g_object_unref (mech);
 557       mech = NULL;
 558       g_free (s);
 559       goto out;
 560     }
 561   g_free (s);
 562
 563  out:
 564   return mech;
 565 }
 566
 567
 568 /* ---------------------------------------------------------------------------------------------------- */
 569
 570 typedef enum
 571 {
 572   CLIENT_STATE_WAITING_FOR_DATA,
 573   CLIENT_STATE_WAITING_FOR_OK,
 574   CLIENT_STATE_WAITING_FOR_REJECT,
 575   CLIENT_STATE_WAITING_FOR_AGREE_UNIX_FD
 576 } ClientState;
 577
 578 gchar *
 579 _g_dbus_auth_run_client (GDBusAuth     *auth,
 580                          GDBusCapabilityFlags offered_capabilities,
 581                          GDBusCapabilityFlags *out_negotiated_capabilities,
 582                          GCancellable  *cancellable,
 583                          GError       **error)
 584 {
 585   gchar *s;
 586   GDataInputStream *dis;
 587   GDataOutputStream *dos;
 588   GCredentials *credentials;
 589   gchar *ret_guid;
 590   gchar *line;
 591   gsize line_length;
 592   gchar **supported_auth_mechs;
 593   GPtrArray *attempted_auth_mechs;
 594   GDBusAuthMechanism *mech;
 595   ClientState state;
 596   GDBusCapabilityFlags negotiated_capabilities;
 597
 598   debug_print ("CLIENT: initiating");
 599
 600   ret_guid = NULL;
 601   supported_auth_mechs = NULL;
 602   attempted_auth_mechs = g_ptr_array_new ();
 603   mech = NULL;
 604   negotiated_capabilities = 0;
 605   credentials = NULL;
 606
 607   dis = G_DATA_INPUT_STREAM (g_data_input_stream_new (g_io_stream_get_input_stream (auth->priv->stream)));
 608   dos = G_DATA_OUTPUT_STREAM (g_data_output_stream_new (g_io_stream_get_output_stream (auth->priv->stream)));
 609   g_filter_input_stream_set_close_base_stream (G_FILTER_INPUT_STREAM (dis), FALSE);
 610   g_filter_output_stream_set_close_base_stream (G_FILTER_OUTPUT_STREAM (dos), FALSE);
 611
 612   g_data_input_stream_set_newline_type (dis, G_DATA_STREAM_NEWLINE_TYPE_CR_LF);
 613
 614 #ifdef G_OS_UNIX
 615   if (G_IS_UNIX_CONNECTION (auth->priv->stream) && g_unix_credentials_message_is_supported ())
 616     {
 617       credentials = g_credentials_new ();
 618       if (!g_unix_connection_send_credentials (G_UNIX_CONNECTION (auth->priv->stream),
 619                                                cancellable,
 620                                                error))
 621         goto out;
 622     }
 623   else
 624     {
 625       if (!g_data_output_stream_put_byte (dos, '\0', cancellable, error))
 626         goto out;
 627     }
 628 #else
 629   if (!g_data_output_stream_put_byte (dos, '\0', cancellable, error))
 630     goto out;
 631 #endif
 632
 633   if (credentials != NULL)
 634     {
 635       if (G_UNLIKELY (_g_dbus_debug_authentication ()))
 636         {
 637           s = g_credentials_to_string (credentials);
 638           debug_print ("CLIENT: sent credentials `%s'", s);
 639           g_free (s);
 640         }
 641     }
 642   else
 643     {
 644       debug_print ("CLIENT: didn't send any credentials");
 645     }
 646
 647   /* TODO: to reduce roundtrips, try to pick an auth mechanism to start with */
 648
 649   /* Get list of supported authentication mechanisms */
 650   s = "AUTH\r\n";
 651   debug_print ("CLIENT: writing `%s'", s);
 652   if (!g_data_output_stream_put_string (dos, s, cancellable, error))
 653     goto out;
 654   state = CLIENT_STATE_WAITING_FOR_REJECT;
 655
 656   while (TRUE)
 657     {
 658       switch (state)
 659         {
 660         case CLIENT_STATE_WAITING_FOR_REJECT:
 661           debug_print ("CLIENT: WaitingForReject");
 662           line = _my_g_data_input_stream_read_line (dis, &line_length, cancellable, error);
 663           if (line == NULL)
 664             goto out;
 665           debug_print ("CLIENT: WaitingForReject, read '%s'", line);
 666         foobar:
 667           if (!g_str_has_prefix (line, "REJECTED "))
 668             {
 669               g_set_error (error,
 670                            G_IO_ERROR,
 671                            G_IO_ERROR_FAILED,
 672                            "In WaitingForReject: Expected `REJECTED am1 am2 ... amN', got `%s'",
 673                            line);
 674               g_free (line);
 675               goto out;
 676             }
 677           if (supported_auth_mechs == NULL)
 678             {
 679               supported_auth_mechs = g_strsplit (line + sizeof ("REJECTED ") - 1, " ", 0);
 680 #if 0
 681               for (n = 0; supported_auth_mechs != NULL && supported_auth_mechs[n] != NULL; n++)
 682                 g_printerr ("supported_auth_mechs[%d] = `%s'\n", n, supported_auth_mechs[n]);
 683 #endif
 684             }
 685           g_free (line);
 686           mech = client_choose_mech_and_send_initial_response (auth,
 687                                                                credentials,
 688                                                                (const gchar* const *) supported_auth_mechs,
 689                                                                attempted_auth_mechs,
 690                                                                dos,
 691                                                                cancellable,
 692                                                                error);
 693           if (mech == NULL)
 694             goto out;
 695           if (_g_dbus_auth_mechanism_client_get_state (mech) == G_DBUS_AUTH_MECHANISM_STATE_WAITING_FOR_DATA)
 696             state = CLIENT_STATE_WAITING_FOR_DATA;
 697           else
 698             state = CLIENT_STATE_WAITING_FOR_OK;
 699           break;
 700
 701         case CLIENT_STATE_WAITING_FOR_OK:
 702           debug_print ("CLIENT: WaitingForOK");
 703           line = _my_g_data_input_stream_read_line (dis, &line_length, cancellable, error);
 704           if (line == NULL)
 705             goto out;
 706           debug_print ("CLIENT: WaitingForOK, read `%s'", line);
 707           if (g_str_has_prefix (line, "OK "))
 708             {
 709               if (!g_dbus_is_guid (line + 3))
 710                 {
 711                   g_set_error (error,
 712                                G_IO_ERROR,
 713                                G_IO_ERROR_FAILED,
 714                                "Invalid OK response `%s'",
 715                                line);
 716                   g_free (line);
 717                   goto out;
 718                 }
 719               ret_guid = g_strdup (line + 3);
 720               g_free (line);
 721
 722               if (offered_capabilities & G_DBUS_CAPABILITY_FLAGS_UNIX_FD_PASSING)
 723                 {
 724                   s = "NEGOTIATE_UNIX_FD\r\n";
 725                   debug_print ("CLIENT: writing `%s'", s);
 726                   if (!g_data_output_stream_put_string (dos, s, cancellable, error))
 727                     goto out;
 728                   state = CLIENT_STATE_WAITING_FOR_AGREE_UNIX_FD;
 729                 }
 730               else
 731                 {
 732                   s = "BEGIN\r\n";
 733                   debug_print ("CLIENT: writing `%s'", s);
 734                   if (!g_data_output_stream_put_string (dos, s, cancellable, error))
 735                     goto out;
 736                   /* and we're done! */
 737                   goto out;
 738                 }
 739             }
 740           else if (g_str_has_prefix (line, "REJECTED "))
 741             {
 742               goto foobar;
 743             }
 744           else
 745             {
 746               /* TODO: handle other valid responses */
 747               g_set_error (error,
 748                            G_IO_ERROR,
 749                            G_IO_ERROR_FAILED,
 750                            "In WaitingForOk: unexpected response `%s'",
 751                            line);
 752               g_free (line);
 753               goto out;
 754             }
 755           break;
 756
 757         case CLIENT_STATE_WAITING_FOR_AGREE_UNIX_FD:
 758           debug_print ("CLIENT: WaitingForAgreeUnixFD");
 759           line = _my_g_data_input_stream_read_line (dis, &line_length, cancellable, error);
 760           if (line == NULL)
 761             goto out;
 762           debug_print ("CLIENT: WaitingForAgreeUnixFD, read=`%s'", line);
 763           if (g_strcmp0 (line, "AGREE_UNIX_FD") == 0)
 764             {
 765               g_free (line);
 766               negotiated_capabilities |= G_DBUS_CAPABILITY_FLAGS_UNIX_FD_PASSING;
 767               s = "BEGIN\r\n";
 768               debug_print ("CLIENT: writing `%s'", s);
 769               if (!g_data_output_stream_put_string (dos, s, cancellable, error))
 770                 goto out;
 771               /* and we're done! */
 772               goto out;
 773             }
 774           else if (g_str_has_prefix (line, "ERROR") && (line[5] == 0 || g_ascii_isspace (line[5])))
 775             {
 776               //g_strstrip (line + 5); g_debug ("bah, no unix_fd: `%s'", line + 5);
 777               g_free (line);
 778               s = "BEGIN\r\n";
 779               debug_print ("CLIENT: writing `%s'", s);
 780               if (!g_data_output_stream_put_string (dos, s, cancellable, error))
 781                 goto out;
 782               /* and we're done! */
 783               goto out;
 784             }
 785           else
 786             {
 787               /* TODO: handle other valid responses */
 788               g_set_error (error,
 789                            G_IO_ERROR,
 790                            G_IO_ERROR_FAILED,
 791                            "In WaitingForAgreeUnixFd: unexpected response `%s'",
 792                            line);
 793               g_free (line);
 794               goto out;
 795             }
 796           break;
 797
 798         case CLIENT_STATE_WAITING_FOR_DATA:
 799           debug_print ("CLIENT: WaitingForData");
 800           line = _my_g_data_input_stream_read_line (dis, &line_length, cancellable, error);
 801           if (line == NULL)
 802             goto out;
 803           debug_print ("CLIENT: WaitingForData, read=`%s'", line);
 804           if (g_str_has_prefix (line, "DATA "))
 805             {
 806               gchar *encoded;
 807               gchar *decoded_data;
 808               gsize decoded_data_len = 0;
 809
 810               encoded = g_strdup (line + 5);
 811               g_free (line);
 812               g_strstrip (encoded);
 813               decoded_data = hexdecode (encoded, &decoded_data_len, error);
 814               g_free (encoded);
 815               if (decoded_data == NULL)
 816                 {
 817                   g_prefix_error (error, "DATA response is malformed: ");
 818                   /* invalid encoding, disconnect! */
 819                   goto out;
 820                 }
 821               _g_dbus_auth_mechanism_client_data_receive (mech, decoded_data, decoded_data_len);
 822               g_free (decoded_data);
 823
 824               if (_g_dbus_auth_mechanism_client_get_state (mech) == G_DBUS_AUTH_MECHANISM_STATE_HAVE_DATA_TO_SEND)
 825                 {
 826                   gchar *data;
 827                   gsize data_len;
 828                   gchar *encoded_data;
 829                   data = _g_dbus_auth_mechanism_client_data_send (mech, &data_len);
 830                   encoded_data = hexencode (data);
 831                   s = g_strdup_printf ("DATA %s\r\n", encoded_data);
 832                   g_free (encoded_data);
 833                   g_free (data);
 834                   debug_print ("CLIENT: writing `%s'", s);
 835                   if (!g_data_output_stream_put_string (dos, s, cancellable, error))
 836                     {
 837                       g_free (s);
 838                       goto out;
 839                     }
 840                   g_free (s);
 841                 }
 842               state = CLIENT_STATE_WAITING_FOR_OK;
 843             }
 844           else
 845             {
 846               g_set_error (error,
 847                            G_IO_ERROR,
 848                            G_IO_ERROR_FAILED,
 849                            "In WaitingForData: unexpected response `%s'",
 850                            line);
 851               g_free (line);
 852               goto out;
 853             }
 854           break;
 855
 856         default:
 857           g_assert_not_reached ();
 858           break;
 859         }
 860
 861     }; /* main authentication client loop */
 862
 863  out:
 864   if (mech != NULL)
 865     g_object_unref (mech);
 866   g_ptr_array_unref (attempted_auth_mechs);
 867   g_strfreev (supported_auth_mechs);
 868   g_object_unref (dis);
 869   g_object_unref (dos);
 870
 871   /* ensure return value is NULL if error is set */
 872   if (error != NULL && *error != NULL)
 873     {
 874       g_free (ret_guid);
 875       ret_guid = NULL;
 876     }
 877
 878   if (ret_guid != NULL)
 879     {
 880       if (out_negotiated_capabilities != NULL)
 881         *out_negotiated_capabilities = negotiated_capabilities;
 882     }
 883
 884   if (credentials != NULL)
 885     g_object_unref (credentials);
 886
 887   debug_print ("CLIENT: Done, authenticated=%d", ret_guid != NULL);
 888
 889   return ret_guid;
 890 }
 891
 892 /* ---------------------------------------------------------------------------------------------------- */
 893
 894 static gchar *
 895 get_auth_mechanisms (GDBusAuth     *auth,
 896                      gboolean       allow_anonymous,
 897                      const gchar   *prefix,
 898                      const gchar   *suffix,
 899                      const gchar   *separator)
 900 {
 901   GList *l;
 902   GString *str;
 903   gboolean need_sep;
 904
 905   str = g_string_new (prefix);
 906   need_sep = FALSE;
 907   for (l = auth->priv->available_mechanisms; l != NULL; l = l->next)
 908     {
 909       Mechanism *m = l->data;
 910
 911       if (!allow_anonymous && g_strcmp0 (m->name, "ANONYMOUS") == 0)
 912         continue;
 913
 914       if (need_sep)
 915         g_string_append (str, separator);
 916       g_string_append (str, m->name);
 917       need_sep = TRUE;
 918     }
 919
 920   g_string_append (str, suffix);
 921   return g_string_free (str, FALSE);
 922 }
 923
 924
 925 typedef enum
 926 {
 927   SERVER_STATE_WAITING_FOR_AUTH,
 928   SERVER_STATE_WAITING_FOR_DATA,
 929   SERVER_STATE_WAITING_FOR_BEGIN
 930 } ServerState;
 931
 932 gboolean
 933 _g_dbus_auth_run_server (GDBusAuth              *auth,
 934                          GDBusAuthObserver      *observer,
 935                          const gchar            *guid,
 936                          gboolean                allow_anonymous,
 937                          GDBusCapabilityFlags    offered_capabilities,
 938                          GDBusCapabilityFlags   *out_negotiated_capabilities,
 939                          GCredentials          **out_received_credentials,
 940                          GCancellable           *cancellable,
 941                          GError                **error)
 942 {
 943   gboolean ret;
 944   ServerState state;
 945   GDataInputStream *dis;
 946   GDataOutputStream *dos;
 947   GError *local_error;
 948   guchar byte;
 949   gchar *line;
 950   gsize line_length;
 951   GDBusAuthMechanism *mech;
 952   gchar *s;
 953   GDBusCapabilityFlags negotiated_capabilities;
 954   GCredentials *credentials;
 955
 956   debug_print ("SERVER: initiating");
 957
 958   ret = FALSE;
 959   dis = NULL;
 960   dos = NULL;
 961   mech = NULL;
 962   negotiated_capabilities = 0;
 963   credentials = NULL;
 964
 965   if (!g_dbus_is_guid (guid))
 966     {
 967       g_set_error (error,
 968                    G_IO_ERROR,
 969                    G_IO_ERROR_FAILED,
 970                    "The given guid `%s' is not valid",
 971                    guid);
 972       goto out;
 973     }
 974
 975   dis = G_DATA_INPUT_STREAM (g_data_input_stream_new (g_io_stream_get_input_stream (auth->priv->stream)));
 976   dos = G_DATA_OUTPUT_STREAM (g_data_output_stream_new (g_io_stream_get_output_stream (auth->priv->stream)));
 977   g_filter_input_stream_set_close_base_stream (G_FILTER_INPUT_STREAM (dis), FALSE);
 978   g_filter_output_stream_set_close_base_stream (G_FILTER_OUTPUT_STREAM (dos), FALSE);
 979
 980   g_data_input_stream_set_newline_type (dis, G_DATA_STREAM_NEWLINE_TYPE_CR_LF);
 981
 982   /* first read the NUL-byte (TODO: read credentials if using a unix domain socket) */
 983 #ifdef G_OS_UNIX
 984   if (G_IS_UNIX_CONNECTION (auth->priv->stream) && g_unix_credentials_message_is_supported ())
 985     {
 986       local_error = NULL;
 987       credentials = g_unix_connection_receive_credentials (G_UNIX_CONNECTION (auth->priv->stream),
 988                                                            cancellable,
 989                                                            &local_error);
 990       if (credentials == NULL)
 991         {
 992           g_propagate_error (error, local_error);
 993           goto out;
 994         }
 995     }
 996   else
 997     {
 998       local_error = NULL;
 999       byte = g_data_input_stream_read_byte (dis, cancellable, &local_error);
1000       byte = byte; /* To avoid -Wunused-but-set-variable */
1001       if (local_error != NULL)
1002         {
1003           g_propagate_error (error, local_error);
1004           goto out;
1005         }
1006     }
1007 #else
1008   local_error = NULL;
1009   byte = g_data_input_stream_read_byte (dis, cancellable, &local_error);
1010   if (local_error != NULL)
1011     {
1012       g_propagate_error (error, local_error);
1013       goto out;
1014     }
1015 #endif
1016   if (credentials != NULL)
1017     {
1018       if (G_UNLIKELY (_g_dbus_debug_authentication ()))
1019         {
1020           s = g_credentials_to_string (credentials);
1021           debug_print ("SERVER: received credentials `%s'", s);
1022           g_free (s);
1023         }
1024     }
1025   else
1026     {
1027       debug_print ("SERVER: didn't receive any credentials");
1028     }
1029
1030   state = SERVER_STATE_WAITING_FOR_AUTH;
1031   while (TRUE)
1032     {
1033       switch (state)
1034         {
1035         case SERVER_STATE_WAITING_FOR_AUTH:
1036           debug_print ("SERVER: WaitingForAuth");
1037           line = _my_g_data_input_stream_read_line (dis, &line_length, cancellable, error);
1038           debug_print ("SERVER: WaitingForAuth, read `%s'", line);
1039           if (line == NULL)
1040             goto out;
1041           if (g_strcmp0 (line, "AUTH") == 0)
1042             {
1043               s = get_auth_mechanisms (auth, allow_anonymous, "REJECTED ", "\r\n", " ");
1044               debug_print ("SERVER: writing `%s'", s);
1045               if (!g_data_output_stream_put_string (dos, s, cancellable, error))
1046                 {
1047                   g_free (s);
1048                   goto out;
1049                 }
1050               g_free (s);
1051               g_free (line);
1052             }
1053           else if (g_str_has_prefix (line, "AUTH "))
1054             {
1055               gchar **tokens;
1056               const gchar *encoded;
1057               const gchar *mech_name;
1058               GType auth_mech_to_use_gtype;
1059
1060               tokens = g_strsplit (line, " ", 0);
1061               g_free (line);
1062
1063               switch (g_strv_length (tokens))
1064                 {
1065                 case 2:
1066                   /* no initial response */
1067                   mech_name = tokens[1];
1068                   encoded = NULL;
1069                   break;
1070
1071                 case 3:
1072                   /* initial response */
1073                   mech_name = tokens[1];
1074                   encoded = tokens[2];
1075                   break;
1076
1077                 default:
1078                   g_set_error (error,
1079                                G_IO_ERROR,
1080                                G_IO_ERROR_FAILED,
1081                                "Unexpected line `%s' while in WaitingForAuth state",
1082                                line);
1083                   g_strfreev (tokens);
1084                   goto out;
1085                 }
1086
1087               /* TODO: record that the client has attempted to use this mechanism */
1088               //g_debug ("client is trying `%s'", mech_name);
1089
1090               auth_mech_to_use_gtype = find_mech_by_name (auth, mech_name);
1091               if ((auth_mech_to_use_gtype == (GType) 0) ||
1092                   (!allow_anonymous && g_strcmp0 (mech_name, "ANONYMOUS") == 0))
1093                 {
1094                   /* We don't support this auth mechanism */
1095                   g_strfreev (tokens);
1096                   s = get_auth_mechanisms (auth, allow_anonymous, "REJECTED ", "\r\n", " ");
1097                   debug_print ("SERVER: writing `%s'", s);
1098                   if (!g_data_output_stream_put_string (dos, s, cancellable, error))
1099                     {
1100                       g_free (s);
1101                       goto out;
1102                     }
1103                   g_free (s);
1104
1105                   /* stay in WAITING FOR AUTH */
1106                   state = SERVER_STATE_WAITING_FOR_AUTH;
1107                 }
1108               else
1109                 {
1110                   gchar *initial_response;
1111                   gsize initial_response_len;
1112
1113                   mech = g_object_new (auth_mech_to_use_gtype,
1114                                        "stream", auth->priv->stream,
1115                                        "credentials", credentials,
1116                                        NULL);
1117
1118                   initial_response = NULL;
1119                   initial_response_len = 0;
1120                   if (encoded != NULL)
1121                     {
1122                       initial_response = hexdecode (encoded, &initial_response_len, error);
1123                       if (initial_response == NULL)
1124                         {
1125                           g_prefix_error (error, "Initial response is malformed: ");
1126                           /* invalid encoding, disconnect! */
1127                           g_strfreev (tokens);
1128                           goto out;
1129                         }
1130                     }
1131
1132                   _g_dbus_auth_mechanism_server_initiate (mech,
1133                                                           initial_response,
1134                                                           initial_response_len);
1135                   g_free (initial_response);
1136                   g_strfreev (tokens);
1137
1138                 change_state:
1139                   switch (_g_dbus_auth_mechanism_server_get_state (mech))
1140                     {
1141                     case G_DBUS_AUTH_MECHANISM_STATE_ACCEPTED:
1142                       if (observer != NULL &&
1143                           !g_dbus_auth_observer_authorize_authenticated_peer (observer,
1144                                                                               auth->priv->stream,
1145                                                                               credentials))
1146                         {
1147                           /* disconnect */
1148                           g_set_error_literal (error,
1149                                                G_IO_ERROR,
1150                                                G_IO_ERROR_FAILED,
1151                                                _("Cancelled via GDBusAuthObserver::authorize-authenticated-peer"));
1152                           goto out;
1153                         }
1154                       else
1155                         {
1156                           s = g_strdup_printf ("OK %s\r\n", guid);
1157                           debug_print ("SERVER: writing `%s'", s);
1158                           if (!g_data_output_stream_put_string (dos, s, cancellable, error))
1159                             {
1160                               g_free (s);
1161                               goto out;
1162                             }
1163                           g_free (s);
1164                           state = SERVER_STATE_WAITING_FOR_BEGIN;
1165                         }
1166                       break;
1167
1168                     case G_DBUS_AUTH_MECHANISM_STATE_REJECTED:
1169                       s = get_auth_mechanisms (auth, allow_anonymous, "REJECTED ", "\r\n", " ");
1170                       debug_print ("SERVER: writing `%s'", s);
1171                       if (!g_data_output_stream_put_string (dos, s, cancellable, error))
1172                         {
1173                           g_free (s);
1174                           goto out;
1175                         }
1176                       g_free (s);
1177                       state = SERVER_STATE_WAITING_FOR_AUTH;
1178                       break;
1179
1180                     case G_DBUS_AUTH_MECHANISM_STATE_WAITING_FOR_DATA:
1181                       state = SERVER_STATE_WAITING_FOR_DATA;
1182                       break;
1183
1184                     case G_DBUS_AUTH_MECHANISM_STATE_HAVE_DATA_TO_SEND:
1185                       {
1186                         gchar *data;
1187                         gsize data_len;
1188                         gchar *encoded_data;
1189                         data = _g_dbus_auth_mechanism_server_data_send (mech, &data_len);
1190                         encoded_data = hexencode (data);
1191                         s = g_strdup_printf ("DATA %s\r\n", encoded_data);
1192                         g_free (encoded_data);
1193                         g_free (data);
1194                         debug_print ("SERVER: writing `%s'", s);
1195                         if (!g_data_output_stream_put_string (dos, s, cancellable, error))
1196                           {
1197                             g_free (s);
1198                             goto out;
1199                           }
1200                         g_free (s);
1201                       }
1202                       goto change_state;
1203                       break;
1204
1205                     default:
1206                       /* TODO */
1207                       g_assert_not_reached ();
1208                       break;
1209                     }
1210                 }
1211             }
1212           else
1213             {
1214               g_set_error (error,
1215                            G_IO_ERROR,
1216                            G_IO_ERROR_FAILED,
1217                            "Unexpected line `%s' while in WaitingForAuth state",
1218                            line);
1219               g_free (line);
1220               goto out;
1221             }
1222           break;
1223
1224         case SERVER_STATE_WAITING_FOR_DATA:
1225           debug_print ("SERVER: WaitingForData");
1226           line = _my_g_data_input_stream_read_line (dis, &line_length, cancellable, error);
1227           debug_print ("SERVER: WaitingForData, read `%s'", line);
1228           if (line == NULL)
1229             goto out;
1230           if (g_str_has_prefix (line, "DATA "))
1231             {
1232               gchar *encoded;
1233               gchar *decoded_data;
1234               gsize decoded_data_len = 0;
1235
1236               encoded = g_strdup (line + 5);
1237               g_free (line);
1238               g_strstrip (encoded);
1239               decoded_data = hexdecode (encoded, &decoded_data_len, error);
1240               g_free (encoded);
1241               if (decoded_data == NULL)
1242                 {
1243                   g_prefix_error (error, "DATA response is malformed: ");
1244                   /* invalid encoding, disconnect! */
1245                   goto out;
1246                 }
1247               _g_dbus_auth_mechanism_server_data_receive (mech, decoded_data, decoded_data_len);
1248               g_free (decoded_data);
1249               /* oh man, this goto-crap is so ugly.. really need to rewrite the state machine */
1250               goto change_state;
1251             }
1252           else
1253             {
1254               g_set_error (error,
1255                            G_IO_ERROR,
1256                            G_IO_ERROR_FAILED,
1257                            "Unexpected line `%s' while in WaitingForData state",
1258                            line);
1259               g_free (line);
1260             }
1261           goto out;
1262
1263         case SERVER_STATE_WAITING_FOR_BEGIN:
1264           debug_print ("SERVER: WaitingForBegin");
1265           /* Use extremely slow (but reliable) line reader - this basically
1266            * does a recvfrom() system call per character
1267            *
1268            * (the problem with using GDataInputStream's read_line is that because of
1269            * buffering it might start reading into the first D-Bus message that
1270            * appears after "BEGIN\r\n"....)
1271            */
1272           line = _my_g_input_stream_read_line_safe (g_io_stream_get_input_stream (auth->priv->stream),
1273                                                     &line_length,
1274                                                     cancellable,
1275                                                     error);
1276           debug_print ("SERVER: WaitingForBegin, read `%s'", line);
1277           if (line == NULL)
1278             goto out;
1279           if (g_strcmp0 (line, "BEGIN") == 0)
1280             {
1281               /* YAY, done! */
1282               ret = TRUE;
1283               g_free (line);
1284               goto out;
1285             }
1286           else if (g_strcmp0 (line, "NEGOTIATE_UNIX_FD") == 0)
1287             {
1288               g_free (line);
1289               if (offered_capabilities & G_DBUS_CAPABILITY_FLAGS_UNIX_FD_PASSING)
1290                 {
1291                   negotiated_capabilities |= G_DBUS_CAPABILITY_FLAGS_UNIX_FD_PASSING;
1292                   s = "AGREE_UNIX_FD\r\n";
1293                   debug_print ("SERVER: writing `%s'", s);
1294                   if (!g_data_output_stream_put_string (dos, s, cancellable, error))
1295                     goto out;
1296                 }
1297               else
1298                 {
1299                   s = "ERROR \"fd passing not offered\"\r\n";
1300                   debug_print ("SERVER: writing `%s'", s);
1301                   if (!g_data_output_stream_put_string (dos, s, cancellable, error))
1302                     goto out;
1303                 }
1304             }
1305           else
1306             {
1307               g_debug ("Unexpected line `%s' while in WaitingForBegin state", line);
1308               g_free (line);
1309               s = "ERROR \"Unknown Command\"\r\n";
1310               debug_print ("SERVER: writing `%s'", s);
1311               if (!g_data_output_stream_put_string (dos, s, cancellable, error))
1312                 goto out;
1313             }
1314           break;
1315
1316         default:
1317           g_assert_not_reached ();
1318           break;
1319         }
1320     }
1321
1322
1323   g_set_error_literal (error,
1324                        G_IO_ERROR,
1325                        G_IO_ERROR_FAILED,
1326                        "Not implemented (server)");
1327
1328  out:
1329   if (mech != NULL)
1330     g_object_unref (mech);
1331   if (dis != NULL)
1332     g_object_unref (dis);
1333   if (dos != NULL)
1334     g_object_unref (dos);
1335
1336   /* ensure return value is FALSE if error is set */
1337   if (error != NULL && *error != NULL)
1338     {
1339       ret = FALSE;
1340     }
1341
1342   if (ret)
1343     {
1344       if (out_negotiated_capabilities != NULL)
1345         *out_negotiated_capabilities = negotiated_capabilities;
1346       if (out_received_credentials != NULL)
1347         *out_received_credentials = credentials != NULL ? g_object_ref (credentials) : NULL;
1348     }
1349
1350   if (credentials != NULL)
1351     g_object_unref (credentials);
1352
1353   debug_print ("SERVER: Done, authenticated=%d", ret);
1354
1355   return ret;
1356 }
1357
1358 /* ---------------------------------------------------------------------------------------------------- */