+ return FALSE;
+}
+
+static gboolean
+on_idle_delete_message (gpointer user_data)
+{
+ const char *uri = NULL;
+
+ uri = (char *) user_data;
+
+ g_thread_create (thread_prepare_delete_message, g_strdup (uri), FALSE, NULL);
+
+ return FALSE;
+
+}
+
+
+
+
+static gint
+on_delete_message (GArray *arguments, gpointer data, osso_rpc_t *retval)
+{
+ /* Get the arguments: */
+ osso_rpc_t val = g_array_index (arguments,
+ osso_rpc_t,
+ MODEST_DBUS_DELETE_MESSAGE_ARG_URI);
+ gchar *uri = g_strdup (val.value.s);
+
+ /* Use g_idle to context-switch into the application's thread: */
+ g_idle_add(on_idle_delete_message, (gpointer)uri);
+
+ return OSSO_OK;
+}
+
+typedef struct _SendReceivePerformerData {
+ gchar *account_id;
+ gboolean manual;
+ ModestMailOperation *mail_op;
+} SendReceivePerformerData;
+
+static void send_receive_performer_data_free (SendReceivePerformerData *data)
+{
+ if (data->mail_op) {
+ g_object_unref (data->mail_op);
+ }
+ g_free (data->account_id);
+ g_slice_free (SendReceivePerformerData, data);
+}
+
+static gboolean
+on_idle_send_receive(gpointer user_data)
+{
+ gboolean auto_update;
+ SendReceivePerformerData *data = (SendReceivePerformerData *) user_data;
+ ModestConnectedVia connect_when;
+ gboolean right_connection = FALSE;
+
+ gdk_threads_enter (); /* CHECKED */
+
+ /* Check if the autoupdate feature is on */
+ auto_update = modest_conf_get_bool (modest_runtime_get_conf (),
+ MODEST_CONF_AUTO_UPDATE, NULL);
+
+ if (auto_update) {
+ /* Do send receive. Never set the current top window
+ as we always assume that DBus send/receive requests
+ are not user driven */
+
+ connect_when = modest_conf_get_int (modest_runtime_get_conf (),
+ MODEST_CONF_UPDATE_WHEN_CONNECTED_BY, NULL);
+ /* Perform a send and receive if the user selected to connect
+ via any mean or if the current connection method is the
+ same as the one specified by the user */
+ if (connect_when == MODEST_CONNECTED_VIA_ANY ||
+ connect_when == modest_platform_get_current_connection ()) {
+ right_connection = TRUE;
+ }
+ } else {
+ /* Disable auto update */
+ modest_platform_set_update_interval (0);
+ }
+
+ if ((auto_update && right_connection) || data->manual) {
+ if (data->account_id) {
+ modest_ui_actions_do_send_receive (data->account_id, data->manual, FALSE, data->manual, NULL);
+ } else {
+ modest_ui_actions_do_send_receive_all (NULL, data->manual, FALSE, data->manual);
+ }
+ }
+
+ modest_mail_operation_queue_remove (modest_runtime_get_mail_operation_queue (),
+ data->mail_op);
+
+ send_receive_performer_data_free (data);
+
+ gdk_threads_leave (); /* CHECKED */
+
+ return FALSE;
+}
+
+static gint
+on_dbus_method_dump_send_queues (DBusConnection *con, DBusMessage *message)
+{
+ gchar *str;
+
+ DBusMessage *reply;
+ dbus_uint32_t serial = 0;
+
+ GSList *account_names, *cursor;
+
+ str = g_strdup("\nsend queues\n"
+ "===========\n");
+
+ cursor = account_names = modest_account_mgr_account_names
+ (modest_runtime_get_account_mgr(), TRUE); /* only enabled accounts */
+
+ while (cursor) {
+ TnyAccount *acc;
+ gchar *tmp, *accname = (gchar*)cursor->data;
+
+ tmp = g_strdup_printf ("%s", str);
+ g_free (str);
+ str = tmp;
+
+ /* transport */
+ acc = modest_tny_account_store_get_server_account (
+ modest_runtime_get_account_store(), accname,
+ TNY_ACCOUNT_TYPE_TRANSPORT);
+ if (TNY_IS_ACCOUNT(acc)) {
+ gchar *tmp = NULL, *url = tny_account_get_url_string (acc);
+ ModestTnySendQueue *sendqueue =
+ modest_runtime_get_send_queue (TNY_TRANSPORT_ACCOUNT(acc), TRUE);
+
+ if (TNY_IS_SEND_QUEUE (sendqueue)) {
+ gchar *queue_str = modest_tny_send_queue_to_string (sendqueue);
+
+ tmp = g_strdup_printf ("%s[%s]: '%s': %s\n%s",
+ str, accname, tny_account_get_id (acc), url,
+ queue_str);
+ g_free(queue_str);
+ g_free (str);
+ str = tmp;
+ }
+ g_free (url);
+
+ g_object_unref (acc);
+ }
+
+ cursor = g_slist_next (cursor);
+ }
+ modest_account_mgr_free_account_names (account_names);
+
+ g_printerr (str);
+
+ reply = dbus_message_new_method_return (message);
+ if (reply) {
+ dbus_message_append_args (reply,
+ DBUS_TYPE_STRING, &str,
+ DBUS_TYPE_INVALID);
+ dbus_connection_send (con, reply, &serial);
+ dbus_connection_flush (con);
+ dbus_message_unref (reply);
+ }
+ g_free (str);
+
+ /* Let modest die */
+ g_idle_add (notify_error_in_dbus_callback, NULL);
+
+ return OSSO_OK;
+}
+
+
+static gint
+on_dbus_method_dump_operation_queue (DBusConnection *con, DBusMessage *message)
+{
+ gchar *str;
+ gchar *op_queue_str;
+
+ DBusMessage *reply;
+ dbus_uint32_t serial = 0;
+
+ /* operations queue; */
+ op_queue_str = modest_mail_operation_queue_to_string
+ (modest_runtime_get_mail_operation_queue ());
+
+ str = g_strdup_printf ("\noperation queue\n"
+ "===============\n"
+ "status: %s\n"
+ "%s\n",
+ tny_device_is_online (modest_runtime_get_device ()) ? "online" : "offline",
+ op_queue_str);
+ g_free (op_queue_str);
+
+ g_printerr (str);
+
+ reply = dbus_message_new_method_return (message);
+ if (reply) {
+ dbus_message_append_args (reply,
+ DBUS_TYPE_STRING, &str,
+ DBUS_TYPE_INVALID);
+ dbus_connection_send (con, reply, &serial);
+ dbus_connection_flush (con);
+ dbus_message_unref (reply);
+ }
+ g_free (str);
+
+ /* Let modest die */
+ g_idle_add (notify_error_in_dbus_callback, NULL);
+
+ return OSSO_OK;
+}
+
+
+
+static gint
+on_dbus_method_dump_accounts (DBusConnection *con, DBusMessage *message)
+{
+ gchar *str;
+
+ DBusMessage *reply;
+ dbus_uint32_t serial = 0;
+
+ GSList *account_names, *cursor;
+
+ str = g_strdup ("\naccounts\n========\n");
+
+ cursor = account_names = modest_account_mgr_account_names
+ (modest_runtime_get_account_mgr(), TRUE); /* only enabled accounts */
+
+ while (cursor) {
+ TnyAccount *acc;
+ gchar *tmp, *accname = (gchar*)cursor->data;
+
+ tmp = g_strdup_printf ("%s[%s]\n", str, accname);
+ g_free (str);
+ str = tmp;
+
+ /* store */
+ acc = modest_tny_account_store_get_server_account (
+ modest_runtime_get_account_store(), accname,
+ TNY_ACCOUNT_TYPE_STORE);
+ if (TNY_IS_ACCOUNT(acc)) {
+ gchar *tmp, *url = tny_account_get_url_string (acc);
+ tmp = g_strdup_printf ("%sstore : '%s': %s (refs: %d)\n",
+ str, tny_account_get_id (acc), url,
+ ((GObject*)acc)->ref_count-1);
+ g_free (str);
+ str = tmp;
+ g_free (url);
+ g_object_unref (acc);
+ }
+
+ /* transport */
+ acc = modest_tny_account_store_get_server_account (
+ modest_runtime_get_account_store(), accname,
+ TNY_ACCOUNT_TYPE_TRANSPORT);
+ if (TNY_IS_ACCOUNT(acc)) {
+ gchar *tmp, *url = tny_account_get_url_string (acc);
+ tmp = g_strdup_printf ("%stransport: '%s': %s (refs: %d)\n",
+ str, tny_account_get_id (acc), url,
+ ((GObject*)acc)->ref_count-1);
+ g_free (str);
+ str = tmp;
+ g_free (url);
+ g_object_unref (acc);
+ }
+
+ cursor = g_slist_next (cursor);
+ }
+
+ modest_account_mgr_free_account_names (account_names);
+
+ g_printerr (str);
+
+ reply = dbus_message_new_method_return (message);
+ if (reply) {
+ dbus_message_append_args (reply,
+ DBUS_TYPE_STRING, &str,
+ DBUS_TYPE_INVALID);
+ dbus_connection_send (con, reply, &serial);
+ dbus_connection_flush (con);
+ dbus_message_unref (reply);
+ }
+ g_free (str);
+
+ /* Let modest die */
+ g_idle_add (notify_error_in_dbus_callback, NULL);
+
+ return OSSO_OK;
+}
+
+static void
+on_send_receive_performer(gboolean canceled,
+ GError *err,
+ ModestWindow *parent_window,
+ TnyAccount *account,
+ gpointer user_data)
+{
+ SendReceivePerformerData *data = (SendReceivePerformerData *) user_data;
+
+ if (err || canceled || data == NULL) {
+ g_idle_add (notify_error_in_dbus_callback, NULL);
+ if (data) {
+ send_receive_performer_data_free (data);
+ }
+ return;
+ }
+
+ data->mail_op = modest_mail_operation_new (NULL);
+ modest_mail_operation_queue_add (modest_runtime_get_mail_operation_queue (),
+ data->mail_op);
+ if (data->manual) {
+ g_idle_add (on_idle_send_receive, data);
+ } else {
+ modest_heartbeat_add (on_idle_send_receive, data);
+ }
+}
+
+
+static gint
+on_send_receive(GArray *arguments, gpointer data, osso_rpc_t * retval)
+{
+ TnyDevice *device = modest_runtime_get_device ();
+ SendReceivePerformerData *srp_data;
+
+ srp_data = g_slice_new0 (SendReceivePerformerData);
+ srp_data->account_id = NULL;
+ srp_data->manual = FALSE;
+ srp_data->mail_op = NULL;
+
+ if (!tny_device_is_online (device))
+ modest_platform_connect_and_perform (NULL, FALSE, NULL, on_send_receive_performer, srp_data);
+ else
+ on_send_receive_performer (FALSE, NULL, NULL, NULL, srp_data);
+
+ return OSSO_OK;
+}
+
+static gint
+on_send_receive_full (GArray *arguments, gpointer data, osso_rpc_t * retval)
+{
+ osso_rpc_t val;
+ gchar *account_id;
+ gboolean manual;
+ TnyDevice *device;
+ SendReceivePerformerData *srp_data;
+
+ val = g_array_index (arguments, osso_rpc_t, MODEST_DBUS_SEND_RECEIVE_FULL_ARG_ACCOUNT_ID);
+ account_id = g_strdup (val.value.s);
+ val = g_array_index (arguments, osso_rpc_t, MODEST_DBUS_SEND_RECEIVE_FULL_ARG_MANUAL);
+ manual = val.value.b;
+
+ srp_data = g_slice_new0 (SendReceivePerformerData);
+ srp_data->manual = manual;
+ if (account_id && account_id[0] != '\0') {
+ srp_data->account_id = account_id;
+ } else {
+ srp_data->account_id = NULL;
+ g_free (account_id);
+ }
+ srp_data->mail_op = NULL;
+ device = modest_runtime_get_device ();
+ if (!tny_device_is_online (device))
+ modest_platform_connect_and_perform (NULL, FALSE, NULL, on_send_receive_performer, srp_data);
+ else
+ on_send_receive_performer (FALSE, NULL, NULL, NULL, srp_data);
+
+ return OSSO_OK;
+}
+
+static gboolean
+on_idle_update_folder_counts (gpointer userdata)
+{
+ ModestMailOperation *mail_op;
+ gchar *account_id = (gchar *) userdata;
+
+ mail_op = modest_mail_operation_new (NULL);
+ modest_mail_operation_queue_add (modest_runtime_get_mail_operation_queue (),
+ mail_op);
+ modest_mail_operation_update_folder_counts (mail_op, account_id);
+ g_object_unref (mail_op);
+ g_free (account_id);
+
+ return FALSE;
+
+}
+
+static gint
+on_update_folder_counts (GArray *arguments, gpointer data, osso_rpc_t * retval)
+{
+ osso_rpc_t val;
+ gchar *account_id;