0
@@ -1,3 +1,42 @@
0
+/* twitter-client.h: Wrapper for the Twitter API
0
+ * Copyright (C) 2008  Emmanuele Bassi <ebassi@gnome.org>
0
+ *
0
+ * This file is part of Twitter-GLib.
0
+ *
0
+ * This library is free software; you can redistribute it and/or
0
+ * modify it under the terms of the GNU Lesser General Public
0
+ * License as published by the Free Software Foundation; either
0
+ * version 2 of the License, or (at your option) any later version.
0
+ *
0
+ * This library is distributed in the hope that it will be useful,
0
+ * but WITHOUT ANY WARRANTY; without even the implied warranty of
0
+ * MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE.  See the GNU
0
+ * Lesser General Public License for more details.
0
+ */
0
+
0
+/**
0
+ * SECTION:twitter-client
0
+ * @short_description: Wrapper for the Twitter API
0
+ *
0
+ * #TwitterClient is the main object wrapping the details of the
0
+ * Twitter web API.
0
+ *
0
+ * In order to use Twitter through #TwitterClient, a new instance
0
+ * should be created using twitter_client_new() or
0
+ * twitter_client_new_for_user(). #TwitterClient handles every
0
+ * operation asynchronously, thus requiring a #GMainLoop running.
0
+ * Every result will emit one of the #TwitterClient signals; in
0
+ * case of error, the #GError parameter of the signals will be
0
+ * set.
0
+ *
0
+ * Authentication is handled automatically by setting the
0
+ * TwitterClient:email and TwitterClient:password properties.
0
+ * These two properties can be set at construction time or by
0
+ * using twitter_client_set_user(). Interactive authentication
0
+ * can be implemented by using the TwitterClient::authenticate
0
+ * signal as well.
0
+ */
0
+
0
 #ifdef HAVE_CONFIG_H
0
 #include "config.h"
0
 #endif
0
0
0
0
@@ -18,20 +57,17 @@
0
 
0
 #include <libsoup/soup.h>
0
 
0
+#include "twitter-api.h"
0
+#include "twitter-client.h"
0
 #include "twitter-common.h"
0
 #include "twitter-enum-types.h"
0
 #include "twitter-marshal.h"
0
 #include "twitter-private.h"
0
-#include "twitter-client.h"
0
 #include "twitter-status.h"
0
 #include "twitter-timeline.h"
0
 #include "twitter-user.h"
0
+#include "twitter-user-list.h"
0
 
0
-#define TWITTER_API_PUBLIC_TIMELINE     "http://twitter.com/statuses/public_timeline.json"
0
-#define TWITTER_API_FRIENDS_TIMELINE    "http://twitter.com/statuses/friends_timeline"
0
-#define TWITTER_API_USER_TIMELINE       "http://twitter.com/statuses/user_timeline"
0
-#define TWITTER_API_SHOW                "http://twitter.com/statuses/show/"
0
-
0
 #define TWITTER_CLIENT_GET_PRIVATE(obj) (G_TYPE_INSTANCE_GET_PRIVATE ((obj), TWITTER_TYPE_CLIENT, TwitterClientPrivate))
0
 
0
 struct _TwitterClientPrivate
0
0
@@ -58,8 +94,8 @@
0
 enum
0
 {
0
   AUTHENTICATE,
0
-  TIMELINE_RECEIVED,
0
   STATUS_RECEIVED,
0
+  USER_RECEIVED,
0
 
0
   LAST_SIGNAL
0
 };
0
0
@@ -91,7 +127,24 @@
0
                              const GValue *value,
0
                              GParamSpec   *pspec)
0
 {
0
+  TwitterClientPrivate *priv = TWITTER_CLIENT (gobject)->priv;
0
 
0
+  switch (prop_id)
0
+    {
0
+    case PROP_EMAIL:
0
+      g_free (priv->email);
0
+      priv->email = g_value_dup_string (value);
0
+      break;
0
+
0
+    case PROP_PASSWORD:
0
+      g_free (priv->password);
0
+      priv->password = g_value_dup_string (value);
0
+      break;
0
+
0
+    default:
0
+      G_OBJECT_WARN_INVALID_PROPERTY_ID (gobject, prop_id, pspec);
0
+      break;
0
+    }
0
 }
0
 
0
 static void
0
0
@@ -100,7 +153,22 @@
0
                              GValue     *value,
0
                              GParamSpec *pspec)
0
 {
0
+  TwitterClientPrivate *priv = TWITTER_CLIENT (gobject)->priv;
0
 
0
+  switch (prop_id)
0
+    {
0
+    case PROP_EMAIL:
0
+      g_value_set_string (value, priv->email);
0
+      break;
0
+
0
+    case PROP_PASSWORD:
0
+      g_value_set_string (value, priv->password);
0
+      break;
0
+
0
+    default:
0
+      G_OBJECT_WARN_INVALID_PROPERTY_ID (gobject, prop_id, pspec);
0
+      break;
0
+    }
0
 }
0
 
0
 static void
0
0
0
@@ -138,15 +206,15 @@
0
                   _twitter_marshal_BOOLEAN__ENUM,
0
                   G_TYPE_BOOLEAN, 1,
0
                   TWITTER_TYPE_AUTH_STATE);
0
-  client_signals[TIMELINE_RECEIVED] =
0
-    g_signal_new ("timeline-received",
0
+  client_signals[USER_RECEIVED] =
0
+    g_signal_new ("user-received",
0
                   G_TYPE_FROM_CLASS (gobject_class),
0
                   G_SIGNAL_RUN_LAST,
0
-                  G_STRUCT_OFFSET (TwitterClientClass, timeline_received),
0
+                  G_STRUCT_OFFSET (TwitterClientClass, user_received),
0
                   NULL, NULL,
0
                   _twitter_marshal_VOID__OBJECT_POINTER,
0
                   G_TYPE_NONE, 2,
0
-                  TWITTER_TYPE_TIMELINE,
0
+                  TWITTER_TYPE_USER,
0
                   G_TYPE_POINTER);
0
   client_signals[STATUS_RECEIVED] =
0
     g_signal_new ("status-received",
0
0
0
0
@@ -175,30 +243,37 @@
0
                                          NULL);
0
 }
0
 
0
-TwitterClient *
0
-twitter_client_new (void)
0
-{
0
-  return g_object_new (TWITTER_TYPE_CLIENT, NULL);
0
-}
0
-
0
-TwitterClient *
0
-twitter_client_new_for_user (const gchar *email,
0
-                             const gchar *password)
0
-{
0
-  return g_object_new (TWITTER_TYPE_CLIENT,
0
-                       "email", email,
0
-                       "password", password,
0
-                       NULL);
0
-}
0
-
0
 typedef enum {
0
   PUBLIC_TIMELINE,
0
   FRIENDS_TIMELINE,
0
   USER_TIMELINE,
0
+  STATUS_SHOW,
0
+  UPDATE,
0
   REPLIES,
0
-  SHOW
0
+  DESTROY,
0
+  FRIENDS,
0
+  FOLLOWERS,
0
+  FEATURED,
0
+  VERIFY_CREDENTIALS,
0
+  END_SESSION,
0
+
0
+  N_CLIENT_ACTIONS
0
 } ClientAction;
0
 
0
+static const gchar *action_names[N_CLIENT_ACTIONS] = {
0
+  "public-timeline",
0
+  "friends-timeline",
0
+  "user-timeline",
0
+  "status-show",
0
+  "update",
0
+  "replies",
0
+  "destroy",
0
+  "friends",
0
+  "followers",
0
+  "verify-credentials",
0
+  "end-session"
0
+};
0
+
0
 typedef struct {
0
   ClientAction action;
0
   TwitterClient *client;
0
0
0
0
0
0
0
0
0
0
0
0
0
0
0
0
0
@@ -211,55 +286,161 @@
0
   TwitterStatus *status;
0
 } GetStatusClosure;
0
 
0
+typedef struct {
0
+  ClientAction action;
0
+  TwitterClient *client;
0
+  TwitterUserList *user_list;
0
+} GetUserListClosure;
0
+
0
+typedef struct {
0
+  ClientAction action;
0
+  TwitterClient *client;
0
+  TwitterUser *user;
0
+} GetUserClosure;
0
+
0
 static void
0
-get_timeline_cb (SoupSession *session,
0
-                 SoupMessage *msg,
0
-                 gpointer     user_data)
0
+twitter_client_auth (SoupSession *session,
0
+                     SoupMessage *msg,
0
+                     SoupAuth    *auth,
0
+                     gboolean     retrying,
0
+                     gpointer     user_data)
0
 {
0
-  GetTimelineClosure *closure = user_data;
0
-  TwitterClient *client = closure->client; 
0
-  guint status;
0
+  TwitterClient *client = user_data;
0
+  TwitterClientPrivate *priv = client->priv;
0
+  gboolean retval = FALSE;
0
 
0
-  status = msg->status_code;
0
-  if (!SOUP_STATUS_IS_SUCCESSFUL (status))
0
+  if (!retrying)
0
     {
0
-      GError *error = NULL;
0
+      g_signal_emit (client, client_signals[AUTHENTICATE], 0,
0
+                     TWITTER_AUTH_NEGOTIATING, &retval);
0
 
0
-      g_set_error (&error, TWITTER_ERROR,
0
-                   twitter_error_from_status (status),
0
-                   msg->reason_phrase);
0
+      soup_auth_authenticate (auth, priv->email, priv->password);
0
 
0
-      g_signal_emit (client, client_signals[TIMELINE_RECEIVED], 0,
0
-                     closure->timeline, error);
0
+      priv->auth_complete = TRUE;
0
     }
0
   else
0
     {
0
-      gchar *buffer;
0
+      g_signal_emit (client, client_signals[AUTHENTICATE], 0,
0
+                     TWITTER_AUTH_RETRY, &retval);
0
 
0
-      buffer = g_strndup (msg->response_body->data,
0
-                          msg->response_body->length);
0
-      if (G_UNLIKELY (!buffer))
0
-        g_warning ("No data received");
0
+      if (G_LIKELY (retval))
0
+        {
0
+          soup_auth_authenticate (auth, priv->email, priv->password);
0
+          priv->auth_complete = TRUE;
0
+        }
0
       else
0
-        twitter_timeline_load_from_data (closure->timeline, buffer);
0
+        {
0
+          g_signal_emit (client, client_signals[AUTHENTICATE], 0,
0
+                         TWITTER_AUTH_FAILED, &retval);
0
+          priv->auth_complete = FALSE;
0
+        }
0
+    }
0
+}
0
 
0
-      g_signal_emit (client, client_signals[TIMELINE_RECEIVED], 0,
0
-                     closure->timeline, NULL);
0
+static void
0
+twitter_client_queue_message (TwitterClient       *client,
0
+                              SoupMessage         *msg,
0
+                              gboolean             requires_auth,
0
+                              SoupSessionCallback  callback,
0
+                              gpointer             data)
0
+{
0
+  TwitterClientPrivate *priv = client->priv;
0
 
0
-      g_free (buffer);
0
-    }
0
+  if (requires_auth && !priv->auth_id)
0
+    priv->auth_id = g_signal_connect (priv->session_async, "authenticate",
0
+                                      G_CALLBACK (twitter_client_auth),
0
+                                      client);
0
 
0
-  g_object_unref (closure->timeline);
0
-  g_object_unref (closure->client);
0
+  soup_session_queue_message (priv->session_async, msg,
0
+                              callback,
0
+                              data);
0
+}
0
 
0
-  g_free (closure);
0
+TwitterClient *
0
+twitter_client_new (void)
0
+{
0
+  return g_object_new (TWITTER_TYPE_CLIENT, NULL);
0
 }
0
 
0
+TwitterClient *
0
+twitter_client_new_for_user (const gchar *email,
0
+                             const gchar *password)
0
+{
0
+  return g_object_new (TWITTER_TYPE_CLIENT,
0
+                       "email", email,
0
+                       "password", password,
0
+                       NULL);
0
+}
0
+
0
+void
0
+twitter_client_set_user (TwitterClient *client,
0
+                         const gchar   *email,
0
+                         const gchar   *password)
0
+{
0
+  TwitterClientPrivate *priv;
0
+
0
+  g_return_if_fail (TWITTER_IS_CLIENT (client));
0
+  g_return_if_fail (email != NULL);
0
+  g_return_if_fail (password != NULL);
0
+
0
+  priv = client->priv;
0
+
0
+  g_free (priv->email);
0
+  g_free (priv->password);
0
+
0
+  priv->email = g_strdup (email);
0
+  priv->password = g_strdup (password);
0
+
0
+  priv->auth_complete = FALSE;
0
+
0
+  g_object_notify (G_OBJECT (client), "email");
0
+  g_object_notify (G_OBJECT (client), "password");
0
+}
0
+
0
+void
0
+twitter_client_get_user (TwitterClient  *client,
0
+                         gchar         **email,
0
+                         gchar         **password)
0
+{
0
+  g_return_if_fail (TWITTER_IS_CLIENT (client));
0
+
0
+  if (email)
0
+    *email = g_strdup (client->priv->email);
0
+  if (password)
0
+    *password = g_strdup (client->priv->password);
0
+}
0
+
0
+typedef struct {
0
+  TwitterClient *client;
0
+  GList *users;
0
+  guint n_users;
0
+  guint current_user;
0
+} EmitUserClosure;
0
+
0
+static gboolean
0
+do_emit_user_received (gpointer data)
0
+{
0
+  return FALSE;
0
+}
0
+
0
 static void
0
-get_status_cb (SoupSession *session,
0
-               SoupMessage *msg,
0
-               gpointer     user_data)
0
+cleanup_emit_user_received (gpointer data)
0
 {
0
+
0
+}
0
+
0
+static void
0
+emit_user_received (TwitterClient *client,
0
+                    TwitterUserList *list)
0
+{
0
+
0
+}
0
+
0
+static void
0
+get_user_cb (SoupSession *session,
0
+             SoupMessage *msg,
0
+             gpointer     user_data)
0
+{
0
   GetStatusClosure *closure = user_data;
0
   TwitterClient *client = closure->client; 
0
 
0
0
0
0
0
0
0
0
0
0
0
0
0
0
@@ -297,65 +478,121 @@
0
   g_free (closure);
0
 }
0
 
0
+void
0
+twitter_client_verify_user (TwitterClient *client)
0
+{
0
+
0
+}
0
+
0
+void
0
+twitter_client_end_session (TwitterClient *client)
0
+{
0
+
0
+}
0
+
0
+typedef struct {
0
+  TwitterClient *client;
0
+  TwitterTimeline *timeline;
0
+  guint n_status;
0
+  guint current_status;
0
+} EmitStatusClosure;
0
+
0
+static gboolean
0
+do_emit_status_received (gpointer data)
0
+{
0
+  EmitStatusClosure *closure = data;
0
+  TwitterStatus *status;
0
+
0
+  status = twitter_timeline_get_pos (closure->timeline,
0
+                                     closure->current_status);
0
+  if (!status)
0
+    return FALSE;
0
+
0
+  g_signal_emit (closure->client, client_signals[STATUS_RECEIVED], 0,
0
+                 status, NULL);
0
+
0
+  closure->current_status += 1;
0
+
0
+  if (closure->current_status == closure->n_status)
0
+    return FALSE;
0
+
0
+  return TRUE;
0
+}
0
+
0
 static void
0
-twitter_client_auth (SoupSession *session,
0
-                     SoupMessage *msg,
0
-                     SoupAuth    *auth,
0
-                     gboolean     retrying,
0
-                     gpointer     user_data)
0
+cleanup_emit_status_received (gpointer data)
0
 {
0
-  TwitterClient *client = user_data;
0
-  TwitterClientPrivate *priv = client->priv;
0
-  gboolean retval = FALSE;
0
+  EmitStatusClosure *closure = data;
0
 
0
-  if (!retrying)
0
+  g_object_unref (closure->client);
0
+  g_object_unref (closure->timeline);
0
+
0
+  g_free (closure);
0
+}
0
+
0
+static void
0
+emit_status_received (TwitterClient   *client,
0
+                      TwitterTimeline *timeline)
0
+{
0
+  EmitStatusClosure *closure;
0
+  guint count;
0
+
0
+  count = twitter_timeline_get_count (timeline);
0
+
0
+  closure = g_new (EmitStatusClosure, 1);
0
+  closure->client = g_object_ref (client);
0
+  closure->timeline = g_object_ref (timeline);
0
+  closure->n_status = count;
0
+  closure->current_status = 0;
0
+
0
+  g_idle_add_full (G_PRIORITY_DEFAULT_IDLE,
0
+                   do_emit_status_received,
0
+                   closure,
0
+                   cleanup_emit_status_received);
0
+}
0
+
0
+static void
0
+get_timeline_cb (SoupSession *session,
0
+                 SoupMessage *msg,
0
+                 gpointer     user_data)
0
+{
0
+  GetTimelineClosure *closure = user_data;
0
+  TwitterClient *client = closure->client;
0
+  guint status;
0
+
0
+  status = msg->status_code;
0
+  if (!SOUP_STATUS_IS_SUCCESSFUL (status))
0
     {
0
-      g_signal_emit (client, client_signals[AUTHENTICATE], 0,
0
-                     TWITTER_AUTH_NEGOTIATING, &retval);
0
+      GError *error = NULL;
0
 
0
-      soup_auth_authenticate (auth, priv->email, priv->password);
0
+      g_set_error (&error, TWITTER_ERROR,
0
+                   twitter_error_from_status (status),
0
+                   msg->reason_phrase);
0
 
0
-      priv->auth_complete = TRUE;
0
+      g_signal_emit (client, client_signals[STATUS_RECEIVED], 0,
0
+                     NULL, error);
0
     }
0
   else
0
     {
0
-      g_signal_emit (client, client_signals[AUTHENTICATE], 0,
0
-                     TWITTER_AUTH_RETRY, &retval);
0
+      gchar *buffer;
0
 
0
-      if (G_LIKELY (retval))
0
-        {
0
-          soup_auth_authenticate (auth, priv->email, priv->password);
0
-          priv->auth_complete = TRUE;
0
-        }
0
+      buffer = g_strndup (msg->response_body->data,
0
+                          msg->response_body->length);
0
+
0
+      if (G_UNLIKELY (!buffer))
0
+        g_warning ("No data received");
0
       else
0
-        {
0
-          g_signal_emit (client, client_signals[AUTHENTICATE], 0,
0
-                         TWITTER_AUTH_FAILED, &retval);
0
-          priv->auth_complete = FALSE;
0
-        }
0
-    }
0
-}
0
+        twitter_timeline_load_from_data (closure->timeline, buffer);
0
 
0
-static void
0
-twitter_client_queue_message (TwitterClient       *client,
0
-                              const gchar         *url,
0
-                              gboolean             requires_auth,
0
-                              SoupSessionCallback  callback,
0
-                              gpointer             data)
0
-{
0
-  TwitterClientPrivate *priv = client->priv;
0
-  SoupMessage *msg;
0
+      emit_status_received (closure->client, closure->timeline);
0
 
0
-  msg = soup_message_new (SOUP_METHOD_GET, url);
0
+      g_free (buffer);
0
+    }
0
 
0
-  if (requires_auth && !priv->auth_id)
0
-    priv->auth_id = g_signal_connect (priv->session_async, "authenticate",
0
-                                      G_CALLBACK (twitter_client_auth),
0
-                                      client);
0
+  g_object_unref (closure->timeline);
0
+  g_object_unref (closure->client);
0
 
0
-  soup_session_queue_message (priv->session_async, msg,
0
-                              callback,
0
-                              data);
0
+  g_free (closure);
0
 }
0
 
0
 void
0
0
0
0
@@ -363,27 +600,20 @@
0
                                     guint          since_id)
0
 {
0
   GetTimelineClosure *clos;
0
-  gchar *url;
0
+  SoupMessage *msg;
0
 
0
   g_return_if_fail (TWITTER_IS_CLIENT (client));
0
 
0
-  if (since_id > 0)