#include "config.h"

#include <gio/gio.h>

#include <telepathy-glib/telepathy-glib.h>

#include <libaccounts-glib/ag-account.h>

#include "empathy-webcredentials-monitor.h"

G_DEFINE_TYPE (EmpathyWebcredentialsMonitor, empathy_webcredentials_monitor, G_TYPE_OBJECT)

#define WEBCRED_BUS_NAME "com.canonical.indicators.webcredentials"
#define WEBCRED_PATH "/com/canonical/indicators/webcredentials"
#define WEBCRED_IFACE "com.canonical.indicators.webcredentials"

#define FAILURES_PROP "Failures"

enum
{
  PROP_MANAGER = 1,
  N_PROPS
};

enum
{
  SIG_FAILURE_ADDED,
  SIG_FAILURE_REMOVED,
  LAST_SIGNAL
};

static guint signals[LAST_SIGNAL];

struct _EmpathyWebcredentialsMonitorPriv
{
  AgManager *manager;
  GDBusProxy *proxy;

  /* array of owned AgAccount */
  GPtrArray *failures;
};

static void
empathy_webcredentials_monitor_get_property (GObject *object,
    guint property_id,
    GValue *value,
    GParamSpec *pspec)
{
  EmpathyWebcredentialsMonitor *self = EMPATHY_WEBCREDENTIALS_MONITOR (object);

  switch (property_id)
    {
      case PROP_MANAGER:
        g_value_set_object (value, self->priv->manager);
        break;
      default:
        G_OBJECT_WARN_INVALID_PROPERTY_ID (object, property_id, pspec);
        break;
    }
}

static void
empathy_webcredentials_monitor_set_property (GObject *object,
    guint property_id,
    const GValue *value,
    GParamSpec *pspec)
{
  EmpathyWebcredentialsMonitor *self = EMPATHY_WEBCREDENTIALS_MONITOR (object);

  switch (property_id)
    {
      case PROP_MANAGER:
        g_assert (self->priv->manager == NULL); /* construct only */
        self->priv->manager = g_value_dup_object (value);
        break;
      default:
        G_OBJECT_WARN_INVALID_PROPERTY_ID (object, property_id, pspec);
        break;
    }
}

static void
empathy_webcredentials_monitor_constructed (GObject *object)
{
  EmpathyWebcredentialsMonitor *self = EMPATHY_WEBCREDENTIALS_MONITOR (object);
  void (*chain_up) (GObject *) =
      ((GObjectClass *) empathy_webcredentials_monitor_parent_class)->constructed;

  chain_up (object);

  g_assert (AG_IS_MANAGER (self->priv->manager));
}

static void
empathy_webcredentials_monitor_dispose (GObject *object)
{
  EmpathyWebcredentialsMonitor *self = EMPATHY_WEBCREDENTIALS_MONITOR (object);
  void (*chain_up) (GObject *) =
      ((GObjectClass *) empathy_webcredentials_monitor_parent_class)->dispose;

  g_clear_object (&self->priv->manager);
  g_clear_object (&self->priv->proxy);

  chain_up (object);
}

static void
empathy_webcredentials_monitor_finalize (GObject *object)
{
  EmpathyWebcredentialsMonitor *self = EMPATHY_WEBCREDENTIALS_MONITOR (object);
  void (*chain_up) (GObject *) =
      ((GObjectClass *) empathy_webcredentials_monitor_parent_class)->finalize;

  g_ptr_array_unref (self->priv->failures);

  chain_up (object);
}

static void
empathy_webcredentials_monitor_class_init (
    EmpathyWebcredentialsMonitorClass *klass)
{
  GObjectClass *oclass = G_OBJECT_CLASS (klass);
  GParamSpec *spec;

  oclass->get_property = empathy_webcredentials_monitor_get_property;
  oclass->set_property = empathy_webcredentials_monitor_set_property;
  oclass->constructed = empathy_webcredentials_monitor_constructed;
  oclass->dispose = empathy_webcredentials_monitor_dispose;
  oclass->finalize = empathy_webcredentials_monitor_finalize;

  spec = g_param_spec_object ("manager", "Manager",
      "AgManager",
      AG_TYPE_MANAGER,
      G_PARAM_READWRITE | G_PARAM_CONSTRUCT_ONLY | G_PARAM_STATIC_STRINGS);
  g_object_class_install_property (oclass, PROP_MANAGER, spec);

  signals[SIG_FAILURE_ADDED] = g_signal_new ("failure-added",
      G_OBJECT_CLASS_TYPE (klass),
      G_SIGNAL_RUN_LAST,
      0, NULL, NULL, NULL,
      G_TYPE_NONE,
      1, AG_TYPE_ACCOUNT);

  signals[SIG_FAILURE_REMOVED] = g_signal_new ("failure-removed",
      G_OBJECT_CLASS_TYPE (klass),
      G_SIGNAL_RUN_LAST,
      0, NULL, NULL, NULL,
      G_TYPE_NONE,
      1, AG_TYPE_ACCOUNT);

  g_type_class_add_private (klass, sizeof (EmpathyWebcredentialsMonitorPriv));
}

static void
update_failures (EmpathyWebcredentialsMonitor *self)
{
  GVariant *failures, *f;
  GVariantIter iter;
  GList *new_list = NULL;
  guint i;

  failures = g_dbus_proxy_get_cached_property (self->priv->proxy,
      FAILURES_PROP);
  if (failures == NULL)
    {
      g_debug ("Does not implement Failures property");
      return;
    }

  g_variant_iter_init (&iter, failures);
  while ((f = g_variant_iter_next_value (&iter)) != NULL)
    {
      guint32 id;
      AgAccount *account;

      id = g_variant_get_uint32 (f);

      account = ag_manager_get_account (self->priv->manager, id);
      if (account == NULL)
        continue;

      /* Pass ownership of 'account' to the list */
      new_list = g_list_append (new_list, account);

      if (!tp_g_ptr_array_contains (self->priv->failures, account))
        {
          g_ptr_array_add (self->priv->failures, g_object_ref (account));

          g_signal_emit (self, signals[SIG_FAILURE_ADDED], 0, account);
        }

      g_variant_unref (f);
    }

  g_variant_unref (failures);

  for (i = 0; i < self->priv->failures->len; i++)
    {
      AgAccount *account = g_ptr_array_index (self->priv->failures, i);

      if (g_list_find (new_list, account) == NULL)
        {
          g_object_ref (account);
          g_ptr_array_remove (self->priv->failures, account);

          g_signal_emit (self, signals[SIG_FAILURE_REMOVED], 0, account);
          g_object_unref (account);
        }
    }

  g_list_free_full (new_list, g_object_unref);
}

static void
properties_changed_cb (GDBusProxy *proxy,
    GVariant *changed_properties,
    GStrv invalidated_properties,
    EmpathyWebcredentialsMonitor *self)
{
  if (g_variant_lookup_value (changed_properties, FAILURES_PROP, NULL) == NULL)
    return;

  update_failures (self);
}

static void
proxy_new_cb (GObject *source,
    GAsyncResult *result,
    gpointer user_data)
{
  EmpathyWebcredentialsMonitor *self;
  TpWeakRef *wr = user_data;
  GError *error = NULL;

  self = tp_weak_ref_dup_object (wr);
  if (self == NULL)
    goto out;

  self->priv->proxy = g_dbus_proxy_new_for_bus_finish (result, &error);
  if (self->priv->proxy == NULL)
    {
      g_debug ("Failed to create webcredentials proxy: %s", error->message);
      g_error_free (error);
      goto out;
    }

  update_failures (self);

  g_signal_connect (self->priv->proxy, "g-properties-changed",
      G_CALLBACK (properties_changed_cb), self);

out:
  tp_weak_ref_destroy (wr);
  g_clear_object (&self);
}

static void
empathy_webcredentials_monitor_init (EmpathyWebcredentialsMonitor *self)
{
  self->priv = G_TYPE_INSTANCE_GET_PRIVATE (self,
      EMPATHY_TYPE_WEBCREDENTIALS_MONITOR, EmpathyWebcredentialsMonitorPriv);

  self->priv->failures = g_ptr_array_new_with_free_func (g_object_unref);

  g_dbus_proxy_new_for_bus (G_BUS_TYPE_SESSION, G_DBUS_PROXY_FLAGS_NONE, NULL,
      WEBCRED_BUS_NAME, WEBCRED_PATH, WEBCRED_IFACE,
      NULL, proxy_new_cb, tp_weak_ref_new (self, NULL, NULL));
}

EmpathyWebcredentialsMonitor *
empathy_webcredentials_monitor_new (AgManager *manager)
{
  return g_object_new (EMPATHY_TYPE_WEBCREDENTIALS_MONITOR,
      "manager", manager,
      NULL);
}

GPtrArray *
empathy_webcredentials_get_failures (EmpathyWebcredentialsMonitor *self)
{
  return self->priv->failures;
}