Implement Connection.Interface.Aliasing

* src/facebook-connection.c (_GruschlerFacebookConnectionPrivate,
  _finalize, gruschler_facebook_connection_init, _get_contact_alias,
  _update_profiles, gruschler_facebook_connection_class_init,
  _aliasing_get_alias_flags, _aliasing_request_aliases,
  _aliasing_get_aliases, _aliasing_set_aliases, _aliasing_iface_init):
  Add profiles table. Parse results of "profiles" FQL query. Implement
  the Connection.Interface.Aliasing interface.

1 files changed, 169 insertions, 10 deletions

diff --git a/src/facebook-connection.c b/src/facebook-connection.c
index d0fc959..5a02929 100644
--- a/src/facebook-connection.c
+++ b/src/facebook-connection.c
@@ -28,6 +28,7 @@
 #include <rtcom-telepathy-glib/extensions.h>
 
 #include <telepathy-glib/dbus.h>
+#include <telepathy-glib/gtypes.h>
 #include <telepathy-glib/handle-repo-dynamic.h>
 #include <telepathy-glib/handle-repo-static.h>
 #include <telepathy-glib/interfaces.h>
@@ -62,6 +63,7 @@ struct _GruschlerFacebookConnectionPrivate {
 
   GHashTable        *group_channels;
   GHashTable        *list_channels;
+  GHashTable        *profiles;
 
   char              *email;
   char              *password;
@@ -69,7 +71,10 @@ struct _GruschlerFacebookConnectionPrivate {
 };
 
 static void
-_channel_manager_iface_init (TpChannelManagerIface *iface);
+_channel_manager_iface_init (TpChannelManagerIface                 *iface);
+
+static void
+_aliasing_iface_init        (TpSvcConnectionInterfaceAliasingClass *iface);
 
 G_DEFINE_TYPE_WITH_CODE (GruschlerFacebookConnection,
                          gruschler_facebook_connection,
@@ -77,6 +82,9 @@ G_DEFINE_TYPE_WITH_CODE (GruschlerFacebookConnection,
 
   G_IMPLEMENT_INTERFACE (TP_TYPE_CHANNEL_MANAGER,
                          _channel_manager_iface_init);
+
+  G_IMPLEMENT_INTERFACE (TP_TYPE_SVC_CONNECTION_INTERFACE_ALIASING,
+                         _aliasing_iface_init);
 );
 
 static void
@@ -151,10 +159,10 @@ _finalize (GObject *object)
     g_object_unref (self->priv->groups);
   if (self->priv->lists)
     g_object_unref (self->priv->lists);
-  if (self->priv->list_channels)
-    g_hash_table_unref (self->priv->list_channels);
-  if (self->priv->group_channels)
-    g_hash_table_unref (self->priv->group_channels);
+
+  g_hash_table_unref (self->priv->list_channels);
+  g_hash_table_unref (self->priv->group_channels);
+  g_hash_table_unref (self->priv->profiles);
 
   g_free (self->priv->email);
   g_free (self->priv->password);
@@ -336,12 +344,31 @@ _get_unique_connection_name (TpBaseConnection *connection)
 }
 
 const char *
-_get_uid (GruschlerFacebookConnection *self)
+_get_self_uid (GruschlerFacebookConnection *self)
 {
   return tp_handle_inspect (self->priv->contacts,
                             TP_BASE_CONNECTION (self)->self_handle);
 }
 
+const char *
+_get_contact_alias (GruschlerFacebookConnection *self,
+                    TpHandle                     handle)
+{
+  RestXmlNode *profile, *node = NULL;
+
+  profile = g_hash_table_lookup (self->priv->profiles,
+                                 GUINT_TO_POINTER (handle));
+
+  if (!profile)
+    return NULL;
+
+  if (NULL != (node = rest_xml_node_find (profile, "name")) ||
+      NULL != (node = rest_xml_node_find (profile, "uid")))
+    return node->content;
+
+  return NULL;
+}
+
 static void
 _report_network_error (GruschlerFacebookConnection *self)
 {
@@ -443,7 +470,50 @@ static void
 _update_profiles (GruschlerFacebookConnection *self,
                   RestXmlNode                 *result)
 {
-  /* TODO: read profiles to make aliasing interface work */
+  RestXmlNode *user, *uid, *name;
+  GValue       entry = { 0, };
+  GPtrArray   *aliases;
+  TpHandle     handle;
+  int          i;
+
+  g_value_init (&entry, TP_STRUCT_TYPE_ALIAS_PAIR);
+  g_value_take_boxed (&entry, dbus_g_type_specialized_construct
+                                        (TP_STRUCT_TYPE_ALIAS_PAIR));
+
+  aliases = g_ptr_array_new ();
+
+  for (user = rest_xml_node_find (result, "user"); user; user = user->next)
+    {
+      if (g_strcmp0 (user->name, "user"))
+        continue;
+
+      uid  = rest_xml_node_find (user, "uid");
+      name = rest_xml_node_find (user, "name");
+
+      if (!uid)
+        continue;
+
+      handle = tp_handle_ensure (self->priv->contacts,
+                                 uid->content, NULL, NULL);
+
+      g_hash_table_insert (self->priv->profiles,
+                           GUINT_TO_POINTER (handle),
+                           rest_xml_node_ref (user));
+
+      dbus_g_type_struct_set (&entry, 0, handle,
+                              1, name ? name->content
+                                      : uid->content, G_MAXUINT);
+
+      g_ptr_array_add (aliases, g_value_dup_boxed (&entry));
+    }
+
+  tp_svc_connection_interface_aliasing_emit_aliases_changed (aliases, aliases);
+
+  for (i = 0; aliases->len; ++i)
+    g_boxed_free (TP_STRUCT_TYPE_ALIAS_PAIR, aliases->pdata[i]);
+
+  g_ptr_array_free (aliases, TRUE);
+  g_value_unset (&entry);
 }
 
 static void
@@ -502,7 +572,7 @@ _update_friends (GruschlerFacebookConnection *self)
   g_string_append_printf (queries,
                           "\"uids\":"
                           "\"SELECT uid2 FROM friend WHERE uid1=%s\"",
-                          _get_uid (self));
+                          _get_self_uid (self));
 
   g_string_append_c (queries, ',');
 
@@ -510,7 +580,7 @@ _update_friends (GruschlerFacebookConnection *self)
                           "\"profiles\":"
                           "\"SELECT uid,name,profile_update_time "
                             "FROM user WHERE uid IN (SELECT uid2 FROM friend WHERE uid1=%s)\"",
-                          _get_uid (self));
+                          _get_self_uid (self));
   /* TODO: "AND profile_update_time > 0" */
 
   g_string_append_c (queries, '}');
@@ -845,8 +915,8 @@ static void
 gruschler_facebook_connection_class_init (GruschlerFacebookConnectionClass *class)
 {
   static const char *interfaces[] = {
-#if 0
     TP_IFACE_CONNECTION_INTERFACE_ALIASING,
+#if 0
     TP_IFACE_CONNECTION_INTERFACE_AVATARS,
     TP_IFACE_CONNECTION_INTERFACE_SIMPLE_PRESENCE,
     TP_IFACE_CONNECTION_INTERFACE_CONTACTS,
@@ -1041,6 +1111,93 @@ _channel_manager_iface_init (TpChannelManagerIface *iface)
 }
 
 static void
+_aliasing_get_alias_flags (TpSvcConnectionInterfaceAliasing *aliasing,
+                           DBusGMethodInvocation            *context)
+{
+  tp_svc_connection_interface_aliasing_return_from_get_alias_flags (context, 0);
+}
+
+static void
+_aliasing_request_aliases (TpSvcConnectionInterfaceAliasing *aliasing,
+                           const GArray                     *contacts,
+                           DBusGMethodInvocation            *context)
+{
+  GruschlerFacebookConnection  *self;
+  const char                  **aliases;
+  TpHandle                      handle;
+  int                           i;
+
+  self = GRUSCHLER_FACEBOOK_CONNECTION (aliasing);
+  aliases = g_new0 (const char *, contacts->len + 1);
+
+  for (i = 0; i < contacts->len; ++i)
+    {
+      handle = g_array_index (contacts, TpHandle, i);
+      aliases[i] = _get_contact_alias (self, handle);
+    }
+
+  tp_svc_connection_interface_aliasing_return_from_request_aliases (context, aliases);
+
+  g_free (aliases);
+}
+
+static void
+_aliasing_get_aliases (TpSvcConnectionInterfaceAliasing *aliasing,
+                       const GArray                     *contacts,
+                       DBusGMethodInvocation            *context)
+{
+  GruschlerFacebookConnection *self;
+  GHashTable                  *aliases;
+  TpHandle                     handle;
+  const char                  *name;
+  int                          i;
+
+  self = GRUSCHLER_FACEBOOK_CONNECTION (aliasing);
+  aliases = g_hash_table_new_full (g_direct_hash, g_direct_equal, NULL, g_free);
+
+  for (i = 0; i < contacts->len; ++i)
+    {
+      handle = g_array_index (contacts, TpHandle, i);
+      name = _get_contact_alias (self, handle);
+
+      if (!name)
+        continue;
+
+      g_hash_table_insert (aliases,
+                           GUINT_TO_POINTER (handle),
+                           g_strdup (name));
+    }
+
+  tp_svc_connection_interface_aliasing_return_from_get_aliases (context, aliases);
+  g_hash_table_unref (aliases);
+}
+
+static void
+_aliasing_set_aliases (TpSvcConnectionInterfaceAliasing *aliasing,
+                       GHashTable                       *aliases,
+                       DBusGMethodInvocation            *context)
+{
+  GError error = {
+    TP_ERRORS, TP_ERROR_NOT_IMPLEMENTED,
+    "you cannot modify Facebook aliases"
+  };
+
+  dbus_g_method_return_error (context, &error);
+}
+
+static void
+_aliasing_iface_init (TpSvcConnectionInterfaceAliasingClass *iface)
+{
+#define IMPLEMENT(x) \
+  tp_svc_connection_interface_aliasing_implement_##x (iface, _aliasing_##x)
+  IMPLEMENT (get_alias_flags);
+  IMPLEMENT (request_aliases);
+  IMPLEMENT (get_aliases);
+  IMPLEMENT (set_aliases);
+#undef IMPLEMENT
+}
+
+static void
 gruschler_facebook_connection_init (GruschlerFacebookConnection *self)
 {
   self->priv = G_TYPE_INSTANCE_GET_PRIVATE (self,
@@ -1051,6 +1208,8 @@ gruschler_facebook_connection_init (GruschlerFacebookConnection *self)
     (g_direct_hash, g_direct_equal, NULL, g_object_unref);
   self->priv->group_channels = g_hash_table_new_full
     (g_direct_hash, g_direct_equal, NULL, g_object_unref);
+  self->priv->profiles = g_hash_table_new_full
+    (g_direct_hash, g_direct_equal, NULL, (GDestroyNotify) rest_xml_node_unref);
 }
 
 TpBaseConnection *