+ if (uri && g_str_has_prefix (uri, "merge://")) {
+ /* we assume we're talking about outbox folder, as this
+ * is the only merge folder we work with in modest */
+ return modest_tny_account_store_find_msg_in_outboxes (astore, uri, ac_out);
+ }
+ account = tny_account_store_find_account (TNY_ACCOUNT_STORE (astore),
+ uri);
+
+ if (account == NULL || !TNY_IS_STORE_ACCOUNT (account))
+ goto out;
+ *ac_out = account;
+
+ folder = tny_store_account_find_folder (TNY_STORE_ACCOUNT (account), uri, NULL);
+
+ if (folder == NULL)
+ goto out;
+
+ msg = tny_folder_find_msg (folder, uri, NULL);
+
+out:
+ if (account && !msg) {
+ g_object_unref (account);
+ *ac_out = NULL;
+ }
+ if (folder)
+ g_object_unref (folder);
+
+ return msg;
+}
+
+typedef struct {
+ TnyAccount *account;
+ gchar *uri;
+} OpenMsgPerformerInfo;
+
+static void
+on_open_message_performer (gboolean canceled,
+ GError *err,
+ GtkWindow *parent_window,
+ TnyAccount *account,
+ gpointer user_data)
+{
+ OpenMsgPerformerInfo *info;
+ gchar *uri;
+ TnyHeader *header;
+ gchar *msg_uid;
+ ModestWindowMgr *win_mgr;
+ ModestWindow *msg_view = NULL;
+ gboolean is_draft = FALSE;
+ TnyFolder *folder = NULL;
+ TnyMsg *msg = NULL;
+
+ info = (OpenMsgPerformerInfo *) user_data;
+ uri = info->uri;
+
+ if (canceled || err) {
+ goto frees;
+ }
+
+ /* Get message */
+ folder = tny_store_account_find_folder (TNY_STORE_ACCOUNT (account), uri, NULL);
+ msg = tny_folder_find_msg (folder, uri, NULL);
+
+ if (modest_tny_folder_is_local_folder (folder) &&
+ (modest_tny_folder_get_local_or_mmc_folder_type (folder) == TNY_FOLDER_TYPE_DRAFTS)) {
+ is_draft = TRUE;
+ }
+
+ if (!msg) {
+ g_idle_add (notify_msg_not_found_in_idle, NULL);
+ goto frees;
+ }
+
+ header = tny_msg_get_header (msg);
+ if (header && (tny_header_get_flags (header)&TNY_HEADER_FLAG_DELETED)) {
+ g_object_unref (header);
+ g_object_unref (msg);
+ g_idle_add (notify_msg_not_found_in_idle, NULL);
+ goto frees;
+ }
+ msg_uid = modest_tny_folder_get_header_unique_id (header);
+ win_mgr = modest_runtime_get_window_mgr ();
+
+ if (modest_window_mgr_find_registered_header (win_mgr, header, &msg_view)) {
+ gtk_window_present (GTK_WINDOW(msg_view));
+ } else {
+ const gchar *modest_account_name;
+
+ /* g_debug ("creating new window for this msg"); */
+ modest_window_mgr_register_header (win_mgr, header, NULL);
+
+ modest_account_name =
+ modest_tny_account_get_parent_modest_account_name_for_server_account (account);
+
+ /* Drafts will be opened in the editor, and others will be opened in the viewer */
+ if (is_draft) {
+ msg_view = modest_msg_edit_window_new (msg, modest_account_name, TRUE);
+ } else {
+ TnyHeader *header;
+ header = tny_msg_get_header (msg);
+ msg_view = modest_msg_view_window_new_for_search_result (msg, modest_account_name, msg_uid);
+ if (! (tny_header_get_flags (header) & TNY_HEADER_FLAG_SEEN))
+ tny_header_set_flag (header, TNY_HEADER_FLAG_SEEN);
+ g_object_unref (header);
+
+ }
+ modest_window_mgr_register_window (win_mgr, msg_view);
+ gtk_widget_show_all (GTK_WIDGET (msg_view));
+ }
+ g_object_unref (header);
+ g_object_unref (msg);
+ g_object_unref (folder);
+
+ frees:
+ g_free (info->uri);
+ g_object_unref (info->account);
+ g_slice_free (OpenMsgPerformerInfo, info);
+}
+
+static gboolean
+on_idle_open_message_performer (gpointer user_data)
+{
+ OpenMsgPerformerInfo *info = (OpenMsgPerformerInfo *) user_data;
+
+ /* Lock before the call as we're in an idle handler */
+ gdk_threads_enter ();
+ modest_platform_connect_and_perform (NULL, info->account,
+ on_open_message_performer, info);
+ gdk_threads_leave ();
+
+ return FALSE;
+}
+
+static gint
+on_open_message (GArray * arguments, gpointer data, osso_rpc_t * retval)
+{
+ osso_rpc_t val;
+ gchar *uri;
+ TnyAccount *account = NULL;
+ gint osso_retval;
+
+ /* Get the arguments: */
+ val = g_array_index(arguments, osso_rpc_t, MODEST_DBUS_OPEN_MESSAGE_ARG_URI);
+ uri = g_strdup (val.value.s);
+
+ /* Get the account */
+ account = tny_account_store_find_account (TNY_ACCOUNT_STORE (modest_runtime_get_account_store ()),
+ uri);
+
+
+ if (account) {
+ OpenMsgPerformerInfo *info;
+
+ info = g_slice_new0 (OpenMsgPerformerInfo);
+ info->account = g_object_ref (account);
+ info->uri = uri;
+
+ /* We need to call it into an idle to get
+ modest_platform_connect_and_perform into the main
+ loop */
+ g_idle_add (on_idle_open_message_performer, info);
+ osso_retval = OSSO_OK;
+ } else {
+ g_free (uri);
+ osso_retval = OSSO_ERROR;
+ g_idle_add (notify_error_in_dbus_callback, NULL);
+ }
+
+ g_object_unref (account);
+ return osso_retval;
+}
+
+static gboolean
+on_idle_delete_message (gpointer user_data)
+{
+ TnyList *headers = NULL;
+ TnyFolder *folder = NULL;
+ TnyIterator *iter = NULL;
+ TnyHeader *header = NULL, *msg_header = NULL;
+ TnyMsg *msg = NULL;
+ TnyAccount *account = NULL;
+ const char *uri = NULL, *uid = NULL;
+ gint res = 0;
+ ModestMailOperation *mail_op = NULL;
+ ModestWindow *main_win = NULL, *msg_view = NULL;
+
+ uri = (char *) user_data;
+
+ msg = find_message_by_url (uri, &account);
+
+ if (!msg) {
+ g_warning ("%s: Could not find message '%s'", __FUNCTION__, uri);
+ g_idle_add (notify_error_in_dbus_callback, NULL);
+ return OSSO_ERROR;
+ }
+
+ main_win = modest_window_mgr_get_main_window (modest_runtime_get_window_mgr(),
+ FALSE); /* don't create */
+
+ msg_header = tny_msg_get_header (msg);
+ uid = tny_header_get_uid (msg_header);
+ folder = tny_msg_get_folder (msg);
+
+ if (!folder) {
+ g_warning ("%s: Could not find folder (uri:'%s')", __FUNCTION__, uri);
+ g_object_unref (msg);
+ g_idle_add (notify_error_in_dbus_callback, NULL);
+ return OSSO_ERROR;
+ }
+
+ headers = tny_simple_list_new ();
+ tny_folder_get_headers (folder, headers, TRUE, NULL);
+ iter = tny_list_create_iterator (headers);
+ header = NULL;
+
+ while (!tny_iterator_is_done (iter)) {
+ const char *cur_id = NULL;
+
+ header = TNY_HEADER (tny_iterator_get_current (iter));
+ if (header)
+ cur_id = tny_header_get_uid (header);
+
+ if (cur_id && uid && g_str_equal (cur_id, uid)) {
+ /* g_debug ("Found corresponding header from folder"); */
+ break;
+ }
+
+ if (header) {
+ g_object_unref (header);
+ header = NULL;
+ }
+
+ tny_iterator_next (iter);
+ }
+
+ g_object_unref (iter);
+ iter = NULL;
+ g_object_unref (headers);
+ headers = NULL;
+
+ g_object_unref (msg_header);
+ msg_header = NULL;
+ g_object_unref (msg);
+ msg = NULL;
+
+ if (header == NULL) {
+ if (folder)
+ g_object_unref (folder);
+ g_idle_add (notify_error_in_dbus_callback, NULL);
+ return OSSO_ERROR;
+ }
+
+ res = OSSO_OK;
+
+ /* This is a GDK lock because we are an idle callback and
+ * the code below is or does Gtk+ code */
+ gdk_threads_enter (); /* CHECKED */
+
+ mail_op = modest_mail_operation_new (main_win ? G_OBJECT(main_win) : NULL);
+ modest_mail_operation_queue_add (modest_runtime_get_mail_operation_queue (), mail_op);
+ modest_mail_operation_remove_msg (mail_op, header, FALSE);
+ g_object_unref (G_OBJECT (mail_op));
+
+ if (main_win) { /* no need if there's no window */
+ if (modest_window_mgr_find_registered_header (modest_runtime_get_window_mgr(),
+ header, &msg_view)) {
+ if (MODEST_IS_MSG_VIEW_WINDOW (msg_view))
+ modest_ui_actions_refresh_message_window_after_delete (MODEST_MSG_VIEW_WINDOW (msg_view));
+ }
+ }
+ gdk_threads_leave (); /* CHECKED */
+
+ if (header)
+ g_object_unref (header);
+
+ if (folder) {
+ /* Trick: do a poke status in order to speed up the signaling
+ of observers.
+ A delete via the menu does this, in do_headers_action(),
+ though I don't know why.
+ */
+ tny_folder_poke_status (folder);
+
+ g_object_unref (folder);
+ }
+
+ if (account)
+ g_object_unref (account);
+
+ /* Refilter the header view explicitly, to make sure that
+ * deleted emails are really removed from view.
+ * (They are not really deleted until contact is made with the server,
+ * so they would appear with a strike-through until then):
+ */
+ if (main_win) { /* only needed when there's a mainwindow / UI */
+
+ /* This is a GDK lock because we are an idle callback and
+ * the code below is or does Gtk+ code */
+ gdk_threads_enter (); /* CHECKED */
+ ModestHeaderView *header_view = (ModestHeaderView *)
+ modest_main_window_get_child_widget (MODEST_MAIN_WINDOW(main_win),
+ MODEST_MAIN_WINDOW_WIDGET_TYPE_HEADER_VIEW);
+ if (header_view && MODEST_IS_HEADER_VIEW (header_view))
+ modest_header_view_refilter (header_view);
+ gdk_threads_leave ();
+ }
+
+ return res;
+}
+
+
+
+
+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);