/*

 * gabble-register.c - Source for Gabble account registration

 *

 * Copyright (C) 2006 Collabora Ltd.

 * 

 *   @author Ole Andre Vadla Ravnaas <ole.andre.ravnaas@collabora.co.uk>

 *

 * This library is free software; you can redistribute it and/or

 * modify it under the terms of the GNU Lesser General Public

 * License as published by the Free Software Foundation; either

 * version 2.1 of the License, or (at your option) any later version.

 *

 * This library is distributed in the hope that it will be useful,

 * but WITHOUT ANY WARRANTY; without even the implied warranty of

 * MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE.  See the GNU

 * Lesser General Public License for more details.

 *

 * You should have received a copy of the GNU Lesser General Public

 * License along with this library; if not, write to the Free Software

 * Foundation, Inc., 51 Franklin St, Fifth Floor, Boston, MA  02110-1301  USA

 */

#define DBUS_API_SUBJECT_TO_CHANGE

#include <dbus/dbus-glib.h>

#include <dbus/dbus-glib-lowlevel.h>

#include <stdlib.h>

#include <string.h>

#include "telepathy-helpers.h"

#include "telepathy-errors.h"

#include "gabble-connection.h"

#include "gabble-error.h"

#include "gabble-register.h"

#include "gabble-register-signals-marshal.h"

#include "namespaces.h"

#include "util.h"

#include "gabble_enums.h"

#ifndef EMULATOR

G_DEFINE_TYPE(GabbleRegister, gabble_register, G_TYPE_OBJECT);

#endif

/* signal enum */

enum

{

  FINISHED,

  LAST_SIGNAL 

#ifdef EMULATOR  

  = LAST_SIGNAL_REGISTER

#endif

};

#ifdef EMULATOR

#include "libgabble_wsd_solution.h"

	GET_STATIC_ARRAY_FROM_TLS(signals,gabble_register,guint)

	#define signals (GET_WSD_VAR_NAME(signals,gabble_register, s)())

	GET_STATIC_VAR_FROM_TLS(gabble_register_parent_class,gabble_register,gpointer)

	#define gabble_register_parent_class (*GET_WSD_VAR_NAME(gabble_register_parent_class,gabble_register,s)())

	GET_STATIC_VAR_FROM_TLS(g_define_type_id,gabble_register,GType)

	#define g_define_type_id (*GET_WSD_VAR_NAME(g_define_type_id,gabble_register,s)())

static void gabble_register_init (GabbleRegister *self); 

static void gabble_register_class_init (GabbleRegisterClass *klass); 

static void gabble_register_class_intern_init (gpointer klass) 

{

 gabble_register_parent_class = g_type_class_peek_parent (klass); 

 gabble_register_class_init ((GabbleRegisterClass*) klass); 

 } 

 EXPORT_C GType gabble_register_get_type (void) 

 { 

 if ((g_define_type_id == 0)) 

 	{ static const GTypeInfo g_define_type_info = { sizeof (GabbleRegisterClass), (GBaseInitFunc) ((void *)0), (GBaseFinalizeFunc) ((void *)0), (GClassInitFunc) gabble_register_class_intern_init, (GClassFinalizeFunc) ((void *)0), ((void *)0), sizeof (GabbleRegister), 0, (GInstanceInitFunc) gabble_register_init, ((void *)0) }; g_define_type_id = g_type_register_static ( ((GType) ((20) << (2))), g_intern_static_string ("GabbleRegister"), &g_define_type_info, (GTypeFlags) 0); { {} ; } } return g_define_type_id; 

 } ;

#else

	static guint signals[LAST_SIGNAL] = {0};

#endif

/* properties */

enum

{

  PROP_CONNECTION = 1,

  LAST_PROPERTY

};

/* private structure */

typedef struct _GabbleRegisterPrivate GabbleRegisterPrivate;

struct _GabbleRegisterPrivate

{

  GabbleConnection *conn;

  gboolean dispose_has_run;

};

#define GABBLE_REGISTER_GET_PRIVATE(o)     (G_TYPE_INSTANCE_GET_PRIVATE ((o), GABBLE_TYPE_REGISTER, GabbleRegisterPrivate))

static void

gabble_register_init (GabbleRegister *obj)

{

}

static void gabble_register_set_property (GObject *object, guint property_id,

    const GValue *value, GParamSpec *pspec);

static void gabble_register_get_property (GObject *object, guint property_id,

    GValue *value, GParamSpec *pspec);

static void gabble_register_dispose (GObject *object);

static void gabble_register_finalize (GObject *object);

static void

gabble_register_class_init (GabbleRegisterClass *gabble_register_class)

{

  GObjectClass *object_class = G_OBJECT_CLASS (gabble_register_class);

  GParamSpec *param_spec;

  g_type_class_add_private (gabble_register_class, sizeof (GabbleRegisterPrivate));

  object_class->get_property = gabble_register_get_property;

  object_class->set_property = gabble_register_set_property;

  object_class->dispose = gabble_register_dispose;

  object_class->finalize = gabble_register_finalize;

  param_spec = g_param_spec_object ("connection", "GabbleConnection object",

                                    "Gabble connection object that owns this "

                                    "GabbleRegister object.",

                                    GABBLE_TYPE_CONNECTION,

                                    G_PARAM_CONSTRUCT_ONLY |

                                    G_PARAM_READWRITE |

                                    G_PARAM_STATIC_NICK |

                                    G_PARAM_STATIC_BLURB);

  g_object_class_install_property (object_class, PROP_CONNECTION, param_spec);

  signals[FINISHED] =

    g_signal_new ("finished",

                  G_OBJECT_CLASS_TYPE (gabble_register_class),

                  G_SIGNAL_RUN_LAST | G_SIGNAL_DETAILED,

                  0,

                  NULL, NULL,

                  gabble_register_marshal_VOID__BOOLEAN_INT_STRING,

                  G_TYPE_NONE, 3, G_TYPE_BOOLEAN, G_TYPE_INT, G_TYPE_STRING);

}

static void

gabble_register_get_property (GObject    *object,

                              guint       property_id,

                              GValue     *value,

                              GParamSpec *pspec)

{

  GabbleRegister *chan = GABBLE_REGISTER (object);

  GabbleRegisterPrivate *priv = GABBLE_REGISTER_GET_PRIVATE (chan);

  switch (property_id) {

    case PROP_CONNECTION:

      g_value_set_object (value, priv->conn);

      break;

    default:

      G_OBJECT_WARN_INVALID_PROPERTY_ID (object, property_id, pspec);

      break;

  }

}

static void

gabble_register_set_property (GObject     *object,

                              guint        property_id,

                              const GValue *value,

                              GParamSpec   *pspec)

{

  GabbleRegister *chan = GABBLE_REGISTER (object);

  GabbleRegisterPrivate *priv = GABBLE_REGISTER_GET_PRIVATE (chan);

  switch (property_id) {

    case PROP_CONNECTION:

      priv->conn = g_value_get_object (value);

      break;

    default:

      G_OBJECT_WARN_INVALID_PROPERTY_ID (object, property_id, pspec);

      break;

  }

}

void

gabble_register_dispose (GObject *object)

{

  GabbleRegister *self = GABBLE_REGISTER (object);

  GabbleRegisterPrivate *priv = GABBLE_REGISTER_GET_PRIVATE (self);

  if (priv->dispose_has_run)

    return;

  priv->dispose_has_run = TRUE;

  g_debug ("%s: dispose called", G_STRFUNC);

  if (G_OBJECT_CLASS (gabble_register_parent_class)->dispose)

    G_OBJECT_CLASS (gabble_register_parent_class)->dispose (object);

}

void

gabble_register_finalize (GObject *object)

{

  g_debug ("%s called with %p", G_STRFUNC, object);

  G_OBJECT_CLASS (gabble_register_parent_class)->finalize (object);

}

/**

 * gabble_register_new:

 *

 * Creates an object to use for account registration.

 *

 * @conn: The #GabbleConnection to register an account on

 */

GabbleRegister *

gabble_register_new (GabbleConnection *conn)

{

  g_return_val_if_fail (GABBLE_IS_CONNECTION (conn), NULL);

  return GABBLE_REGISTER (g_object_new (GABBLE_TYPE_REGISTER,

        "connection", conn, NULL));

}

static LmHandlerResult

set_reply_cb (GabbleConnection *conn,

              LmMessage *sent_msg,

              LmMessage *reply_msg,

              GObject *object,

              gpointer user_data)

{

  if (lm_message_get_sub_type (reply_msg) != LM_MESSAGE_SUB_TYPE_RESULT)

    {

      LmMessageNode *node;

      gint code = NotAvailable;

      GString *msg;

      msg = g_string_sized_new (30);

      g_string_append (msg, "Request failed");

      node = lm_message_node_get_child (reply_msg->node, "error");

      if (node)

        {

          GabbleXmppError error;

          error = gabble_xmpp_error_from_node (node);

          if (error == XMPP_ERROR_CONFLICT)

            {

              code = InvalidArgument;

            }

          if (error != INVALID_XMPP_ERROR)

            {

              g_string_append_printf (msg, ": %s",

                  gabble_xmpp_error_string (error));

            }

        }

      g_signal_emit (object, signals[FINISHED], 0, FALSE, code, msg->str);

      g_string_free (msg, TRUE);

    }

  else

    {

      g_signal_emit (object, signals[FINISHED], 0, TRUE, -1, NULL);

    }

  return LM_HANDLER_RESULT_REMOVE_MESSAGE;

}

static LmHandlerResult

get_reply_cb (GabbleConnection *conn,

              LmMessage *sent_msg,

              LmMessage *reply_msg,

              GObject *object,

              gpointer user_data)

{

  GabbleRegister *reg = GABBLE_REGISTER (object);

  GabbleRegisterPrivate *priv = GABBLE_REGISTER_GET_PRIVATE (reg);

  GError *error = NULL;

  gint err_code = -1;

  const gchar *err_msg = NULL;

  LmMessage *msg = NULL;

  LmMessageNode *query_node;

  gchar *username, *password;

  if (lm_message_get_sub_type (reply_msg) != LM_MESSAGE_SUB_TYPE_RESULT)

    {

      err_code = NotAvailable;

      err_msg = "Server doesn't support " NS_REGISTER;

      goto OUT;

    }

  /* sanity check the reply to some degree ... */

  query_node = lm_message_node_get_child_with_namespace (reply_msg->node,

      "query", NS_REGISTER);

  if (query_node == NULL)

    goto ERROR_MALFORMED_REPLY;

  if (!lm_message_node_get_child (query_node, "username"))

    goto ERROR_MALFORMED_REPLY;

  if (!lm_message_node_get_child (query_node, "password"))

    goto ERROR_MALFORMED_REPLY;

  /* craft a reply */

  msg = lm_message_new_with_sub_type (NULL, LM_MESSAGE_TYPE_IQ,

                                      LM_MESSAGE_SUB_TYPE_SET);

  query_node = lm_message_node_add_child (msg->node, "query", NULL);

  lm_message_node_set_attribute (query_node, "xmlns", NS_REGISTER);

  g_object_get (priv->conn,

      "username", &username,

      "password", &password,

      NULL);

  lm_message_node_add_child (query_node, "username", username);

  lm_message_node_add_child (query_node, "password", password);

  g_free (username);

  g_free (password);

  if (!_gabble_connection_send_with_reply (priv->conn, msg, set_reply_cb,

                                           G_OBJECT (reg), NULL, &error))

    {

      err_code = error->code;

      err_msg = error->message;

    }

  goto OUT;

ERROR_MALFORMED_REPLY:

  err_code = NotAvailable;

  err_msg = "Malformed reply";

OUT:

  if (err_code != -1)

    {

      g_signal_emit (reg, signals[FINISHED], 0, FALSE, err_code, err_msg);

    }

  if (msg)

    lm_message_unref (msg);

  if (error)

    g_error_free (error);

  return LM_HANDLER_RESULT_REMOVE_MESSAGE;

}

/**

 * gabble_register_start:

 *

 * Start account registration.

 *

 * @reg: The #GabbleRegister object performing the registration

 */

void gabble_register_start (GabbleRegister *reg)

{

  GabbleRegisterPrivate *priv = GABBLE_REGISTER_GET_PRIVATE (reg);

  LmMessage *msg;

  LmMessageNode *node;

  GError *error = NULL;

  msg = lm_message_new_with_sub_type (NULL, LM_MESSAGE_TYPE_IQ,

                                      LM_MESSAGE_SUB_TYPE_GET);

  node = lm_message_node_add_child (msg->node, "query", NULL);

  lm_message_node_set_attribute (node, "xmlns", NS_REGISTER);

  if (!_gabble_connection_send_with_reply (priv->conn, msg, get_reply_cb,

                                           G_OBJECT (reg), NULL, &error))

    {

      g_signal_emit (reg, signals[FINISHED], 0, FALSE, error->code,

                     error->message);

      g_error_free (error);

    }

  lm_message_unref (msg);

}