Resolve service icon when account manager is ready
[conv-inbox] / src / el-home-applet.c
index 39274d3..97cd97d 100644 (file)
@@ -22,7 +22,7 @@
 
 #include "config.h"
 #include "el-home-applet.h"
-
+#include <libintl.h>
 #include <hildon/hildon.h>
 #include <rtcom-eventlogger/eventlogger.h>
 #include <sqlite3.h>
@@ -32,7 +32,6 @@
 #include <libosso-abook/osso-abook-contact.h>
 #include <libosso-abook/osso-abook-waitable.h>
 #include <libosso-abook/osso-abook-presence.h>
-#include <libosso-abook/osso-abook-avatar.h>
 #include <libosso-abook/osso-abook-touch-contact-starter.h>
 #include <libosso-abook/osso-abook-temporary-contact-dialog.h>
 #include <libosso-abook/osso-abook-account-manager.h>
 #define NOTIFICATION_UI_DBUS_PATH     "/org/freedesktop/Telepathy/Client/NotificationUI"
 #define NOTIFICATION_UI_DBUS_IFACE    "com.nokia.RtcomNotificationUi"
 
+#define CONVERSATIONS_UI_DBUS_NAME     "com.nokia.MessagingUI"
+#define CONVERSATIONS_UI_DBUS_PATH     "/com/nokia/MessagingUI"
+#define CONVERSATIONS_UI_DBUS_IFACE    "com.nokia.MessagingUI"
+
 static const gchar *conv_services[] = {"RTCOM_EL_SERVICE_SMS",
                                        "RTCOM_EL_SERVICE_CHAT",
                                        NULL};
@@ -100,9 +103,12 @@ struct _ELHomeAppletPrivate
         GtkWidget *icon;
         GtkWidget *unread;
         GtkWidget *received;
-        GtkWidget *empty;
         GtkWidget *cut_message;
-        GtkWidget *avatar;
+
+        /* empty view*/
+        GtkWidget *empty;
+        GtkWidget *sms_total;
+        GtkWidget *chat_total;
 
         gchar *message;
         gint event_id;
@@ -635,6 +641,16 @@ presence_updated (OssoABookPresence *presence,
         update_presence_pixbuf (self, presence);
 }
 
+static void
+show_contact (ELHomeApplet *self)
+{
+        ELHomeAppletPrivate *priv = self->priv;
+
+        gtk_label_set_text (GTK_LABEL (priv->sender),
+                            osso_abook_contact_get_display_name (priv->contact));
+        resize_sender (priv);
+        gtk_widget_queue_draw (GTK_WIDGET (self));
+}
 
 static void
 resolve_contact (ELHomeApplet *self)
@@ -670,26 +686,19 @@ resolve_contact (ELHomeApplet *self)
 
         if (contacts && contacts->data) {
                 priv->contact = g_object_ref (OSSO_ABOOK_CONTACT (contacts->data));
-                gtk_label_set_text (GTK_LABEL (priv->sender),
-                                    osso_abook_contact_get_display_name (priv->contact));
-
+                g_signal_connect (priv->contact,
+                                  "notify::presence-status",
+                                  G_CALLBACK (presence_updated),
+                                  self);
                 priv->avatar_pixbuf = osso_abook_avatar_get_image_scaled
                         (OSSO_ABOOK_AVATAR (priv->contact),
                          HILDON_ICON_PIXEL_SIZE_THUMB,
                          HILDON_ICON_PIXEL_SIZE_THUMB,
                          TRUE);
-
                 update_presence_pixbuf (self,
                                         OSSO_ABOOK_PRESENCE (priv->contact));
-                g_signal_connect (priv->contact,
-                                  "notify::presence-status",
-                                  G_CALLBACK (presence_updated),
-                                  self);
-
-                resize_sender (priv);
-                gtk_widget_queue_draw (GTK_WIDGET (self));
+                show_contact (self);
         }
-
 }
 
 static void
@@ -709,8 +718,6 @@ reset_contact (ELHomeApplet *self)
 {
         ELHomeAppletPrivate *priv = self->priv;
 
-        gtk_widget_hide (priv->icon);
-
         if (priv->avatar_pixbuf) {
                 g_object_unref (priv->avatar_pixbuf);
                 priv->avatar_pixbuf = NULL;
@@ -762,12 +769,35 @@ contacts_removed (OssoABookRoster *roster,
 }
 
 static void
-clean_state (ELHomeApplet *self)
+clean_contact (ELHomeApplet *self)
 {
         ELHomeAppletPrivate *priv = self->priv;
 
         reset_contact (self);
 
+        if (priv->aggregator) {
+                if (priv->aggregator_ready_closure){
+                        osso_abook_waitable_cancel (OSSO_ABOOK_WAITABLE (priv->aggregator),
+                                                    priv->aggregator_ready_closure);
+                        priv->aggregator_ready_closure = NULL;
+                }
+                g_signal_handlers_disconnect_by_func (priv->aggregator,
+                                                      contacts_added,
+                                                      self);
+                g_signal_handlers_disconnect_by_func (priv->aggregator,
+                                                      contacts_removed,
+                                                      self);
+                osso_abook_roster_stop (priv->aggregator);
+                g_object_unref (priv->aggregator);
+                priv->aggregator = NULL;
+        }
+}
+
+static void
+clean_state (ELHomeApplet *self)
+{
+        ELHomeAppletPrivate *priv = self->priv;
+
         if (priv->message) {
                 g_free (priv->message);
                 priv->message = NULL;
@@ -789,23 +819,6 @@ clean_state (ELHomeApplet *self)
                 g_free (priv->group_uid);
                 priv->group_uid = NULL;
         }
-
-        if (priv->aggregator) {
-                if (priv->aggregator_ready_closure){
-                        osso_abook_waitable_cancel (OSSO_ABOOK_WAITABLE (priv->aggregator),
-                                                    priv->aggregator_ready_closure);
-                        priv->aggregator_ready_closure = NULL;
-                }
-                g_signal_handlers_disconnect_by_func (priv->aggregator,
-                                                      contacts_added,
-                                                      self);
-                g_signal_handlers_disconnect_by_func (priv->aggregator,
-                                                      contacts_removed,
-                                                      self);
-                osso_abook_roster_stop (priv->aggregator);
-                g_object_unref (priv->aggregator);
-                priv->aggregator = NULL;
-        }
 }
 
 static void
@@ -828,6 +841,7 @@ dispose (GObject *self)
         }
 
         clean_state (EL_HOME_APPLET (self));
+        clean_contact (EL_HOME_APPLET (self));
 
         G_OBJECT_CLASS (el_home_applet_parent_class)->dispose (self);
 }
@@ -982,8 +996,6 @@ show_event (ELHomeApplet *self, RTComElIter *it)
                 priv->event_id = -1;
         }
 
-        gtk_widget_hide (priv->avatar);
-
         if (priv->message) {
                 gtk_widget_hide (priv->empty);
         }
@@ -1029,7 +1041,7 @@ make_query (RTComEl *el, gint event_id)
                 rtcom_el_query_prepare (query,
                                         "is-read", FALSE, RTCOM_EL_OP_EQUAL,
                                         "service", conv_services, RTCOM_EL_OP_IN_STRV,
-                                        /* "event-type", conv_event_types, RTCOM_EL_OP_IN_STRV, */
+                                        "event-type", conv_event_types, RTCOM_EL_OP_IN_STRV,
                                         NULL);
         }
         it = rtcom_el_get_events (el, query);
@@ -1089,40 +1101,172 @@ query_unread_events (RTComEl *el)
         return count;
 }
 
+static gboolean
+query_read_events (RTComEl *el, const gchar *service, gint *events, gint *conversations)
+{
+        sqlite3 *db;
+        sqlite3_stmt *stmt;
+        int ret;
+        gboolean result = TRUE;
+
+        g_object_get (el, "db", &db, NULL);
+
+        if (sqlite3_prepare_v2 (db,
+                                "SELECT SUM(total_events), COUNT(group_uid) FROM GroupCache, Services "
+                                "WHERE GroupCache.service_id=Services.id AND Services.name=?;",
+                                -1,
+                                &stmt,
+                                NULL) != SQLITE_OK) {
+                g_error ("%s: can't compile SQL", G_STRFUNC);
+                return FALSE;
+        }
+        if (sqlite3_bind_text (stmt, 1, service, -1, SQLITE_STATIC) != SQLITE_OK)  {
+                g_error ("Failed to bind %s to SQL stmt", service);
+                result = FALSE;
+                goto DONE;
+        }
+
+        while (SQLITE_BUSY == (ret = sqlite3_step (stmt)));
+
+        if (ret == SQLITE_ROW) {
+                *events = sqlite3_column_int (stmt, 0);
+                *conversations = sqlite3_column_int (stmt, 1);
+        }
+        else {
+                g_error ("%s: error while executing SQL", G_STRFUNC);
+                result = FALSE;
+                goto DONE;
+        }
+
+ DONE:
+        sqlite3_finalize (stmt);
+
+        return result;
+}
+
+static void
+am_ready (OssoABookAccountManager *manager,
+          const GError            *error,
+          gpointer                 user_data)
+{
+        ELHomeApplet *self = EL_HOME_APPLET (user_data);
+        ELHomeAppletPrivate *priv = self->priv;
+
+        if (!error &&
+            priv->local_id &&
+            !GTK_WIDGET_VISIBLE (priv->icon)) {
+                McAccount *account;
+
+                account = osso_abook_account_manager_lookup_by_name (NULL,
+                                                                     priv->local_id);
+                if (account) {
+                        McProfile *profile = mc_profile_lookup (mc_account_compat_get_profile (account));
+                        const gchar *icon_name = mc_profile_get_icon_name (profile);
+                        if (icon_name) {
+                                gtk_image_set_from_icon_name (GTK_IMAGE (priv->icon),
+                                                              icon_name,
+                                                              HILDON_ICON_SIZE_XSMALL);
+                                gtk_widget_show (priv->icon);
+                        }
+                }
+        }
+}
+
 static void
 read_event (ELHomeApplet *self)
 {
         ELHomeAppletPrivate *priv = self->priv;
         RTComElIter *it = NULL;
         const gchar *icon_name = NULL;
+        gchar *remote_id;
+        gchar *local_id;
+
+        remote_id = g_strdup (priv->remote_id);
+        local_id = g_strdup (priv->local_id);
 
         clean_state (self);
 
         it = make_query (priv->eventlogger, -1);
         show_event (self, it);
-        start_aggregator (self);
 
-        if (g_strcmp0 (priv->local_id, "ring/tel/ring") == 0) {
-                icon_name = "general_sms";
-        }
-        else{
-                McAccount *account;
-                account = osso_abook_account_manager_lookup_by_name (NULL,
-                                                                     priv->local_id);
-                if (account) {
-                        McProfile *profile = mc_profile_lookup (mc_account_compat_get_profile (account));
-                        icon_name = mc_profile_get_icon_name (profile);
+        if (it) g_object_unref (it);
+
+        if (priv->event_id >= 0) {
+                gboolean new_account = g_strcmp0 (priv->local_id, local_id);
+
+                if (g_strcmp0 (priv->remote_id, remote_id) || new_account) {
+                        clean_contact (self);
+                        start_aggregator (self);
+                }
+                else {
+                        show_contact (self);
+                }
+
+                if (new_account) {
+                        g_warning ("Update service icon");
+                        if (g_strcmp0 (priv->local_id, "ring/tel/ring") == 0) {
+                                icon_name = "general_sms";
+                        }
+                        else {
+                                McAccount *account;
+                                OssoABookAccountManager *am = osso_abook_account_manager_get_default ();
+                                if (!osso_abook_waitable_is_ready (OSSO_ABOOK_WAITABLE (am), NULL)) {
+                                        osso_abook_account_manager_call_when_ready  (am,
+                                                                                     am_ready,
+                                                                                     self,
+                                                                                     NULL);
+                                }
+                                else {
+                                        account = osso_abook_account_manager_lookup_by_name (NULL,
+                                                                                             priv->local_id);
+                                        if (account) {
+                                                McProfile *profile = mc_profile_lookup (mc_account_compat_get_profile (account));
+                                                icon_name = mc_profile_get_icon_name (profile);
+                                        }
+                                }
+                        }
+
+                        if (icon_name) {
+                                gtk_image_set_from_icon_name (GTK_IMAGE (priv->icon),
+                                                              icon_name,
+                                                              HILDON_ICON_SIZE_XSMALL);
+                                gtk_widget_show (priv->icon);
+                        }
+                        else
+                                gtk_widget_hide (priv->icon);
                 }
         }
+        else {
+                gchar *text;
+                gint n_sms_events = 0, n_sms_convs = 0;
+                gint n_chat_events = 0, n_chat_convs = 0;
+                const gchar *fmt = "%d <span size=\"small\">(%d)</span>";
+
+                query_read_events (priv->eventlogger,
+                                   "RTCOM_EL_SERVICE_SMS",
+                                   &n_sms_events, &n_sms_convs);
+                query_read_events (priv->eventlogger,
+                                   "RTCOM_EL_SERVICE_CHAT",
+                                   &n_chat_events, &n_chat_convs);
+
+                text = g_strdup_printf (fmt, n_sms_convs, n_sms_events);
+                gtk_label_set_markup (GTK_LABEL (priv->sms_total), text);
+                g_free (text);
+
+                text = g_strdup_printf (fmt, n_chat_convs, n_chat_events);
+                gtk_label_set_markup (GTK_LABEL (priv->chat_total), text);
+                g_free (text);
+
+                gtk_label_set_text (GTK_LABEL (priv->sender),
+                                    dgettext ("rtcom-messaging-ui",
+                                              "messaging_ap_conversations"));
 
-        if (icon_name) {
-                gtk_image_set_from_icon_name (GTK_IMAGE (priv->icon),
-                                              icon_name,
-                                              HILDON_ICON_SIZE_XSMALL);
-                gtk_widget_show (priv->icon);
+                clean_contact (self);
+                gtk_widget_hide (priv->icon);
         }
 
-        if (it) g_object_unref (it);
+        g_free (local_id);
+        g_free (remote_id);
 }
 
 static void
@@ -1130,7 +1274,7 @@ remove_notification (ELHomeApplet *self)
 {
         ELHomeAppletPrivate *priv = self->priv;
 
-        DBusGConnection* conn;
+        DBusGConnection *conn;
         GError *error;
         DBusGProxy *proxy;
         GPtrArray *conv_structs;
@@ -1206,6 +1350,38 @@ mark_as_read (ELHomeApplet *self)
 }
 
 static void
+launch_conversations (ELHomeApplet *self)
+{
+        DBusConnection *conn;
+        DBusMessage *message;
+        DBusError error;
+
+        dbus_error_init (&error);
+        conn = hd_home_plugin_item_get_dbus_connection (HD_HOME_PLUGIN_ITEM (self),
+                                                        DBUS_BUS_SESSION,
+                                                        &error);
+        if (!conn) {
+                if (dbus_error_is_set (&error)) {
+                        g_error ("Failed to get dbus connection %s", error.message);
+                        dbus_error_free (&error);
+                }
+                return;
+        }
+
+        message = dbus_message_new_method_call (CONVERSATIONS_UI_DBUS_NAME,
+                                                CONVERSATIONS_UI_DBUS_PATH,
+                                                CONVERSATIONS_UI_DBUS_IFACE,
+                                                "top_application");
+        dbus_message_set_no_reply (message, TRUE);
+
+        if (dbus_connection_send (conn, message, NULL))
+                dbus_connection_flush (conn);
+        dbus_message_unref (message);
+
+        dbus_connection_close (conn);
+}
+
+static void
 open_conversation (ELHomeApplet *self)
 {
         ELHomeAppletPrivate *priv = self->priv;
@@ -1301,20 +1477,21 @@ new_event_cb (RTComEl      *backend,
               ELHomeApplet *self)
 {
         g_warning ("%s %s %s %s", local_uid, remote_uid, remote_ebook_uid, service);
-#if 0
-        const gchar** conv_service = conv_services;
+
+        if (service && service[0] != '\0') {
+                const gchar** conv_service = conv_services;
                 g_warning ("%s", service);
-        do {
-                g_warning ("%s", *conv_service);
-                if (!g_strcmp0 (*conv_service, service)) {
-                        add_new_idle (self);
-                        return;
+                do {
+                        g_warning ("%s", *conv_service);
+                        if (!g_strcmp0 (*conv_service, service)) {
+                                add_new_idle (self);
+                                return;
+                        }
                 }
+                while(*++conv_service);
         }
-        while(*++conv_service);
-#else
-        add_new_idle (self);
-#endif
+        else
+                add_new_idle (self);
 }
 
 static gboolean
@@ -1346,7 +1523,7 @@ button_press_event_cb (GtkWidget      *widget,
 {
         ELHomeAppletPrivate *priv = self->priv;
 
-        if (priv->event_id > 0) {
+        if (priv->event_id >= 0) {
                 if (event->y < CONTENT_OFFSET_Y_TOP + HEADER_HEIGHT) {
                         if (priv->aggregator &&
                             osso_abook_waitable_is_ready
@@ -1358,10 +1535,13 @@ button_press_event_cb (GtkWidget      *widget,
                         priv->active = SELECTED_FOOTER;
                 else
                         priv->active = SELECTED_BODY;
-
-                gtk_widget_queue_draw (widget);
+        }
+        else {
+                priv->active = SELECTED_BODY;
         }
 
+        gtk_widget_queue_draw (widget);
+
         return TRUE;
 }
 
@@ -1427,8 +1607,12 @@ button_release_event_cb (GtkWidget      *widget,
 
         switch (priv->active) {
         case SELECTED_BODY:
-                reset_scroll (self);
-                open_conversation (self);
+                if (priv->event_id >= 0) {
+                        reset_scroll (self);
+                        open_conversation (self);
+                }
+                else
+                        launch_conversations (self);
                 break;
         case SELECTED_HEADER: {
                 GtkWidget *dialog = NULL;
@@ -1498,6 +1682,7 @@ el_home_applet_init (ELHomeApplet *self)
         ELHomeAppletPrivate *priv;
         GtkWidget *event_box;
         GtkWidget *hbox, *vbox, *align, *footer;
+        GtkWidget *w;
 
         self->priv = EL_HOME_APPLET_GET_PRIVATE (self);
         priv = self->priv;
@@ -1515,11 +1700,6 @@ el_home_applet_init (ELHomeApplet *self)
                                 0.5f,
                                 0.5f);
 
-        priv->avatar = gtk_image_new ();
-        gtk_misc_set_alignment (GTK_MISC (priv->avatar),
-                                0.5f,
-                                0.5f);
-
         priv->sender = gtk_label_new ("asdf asdf asdf asdf asdf");
         gtk_misc_set_alignment (GTK_MISC (priv->sender),
                                 0.5f,
@@ -1534,9 +1714,33 @@ el_home_applet_init (ELHomeApplet *self)
 
         priv->message = g_strdup ("One two three four five six seven eight nine ten");
 
-        /* TODO: l10n */
-        priv->empty = gtk_label_new ("No new messages");
-        gtk_widget_set_name (priv->empty, "hildon-shadow-label");
+        /* construt empty table */
+        priv->empty = gtk_fixed_new ();
+
+        w = gtk_image_new_from_icon_name ("general_sms", HILDON_ICON_SIZE_FINGER);
+        gtk_fixed_put (GTK_FIXED (priv->empty), w,
+                       4*HILDON_MARGIN_DOUBLE,
+                       2*HILDON_MARGIN_DOUBLE);
+
+        w = gtk_image_new_from_icon_name ("general_chat", HILDON_ICON_SIZE_FINGER);
+        gtk_fixed_put (GTK_FIXED (priv->empty), w,
+                       4*HILDON_MARGIN_DOUBLE,
+                       3*HILDON_MARGIN_DOUBLE + HILDON_ICON_PIXEL_SIZE_FINGER);
+
+        priv->sms_total = gtk_label_new (NULL);
+        gtk_widget_set_name (priv->sms_total, "hildon-shadow-label");
+        gtk_fixed_put (GTK_FIXED (priv->empty), priv->sms_total,
+                       5*HILDON_MARGIN_DOUBLE  + HILDON_ICON_PIXEL_SIZE_FINGER,
+                       2*HILDON_MARGIN_DOUBLE + HILDON_MARGIN_HALF);
+
+        priv->chat_total = gtk_label_new (NULL);
+        gtk_widget_set_name (priv->chat_total, "hildon-shadow-label");
+        gtk_fixed_put (GTK_FIXED (priv->empty), priv->chat_total,
+                       5*HILDON_MARGIN_DOUBLE  + HILDON_ICON_PIXEL_SIZE_FINGER,
+                       3*HILDON_MARGIN_DOUBLE + HILDON_MARGIN_HALF + HILDON_ICON_PIXEL_SIZE_FINGER);
+
+        gtk_widget_show_all (GTK_WIDGET (priv->empty));
+        gtk_widget_hide (GTK_WIDGET (priv->empty));
         GTK_WIDGET_SET_FLAGS (priv->empty, GTK_NO_SHOW_ALL);
 
         priv->received = gtk_label_new ("aewf aewf aewf awef");