* src/modest-tny-local-folders-account.c,
[modest] / src / modest-mail-operation.c
index 7691b5f..8707d0e 100644 (file)
@@ -630,17 +630,21 @@ modest_mail_operation_clone_state (ModestMailOperation *self)
 /* ************************** SEND   ACTIONS ************************* */
 /* ******************************************************************* */
 
+typedef struct 
+{
+       ModestMailOperation *mail_op;
+       gboolean notify;
+} SendNewMailHelper;
+
 static void
-send_mail_on_added_to_outbox (TnySendQueue *send_queue, 
-                             gboolean cancelled, 
-                             TnyMsg *msg, 
-                             GError *err,
-                             gpointer user_data)
+send_mail_common_cb (gboolean cancelled, 
+                    GError *err, 
+                    SendNewMailHelper *helper)
 {
        ModestMailOperationPrivate *priv;
        ModestMailOperation *self;
 
-       self = MODEST_MAIL_OPERATION (user_data);
+       self = helper->mail_op;
        priv = MODEST_MAIL_OPERATION_GET_PRIVATE (self);
 
        if (cancelled || err)
@@ -654,53 +658,33 @@ send_mail_on_added_to_outbox (TnySendQueue *send_queue,
        } else {
                priv->status = MODEST_MAIL_OPERATION_STATUS_SUCCESS;
        }
+
  end:
-       modest_mail_operation_notify_end (self);
-       g_object_unref (self);
+       if (helper->notify)
+               modest_mail_operation_notify_end (self);
+
+       g_object_unref (helper->mail_op);
+       g_slice_free (SendNewMailHelper, helper);
 }
 
-void
-modest_mail_operation_send_mail (ModestMailOperation *self,
-                                TnyTransportAccount *transport_account,
-                                TnyMsg* msg)
+static void
+send_mail_on_sync_async_cb (TnyFolder *self, 
+                           gboolean cancelled, 
+                           GError *err, 
+                           gpointer user_data)
 {
-       TnySendQueue *send_queue = NULL;
-       ModestMailOperationPrivate *priv;
-       
-       g_return_if_fail (self && MODEST_IS_MAIL_OPERATION (self));
-       g_return_if_fail (transport_account && TNY_IS_TRANSPORT_ACCOUNT (transport_account));
-       g_return_if_fail (msg && TNY_IS_MSG (msg));
-       
-       priv = MODEST_MAIL_OPERATION_GET_PRIVATE(self);
-
-       /* Get account and set it into mail_operation */
-       priv->account = g_object_ref (transport_account);
-       priv->op_type = MODEST_MAIL_OPERATION_TYPE_SEND;
-       priv->done = 1;
-       priv->total = 1;
-
-       send_queue = TNY_SEND_QUEUE (modest_runtime_get_send_queue (transport_account, TRUE));
-       if (!TNY_IS_SEND_QUEUE(send_queue)) {
-               if (priv->error) {
-                       g_error_free (priv->error);
-                       priv->error = NULL;
-               }
-               g_set_error (&(priv->error), MODEST_MAIL_OPERATION_ERROR,
-                            MODEST_MAIL_OPERATION_ERROR_ITEM_NOT_FOUND,
-                            "modest: could not find send queue for account\n");
-               priv->status = MODEST_MAIL_OPERATION_STATUS_FAILED;
-               modest_mail_operation_notify_end (self);
-       } else {
-               modest_mail_operation_notify_start (self);
-               /* Add the msg to the queue. The callback will
-                  finalize the mail operation */
-               tny_send_queue_add_async (send_queue, msg, send_mail_on_added_to_outbox, 
-                                         NULL, g_object_ref (self));
-               modest_tny_send_queue_set_requested_send_receive (MODEST_TNY_SEND_QUEUE (send_queue), 
-                                                                 FALSE);
-       }
+       send_mail_common_cb (cancelled, err, (SendNewMailHelper *) user_data);
 }
 
+static void
+send_mail_on_added_to_outbox (TnySendQueue *send_queue, 
+                             gboolean cancelled, 
+                             TnyMsg *msg, 
+                             GError *err,
+                             gpointer user_data)
+{
+       send_mail_common_cb (cancelled, err, (SendNewMailHelper *) user_data);
+}
 
 static gboolean
 idle_create_msg_cb (gpointer idle_data)
@@ -843,6 +827,7 @@ modest_mail_operation_send_new_mail_cb (ModestMailOperation *self,
                                        TnyMsg *msg,
                                        gpointer userdata)
 {
+       TnySendQueue *send_queue = NULL;
        ModestMailOperationPrivate *priv = NULL;
        SendNewMailInfo *info = (SendNewMailInfo *) userdata;
        TnyFolder *draft_folder = NULL;
@@ -863,8 +848,31 @@ modest_mail_operation_send_new_mail_cb (ModestMailOperation *self,
                goto end;
        }
 
-       /* Call mail operation */
-       modest_mail_operation_send_mail (self, info->transport_account, msg);
+       /* Add message to send queue */
+       send_queue = TNY_SEND_QUEUE (modest_runtime_get_send_queue (info->transport_account, TRUE));
+       if (!TNY_IS_SEND_QUEUE(send_queue)) {
+               if (priv->error) {
+                       g_error_free (priv->error);
+                       priv->error = NULL;
+               }
+               g_set_error (&(priv->error), MODEST_MAIL_OPERATION_ERROR,
+                            MODEST_MAIL_OPERATION_ERROR_ITEM_NOT_FOUND,
+                            "modest: could not find send queue for account\n");
+               priv->status = MODEST_MAIL_OPERATION_STATUS_FAILED;
+               modest_mail_operation_notify_end (self);
+               goto end;
+       } else {
+               SendNewMailHelper *helper = g_slice_new (SendNewMailHelper);
+               helper->mail_op = g_object_ref (self);
+               helper->notify = (info->draft_msg == NULL);
+
+               /* Add the msg to the queue. The callback will free
+                  the helper */
+               modest_tny_send_queue_set_requested_send_receive (MODEST_TNY_SEND_QUEUE (send_queue), 
+                                                                 FALSE);
+               tny_send_queue_add_async (send_queue, msg, send_mail_on_added_to_outbox, 
+                                         NULL, helper);
+       }
 
        if (info->draft_msg != NULL) {
                TnyList *tmp_headers = NULL;
@@ -872,6 +880,7 @@ modest_mail_operation_send_new_mail_cb (ModestMailOperation *self,
                TnyFolder *src_folder = NULL;
                TnyFolderType folder_type;              
                TnyTransportAccount *transport_account = NULL;
+               SendNewMailHelper *helper = NULL;
 
                /* To remove the old mail from its source folder, we need to get the
                 * transport account of the original draft message (the transport account
@@ -890,16 +899,21 @@ modest_mail_operation_send_new_mail_cb (ModestMailOperation *self,
                if (!draft_folder) {
                        g_warning ("%s: modest_tny_account_get_special_folder(..) returned a NULL drafts folder",
                                   __FUNCTION__);
+                       modest_mail_operation_notify_end (self);
                        goto end;
                }
                if (!outbox_folder) {
                        g_warning ("%s: modest_tny_account_get_special_folder(..) returned a NULL outbox folder",
                                   __FUNCTION__);
+                       modest_mail_operation_notify_end (self);
                        goto end;
                }
 
                folder = tny_msg_get_folder (info->draft_msg);          
-               if (folder == NULL) goto end;
+               if (folder == NULL) {
+                       modest_mail_operation_notify_end (self);
+                       goto end;
+               }
                folder_type = modest_tny_folder_guess_folder_type (folder);
 
                if (folder_type == TNY_FOLDER_TYPE_INVALID)
@@ -912,12 +926,16 @@ modest_mail_operation_send_new_mail_cb (ModestMailOperation *self,
 
                /* Note: This can fail (with a warning) if the message is not really already in a folder,
                 * because this function requires it to have a UID. */
+               helper = g_slice_new (SendNewMailHelper);
+               helper->mail_op = g_object_ref (self);
+               helper->notify = TRUE;
+
                tmp_headers = tny_simple_list_new ();
                tny_list_append (tmp_headers, (GObject*) header);
                tny_folder_remove_msgs_async (src_folder, tmp_headers, NULL, NULL, NULL);
                g_object_unref (tmp_headers);
-               tny_folder_sync_async (src_folder, TRUE, NULL, NULL, NULL);  /* expunge */
-               
+               tny_folder_sync_async (src_folder, TRUE, send_mail_on_sync_async_cb, 
+                                      NULL, helper);
                g_object_unref (folder);
        }
 
@@ -957,7 +975,9 @@ modest_mail_operation_send_new_mail (ModestMailOperation *self,
        priv->op_type = MODEST_MAIL_OPERATION_TYPE_SEND;
        priv->account = TNY_ACCOUNT (g_object_ref (transport_account));
        priv->status = MODEST_MAIL_OPERATION_STATUS_IN_PROGRESS;
-       
+
+       modest_mail_operation_notify_start (self);
+
        /* Check parametters */
        if (to == NULL) {
                /* Set status failed and set an error */
@@ -965,6 +985,7 @@ modest_mail_operation_send_new_mail (ModestMailOperation *self,
                g_set_error (&(priv->error), MODEST_MAIL_OPERATION_ERROR,
                             MODEST_MAIL_OPERATION_ERROR_BAD_PARAMETER,
                             _("Error trying to send a mail. You need to set at least one recipient"));
+               modest_mail_operation_notify_end (self);
                return;
        }
        info = g_slice_new0 (SendNewMailInfo);
@@ -976,7 +997,6 @@ modest_mail_operation_send_new_mail (ModestMailOperation *self,
                g_object_ref (draft_msg);
 
 
-       modest_mail_operation_notify_start (self);
        modest_mail_operation_create_msg (self, from, to, cc, bcc, subject, plain_body, html_body,
                                          attachments_list, images_list, priority_flags,
                                          modest_mail_operation_send_new_mail_cb, info);
@@ -1269,10 +1289,17 @@ static void
 update_account_send_mail (UpdateAccountInfo *info)
 {
        TnyTransportAccount *transport_account = NULL;
+       ModestTnyAccountStore *account_store;
+
+       account_store = modest_runtime_get_account_store ();
+
+       /* We don't try to send messages while sending mails is blocked */
+       if (modest_tny_account_store_is_send_mail_blocked (account_store))
+               return;
 
        /* Get the transport account */
        transport_account = (TnyTransportAccount *)
-               modest_tny_account_store_get_transport_account_for_open_connection (modest_runtime_get_account_store(),
+               modest_tny_account_store_get_transport_account_for_open_connection (account_store,
                                                                                    info->account_name);
 
        if (transport_account) {
@@ -2601,14 +2628,15 @@ remove_msgs_async_cb (TnyFolder *folder,
 {
        gboolean expunge, leave_on_server;
        const gchar *account_name;
-       const gchar *proto;
        TnyAccount *account;
-       ModestTransportStoreProtocol account_proto = MODEST_PROTOCOL_TRANSPORT_STORE_UNKNOWN;
+       ModestProtocolType account_proto = MODEST_PROTOCOL_REGISTRY_TYPE_INVALID;
        ModestMailOperation *self;
        ModestMailOperationPrivate *priv;
+       ModestProtocolRegistry *protocol_registry;
 
        self = (ModestMailOperation *) user_data;
        priv = MODEST_MAIL_OPERATION_GET_PRIVATE (self);
+       protocol_registry = modest_runtime_get_protocol_registry ();
 
        if (canceled || err) {
                /* If canceled by the user, ignore the error given by Tinymail */
@@ -2630,14 +2658,11 @@ remove_msgs_async_cb (TnyFolder *folder,
        leave_on_server =
                modest_account_mgr_get_leave_on_server (modest_runtime_get_account_mgr (),
                                                        account_name);  
-       proto = tny_account_get_proto (account);
+       account_proto = modest_tny_account_get_protocol_type (account);
        g_object_unref (account);
-
-       if (proto)
-               account_proto = modest_protocol_info_get_transport_store_protocol (proto);
        
-       if (((account_proto == MODEST_PROTOCOL_STORE_POP) && !leave_on_server) ||
-                   modest_tny_folder_is_remote_folder (folder) == FALSE)
+       if (( (modest_protocol_registry_protocol_type_has_leave_on_server (protocol_registry, account_proto) && !leave_on_server) ||
+             modest_tny_folder_is_remote_folder (folder) == FALSE))
                expunge = TRUE;
        else
                expunge = FALSE;
@@ -2944,12 +2969,16 @@ modest_mail_operation_xfer_msgs (ModestMailOperation *self,
        TnyAccount *dst_account = NULL;
        gboolean leave_on_server;
        ModestMailOperationState *state;
+       ModestProtocolRegistry *protocol_registry;
+       ModestProtocolType account_protocol;
 
        g_return_if_fail (self && MODEST_IS_MAIL_OPERATION (self));
        g_return_if_fail (headers && TNY_IS_LIST (headers));
        g_return_if_fail (folder && TNY_IS_FOLDER (folder));
 
        priv = MODEST_MAIL_OPERATION_GET_PRIVATE(self);
+       protocol_registry = modest_runtime_get_protocol_registry ();
+
        priv->total = tny_list_get_length (headers);
        priv->done = 0;
        priv->status = MODEST_MAIL_OPERATION_STATUS_IN_PROGRESS;
@@ -3040,8 +3069,8 @@ modest_mail_operation_xfer_msgs (ModestMailOperation *self,
           this could cause an error if we're offline while
           transferring an already downloaded message from a POP
           account */
-        if (modest_protocol_info_get_transport_store_protocol (tny_account_get_proto (priv->account)) == 
-           MODEST_PROTOCOL_STORE_POP) {
+       account_protocol = modest_tny_account_get_protocol_type (priv->account);
+        if (modest_protocol_registry_protocol_type_has_leave_on_server (protocol_registry, account_protocol)) {
                const gchar *account_name;
 
                account_name = modest_tny_account_get_parent_modest_account_name_for_server_account (priv->account);