git.maemo.org Git - modest/blob - src/modest-mail-operation.c

   1 /* Copyright (c) 2006, Nokia Corporation
   2  * All rights reserved.
   3  *
   4  * Redistribution and use in source and binary forms, with or without
   5  * modification, are permitted provided that the following conditions are
   6  * met:
   7  *
   8  * * Redistributions of source code must retain the above copyright
   9  *   notice, this list of conditions and the following disclaimer.
  10  * * Redistributions in binary form must reproduce the above copyright
  11  *   notice, this list of conditions and the following disclaimer in the
  12  *   documentation and/or other materials provided with the distribution.
  13  * * Neither the name of the Nokia Corporation nor the names of its
  14  *   contributors may be used to endorse or promote products derived from
  15  *   this software without specific prior written permission.
  16  *
  17  * THIS SOFTWARE IS PROVIDED BY THE COPYRIGHT HOLDERS AND CONTRIBUTORS "AS
  18  * IS" AND ANY EXPRESS OR IMPLIED WARRANTIES, INCLUDING, BUT NOT LIMITED
  19  * TO, THE IMPLIED WARRANTIES OF MERCHANTABILITY AND FITNESS FOR A
  20  * PARTICULAR PURPOSE ARE DISCLAIMED. IN NO EVENT SHALL THE COPYRIGHT OWNER
  21  * OR CONTRIBUTORS BE LIABLE FOR ANY DIRECT, INDIRECT, INCIDENTAL, SPECIAL,
  22  * EXEMPLARY, OR CONSEQUENTIAL DAMAGES (INCLUDING, BUT NOT LIMITED TO,
  23  * PROCUREMENT OF SUBSTITUTE GOODS OR SERVICES; LOSS OF USE, DATA, OR
  24  * PROFITS; OR BUSINESS INTERRUPTION) HOWEVER CAUSED AND ON ANY THEORY OF
  25  * LIABILITY, WHETHER IN CONTRACT, STRICT LIABILITY, OR TORT (INCLUDING
  26  * NEGLIGENCE OR OTHERWISE) ARISING IN ANY WAY OUT OF THE USE OF THIS
  27  * SOFTWARE, EVEN IF ADVISED OF THE POSSIBILITY OF SUCH DAMAGE.
  28  */
  29
  30 #include <string.h>
  31 #include <stdarg.h>
  32 #include <tny-mime-part.h>
  33 #include <tny-store-account.h>
  34 #include <tny-folder-store.h>
  35 #include <tny-folder-store-query.h>
  36 #include <tny-camel-stream.h>
  37 #include <tny-camel-pop-store-account.h>
  38 #include <tny-camel-pop-folder.h>
  39 #include <tny-camel-imap-folder.h>
  40 #include <tny-camel-mem-stream.h>
  41 #include <tny-simple-list.h>
  42 #include <tny-send-queue.h>
  43 #include <tny-status.h>
  44 #include <tny-folder-observer.h>
  45 #include <camel/camel-stream-mem.h>
  46 #include <glib/gi18n.h>
  47 #include "modest-platform.h"
  48 #include "modest-account-mgr-helpers.h"
  49 #include <modest-tny-account.h>
  50 #include <modest-tny-send-queue.h>
  51 #include <modest-runtime.h>
  52 #include "modest-text-utils.h"
  53 #include "modest-tny-msg.h"
  54 #include "modest-tny-folder.h"
  55 #include "modest-tny-account-store.h"
  56 #include "modest-tny-platform-factory.h"
  57 #include "modest-marshal.h"
  58 #include "modest-error.h"
  59 #include "modest-mail-operation.h"
  60
  61 #define KB 1024
  62
  63 /*
  64  * Remove all these #ifdef stuff when the tinymail's idle calls become
  65  * locked
  66  */
  67 #define TINYMAIL_IDLES_NOT_LOCKED_YET 1
  68
  69 /* 'private'/'protected' functions */
  70 static void modest_mail_operation_class_init (ModestMailOperationClass *klass);
  71 static void modest_mail_operation_init       (ModestMailOperation *obj);
  72 static void modest_mail_operation_finalize   (GObject *obj);
  73
  74 static void     get_msg_async_cb (TnyFolder *folder,
  75                                   gboolean cancelled,
  76                                   TnyMsg *msg,
  77                                   GError *rr,
  78                                   gpointer user_data);
  79
  80 static void     get_msg_status_cb (GObject *obj,
  81                                    TnyStatus *status,
  82                                    gpointer user_data);
  83
  84 static void     modest_mail_operation_notify_start (ModestMailOperation *self);
  85 static void     modest_mail_operation_notify_end (ModestMailOperation *self);
  86
  87 static void     notify_progress_of_multiple_messages (ModestMailOperation *self,
  88                                                       TnyStatus *status,
  89                                                       gint *last_total_bytes,
  90                                                       gint *sum_total_bytes,
  91                                                       gint total_bytes,
  92                                                       gboolean increment_done);
  93
  94 static guint    compute_message_list_size (TnyList *headers);
  95
  96 static guint    compute_message_array_size (GPtrArray *headers);
  97
  98 static int      compare_headers_by_date   (gconstpointer a,
  99                                            gconstpointer b);
 100
 101 enum _ModestMailOperationSignals
 102 {
 103         PROGRESS_CHANGED_SIGNAL,
 104         OPERATION_STARTED_SIGNAL,
 105         OPERATION_FINISHED_SIGNAL,
 106         NUM_SIGNALS
 107 };
 108
 109 typedef struct _ModestMailOperationPrivate ModestMailOperationPrivate;
 110 struct _ModestMailOperationPrivate {
 111         TnyAccount                *account;
 112         guint                      done;
 113         guint                      total;
 114         GObject                   *source;
 115         GError                    *error;
 116         ErrorCheckingUserCallback  error_checking;
 117         gpointer                   error_checking_user_data;
 118         ErrorCheckingUserDataDestroyer error_checking_user_data_destroyer;
 119         ModestMailOperationStatus  status;
 120         ModestMailOperationTypeOperation op_type;
 121 };
 122
 123 #define MODEST_MAIL_OPERATION_GET_PRIVATE(o)      (G_TYPE_INSTANCE_GET_PRIVATE((o), \
 124                                                    MODEST_TYPE_MAIL_OPERATION, \
 125                                                    ModestMailOperationPrivate))
 126
 127 #define CHECK_EXCEPTION(priv, new_status)  if (priv->error) {\
 128                                                    priv->status = new_status;\
 129                                                }
 130
 131
 132 typedef struct {
 133         GetMsgAsyncUserCallback user_callback;
 134         TnyHeader *header;
 135         gpointer user_data;
 136         ModestMailOperation *mail_op;
 137         GDestroyNotify destroy_notify;
 138         gint last_total_bytes;
 139         gint sum_total_bytes;
 140         gint total_bytes;
 141 } GetMsgInfo;
 142
 143 typedef struct {
 144         ModestMailOperation *mail_op;
 145         TnyMsg *msg;
 146         gulong msg_sent_handler;
 147         gulong error_happened_handler;
 148 } SendMsgInfo;
 149
 150 static void     send_mail_msg_sent_handler (TnySendQueue *queue, TnyHeader *header, TnyMsg *msg,
 151                                             guint nth, guint total, gpointer userdata);
 152 static void     send_mail_error_happened_handler (TnySendQueue *queue, TnyHeader *header, TnyMsg *msg,
 153                                                   GError *error, gpointer userdata);
 154 static void     common_send_mail_operation_end (TnySendQueue *queue, TnyMsg *msg,
 155                                                 SendMsgInfo *info);
 156
 157 typedef struct _RefreshAsyncHelper {
 158         ModestMailOperation *mail_op;
 159         RefreshAsyncUserCallback user_callback;
 160         gpointer user_data;
 161 } RefreshAsyncHelper;
 162
 163 typedef struct _XFerMsgAsyncHelper
 164 {
 165         ModestMailOperation *mail_op;
 166         TnyList *headers;
 167         TnyFolder *dest_folder;
 168         XferAsyncUserCallback user_callback;
 169         gboolean delete;
 170         gpointer user_data;
 171         gint last_total_bytes;
 172         gint sum_total_bytes;
 173         gint total_bytes;
 174 } XFerMsgAsyncHelper;
 175
 176 typedef void (*ModestMailOperationCreateMsgCallback) (ModestMailOperation *mail_op,
 177                                                       TnyMsg *msg,
 178                                                       gpointer userdata);
 179
 180 static void          modest_mail_operation_create_msg (ModestMailOperation *self,
 181                                                        const gchar *from, const gchar *to,
 182                                                        const gchar *cc, const gchar *bcc,
 183                                                        const gchar *subject, const gchar *plain_body,
 184                                                        const gchar *html_body, const GList *attachments_list,
 185                                                        const GList *images_list,
 186                                                        TnyHeaderFlags priority_flags,
 187                                                        ModestMailOperationCreateMsgCallback callback,
 188                                                        gpointer userdata);
 189
 190 static gboolean      idle_notify_queue (gpointer data);
 191 typedef struct
 192 {
 193         ModestMailOperation *mail_op;
 194         gchar *from;
 195         gchar *to;
 196         gchar *cc;
 197         gchar *bcc;
 198         gchar *subject;
 199         gchar *plain_body;
 200         gchar *html_body;
 201         GList *attachments_list;
 202         GList *images_list;
 203         TnyHeaderFlags priority_flags;
 204         ModestMailOperationCreateMsgCallback callback;
 205         gpointer userdata;
 206 } CreateMsgInfo;
 207
 208 typedef struct
 209 {
 210         ModestMailOperation *mail_op;
 211         TnyMsg *msg;
 212         ModestMailOperationCreateMsgCallback callback;
 213         gpointer userdata;
 214 } CreateMsgIdleInfo;
 215
 216 /* globals */
 217 static GObjectClass *parent_class = NULL;
 218
 219 static guint signals[NUM_SIGNALS] = {0};
 220
 221 GType
 222 modest_mail_operation_get_type (void)
 223 {
 224         static GType my_type = 0;
 225         if (!my_type) {
 226                 static const GTypeInfo my_info = {
 227                         sizeof(ModestMailOperationClass),
 228                         NULL,           /* base init */
 229                         NULL,           /* base finalize */
 230                         (GClassInitFunc) modest_mail_operation_class_init,
 231                         NULL,           /* class finalize */
 232                         NULL,           /* class data */
 233                         sizeof(ModestMailOperation),
 234                         1,              /* n_preallocs */
 235                         (GInstanceInitFunc) modest_mail_operation_init,
 236                         NULL
 237                 };
 238                 my_type = g_type_register_static (G_TYPE_OBJECT,
 239                                                   "ModestMailOperation",
 240                                                   &my_info, 0);
 241         }
 242         return my_type;
 243 }
 244
 245 static void
 246 modest_mail_operation_class_init (ModestMailOperationClass *klass)
 247 {
 248         GObjectClass *gobject_class;
 249         gobject_class = (GObjectClass*) klass;
 250
 251         parent_class            = g_type_class_peek_parent (klass);
 252         gobject_class->finalize = modest_mail_operation_finalize;
 253
 254         g_type_class_add_private (gobject_class, sizeof(ModestMailOperationPrivate));
 255
 256         /**
 257          * ModestMailOperation::progress-changed
 258          * @self: the #MailOperation that emits the signal
 259          * @user_data: user data set when the signal handler was connected
 260          *
 261          * Emitted when the progress of a mail operation changes
 262          */
 263         signals[PROGRESS_CHANGED_SIGNAL] =
 264                 g_signal_new ("progress-changed",
 265                               G_TYPE_FROM_CLASS (gobject_class),
 266                               G_SIGNAL_RUN_FIRST,
 267                               G_STRUCT_OFFSET (ModestMailOperationClass, progress_changed),
 268                               NULL, NULL,
 269                               g_cclosure_marshal_VOID__POINTER,
 270                               G_TYPE_NONE, 1, G_TYPE_POINTER);
 271         /**
 272          * operation-started
 273          *
 274          * This signal is issued whenever a mail operation starts, and
 275          * starts mean when the tinymail operation is issued. This
 276          * means that it could happen that something wrong happens and
 277          * the tinymail function is never called. In this situation a
 278          * operation-finished will be issued without any
 279          * operation-started
 280          */
 281         signals[OPERATION_STARTED_SIGNAL] =
 282                 g_signal_new ("operation-started",
 283                               G_TYPE_FROM_CLASS (gobject_class),
 284                               G_SIGNAL_RUN_FIRST,
 285                               G_STRUCT_OFFSET (ModestMailOperationClass, operation_started),
 286                               NULL, NULL,
 287                               g_cclosure_marshal_VOID__VOID,
 288                               G_TYPE_NONE, 0);
 289         /**
 290          * operation-started
 291          *
 292          * This signal is issued whenever a mail operation
 293          * finishes. Note that this signal could be issued without any
 294          * previous "operation-started" signal, because this last one
 295          * is only issued when the tinymail operation is successfully
 296          * started
 297          */
 298         signals[OPERATION_FINISHED_SIGNAL] =
 299                 g_signal_new ("operation-finished",
 300                               G_TYPE_FROM_CLASS (gobject_class),
 301                               G_SIGNAL_RUN_FIRST,
 302                               G_STRUCT_OFFSET (ModestMailOperationClass, operation_finished),
 303                               NULL, NULL,
 304                               g_cclosure_marshal_VOID__VOID,
 305                               G_TYPE_NONE, 0);
 306 }
 307
 308 static void
 309 modest_mail_operation_init (ModestMailOperation *obj)
 310 {
 311         ModestMailOperationPrivate *priv;
 312
 313         priv = MODEST_MAIL_OPERATION_GET_PRIVATE(obj);
 314
 315         priv->account        = NULL;
 316         priv->status         = MODEST_MAIL_OPERATION_STATUS_INVALID;
 317         priv->op_type        = MODEST_MAIL_OPERATION_TYPE_UNKNOWN;
 318         priv->error          = NULL;
 319         priv->done           = 0;
 320         priv->total          = 0;
 321         priv->source         = NULL;
 322         priv->error_checking = NULL;
 323         priv->error_checking_user_data = NULL;
 324 }
 325
 326 static void
 327 modest_mail_operation_finalize (GObject *obj)
 328 {
 329         ModestMailOperationPrivate *priv;
 330
 331         priv = MODEST_MAIL_OPERATION_GET_PRIVATE(obj);
 332
 333
 334
 335         if (priv->error) {
 336                 g_error_free (priv->error);
 337                 priv->error = NULL;
 338         }
 339         if (priv->source) {
 340                 g_object_unref (priv->source);
 341                 priv->source = NULL;
 342         }
 343         if (priv->account) {
 344                 g_object_unref (priv->account);
 345                 priv->account = NULL;
 346         }
 347
 348
 349         G_OBJECT_CLASS(parent_class)->finalize (obj);
 350 }
 351
 352 ModestMailOperation*
 353 modest_mail_operation_new (GObject *source)
 354 {
 355         ModestMailOperation *obj;
 356         ModestMailOperationPrivate *priv;
 357
 358         obj = MODEST_MAIL_OPERATION(g_object_new(MODEST_TYPE_MAIL_OPERATION, NULL));
 359         priv = MODEST_MAIL_OPERATION_GET_PRIVATE(obj);
 360
 361         if (source != NULL)
 362                 priv->source = g_object_ref(source);
 363
 364         return obj;
 365 }
 366
 367 ModestMailOperation*
 368 modest_mail_operation_new_with_error_handling (GObject *source,
 369                                                ErrorCheckingUserCallback error_handler,
 370                                                gpointer user_data,
 371                                                ErrorCheckingUserDataDestroyer error_handler_destroyer)
 372 {
 373         ModestMailOperation *obj;
 374         ModestMailOperationPrivate *priv;
 375
 376         obj = modest_mail_operation_new (source);
 377         priv = MODEST_MAIL_OPERATION_GET_PRIVATE(obj);
 378
 379         g_return_val_if_fail (error_handler != NULL, obj);
 380         priv->error_checking = error_handler;
 381         priv->error_checking_user_data = user_data;
 382         priv->error_checking_user_data_destroyer = error_handler_destroyer;
 383
 384         return obj;
 385 }
 386
 387 void
 388 modest_mail_operation_execute_error_handler (ModestMailOperation *self)
 389 {
 390         ModestMailOperationPrivate *priv;
 391
 392         g_return_if_fail (self && MODEST_IS_MAIL_OPERATION(self));
 393
 394         priv = MODEST_MAIL_OPERATION_GET_PRIVATE(self);
 395         g_return_if_fail(priv->status != MODEST_MAIL_OPERATION_STATUS_SUCCESS);
 396
 397         /* Call the user callback */
 398         if (priv->error_checking != NULL)
 399                 priv->error_checking (self, priv->error_checking_user_data);
 400 }
 401
 402
 403 ModestMailOperationTypeOperation
 404 modest_mail_operation_get_type_operation (ModestMailOperation *self)
 405 {
 406         ModestMailOperationPrivate *priv;
 407
 408         g_return_val_if_fail (self && MODEST_IS_MAIL_OPERATION(self),
 409                               MODEST_MAIL_OPERATION_TYPE_UNKNOWN);
 410
 411         priv = MODEST_MAIL_OPERATION_GET_PRIVATE(self);
 412
 413         return priv->op_type;
 414 }
 415
 416 gboolean
 417 modest_mail_operation_is_mine (ModestMailOperation *self,
 418                                GObject *me)
 419 {
 420         ModestMailOperationPrivate *priv;
 421
 422         g_return_val_if_fail (self && MODEST_IS_MAIL_OPERATION(self),
 423                               FALSE);
 424
 425         priv = MODEST_MAIL_OPERATION_GET_PRIVATE(self);
 426         if (priv->source == NULL) return FALSE;
 427
 428         return priv->source == me;
 429 }
 430
 431 GObject *
 432 modest_mail_operation_get_source (ModestMailOperation *self)
 433 {
 434         ModestMailOperationPrivate *priv;
 435
 436         g_return_val_if_fail (self && MODEST_IS_MAIL_OPERATION(self),
 437                               NULL);
 438
 439         priv = MODEST_MAIL_OPERATION_GET_PRIVATE(self);
 440         if (!priv) {
 441                 g_warning ("BUG: %s: priv == NULL", __FUNCTION__);
 442                 return NULL;
 443         }
 444
 445         return (priv->source) ? g_object_ref (priv->source) : NULL;
 446 }
 447
 448 ModestMailOperationStatus
 449 modest_mail_operation_get_status (ModestMailOperation *self)
 450 {
 451         ModestMailOperationPrivate *priv;
 452
 453         g_return_val_if_fail (self, MODEST_MAIL_OPERATION_STATUS_INVALID);
 454         g_return_val_if_fail (MODEST_IS_MAIL_OPERATION (self),
 455                               MODEST_MAIL_OPERATION_STATUS_INVALID);
 456
 457         priv = MODEST_MAIL_OPERATION_GET_PRIVATE (self);
 458         if (!priv) {
 459                 g_warning ("BUG: %s: priv == NULL", __FUNCTION__);
 460                 return MODEST_MAIL_OPERATION_STATUS_INVALID;
 461         }
 462
 463         return priv->status;
 464 }
 465
 466 const GError *
 467 modest_mail_operation_get_error (ModestMailOperation *self)
 468 {
 469         ModestMailOperationPrivate *priv;
 470
 471         g_return_val_if_fail (self, NULL);
 472         g_return_val_if_fail (MODEST_IS_MAIL_OPERATION (self), NULL);
 473
 474         priv = MODEST_MAIL_OPERATION_GET_PRIVATE (self);
 475
 476         if (!priv) {
 477                 g_warning ("BUG: %s: priv == NULL", __FUNCTION__);
 478                 return NULL;
 479         }
 480
 481         return priv->error;
 482 }
 483
 484 gboolean
 485 modest_mail_operation_cancel (ModestMailOperation *self)
 486 {
 487         ModestMailOperationPrivate *priv;
 488         gboolean canceled = FALSE;
 489
 490         g_return_val_if_fail (self && MODEST_IS_MAIL_OPERATION (self), FALSE);
 491
 492         priv = MODEST_MAIL_OPERATION_GET_PRIVATE (self);
 493
 494         /* Note that if we call cancel with an already canceled mail
 495            operation the progress changed signal won't be emitted */
 496         if (priv->status == MODEST_MAIL_OPERATION_STATUS_CANCELED)
 497                 return FALSE;
 498
 499         /* Set new status */
 500         priv->status = MODEST_MAIL_OPERATION_STATUS_CANCELED;
 501
 502         /* Cancel the mail operation. We need to wrap it between this
 503            start/stop operations to allow following calls to the
 504            account */
 505         g_return_val_if_fail (priv->account, FALSE);
 506
 507         if (priv->op_type == MODEST_MAIL_OPERATION_TYPE_SEND) {
 508                 ModestTnySendQueue *queue;
 509                 queue = modest_runtime_get_send_queue (TNY_TRANSPORT_ACCOUNT (priv->account));
 510                 /* Cancel sending without removing the item */
 511                 tny_send_queue_cancel (TNY_SEND_QUEUE (queue), FALSE, NULL);
 512         } else {
 513                 /* Cancel operation */
 514                 tny_account_cancel (priv->account);
 515         }
 516
 517         return canceled;
 518 }
 519
 520 guint
 521 modest_mail_operation_get_task_done (ModestMailOperation *self)
 522 {
 523         ModestMailOperationPrivate *priv;
 524
 525         g_return_val_if_fail (self && MODEST_IS_MAIL_OPERATION(self),
 526                               0);
 527
 528         priv = MODEST_MAIL_OPERATION_GET_PRIVATE (self);
 529         return priv->done;
 530 }
 531
 532 guint
 533 modest_mail_operation_get_task_total (ModestMailOperation *self)
 534 {
 535         ModestMailOperationPrivate *priv;
 536
 537         g_return_val_if_fail (self && MODEST_IS_MAIL_OPERATION(self),
 538                               0);
 539
 540         priv = MODEST_MAIL_OPERATION_GET_PRIVATE (self);
 541         return priv->total;
 542 }
 543
 544 gboolean
 545 modest_mail_operation_is_finished (ModestMailOperation *self)
 546 {
 547         ModestMailOperationPrivate *priv;
 548         gboolean retval = FALSE;
 549
 550         g_return_val_if_fail (self && MODEST_IS_MAIL_OPERATION(self),
 551                               FALSE);
 552
 553         priv = MODEST_MAIL_OPERATION_GET_PRIVATE (self);
 554
 555         if (priv->status == MODEST_MAIL_OPERATION_STATUS_SUCCESS   ||
 556             priv->status == MODEST_MAIL_OPERATION_STATUS_FAILED    ||
 557             priv->status == MODEST_MAIL_OPERATION_STATUS_CANCELED  ||
 558             priv->status == MODEST_MAIL_OPERATION_STATUS_FINISHED_WITH_ERRORS) {
 559                 retval = TRUE;
 560         } else {
 561                 retval = FALSE;
 562         }
 563
 564         return retval;
 565 }
 566
 567 /*
 568  * Creates an image of the current state of a mail operation, the
 569  * caller must free it
 570  */
 571 static ModestMailOperationState *
 572 modest_mail_operation_clone_state (ModestMailOperation *self)
 573 {
 574         ModestMailOperationState *state;
 575         ModestMailOperationPrivate *priv;
 576
 577         /* FIXME: this should be fixed properly
 578          *
 579          * in some cases, priv was NULL, so checking here to
 580          * make sure.
 581          */
 582         g_return_val_if_fail (self, NULL);
 583         priv = MODEST_MAIL_OPERATION_GET_PRIVATE (self);
 584         g_return_val_if_fail (priv, NULL);
 585
 586         if (!priv)
 587                 return NULL;
 588
 589         state = g_slice_new (ModestMailOperationState);
 590
 591         state->status = priv->status;
 592         state->op_type = priv->op_type;
 593         state->done = priv->done;
 594         state->total = priv->total;
 595         state->finished = modest_mail_operation_is_finished (self);
 596         state->bytes_done = 0;
 597         state->bytes_total = 0;
 598
 599         return state;
 600 }
 601
 602 /* ******************************************************************* */
 603 /* ************************** SEND   ACTIONS ************************* */
 604 /* ******************************************************************* */
 605
 606 void
 607 modest_mail_operation_send_mail (ModestMailOperation *self,
 608                                  TnyTransportAccount *transport_account,
 609                                  TnyMsg* msg)
 610 {
 611         TnySendQueue *send_queue = NULL;
 612         ModestMailOperationPrivate *priv;
 613         SendMsgInfo *info;
 614
 615         g_return_if_fail (self && MODEST_IS_MAIL_OPERATION (self));
 616         g_return_if_fail (transport_account && TNY_IS_TRANSPORT_ACCOUNT (transport_account));
 617         g_return_if_fail (msg && TNY_IS_MSG (msg));
 618
 619         priv = MODEST_MAIL_OPERATION_GET_PRIVATE(self);
 620
 621         /* Get account and set it into mail_operation */
 622         priv->account = g_object_ref (transport_account);
 623         priv->op_type = MODEST_MAIL_OPERATION_TYPE_SEND;
 624         priv->done = 1;
 625         priv->total = 1;
 626
 627         send_queue = TNY_SEND_QUEUE (modest_runtime_get_send_queue (transport_account));
 628         if (!TNY_IS_SEND_QUEUE(send_queue)) {
 629                 g_set_error (&(priv->error), MODEST_MAIL_OPERATION_ERROR,
 630                              MODEST_MAIL_OPERATION_ERROR_ITEM_NOT_FOUND,
 631                              "modest: could not find send queue for account\n");
 632                 priv->status = MODEST_MAIL_OPERATION_STATUS_FAILED;
 633                 modest_mail_operation_notify_end (self);
 634
 635         } else {
 636                 /* Add the msg to the queue */
 637                 modest_mail_operation_notify_start (self);
 638                 modest_tny_send_queue_add (MODEST_TNY_SEND_QUEUE(send_queue),
 639                                            msg,
 640                                            &(priv->error));
 641
 642                 priv->status = MODEST_MAIL_OPERATION_STATUS_IN_PROGRESS;
 643
 644                 info = g_slice_new0 (SendMsgInfo);
 645
 646                 info->mail_op = g_object_ref (self);
 647                 info->msg = g_object_ref (msg);
 648                 info->msg_sent_handler = g_signal_connect (G_OBJECT (send_queue), "msg-sent",
 649                                                            G_CALLBACK (send_mail_msg_sent_handler), info);
 650                 info->error_happened_handler = g_signal_connect (G_OBJECT (send_queue), "error-happened",
 651                                                                  G_CALLBACK (send_mail_error_happened_handler), info);
 652         }
 653
 654 }
 655
 656 static void
 657 common_send_mail_operation_end (TnySendQueue *queue, TnyMsg *msg,
 658                                 SendMsgInfo *info)
 659 {
 660         g_signal_handler_disconnect (queue, info->msg_sent_handler);
 661         g_signal_handler_disconnect (queue, info->error_happened_handler);
 662
 663         g_object_unref (info->msg);
 664         modest_mail_operation_notify_end (info->mail_op);
 665         g_object_unref (info->mail_op);
 666
 667         g_slice_free (SendMsgInfo, info);
 668 }
 669
 670 static void
 671 send_mail_msg_sent_handler (TnySendQueue *queue, TnyHeader *header, TnyMsg *msg,
 672                             guint nth, guint total, gpointer userdata)
 673 {
 674         SendMsgInfo *info = (SendMsgInfo *) userdata;
 675         TnyHeader *hdr1, *hdr2;
 676         const char *msgid1, *msgid2;
 677         hdr1 = tny_msg_get_header(msg);
 678         hdr2 = tny_msg_get_header(info->msg);
 679         msgid1 = tny_header_get_message_id(hdr1);
 680         msgid2 = tny_header_get_message_id(hdr2);
 681         if (msgid1 == NULL) msgid1 = "(null)";
 682         if (msgid2 == NULL) msgid2 = "(null)";
 683
 684         if (!strcmp (msgid1, msgid2)) {
 685                 ModestMailOperationPrivate *priv = MODEST_MAIL_OPERATION_GET_PRIVATE (info->mail_op);
 686                 priv->status = MODEST_MAIL_OPERATION_STATUS_SUCCESS;
 687
 688                 common_send_mail_operation_end (queue, msg, info);
 689         }
 690         g_object_unref(G_OBJECT(hdr1));
 691         g_object_unref(G_OBJECT(hdr2));
 692 }
 693
 694 static void
 695 send_mail_error_happened_handler (TnySendQueue *queue, TnyHeader *header, TnyMsg *msg,
 696                                   GError *error, gpointer userdata)
 697 {
 698         SendMsgInfo *info = (SendMsgInfo *) userdata;
 699         TnyHeader *hdr1, *hdr2;
 700         const char *msgid1, *msgid2;
 701
 702         hdr1 = tny_msg_get_header(msg);
 703         hdr2 = tny_msg_get_header(info->msg);
 704         msgid1 = tny_header_get_message_id(hdr1);
 705         msgid2 = tny_header_get_message_id(hdr2);
 706         if (msgid1 == NULL) msgid1 = "(null)";
 707         if (msgid2 == NULL) msgid2 = "(null)";
 708
 709         if (!strcmp (msgid1, msgid2)) {
 710                 ModestMailOperationPrivate *priv = MODEST_MAIL_OPERATION_GET_PRIVATE (info->mail_op);
 711                 priv->status = MODEST_MAIL_OPERATION_STATUS_FAILED;
 712                 g_set_error (&(priv->error), MODEST_MAIL_OPERATION_ERROR,
 713                              MODEST_MAIL_OPERATION_ERROR_OPERATION_CANCELED,
 714                              "modest: send mail failed\n");
 715
 716                 common_send_mail_operation_end (queue, msg, info);
 717         }
 718         g_object_unref(G_OBJECT(hdr1));
 719         g_object_unref(G_OBJECT(hdr2));
 720 }
 721
 722
 723 static gboolean
 724 idle_create_msg_cb (gpointer idle_data)
 725 {
 726         CreateMsgIdleInfo *info = (CreateMsgIdleInfo *) idle_data;
 727
 728         /* This is a GDK lock because we are an idle callback and
 729          * info->callback can contain Gtk+ code */
 730
 731         gdk_threads_enter (); /* CHECKED */
 732         info->callback (info->mail_op, info->msg, info->userdata);
 733
 734         g_object_unref (info->mail_op);
 735         if (info->msg)
 736                 g_object_unref (info->msg);
 737         g_slice_free (CreateMsgIdleInfo, info);
 738         gdk_threads_leave (); /* CHECKED */
 739
 740         return FALSE;
 741 }
 742
 743 static gpointer
 744 create_msg_thread (gpointer thread_data)
 745 {
 746         CreateMsgInfo *info = (CreateMsgInfo *) thread_data;
 747         TnyMsg *new_msg = NULL;
 748         ModestMailOperationPrivate *priv;
 749
 750         priv = MODEST_MAIL_OPERATION_GET_PRIVATE(info->mail_op);
 751         if (info->html_body == NULL) {
 752                 new_msg = modest_tny_msg_new (info->to, info->from, info->cc,
 753                                               info->bcc, info->subject, info->plain_body,
 754                                               info->attachments_list);
 755         } else {
 756                 new_msg = modest_tny_msg_new_html_plain (info->to, info->from, info->cc,
 757                                                          info->bcc, info->subject, info->html_body,
 758                                                          info->plain_body, info->attachments_list,
 759                                                          info->images_list);
 760         }
 761
 762         if (new_msg) {
 763                 TnyHeader *header;
 764
 765                 /* Set priority flags in message */
 766                 header = tny_msg_get_header (new_msg);
 767                 tny_header_set_flag (header, info->priority_flags);
 768
 769                 /* Set attachment flags in message */
 770                 if (info->attachments_list != NULL)
 771                         tny_header_set_flag (header, TNY_HEADER_FLAG_ATTACHMENTS);
 772
 773                 g_object_unref (G_OBJECT(header));
 774         } else {
 775                 priv->status = MODEST_MAIL_OPERATION_STATUS_FAILED;
 776                 g_set_error (&(priv->error), MODEST_MAIL_OPERATION_ERROR,
 777                              MODEST_MAIL_OPERATION_ERROR_INSTANCE_CREATION_FAILED,
 778                              "modest: failed to create a new msg\n");
 779         }
 780
 781
 782         g_free (info->to);
 783         g_free (info->from);
 784         g_free (info->cc);
 785         g_free (info->bcc);
 786         g_free (info->plain_body);
 787         g_free (info->html_body);
 788         g_free (info->subject);
 789         g_list_foreach (info->attachments_list, (GFunc) g_object_unref, NULL);
 790         g_list_free (info->attachments_list);
 791         g_list_foreach (info->images_list, (GFunc) g_object_unref, NULL);
 792         g_list_free (info->images_list);
 793
 794         if (info->callback) {
 795                 CreateMsgIdleInfo *idle_info;
 796                 idle_info = g_slice_new0 (CreateMsgIdleInfo);
 797                 idle_info->mail_op = g_object_ref (info->mail_op);
 798                 idle_info->msg = (new_msg) ? g_object_ref (new_msg) : NULL;
 799                 idle_info->callback = info->callback;
 800                 idle_info->userdata = info->userdata;
 801                 g_idle_add (idle_create_msg_cb, idle_info);
 802         } else {
 803                 g_idle_add (idle_notify_queue, g_object_ref (info->mail_op));
 804         }
 805
 806         g_object_unref (info->mail_op);
 807         g_slice_free (CreateMsgInfo, info);
 808         if (new_msg) g_object_unref(new_msg);
 809         return NULL;
 810 }
 811
 812 void
 813 modest_mail_operation_create_msg (ModestMailOperation *self,
 814                                   const gchar *from, const gchar *to,
 815                                   const gchar *cc, const gchar *bcc,
 816                                   const gchar *subject, const gchar *plain_body,
 817                                   const gchar *html_body,
 818                                   const GList *attachments_list,
 819                                   const GList *images_list,
 820                                   TnyHeaderFlags priority_flags,
 821                                   ModestMailOperationCreateMsgCallback callback,
 822                                   gpointer userdata)
 823 {
 824         CreateMsgInfo *info = NULL;
 825
 826         info = g_slice_new0 (CreateMsgInfo);
 827         info->mail_op = g_object_ref (self);
 828
 829         info->from = g_strdup (from);
 830         info->to = g_strdup (to);
 831         info->cc = g_strdup (cc);
 832         info->bcc  = g_strdup (bcc);
 833         info->subject = g_strdup (subject);
 834         info->plain_body = g_strdup (plain_body);
 835         info->html_body = g_strdup (html_body);
 836         info->attachments_list = g_list_copy ((GList *) attachments_list);
 837         g_list_foreach (info->attachments_list, (GFunc) g_object_ref, NULL);
 838         info->images_list = g_list_copy ((GList *) images_list);
 839         g_list_foreach (info->images_list, (GFunc) g_object_ref, NULL);
 840         info->priority_flags = priority_flags;
 841
 842         info->callback = callback;
 843         info->userdata = userdata;
 844
 845         g_thread_create (create_msg_thread, info, FALSE, NULL);
 846 }
 847
 848 typedef struct
 849 {
 850         TnyTransportAccount *transport_account;
 851         TnyMsg *draft_msg;
 852 } SendNewMailInfo;
 853
 854 static void
 855 modest_mail_operation_send_new_mail_cb (ModestMailOperation *self,
 856                                         TnyMsg *msg,
 857                                         gpointer userdata)
 858 {
 859         SendNewMailInfo *info = (SendNewMailInfo *) userdata;
 860         TnyFolder *draft_folder = NULL;
 861         TnyFolder *outbox_folder = NULL;
 862         TnyHeader *header;
 863         GError *err = NULL;
 864
 865         if (!msg) {
 866                 goto end;
 867         }
 868
 869         /* Call mail operation */
 870         modest_mail_operation_send_mail (self, info->transport_account, msg);
 871
 872         /* Remove old mail from its source folder */
 873         draft_folder = modest_tny_account_get_special_folder (TNY_ACCOUNT (info->transport_account),
 874                                                               TNY_FOLDER_TYPE_DRAFTS);
 875         outbox_folder = modest_tny_account_get_special_folder (TNY_ACCOUNT (info->transport_account),
 876                                                                TNY_FOLDER_TYPE_OUTBOX);
 877         if (info->draft_msg != NULL) {
 878                 TnyFolder *folder = NULL;
 879                 TnyFolder *src_folder = NULL;
 880                 TnyFolderType folder_type;
 881                 folder = tny_msg_get_folder (info->draft_msg);
 882                 if (folder == NULL) goto end;
 883                 folder_type = modest_tny_folder_guess_folder_type (folder);
 884
 885                 if (folder_type == TNY_FOLDER_TYPE_INVALID)
 886                         g_warning ("%s: BUG: folder of type TNY_FOLDER_TYPE_INVALID", __FUNCTION__);
 887
 888                 if (folder_type == TNY_FOLDER_TYPE_OUTBOX)
 889                         src_folder = outbox_folder;
 890                 else
 891                         src_folder = draft_folder;
 892
 893                 /* Note: This can fail (with a warning) if the message is not really already in a folder,
 894                  * because this function requires it to have a UID. */
 895                 header = tny_msg_get_header (info->draft_msg);
 896                 tny_folder_remove_msg (src_folder, header, NULL);
 897
 898                 tny_folder_sync (folder, TRUE, &err); /* FALSE --> don't expunge */
 899 /*              tny_folder_sync_async (src_folder, TRUE, NULL, NULL, NULL);  /\* expunge *\/ */
 900
 901                 g_object_unref (header);
 902                 g_object_unref (folder);
 903         }
 904
 905 end:
 906         if (err != NULL)
 907                 g_error_free(err);
 908         if (info->draft_msg)
 909                 g_object_unref (info->draft_msg);
 910         if (draft_folder)
 911                 g_object_unref (draft_folder);
 912         if (outbox_folder)
 913                 g_object_unref (outbox_folder);
 914         if (info->transport_account)
 915                 g_object_unref (info->transport_account);
 916         g_slice_free (SendNewMailInfo, info);
 917 }
 918
 919 void
 920 modest_mail_operation_send_new_mail (ModestMailOperation *self,
 921                                      TnyTransportAccount *transport_account,
 922                                      TnyMsg *draft_msg,
 923                                      const gchar *from,  const gchar *to,
 924                                      const gchar *cc,  const gchar *bcc,
 925                                      const gchar *subject, const gchar *plain_body,
 926                                      const gchar *html_body,
 927                                      const GList *attachments_list,
 928                                      const GList *images_list,
 929                                      TnyHeaderFlags priority_flags)
 930 {
 931         ModestMailOperationPrivate *priv = NULL;
 932         SendNewMailInfo *info;
 933
 934         g_return_if_fail (MODEST_IS_MAIL_OPERATION (self));
 935         g_return_if_fail (TNY_IS_TRANSPORT_ACCOUNT (transport_account));
 936
 937         priv = MODEST_MAIL_OPERATION_GET_PRIVATE(self);
 938         priv->op_type = MODEST_MAIL_OPERATION_TYPE_SEND;
 939         priv->account = TNY_ACCOUNT (g_object_ref (transport_account));
 940         priv->status = MODEST_MAIL_OPERATION_STATUS_IN_PROGRESS;
 941
 942         /* Check parametters */
 943         if (to == NULL) {
 944                 /* Set status failed and set an error */
 945                 priv->status = MODEST_MAIL_OPERATION_STATUS_FAILED;
 946                 g_set_error (&(priv->error), MODEST_MAIL_OPERATION_ERROR,
 947                              MODEST_MAIL_OPERATION_ERROR_BAD_PARAMETER,
 948                              _("Error trying to send a mail. You need to set at least one recipient"));
 949                 return;
 950         }
 951         info = g_slice_new0 (SendNewMailInfo);
 952         info->transport_account = transport_account;
 953         if (transport_account)
 954                 g_object_ref (transport_account);
 955         info->draft_msg = draft_msg;
 956         if (draft_msg)
 957                 g_object_ref (draft_msg);
 958
 959
 960         modest_mail_operation_notify_start (self);
 961         modest_mail_operation_create_msg (self, from, to, cc, bcc, subject, plain_body, html_body,
 962                                           attachments_list, images_list, priority_flags,
 963                                           modest_mail_operation_send_new_mail_cb, info);
 964
 965 }
 966
 967 typedef struct
 968 {
 969         TnyTransportAccount *transport_account;
 970         TnyMsg *draft_msg;
 971         SaveToDraftstCallback callback;
 972         gpointer user_data;
 973         TnyFolder *drafts;
 974         TnyMsg *msg;
 975         ModestMailOperation *mailop;
 976 } SaveToDraftsAddMsgInfo;
 977
 978 static void
 979 modest_mail_operation_save_to_drafts_add_msg_cb(TnyFolder *self,
 980                                                 gboolean canceled,
 981                                                 GError *err,
 982                                                 gpointer userdata)
 983 {
 984         ModestMailOperationPrivate *priv = NULL;
 985         SaveToDraftsAddMsgInfo *info = (SaveToDraftsAddMsgInfo *) userdata;
 986
 987         priv = MODEST_MAIL_OPERATION_GET_PRIVATE(info->mailop);
 988
 989         if (priv->error) {
 990                 g_warning ("%s: priv->error != NULL", __FUNCTION__);
 991                 g_error_free(priv->error);
 992         }
 993
 994         priv->error = (err == NULL) ? NULL : g_error_copy(err);
 995
 996         if ((!priv->error) && (info->draft_msg != NULL)) {
 997                 TnyHeader *header = tny_msg_get_header (info->draft_msg);
 998                 TnyFolder *src_folder = tny_header_get_folder (header);
 999
1000                 /* Remove the old draft */
1001                 tny_folder_remove_msg (src_folder, header, NULL);
1002
1003                 /* Synchronize to expunge and to update the msg counts */
1004                 tny_folder_sync_async (info->drafts, TRUE, NULL, NULL, NULL);
1005                 tny_folder_sync_async (src_folder, TRUE, NULL, NULL, NULL);
1006
1007                 g_object_unref (G_OBJECT(header));
1008                 g_object_unref (G_OBJECT(src_folder));
1009         }
1010
1011         if (!priv->error)
1012                 priv->status = MODEST_MAIL_OPERATION_STATUS_SUCCESS;
1013         else
1014                 priv->status = MODEST_MAIL_OPERATION_STATUS_FAILED;
1015
1016         /* Call the user callback */
1017         if (info->callback)
1018                 info->callback (info->mailop, info->msg, info->user_data);
1019
1020         if (info->transport_account)
1021                 g_object_unref (G_OBJECT(info->transport_account));
1022         if (info->draft_msg)
1023                 g_object_unref (G_OBJECT (info->draft_msg));
1024         if (info->drafts)
1025                 g_object_unref (G_OBJECT(info->drafts));
1026         if (info->msg)
1027                 g_object_unref (G_OBJECT (info->msg));
1028         g_slice_free (SaveToDraftsAddMsgInfo, info);
1029
1030         modest_mail_operation_notify_end (info->mailop);
1031         g_object_unref(info->mailop);
1032 }
1033
1034 typedef struct
1035 {
1036         TnyTransportAccount *transport_account;
1037         TnyMsg *draft_msg;
1038         SaveToDraftstCallback callback;
1039         gpointer user_data;
1040 } SaveToDraftsInfo;
1041
1042 static void
1043 modest_mail_operation_save_to_drafts_cb (ModestMailOperation *self,
1044                                          TnyMsg *msg,
1045                                          gpointer userdata)
1046 {
1047         TnyFolder *drafts = NULL;
1048         ModestMailOperationPrivate *priv = NULL;
1049         SaveToDraftsInfo *info = (SaveToDraftsInfo *) userdata;
1050
1051         priv = MODEST_MAIL_OPERATION_GET_PRIVATE(self);
1052
1053         if (!msg) {
1054                 g_set_error (&(priv->error), MODEST_MAIL_OPERATION_ERROR,
1055                              MODEST_MAIL_OPERATION_ERROR_INSTANCE_CREATION_FAILED,
1056                              "modest: failed to create a new msg\n");
1057         } else {
1058                 drafts = modest_tny_account_get_special_folder (TNY_ACCOUNT (info->transport_account),
1059                                                                 TNY_FOLDER_TYPE_DRAFTS);
1060                 if (!drafts) {
1061                         g_set_error (&(priv->error), MODEST_MAIL_OPERATION_ERROR,
1062                                      MODEST_MAIL_OPERATION_ERROR_ITEM_NOT_FOUND,
1063                                      "modest: failed to create a new msg\n");
1064                 }
1065         }
1066
1067         if (!priv->error) {
1068                 SaveToDraftsAddMsgInfo *cb_info = g_slice_new(SaveToDraftsAddMsgInfo);
1069                 cb_info->transport_account = g_object_ref(info->transport_account);
1070                 cb_info->draft_msg = info->draft_msg ? g_object_ref(info->draft_msg) : NULL;
1071                 cb_info->callback = info->callback;
1072                 cb_info->user_data = info->user_data;
1073                 cb_info->drafts = g_object_ref(drafts);
1074                 cb_info->msg = g_object_ref(msg);
1075                 cb_info->mailop = g_object_ref(self);
1076                 tny_folder_add_msg_async(drafts, msg, modest_mail_operation_save_to_drafts_add_msg_cb,
1077                                          NULL, cb_info);
1078         } else {
1079                 /* Call the user callback */
1080                 priv->status = MODEST_MAIL_OPERATION_STATUS_FAILED;
1081                 if (info->callback)
1082                         info->callback (self, msg, info->user_data);
1083                 modest_mail_operation_notify_end (self);
1084         }
1085
1086         if (drafts)
1087                 g_object_unref (G_OBJECT(drafts));
1088         if (info->draft_msg)
1089                 g_object_unref (G_OBJECT (info->draft_msg));
1090         if (info->transport_account)
1091                 g_object_unref (G_OBJECT(info->transport_account));
1092         g_slice_free (SaveToDraftsInfo, info);
1093 }
1094
1095 void
1096 modest_mail_operation_save_to_drafts (ModestMailOperation *self,
1097                                       TnyTransportAccount *transport_account,
1098                                       TnyMsg *draft_msg,
1099                                       const gchar *from,  const gchar *to,
1100                                       const gchar *cc,  const gchar *bcc,
1101                                       const gchar *subject, const gchar *plain_body,
1102                                       const gchar *html_body,
1103                                       const GList *attachments_list,
1104                                       const GList *images_list,
1105                                       TnyHeaderFlags priority_flags,
1106                                       SaveToDraftstCallback callback,
1107                                       gpointer user_data)
1108 {
1109         ModestMailOperationPrivate *priv = NULL;
1110         SaveToDraftsInfo *info = NULL;
1111
1112         g_return_if_fail (MODEST_IS_MAIL_OPERATION (self));
1113         g_return_if_fail (TNY_IS_TRANSPORT_ACCOUNT (transport_account));
1114
1115         priv = MODEST_MAIL_OPERATION_GET_PRIVATE(self);
1116
1117         /* Get account and set it into mail_operation */
1118         priv->account = g_object_ref (transport_account);
1119         priv->op_type = MODEST_MAIL_OPERATION_TYPE_INFO;
1120
1121         info = g_slice_new0 (SaveToDraftsInfo);
1122         info->transport_account = g_object_ref (transport_account);
1123         info->draft_msg = (draft_msg) ? g_object_ref (draft_msg) : NULL;
1124         info->callback = callback;
1125         info->user_data = user_data;
1126
1127         modest_mail_operation_notify_start (self);
1128         modest_mail_operation_create_msg (self, from, to, cc, bcc, subject, plain_body, html_body,
1129                                           attachments_list, images_list, priority_flags,
1130                                           modest_mail_operation_save_to_drafts_cb, info);
1131 }
1132
1133 typedef struct
1134 {
1135         ModestMailOperation *mail_op;
1136         TnyMimePart *mime_part;
1137         gssize size;
1138         GetMimePartSizeCallback callback;
1139         gpointer userdata;
1140 } GetMimePartSizeInfo;
1141
1142 /***** I N T E R N A L    F O L D E R    O B S E R V E R *****/
1143 /* We use this folder observer to track the headers that have been
1144  * added to a folder */
1145 typedef struct {
1146         GObject parent;
1147         TnyList *new_headers;
1148 } InternalFolderObserver;
1149
1150 typedef struct {
1151         GObjectClass parent;
1152 } InternalFolderObserverClass;
1153
1154 static void tny_folder_observer_init (TnyFolderObserverIface *idace);
1155
1156 G_DEFINE_TYPE_WITH_CODE (InternalFolderObserver,
1157                          internal_folder_observer,
1158                          G_TYPE_OBJECT,
1159                          G_IMPLEMENT_INTERFACE(TNY_TYPE_FOLDER_OBSERVER, tny_folder_observer_init));
1160
1161
1162 static void
1163 foreach_add_item (gpointer header, gpointer user_data)
1164 {
1165         tny_list_prepend (TNY_LIST (user_data),
1166                           g_object_ref (G_OBJECT (header)));
1167 }
1168
1169 /* This is the method that looks for new messages in a folder */
1170 static void
1171 internal_folder_observer_update (TnyFolderObserver *self, TnyFolderChange *change)
1172 {
1173         InternalFolderObserver *derived = (InternalFolderObserver *)self;
1174
1175         TnyFolderChangeChanged changed;
1176
1177         changed = tny_folder_change_get_changed (change);
1178
1179         if (changed & TNY_FOLDER_CHANGE_CHANGED_ADDED_HEADERS) {
1180                 TnyList *list;
1181
1182                 /* Get added headers */
1183                 list = tny_simple_list_new ();
1184                 tny_folder_change_get_added_headers (change, list);
1185
1186                 /* Add them to the folder observer */
1187                 tny_list_foreach (list, foreach_add_item,
1188                                   derived->new_headers);
1189
1190                 g_object_unref (G_OBJECT (list));
1191         }
1192 }
1193
1194 static void
1195 internal_folder_observer_init (InternalFolderObserver *self)
1196 {
1197         self->new_headers = tny_simple_list_new ();
1198 }
1199 static void
1200 internal_folder_observer_finalize (GObject *object)
1201 {
1202         InternalFolderObserver *self;
1203
1204         self = (InternalFolderObserver *) object;
1205         g_object_unref (self->new_headers);
1206
1207         G_OBJECT_CLASS (internal_folder_observer_parent_class)->finalize (object);
1208 }
1209 static void
1210 tny_folder_observer_init (TnyFolderObserverIface *iface)
1211 {
1212         iface->update_func = internal_folder_observer_update;
1213 }
1214 static void
1215 internal_folder_observer_class_init (InternalFolderObserverClass *klass)
1216 {
1217         GObjectClass *object_class;
1218
1219         internal_folder_observer_parent_class = g_type_class_peek_parent (klass);
1220         object_class = (GObjectClass*) klass;
1221         object_class->finalize = internal_folder_observer_finalize;
1222 }
1223
1224 typedef struct
1225 {
1226         ModestMailOperation *mail_op;
1227         gchar *account_name;
1228         UpdateAccountCallback callback;
1229         gpointer user_data;
1230         TnyList *folders;
1231         gint pending_calls;
1232         gboolean poke_all;
1233         TnyFolderObserver *inbox_observer;
1234         guint update_timeout;
1235         RetrieveAllCallback retrieve_all_cb;
1236 } UpdateAccountInfo;
1237
1238
1239 static void
1240 destroy_update_account_info (UpdateAccountInfo *info)
1241 {
1242         if (info->update_timeout) {
1243                 g_source_remove (info->update_timeout);
1244                 info->update_timeout = 0;
1245         }
1246
1247         g_free (info->account_name);
1248         g_object_unref (info->folders);
1249         g_object_unref (info->mail_op);
1250         g_slice_free (UpdateAccountInfo, info);
1251 }
1252
1253 static void
1254 update_account_get_msg_async_cb (TnyFolder *folder,
1255                                  gboolean canceled,
1256                                  TnyMsg *msg,
1257                                  GError *err,
1258                                  gpointer user_data)
1259 {
1260         GetMsgInfo *msg_info = (GetMsgInfo *) user_data;
1261
1262         /* Just delete the helper. Don't do anything with the new
1263            msg. There is also no need to check for errors */
1264         g_object_unref (msg_info->mail_op);
1265         g_object_unref (msg_info->header);
1266         g_slice_free (GetMsgInfo, msg_info);
1267 }
1268
1269
1270 static void
1271 inbox_refreshed_cb (TnyFolder *inbox,
1272                     gboolean canceled,
1273                     GError *err,
1274                     gpointer user_data)
1275 {
1276         UpdateAccountInfo *info;
1277         ModestMailOperationPrivate *priv;
1278         TnyIterator *new_headers_iter;
1279         GPtrArray *new_headers_array = NULL;
1280         gint max_size, retrieve_limit, i;
1281         ModestAccountMgr *mgr;
1282         ModestAccountRetrieveType retrieve_type;
1283         TnyList *new_headers = NULL;
1284         gboolean headers_only, ignore_limit;
1285         TnyTransportAccount *transport_account;
1286         ModestTnySendQueue *send_queue;
1287
1288         info = (UpdateAccountInfo *) user_data;
1289         priv = MODEST_MAIL_OPERATION_GET_PRIVATE (info->mail_op);
1290         mgr = modest_runtime_get_account_mgr ();
1291
1292         if (canceled || err || !inbox) {
1293                 /* Try to send anyway */
1294                 goto send_mail;
1295         }
1296
1297         /* Get the message max size */
1298         max_size  = modest_conf_get_int (modest_runtime_get_conf (),
1299                                          MODEST_CONF_MSG_SIZE_LIMIT, NULL);
1300         if (max_size == 0)
1301                 max_size = G_MAXINT;
1302         else
1303                 max_size = max_size * KB;
1304
1305         /* Create the new headers array. We need it to sort the
1306            new headers by date */
1307         new_headers_array = g_ptr_array_new ();
1308         new_headers_iter = tny_list_create_iterator (((InternalFolderObserver *) info->inbox_observer)->new_headers);
1309         while (!tny_iterator_is_done (new_headers_iter)) {
1310                 TnyHeader *header = NULL;
1311
1312                 header = TNY_HEADER (tny_iterator_get_current (new_headers_iter));
1313                 /* Apply per-message size limits */
1314                 if (tny_header_get_message_size (header) < max_size)
1315                         g_ptr_array_add (new_headers_array, g_object_ref (header));
1316
1317                 g_object_unref (header);
1318                 tny_iterator_next (new_headers_iter);
1319         }
1320         g_object_unref (new_headers_iter);
1321         tny_folder_remove_observer (inbox, info->inbox_observer);
1322         g_object_unref (info->inbox_observer);
1323         info->inbox_observer = NULL;
1324
1325         /* Update the last updated key, even if we don't have to get new headers */
1326         modest_account_mgr_set_last_updated (mgr, tny_account_get_id (priv->account), time (NULL));
1327
1328         if (new_headers_array->len == 0)
1329                 goto send_mail;
1330
1331         /* Get per-account message amount retrieval limit */
1332         retrieve_limit = modest_account_mgr_get_retrieve_limit (mgr, info->account_name);
1333         if (retrieve_limit == 0)
1334                 retrieve_limit = G_MAXINT;
1335
1336         /* Get per-account retrieval type */
1337         retrieve_type = modest_account_mgr_get_retrieve_type (mgr, info->account_name);
1338         headers_only = (retrieve_type == MODEST_ACCOUNT_RETRIEVE_HEADERS_ONLY);
1339
1340         /* Order by date */
1341         g_ptr_array_sort (new_headers_array, (GCompareFunc) compare_headers_by_date);
1342
1343         /* Ask the users if they want to retrieve all the messages
1344            even though the limit was exceeded */
1345         ignore_limit = FALSE;
1346         if (new_headers_array->len > retrieve_limit) {
1347                 /* Ask the user if a callback has been specified and
1348                    if the mail operation has a source (this means that
1349                    was invoked by the user and not automatically by a
1350                    D-Bus method) */
1351                 if (info->retrieve_all_cb && priv->source)
1352                         ignore_limit = info->retrieve_all_cb (priv->source,
1353                                                               new_headers_array->len,
1354                                                               retrieve_limit);
1355         }
1356
1357         if (!headers_only) {
1358                 gint msg_num = 0;
1359                 const gint msg_list_size = compute_message_array_size (new_headers_array);
1360
1361                 priv->done = 0;
1362                 if (ignore_limit)
1363                         priv->total = new_headers_array->len;
1364                 else
1365                         priv->total = MIN (new_headers_array->len, retrieve_limit);
1366                 while (msg_num < priv->total) {
1367                         TnyHeader *header = TNY_HEADER (g_ptr_array_index (new_headers_array, msg_num));
1368                         TnyFolder *folder = tny_header_get_folder (header);
1369                         GetMsgInfo *msg_info;
1370
1371                         /* Create the message info */
1372                         msg_info = g_slice_new0 (GetMsgInfo);
1373                         msg_info->mail_op = g_object_ref (info->mail_op);
1374                         msg_info->header = g_object_ref (header);
1375                         msg_info->total_bytes = msg_list_size;
1376
1377                         /* Get message in an async way */
1378                         tny_folder_get_msg_async (folder, header, update_account_get_msg_async_cb,
1379                                                   get_msg_status_cb, msg_info);
1380
1381                         g_object_unref (folder);
1382
1383                         msg_num++;
1384                 }
1385         }
1386
1387         /* Copy the headers to a list and free the array */
1388         new_headers = tny_simple_list_new ();
1389         for (i=0; i < new_headers_array->len; i++) {
1390                 TnyHeader *header = TNY_HEADER (g_ptr_array_index (new_headers_array, i));
1391                 tny_list_append (new_headers, G_OBJECT (header));
1392         }
1393         g_ptr_array_foreach (new_headers_array, (GFunc) g_object_unref, NULL);
1394         g_ptr_array_free (new_headers_array, FALSE);
1395
1396  send_mail:
1397         /* Send mails */
1398         priv->done = 0;
1399         priv->total = 0;
1400
1401         /* Get the transport account */
1402         transport_account = (TnyTransportAccount *)
1403                 modest_tny_account_store_get_transport_account_for_open_connection (modest_runtime_get_account_store(),
1404                                                                                     info->account_name);
1405
1406         /* Try to send */
1407         send_queue = modest_runtime_get_send_queue (transport_account);
1408         modest_tny_send_queue_try_to_send (send_queue);
1409
1410         /* Check if the operation was a success */
1411         if (!priv->error)
1412                 priv->status = MODEST_MAIL_OPERATION_STATUS_SUCCESS;
1413
1414         /* Set the account back to not busy */
1415         modest_account_mgr_set_account_busy (mgr, info->account_name, FALSE);
1416
1417         /* Call the user callback */
1418         if (info->callback)
1419                 info->callback (info->mail_op, new_headers, info->user_data);
1420
1421         /* Notify about operation end */
1422         modest_mail_operation_notify_end (info->mail_op);
1423
1424         /* Frees */
1425         if (new_headers)
1426                 g_object_unref (new_headers);
1427         destroy_update_account_info (info);
1428 }
1429
1430 static void
1431 recurse_folders_async_cb (TnyFolderStore *folder_store,
1432                           gboolean canceled,
1433                           TnyList *list,
1434                           GError *err,
1435                           gpointer user_data)
1436 {
1437         UpdateAccountInfo *info;
1438         ModestMailOperationPrivate *priv;
1439
1440         info = (UpdateAccountInfo *) user_data;
1441         priv = MODEST_MAIL_OPERATION_GET_PRIVATE (info->mail_op);
1442
1443         if (err || canceled) {
1444                 /* Try to continue anyway */
1445         } else {
1446                 TnyIterator *iter = tny_list_create_iterator (list);
1447                 while (!tny_iterator_is_done (iter)) {
1448                         TnyFolderStore *folder = (TnyFolderStore*) tny_iterator_get_current (iter);
1449                         TnyList *folders = tny_simple_list_new ();
1450
1451                         /* Add to the list of all folders */
1452                         tny_list_append (info->folders, (GObject *) folder);
1453
1454                         /* Add pending call */
1455                         info->pending_calls++;
1456
1457                         tny_folder_store_get_folders_async (folder, folders, recurse_folders_async_cb,
1458                                                             NULL, NULL, info);
1459
1460                         g_object_unref (G_OBJECT (folder));
1461
1462                         tny_iterator_next (iter);
1463                 }
1464                 g_object_unref (G_OBJECT (iter));
1465                 g_object_unref (G_OBJECT (list));
1466         }
1467
1468         /* Remove my own pending call */
1469         info->pending_calls--;
1470
1471         /* This means that we have all the folders */
1472         if (info->pending_calls == 0) {
1473                 TnyIterator *iter_all_folders;
1474                 TnyFolder *inbox = NULL;
1475
1476                 iter_all_folders = tny_list_create_iterator (info->folders);
1477
1478                 /* Do a poke status over all folders */
1479                 while (!tny_iterator_is_done (iter_all_folders) &&
1480                        priv->status == MODEST_MAIL_OPERATION_STATUS_IN_PROGRESS) {
1481                         TnyFolder *folder = NULL;
1482
1483                         folder = TNY_FOLDER (tny_iterator_get_current (iter_all_folders));
1484
1485                         if (tny_folder_get_folder_type (folder) == TNY_FOLDER_TYPE_INBOX) {
1486                                 /* Get a reference to the INBOX */
1487                                 inbox = g_object_ref (folder);
1488                         } else {
1489                                 /* Issue a poke status over the folder */
1490                                 if (info->poke_all)
1491                                         tny_folder_poke_status (folder);
1492                         }
1493
1494                         /* Free and go to next */
1495                         g_object_unref (folder);
1496                         tny_iterator_next (iter_all_folders);
1497                 }
1498                 g_object_unref (iter_all_folders);
1499
1500                 /* Stop the progress notification */
1501                 g_source_remove (info->update_timeout);
1502                 info->update_timeout = 0;
1503
1504                 /* Refresh the INBOX */
1505                 if (inbox) {
1506                         /* Refresh the folder. Our observer receives
1507                          * the new emails during folder refreshes, so
1508                          * we can use observer->new_headers
1509                          */
1510                         info->inbox_observer = g_object_new (internal_folder_observer_get_type (), NULL);
1511                         tny_folder_add_observer (inbox, info->inbox_observer);
1512
1513                         /* Refresh the INBOX */
1514                         tny_folder_refresh_async (inbox, inbox_refreshed_cb, NULL, info);
1515                         g_object_unref (inbox);
1516                 } else {
1517                         /* We could not perform the inbox refresh but
1518                            we'll try to send mails anyway */
1519                         inbox_refreshed_cb (inbox, FALSE, NULL, info);
1520                 }
1521         }
1522 }
1523
1524 /*
1525  * Issues the "progress-changed" signal. The timer won't be removed,
1526  * so you must call g_source_remove to stop the signal emission
1527  */
1528 static gboolean
1529 timeout_notify_progress (gpointer data)
1530 {
1531         ModestMailOperation *mail_op = MODEST_MAIL_OPERATION (data);
1532         ModestMailOperationState *state;
1533
1534         state = modest_mail_operation_clone_state (mail_op);
1535
1536         /* This is a GDK lock because we are an idle callback and
1537          * the handlers of this signal can contain Gtk+ code */
1538
1539         gdk_threads_enter (); /* CHECKED */
1540         g_signal_emit (G_OBJECT (mail_op), signals[PROGRESS_CHANGED_SIGNAL], 0, state, NULL);
1541         gdk_threads_leave (); /* CHECKED */
1542
1543         g_slice_free (ModestMailOperationState, state);
1544
1545         return TRUE;
1546 }
1547
1548 void
1549 modest_mail_operation_update_account (ModestMailOperation *self,
1550                                       const gchar *account_name,
1551                                       gboolean poke_all,
1552                                       RetrieveAllCallback retrieve_all_cb,
1553                                       UpdateAccountCallback callback,
1554                                       gpointer user_data)
1555 {
1556         UpdateAccountInfo *info = NULL;
1557         ModestMailOperationPrivate *priv = NULL;
1558         ModestTnyAccountStore *account_store = NULL;
1559         TnyStoreAccount *store_account = NULL;
1560         TnyList *folders;
1561
1562         /* Init mail operation */
1563         priv = MODEST_MAIL_OPERATION_GET_PRIVATE(self);
1564         priv->total = 0;
1565         priv->done  = 0;
1566         priv->status = MODEST_MAIL_OPERATION_STATUS_IN_PROGRESS;
1567         priv->op_type = MODEST_MAIL_OPERATION_TYPE_RECEIVE;
1568
1569         /* Get the store account */
1570         account_store = modest_runtime_get_account_store ();
1571         store_account = (TnyStoreAccount *)
1572                 modest_tny_account_store_get_server_account (account_store,
1573                                                              account_name,
1574                                                              TNY_ACCOUNT_TYPE_STORE);
1575         priv->account = g_object_ref (store_account);
1576
1577         /* Create the helper object */
1578         info = g_slice_new0 (UpdateAccountInfo);
1579         info->pending_calls = 1;
1580         info->folders = tny_simple_list_new ();
1581         info->mail_op = g_object_ref (self);
1582         info->poke_all = poke_all;
1583         info->account_name = g_strdup (account_name);
1584         info->callback = callback;
1585         info->user_data = user_data;
1586         info->update_timeout = g_timeout_add (250, timeout_notify_progress, self);
1587         info->retrieve_all_cb = retrieve_all_cb;
1588
1589         /* Set account busy */
1590         modest_account_mgr_set_account_busy (modest_runtime_get_account_mgr (), account_name, TRUE);
1591         modest_mail_operation_notify_start (self);
1592
1593         /* Get all folders and continue in the callback */
1594         folders = tny_simple_list_new ();
1595         tny_folder_store_get_folders_async (TNY_FOLDER_STORE (store_account),
1596                                 folders, recurse_folders_async_cb,
1597                                 NULL, NULL, info);
1598 }
1599
1600 /*
1601  * Used to notify the queue from the main
1602  * loop. We call it inside an idle call to achieve that
1603  */
1604 static gboolean
1605 idle_notify_queue (gpointer data)
1606 {
1607         ModestMailOperation *mail_op = MODEST_MAIL_OPERATION (data);
1608
1609         gdk_threads_enter ();
1610         modest_mail_operation_notify_end (mail_op);
1611         gdk_threads_leave ();
1612         g_object_unref (mail_op);
1613
1614         return FALSE;
1615 }
1616
1617 static int
1618 compare_headers_by_date (gconstpointer a,
1619                          gconstpointer b)
1620 {
1621         TnyHeader **header1, **header2;
1622         time_t sent1, sent2;
1623
1624         header1 = (TnyHeader **) a;
1625         header2 = (TnyHeader **) b;
1626
1627         sent1 = tny_header_get_date_sent (*header1);
1628         sent2 = tny_header_get_date_sent (*header2);
1629
1630         /* We want the most recent ones (greater time_t) at the
1631            beginning */
1632         if (sent1 < sent2)
1633                 return 1;
1634         else
1635                 return -1;
1636 }
1637
1638
1639 /* ******************************************************************* */
1640 /* ************************** STORE  ACTIONS ************************* */
1641 /* ******************************************************************* */
1642
1643 typedef struct {
1644         ModestMailOperation *mail_op;
1645         CreateFolderUserCallback callback;
1646         gpointer user_data;
1647 } CreateFolderInfo;
1648
1649
1650 static void
1651 create_folder_cb (TnyFolderStore *parent_folder,
1652                   gboolean canceled,
1653                   TnyFolder *new_folder,
1654                   GError *err,
1655                   gpointer user_data)
1656 {
1657         ModestMailOperationPrivate *priv;
1658         CreateFolderInfo *info;
1659
1660         info = (CreateFolderInfo *) user_data;
1661         priv = MODEST_MAIL_OPERATION_GET_PRIVATE (info->mail_op);
1662
1663         if (canceled || err) {
1664                 priv->status = MODEST_MAIL_OPERATION_STATUS_FAILED;
1665                 if (err)
1666                         priv->error = g_error_copy (err);
1667                 else
1668                         g_set_error (&(priv->error), MODEST_MAIL_OPERATION_ERROR,
1669                                      MODEST_MAIL_OPERATION_ERROR_OPERATION_CANCELED,
1670                                      "canceled");
1671         } else {
1672                 priv->status = MODEST_MAIL_OPERATION_STATUS_SUCCESS;
1673         }
1674
1675         /* The user will unref the new_folder */
1676         if (info->callback)
1677                 info->callback (info->mail_op, parent_folder,
1678                                 new_folder, info->user_data);
1679
1680         /* Notify about operation end */
1681         modest_mail_operation_notify_end (info->mail_op);
1682
1683         /* Frees */
1684         g_object_unref (info->mail_op);
1685         g_slice_free (CreateFolderInfo, info);
1686 }
1687
1688 void
1689 modest_mail_operation_create_folder (ModestMailOperation *self,
1690                                      TnyFolderStore *parent,
1691                                      const gchar *name,
1692                                      CreateFolderUserCallback callback,
1693                                      gpointer user_data)
1694 {
1695         ModestMailOperationPrivate *priv;
1696
1697         g_return_if_fail (TNY_IS_FOLDER_STORE (parent));
1698         g_return_if_fail (name);
1699
1700         priv = MODEST_MAIL_OPERATION_GET_PRIVATE (self);
1701         priv->op_type = MODEST_MAIL_OPERATION_TYPE_INFO;
1702         priv->account = (TNY_IS_ACCOUNT (parent)) ?
1703                 g_object_ref (parent) :
1704                 modest_tny_folder_get_account (TNY_FOLDER (parent));
1705
1706         /* Check for already existing folder */
1707         if (modest_tny_folder_has_subfolder_with_name (parent, name, TRUE)) {
1708                 priv->status = MODEST_MAIL_OPERATION_STATUS_FAILED;
1709                 g_set_error (&(priv->error), MODEST_MAIL_OPERATION_ERROR,
1710                              MODEST_MAIL_OPERATION_ERROR_FOLDER_EXISTS,
1711                              _CS("ckdg_ib_folder_already_exists"));
1712         }
1713
1714         /* Check parent */
1715         if (TNY_IS_FOLDER (parent)) {
1716                 /* Check folder rules */
1717                 ModestTnyFolderRules rules = modest_tny_folder_get_rules (TNY_FOLDER (parent));
1718                 if (rules & MODEST_FOLDER_RULES_FOLDER_NON_WRITEABLE) {
1719                         /* Set status failed and set an error */
1720                         priv->status = MODEST_MAIL_OPERATION_STATUS_FAILED;
1721                         g_set_error (&(priv->error), MODEST_MAIL_OPERATION_ERROR,
1722                                      MODEST_MAIL_OPERATION_ERROR_FOLDER_RULES,
1723                                      _("mail_in_ui_folder_create_error"));
1724                 }
1725         }
1726
1727         if (!strcmp (name, " ") || strchr (name, '/')) {
1728                 priv->status = MODEST_MAIL_OPERATION_STATUS_FAILED;
1729                 g_set_error (&(priv->error), MODEST_MAIL_OPERATION_ERROR,
1730                              MODEST_MAIL_OPERATION_ERROR_FOLDER_RULES,
1731                              _("mail_in_ui_folder_create_error"));
1732         }
1733
1734         if (!priv->error) {
1735                 CreateFolderInfo *info;
1736
1737                 info = g_slice_new0 (CreateFolderInfo);
1738                 info->mail_op = g_object_ref (self);
1739                 info->callback = callback;
1740                 info->user_data = user_data;
1741
1742                 modest_mail_operation_notify_start (self);
1743
1744                 /* Create the folder */
1745                 tny_folder_store_create_folder_async (parent, name, create_folder_cb,
1746                                                       NULL, info);
1747         } else {
1748                 /* Call the user callback anyway */
1749                 if (callback)
1750                         callback (self, parent, NULL, user_data);
1751                 /* Notify about operation end */
1752                 modest_mail_operation_notify_end (self);
1753         }
1754 }
1755
1756 void
1757 modest_mail_operation_remove_folder (ModestMailOperation *self,
1758                                      TnyFolder           *folder,
1759                                      gboolean             remove_to_trash)
1760 {
1761         TnyAccount *account;
1762         ModestMailOperationPrivate *priv;
1763         ModestTnyFolderRules rules;
1764
1765         g_return_if_fail (MODEST_IS_MAIL_OPERATION (self));
1766         g_return_if_fail (TNY_IS_FOLDER (folder));
1767
1768         priv = MODEST_MAIL_OPERATION_GET_PRIVATE (self);
1769
1770         /* Check folder rules */
1771         rules = modest_tny_folder_get_rules (TNY_FOLDER (folder));
1772         if (rules & MODEST_FOLDER_RULES_FOLDER_NON_DELETABLE) {
1773                 /* Set status failed and set an error */
1774                 priv->status = MODEST_MAIL_OPERATION_STATUS_FAILED;
1775                 g_set_error (&(priv->error), MODEST_MAIL_OPERATION_ERROR,
1776                              MODEST_MAIL_OPERATION_ERROR_FOLDER_RULES,
1777                              _("mail_in_ui_folder_delete_error"));
1778                 goto end;
1779         }
1780
1781         /* Get the account */
1782         account = modest_tny_folder_get_account (folder);
1783         priv->account = g_object_ref(account);
1784         priv->op_type = MODEST_MAIL_OPERATION_TYPE_DELETE;
1785
1786         /* Delete folder or move to trash */
1787         if (remove_to_trash) {
1788                 TnyFolder *trash_folder = NULL;
1789                 trash_folder = modest_tny_account_get_special_folder (account,
1790                                                                       TNY_FOLDER_TYPE_TRASH);
1791                 /* TODO: error_handling */
1792                 if (trash_folder) {
1793                         modest_mail_operation_notify_start (self);
1794                         modest_mail_operation_xfer_folder (self, folder,
1795                                                     TNY_FOLDER_STORE (trash_folder),
1796                                                     TRUE, NULL, NULL);
1797                         g_object_unref (trash_folder);
1798                 }
1799         } else {
1800                 TnyFolderStore *parent = tny_folder_get_folder_store (folder);
1801                 if (parent) {
1802                         modest_mail_operation_notify_start (self);
1803                         tny_folder_store_remove_folder (parent, folder, &(priv->error));
1804                         CHECK_EXCEPTION (priv, MODEST_MAIL_OPERATION_STATUS_FAILED);
1805
1806                         if (!priv->error)
1807                                 priv->status = MODEST_MAIL_OPERATION_STATUS_SUCCESS;
1808
1809                         g_object_unref (parent);
1810                 } else
1811                         g_warning ("%s: could not get parent folder", __FUNCTION__);
1812         }
1813         g_object_unref (G_OBJECT (account));
1814
1815  end:
1816         /* Notify about operation end */
1817         modest_mail_operation_notify_end (self);
1818 }
1819
1820 static void
1821 transfer_folder_status_cb (GObject *obj,
1822                            TnyStatus *status,
1823                            gpointer user_data)
1824 {
1825         ModestMailOperation *self;
1826         ModestMailOperationPrivate *priv;
1827         ModestMailOperationState *state;
1828         XFerMsgAsyncHelper *helper;
1829
1830         g_return_if_fail (status != NULL);
1831         g_return_if_fail (status->code == TNY_FOLDER_STATUS_CODE_COPY_FOLDER);
1832
1833         helper = (XFerMsgAsyncHelper *) user_data;
1834         g_return_if_fail (helper != NULL);
1835
1836         self = helper->mail_op;
1837         priv = MODEST_MAIL_OPERATION_GET_PRIVATE(self);
1838
1839         priv->done = status->position;
1840         priv->total = status->of_total;
1841
1842         state = modest_mail_operation_clone_state (self);
1843
1844         /* This is not a GDK lock because we are a Tinymail callback
1845          * which is already GDK locked by Tinymail */
1846
1847         /* no gdk_threads_enter (), CHECKED */
1848
1849         g_signal_emit (G_OBJECT (self), signals[PROGRESS_CHANGED_SIGNAL], 0, state, NULL);
1850
1851         /* no gdk_threads_leave (), CHECKED */
1852
1853         g_slice_free (ModestMailOperationState, state);
1854 }
1855
1856
1857 static void
1858 transfer_folder_cb (TnyFolder *folder,
1859                     gboolean cancelled,
1860                     TnyFolderStore *into,
1861                     TnyFolder *new_folder,
1862                     GError *err,
1863                     gpointer user_data)
1864 {
1865         XFerMsgAsyncHelper *helper;
1866         ModestMailOperation *self = NULL;
1867         ModestMailOperationPrivate *priv = NULL;
1868
1869         helper = (XFerMsgAsyncHelper *) user_data;
1870         g_return_if_fail (helper != NULL);
1871
1872         self = helper->mail_op;
1873         priv = MODEST_MAIL_OPERATION_GET_PRIVATE(self);
1874
1875         if (err) {
1876                 priv->error = g_error_copy (err);
1877                 priv->done = 0;
1878                 priv->status = MODEST_MAIL_OPERATION_STATUS_FAILED;
1879         } else if (cancelled) {
1880                 priv->status = MODEST_MAIL_OPERATION_STATUS_CANCELED;
1881                 g_set_error (&(priv->error), MODEST_MAIL_OPERATION_ERROR,
1882                              MODEST_MAIL_OPERATION_ERROR_OPERATION_CANCELED,
1883                              _("Transference of %s was cancelled."),
1884                              tny_folder_get_name (folder));
1885         } else {
1886                 priv->done = 1;
1887                 priv->status = MODEST_MAIL_OPERATION_STATUS_SUCCESS;
1888         }
1889
1890         /* Notify about operation end */
1891         modest_mail_operation_notify_end (self);
1892
1893         /* If user defined callback function was defined, call it */
1894         if (helper->user_callback) {
1895
1896                 /* This is not a GDK lock because we are a Tinymail callback
1897                  * which is already GDK locked by Tinymail */
1898
1899                 /* no gdk_threads_enter (), CHECKED */
1900                 helper->user_callback (self, helper->user_data);
1901                 /* no gdk_threads_leave () , CHECKED */
1902         }
1903
1904         /* Free */
1905         g_object_unref (helper->mail_op);
1906         g_slice_free   (XFerMsgAsyncHelper, helper);
1907 }
1908
1909 /**
1910  *
1911  * This function checks if the new name is a valid name for our local
1912  * folders account. The new name could not be the same than then name
1913  * of any of the mandatory local folders
1914  *
1915  * We can not rely on tinymail because tinymail does not check the
1916  * name of the virtual folders that the account could have in the case
1917  * that we're doing a rename (because it directly calls Camel which
1918  * knows nothing about our virtual folders).
1919  *
1920  * In the case of an actual copy/move (i.e. move/copy a folder between
1921  * accounts) tinymail uses the tny_folder_store_create_account which
1922  * is reimplemented by our ModestTnyLocalFoldersAccount that indeed
1923  * checks the new name of the folder, so this call in that case
1924  * wouldn't be needed. *But* NOTE that if tinymail changes its
1925  * implementation (if folder transfers within the same account is no
1926  * longer implemented as a rename) this call will allow Modest to work
1927  * perfectly
1928  *
1929  * If the new name is not valid, this function will set the status to
1930  * failed and will set also an error in the mail operation
1931  */
1932 static gboolean
1933 new_name_valid_if_local_account (ModestMailOperationPrivate *priv,
1934                                  TnyFolderStore *into,
1935                                  const gchar *new_name)
1936 {
1937         if (TNY_IS_ACCOUNT (into) &&
1938             modest_tny_account_is_virtual_local_folders (TNY_ACCOUNT (into)) &&
1939             modest_tny_local_folders_account_folder_name_in_use (MODEST_TNY_LOCAL_FOLDERS_ACCOUNT (into),
1940                                                                  new_name)) {
1941                 priv->status = MODEST_MAIL_OPERATION_STATUS_FAILED;
1942                 g_set_error (&(priv->error), MODEST_MAIL_OPERATION_ERROR,
1943                              MODEST_MAIL_OPERATION_ERROR_FOLDER_EXISTS,
1944                              _CS("ckdg_ib_folder_already_exists"));
1945                 return FALSE;
1946         } else
1947                 return TRUE;
1948 }
1949
1950 void
1951 modest_mail_operation_xfer_folder (ModestMailOperation *self,
1952                                    TnyFolder *folder,
1953                                    TnyFolderStore *parent,
1954                                    gboolean delete_original,
1955                                    XferAsyncUserCallback user_callback,
1956                                    gpointer user_data)
1957 {
1958         ModestMailOperationPrivate *priv = NULL;
1959         ModestTnyFolderRules parent_rules = 0, rules;
1960         XFerMsgAsyncHelper *helper = NULL;
1961         const gchar *folder_name = NULL;
1962         const gchar *error_msg;
1963
1964         g_return_if_fail (MODEST_IS_MAIL_OPERATION (self));
1965         g_return_if_fail (TNY_IS_FOLDER (folder));
1966         g_return_if_fail (TNY_IS_FOLDER_STORE (parent));
1967
1968         priv = MODEST_MAIL_OPERATION_GET_PRIVATE (self);
1969         folder_name = tny_folder_get_name (folder);
1970
1971         /* Set the error msg */
1972         error_msg = _("mail_in_ui_folder_move_target_error");
1973
1974         /* Get account and set it into mail_operation */
1975         priv->op_type = MODEST_MAIL_OPERATION_TYPE_RECEIVE;
1976         priv->account = modest_tny_folder_get_account (TNY_FOLDER(folder));
1977         priv->status = MODEST_MAIL_OPERATION_STATUS_IN_PROGRESS;
1978
1979         /* Get folder rules */
1980         rules = modest_tny_folder_get_rules (TNY_FOLDER (folder));
1981         if (TNY_IS_FOLDER (parent))
1982                 parent_rules = modest_tny_folder_get_rules (TNY_FOLDER (parent));
1983
1984         /* Apply operation constraints */
1985         if ((gpointer) parent == (gpointer) folder ||
1986             (!TNY_IS_FOLDER_STORE (parent)) ||
1987             (rules & MODEST_FOLDER_RULES_FOLDER_NON_MOVEABLE)) {
1988                 /* Folder rules */
1989                 goto error;
1990         } else if (TNY_IS_FOLDER (parent) &&
1991                    (parent_rules & MODEST_FOLDER_RULES_FOLDER_NON_WRITEABLE)) {
1992                 /* Folder rules */
1993                 goto error;
1994
1995         } else if (TNY_IS_FOLDER (parent) &&
1996                    TNY_IS_FOLDER_STORE (folder) &&
1997                    modest_tny_folder_is_ancestor (TNY_FOLDER (parent),
1998                                                   TNY_FOLDER_STORE (folder))) {
1999                 /* Do not move a parent into a child */
2000                 goto error;
2001         } else if (TNY_IS_FOLDER_STORE (parent) &&
2002                    modest_tny_folder_has_subfolder_with_name (parent, folder_name, TRUE)) {
2003                 /* Check that the new folder name is not used by any
2004                    parent subfolder */
2005                 goto error;
2006         } else if (!(new_name_valid_if_local_account (priv, parent, folder_name))) {
2007                 /* Check that the new folder name is not used by any
2008                    special local folder */
2009                 goto error;
2010         } else {
2011                 /* Create the helper */
2012                 helper = g_slice_new0 (XFerMsgAsyncHelper);
2013                 helper->mail_op = g_object_ref (self);
2014                 helper->dest_folder = NULL;
2015                 helper->headers = NULL;
2016                 helper->user_callback = user_callback;
2017                 helper->user_data = user_data;
2018
2019                 /* Move/Copy folder */
2020                 modest_mail_operation_notify_start (self);
2021                 tny_folder_copy_async (folder,
2022                                        parent,
2023                                        tny_folder_get_name (folder),
2024                                        delete_original,
2025                                        transfer_folder_cb,
2026                                        transfer_folder_status_cb,
2027                                        helper);
2028                 return;
2029         }
2030
2031  error:
2032         /* Set status failed and set an error */
2033         priv->status = MODEST_MAIL_OPERATION_STATUS_FAILED;
2034         g_set_error (&(priv->error), MODEST_MAIL_OPERATION_ERROR,
2035                      MODEST_MAIL_OPERATION_ERROR_FOLDER_RULES,
2036                      error_msg);
2037
2038         /* Call the user callback if exists */
2039         if (user_callback)
2040                 user_callback (self, user_data);
2041
2042         /* Notify the queue */
2043         modest_mail_operation_notify_end (self);
2044 }
2045
2046 void
2047 modest_mail_operation_rename_folder (ModestMailOperation *self,
2048                                      TnyFolder *folder,
2049                                      const gchar *name)
2050 {
2051         ModestMailOperationPrivate *priv;
2052         ModestTnyFolderRules rules;
2053         XFerMsgAsyncHelper *helper;
2054
2055         g_return_if_fail (MODEST_IS_MAIL_OPERATION (self));
2056         g_return_if_fail (TNY_IS_FOLDER_STORE (folder));
2057         g_return_if_fail (name);
2058
2059         priv = MODEST_MAIL_OPERATION_GET_PRIVATE (self);
2060
2061         /* Get account and set it into mail_operation */
2062         priv->account = modest_tny_folder_get_account (TNY_FOLDER(folder));
2063         priv->op_type = MODEST_MAIL_OPERATION_TYPE_INFO;
2064
2065         /* Check folder rules */
2066         rules = modest_tny_folder_get_rules (TNY_FOLDER (folder));
2067         if (rules & MODEST_FOLDER_RULES_FOLDER_NON_RENAMEABLE) {
2068                 /* Set status failed and set an error */
2069                 priv->status = MODEST_MAIL_OPERATION_STATUS_FAILED;
2070                 g_set_error (&(priv->error), MODEST_MAIL_OPERATION_ERROR,
2071                              MODEST_MAIL_OPERATION_ERROR_FOLDER_RULES,
2072                              _("FIXME: unable to rename"));
2073
2074                 /* Notify about operation end */
2075                 modest_mail_operation_notify_end (self);
2076         } else if (!strcmp (name, " ") || strchr (name, '/')) {
2077                 priv->status = MODEST_MAIL_OPERATION_STATUS_FAILED;
2078                 g_set_error (&(priv->error), MODEST_MAIL_OPERATION_ERROR,
2079                              MODEST_MAIL_OPERATION_ERROR_FOLDER_RULES,
2080                              _("FIXME: unable to rename"));
2081                 /* Notify about operation end */
2082                 modest_mail_operation_notify_end (self);
2083         } else {
2084                 TnyFolderStore *into;
2085
2086                 into = tny_folder_get_folder_store (folder);
2087
2088                 /* Check that the new folder name is not used by any
2089                    special local folder */
2090                 if (new_name_valid_if_local_account (priv, into, name)) {
2091                         /* Create the helper */
2092                         helper = g_slice_new0 (XFerMsgAsyncHelper);
2093                         helper->mail_op = g_object_ref(self);
2094                         helper->dest_folder = NULL;
2095                         helper->headers = NULL;
2096                         helper->user_callback = NULL;
2097                         helper->user_data = NULL;
2098
2099                         /* Rename. Camel handles folder subscription/unsubscription */
2100                         modest_mail_operation_notify_start (self);
2101                         tny_folder_copy_async (folder, into, name, TRUE,
2102                                                transfer_folder_cb,
2103                                                transfer_folder_status_cb,
2104                                                helper);
2105                 } else {
2106                         modest_mail_operation_notify_end (self);
2107                 }
2108                 g_object_unref (into);
2109         }
2110 }
2111
2112 /* ******************************************************************* */
2113 /* **************************  MSG  ACTIONS  ************************* */
2114 /* ******************************************************************* */
2115
2116 void
2117 modest_mail_operation_get_msg (ModestMailOperation *self,
2118                                TnyHeader *header,
2119                                GetMsgAsyncUserCallback user_callback,
2120                                gpointer user_data)
2121 {
2122         GetMsgInfo *helper = NULL;
2123         TnyFolder *folder;
2124         ModestMailOperationPrivate *priv;
2125
2126         g_return_if_fail (MODEST_IS_MAIL_OPERATION (self));
2127         g_return_if_fail (TNY_IS_HEADER (header));
2128
2129         priv = MODEST_MAIL_OPERATION_GET_PRIVATE (self);
2130         folder = tny_header_get_folder (header);
2131
2132         priv->status = MODEST_MAIL_OPERATION_STATUS_IN_PROGRESS;
2133         priv->total = 1;
2134         priv->done = 0;
2135
2136         /* Get account and set it into mail_operation */
2137         priv->account = modest_tny_folder_get_account (TNY_FOLDER(folder));
2138
2139         /* Check for cached messages */
2140         if (tny_header_get_flags (header) & TNY_HEADER_FLAG_CACHED)
2141                 priv->op_type = MODEST_MAIL_OPERATION_TYPE_OPEN;
2142         else
2143                 priv->op_type = MODEST_MAIL_OPERATION_TYPE_RECEIVE;
2144
2145         /* Create the helper */
2146         helper = g_slice_new0 (GetMsgInfo);
2147         helper->header = g_object_ref (header);
2148         helper->mail_op = g_object_ref (self);
2149         helper->user_callback = user_callback;
2150         helper->user_data = user_data;
2151         helper->destroy_notify = NULL;
2152         helper->last_total_bytes = 0;
2153         helper->sum_total_bytes = 0;
2154         helper->total_bytes = tny_header_get_message_size (header);
2155
2156         modest_mail_operation_notify_start (self);
2157         tny_folder_get_msg_async (folder, header, get_msg_async_cb, get_msg_status_cb, helper);
2158
2159         g_object_unref (G_OBJECT (folder));
2160 }
2161
2162 static void
2163 get_msg_status_cb (GObject *obj,
2164                    TnyStatus *status,
2165                    gpointer user_data)
2166 {
2167         GetMsgInfo *helper = NULL;
2168
2169         g_return_if_fail (status != NULL);
2170         g_return_if_fail (status->code == TNY_FOLDER_STATUS_CODE_GET_MSG);
2171
2172         helper = (GetMsgInfo *) user_data;
2173         g_return_if_fail (helper != NULL);
2174
2175         /* Notify progress */
2176         notify_progress_of_multiple_messages (helper->mail_op, status, &(helper->last_total_bytes),
2177                                               &(helper->sum_total_bytes), helper->total_bytes, FALSE);
2178 }
2179
2180 static void
2181 get_msg_async_cb (TnyFolder *folder,
2182                   gboolean canceled,
2183                   TnyMsg *msg,
2184                   GError *err,
2185                   gpointer user_data)
2186 {
2187         GetMsgInfo *info = NULL;
2188         ModestMailOperationPrivate *priv = NULL;
2189         gboolean finished;
2190
2191         info = (GetMsgInfo *) user_data;
2192
2193         priv = MODEST_MAIL_OPERATION_GET_PRIVATE (info->mail_op);
2194         priv->done++;
2195         finished = (priv->done == priv->total) ? TRUE : FALSE;
2196
2197         /* Check errors */
2198         if (canceled || err) {
2199                 priv->status = MODEST_MAIL_OPERATION_STATUS_FINISHED_WITH_ERRORS;
2200                 if (!priv->error)
2201                         g_set_error (&(priv->error), MODEST_MAIL_OPERATION_ERROR,
2202                                      MODEST_MAIL_OPERATION_ERROR_ITEM_NOT_FOUND,
2203                                      err->message);
2204         } else {
2205                 /* Set the success status before calling the user callback */
2206                 if (finished && priv->status == MODEST_MAIL_OPERATION_STATUS_IN_PROGRESS)
2207                         priv->status = MODEST_MAIL_OPERATION_STATUS_SUCCESS;
2208         }
2209
2210
2211         /* Call the user callback */
2212         if (info->user_callback)
2213                 info->user_callback (info->mail_op, info->header, canceled,
2214                                      msg, err, info->user_data);
2215
2216         /* Notify about operation end if this is the last callback */
2217         if (finished) {
2218                 /* Free user data */
2219                 if (info->destroy_notify)
2220                         info->destroy_notify (info->user_data);
2221
2222                 /* Notify about operation end */
2223                 modest_mail_operation_notify_end (info->mail_op);
2224         }
2225
2226         /* Clean */
2227         g_object_unref (info->header);
2228         g_object_unref (info->mail_op);
2229         g_slice_free (GetMsgInfo, info);
2230 }
2231
2232 void
2233 modest_mail_operation_get_msgs_full (ModestMailOperation *self,
2234                                      TnyList *header_list,
2235                                      GetMsgAsyncUserCallback user_callback,
2236                                      gpointer user_data,
2237                                      GDestroyNotify notify)
2238 {
2239         ModestMailOperationPrivate *priv = NULL;
2240         gboolean size_ok = TRUE;
2241         gint max_size;
2242         TnyIterator *iter = NULL;
2243
2244         g_return_if_fail (MODEST_IS_MAIL_OPERATION (self));
2245
2246         /* Init mail operation */
2247         priv = MODEST_MAIL_OPERATION_GET_PRIVATE (self);
2248         priv->status = MODEST_MAIL_OPERATION_STATUS_IN_PROGRESS;
2249         priv->op_type = MODEST_MAIL_OPERATION_TYPE_RECEIVE;
2250         priv->done = 0;
2251         priv->total = tny_list_get_length(header_list);
2252
2253         /* Get account and set it into mail_operation */
2254         if (tny_list_get_length (header_list) >= 1) {
2255                 iter = tny_list_create_iterator (header_list);
2256                 TnyHeader *header = TNY_HEADER (tny_iterator_get_current (iter));
2257                 if (header) {
2258                         TnyFolder *folder = tny_header_get_folder (header);
2259                         if (folder) {
2260                                 priv->account = modest_tny_folder_get_account (TNY_FOLDER(folder));
2261                                 g_object_unref (folder);
2262                         }
2263                         g_object_unref (header);
2264                 }
2265
2266                 if (tny_list_get_length (header_list) == 1) {
2267                         g_object_unref (iter);
2268                         iter = NULL;
2269                 }
2270         }
2271
2272         /* Get msg size limit */
2273         max_size  = modest_conf_get_int (modest_runtime_get_conf (),
2274                                          MODEST_CONF_MSG_SIZE_LIMIT,
2275                                          &(priv->error));
2276         if (priv->error) {
2277                 g_clear_error (&(priv->error));
2278                 max_size = G_MAXINT;
2279         } else {
2280                 max_size = max_size * KB;
2281         }
2282
2283         /* Check message size limits. If there is only one message
2284            always retrieve it */
2285         if (iter != NULL) {
2286                 while (!tny_iterator_is_done (iter) && size_ok) {
2287                         TnyHeader *header = TNY_HEADER (tny_iterator_get_current (iter));
2288                         if (header) {
2289                                 if (tny_header_get_message_size (header) >= max_size)
2290                                         size_ok = FALSE;
2291                                 g_object_unref (header);
2292                         }
2293
2294                         tny_iterator_next (iter);
2295                 }
2296                 g_object_unref (iter);
2297         }
2298
2299         if (size_ok) {
2300                 const gint msg_list_size = compute_message_list_size (header_list);
2301
2302                 modest_mail_operation_notify_start (self);
2303                 iter = tny_list_create_iterator (header_list);
2304                 while (!tny_iterator_is_done (iter)) {
2305                         GetMsgInfo *msg_info = NULL;
2306                         TnyHeader *header = TNY_HEADER (tny_iterator_get_current (iter));
2307                         TnyFolder *folder = tny_header_get_folder (header);
2308
2309                         /* Create the message info */
2310                         msg_info = g_slice_new0 (GetMsgInfo);
2311                         msg_info->mail_op = g_object_ref (self);
2312                         msg_info->header = g_object_ref (header);
2313                         msg_info->user_callback = user_callback;
2314                         msg_info->user_data = user_data;
2315                         msg_info->destroy_notify = notify;
2316                         msg_info->last_total_bytes = 0;
2317                         msg_info->sum_total_bytes = 0;
2318                         msg_info->total_bytes = msg_list_size;
2319
2320                         /* The callback will call it per each header */
2321                         tny_folder_get_msg_async (folder, header, get_msg_async_cb, get_msg_status_cb, msg_info);
2322
2323                         /* Free and go on */
2324                         g_object_unref (header);
2325                         g_object_unref (folder);
2326                         tny_iterator_next (iter);
2327                 }
2328                 g_object_unref (iter);
2329         } else {
2330                 /* Set status failed and set an error */
2331                 priv->status = MODEST_MAIL_OPERATION_STATUS_FAILED;
2332                 /* FIXME: the error msg is different for pop */
2333                 g_set_error (&(priv->error), MODEST_MAIL_OPERATION_ERROR,
2334                              MODEST_MAIL_OPERATION_ERROR_MESSAGE_SIZE_LIMIT,
2335                              _("emev_ni_ui_imap_msg_size_exceed_error"));
2336                 /* Remove from queue and free resources */
2337                 modest_mail_operation_notify_end (self);
2338                 if (notify)
2339                         notify (user_data);
2340         }
2341 }
2342
2343
2344 void
2345 modest_mail_operation_remove_msg (ModestMailOperation *self,
2346                                   TnyHeader *header,
2347                                   gboolean remove_to_trash /*ignored*/)
2348 {
2349         TnyFolder *folder;
2350         ModestMailOperationPrivate *priv;
2351
2352         g_return_if_fail (MODEST_IS_MAIL_OPERATION (self));
2353         g_return_if_fail (TNY_IS_HEADER (header));
2354
2355         if (remove_to_trash)
2356                 g_warning ("remove to trash is not implemented");
2357
2358         priv = MODEST_MAIL_OPERATION_GET_PRIVATE (self);
2359         folder = tny_header_get_folder (header);
2360
2361         /* Get account and set it into mail_operation */
2362         priv->account = modest_tny_folder_get_account (TNY_FOLDER(folder));
2363         priv->op_type = MODEST_MAIL_OPERATION_TYPE_DELETE;
2364         priv->status = MODEST_MAIL_OPERATION_STATUS_IN_PROGRESS;
2365
2366         /* remove message from folder */
2367         tny_folder_remove_msg (folder, header, &(priv->error));
2368         if (!priv->error) {
2369                 gboolean expunge, leave_on_server;
2370                 const gchar *account_name;
2371                 TnyAccount *account;
2372                 ModestTransportStoreProtocol account_proto;
2373
2374                 tny_header_set_flag (header, TNY_HEADER_FLAG_DELETED);
2375                 tny_header_set_flag (header, TNY_HEADER_FLAG_SEEN);
2376
2377                 modest_mail_operation_notify_start (self);
2378
2379                 /* Get leave on server setting */
2380                 account = tny_folder_get_account (folder);
2381                 account_name = modest_tny_account_get_parent_modest_account_name_for_server_account (account);
2382                 leave_on_server =
2383                         modest_account_mgr_get_leave_on_server (modest_runtime_get_account_mgr (),
2384                                                                 account_name);
2385
2386                 account_proto = modest_protocol_info_get_transport_store_protocol (tny_account_get_proto (account));
2387
2388                 if (((account_proto == MODEST_PROTOCOL_STORE_POP) && !leave_on_server) ||
2389                     modest_tny_folder_is_remote_folder (folder) == FALSE)
2390                         expunge = TRUE;
2391                 else
2392                         expunge = FALSE;
2393
2394                 /* Sync folder */
2395                 tny_folder_sync_async(folder, expunge, NULL, NULL, NULL);
2396
2397                 /* Unref */
2398                 g_object_unref (account);
2399         }
2400
2401
2402         /* Set status */
2403         if (!priv->error)
2404                 priv->status = MODEST_MAIL_OPERATION_STATUS_SUCCESS;
2405         else
2406                 priv->status = MODEST_MAIL_OPERATION_STATUS_FAILED;
2407
2408         /* Free */
2409         g_object_unref (G_OBJECT (folder));
2410
2411         /* Notify about operation end */
2412         modest_mail_operation_notify_end (self);
2413 }
2414
2415 void
2416 modest_mail_operation_remove_msgs (ModestMailOperation *self,
2417                                    TnyList *headers,
2418                                   gboolean remove_to_trash /*ignored*/)
2419 {
2420         TnyFolder *folder;
2421         ModestMailOperationPrivate *priv;
2422         TnyIterator *iter = NULL;
2423         TnyHeader *header = NULL;
2424         TnyList *remove_headers = NULL;
2425         TnyFolderType folder_type = TNY_FOLDER_TYPE_UNKNOWN;
2426
2427         g_return_if_fail (MODEST_IS_MAIL_OPERATION (self));
2428         g_return_if_fail (TNY_IS_LIST (headers));
2429
2430         if (remove_to_trash)
2431                 g_warning ("remove to trash is not implemented");
2432
2433         priv = MODEST_MAIL_OPERATION_GET_PRIVATE (self);
2434
2435         remove_headers = g_object_ref(headers);
2436
2437         /* Get folder from first header and sync it */
2438         iter = tny_list_create_iterator (headers);
2439         header = TNY_HEADER (tny_iterator_get_current (iter));
2440         folder = tny_header_get_folder (header);
2441
2442         /* Don't remove messages that are being sent */
2443         if (modest_tny_folder_is_local_folder (folder)) {
2444                 folder_type = modest_tny_folder_get_local_or_mmc_folder_type (folder);
2445         }
2446         if (folder_type == TNY_FOLDER_TYPE_OUTBOX) {
2447                 TnyTransportAccount *traccount = NULL;
2448                 ModestTnyAccountStore *accstore = modest_runtime_get_account_store();
2449                 traccount = modest_tny_account_store_get_transport_account_from_outbox_header(accstore, header);
2450                 if (traccount) {
2451                         ModestTnySendQueueStatus status;
2452                         ModestTnySendQueue *send_queue = modest_runtime_get_send_queue(traccount);
2453                         TnyIterator *iter = tny_list_create_iterator(headers);
2454                         g_object_unref(remove_headers);
2455                         remove_headers = TNY_LIST(tny_simple_list_new());
2456                         while (!tny_iterator_is_done(iter)) {
2457                                 char *msg_id;
2458                                 TnyHeader *hdr = TNY_HEADER(tny_iterator_get_current(iter));
2459                                 msg_id = modest_tny_send_queue_get_msg_id (hdr);
2460                                 status = modest_tny_send_queue_get_msg_status(send_queue, msg_id);
2461                                 if (status != MODEST_TNY_SEND_QUEUE_SENDING) {
2462                                         tny_list_append(remove_headers, G_OBJECT(hdr));
2463                                 }
2464                                 g_object_unref(hdr);
2465                                 g_free(msg_id);
2466                                 tny_iterator_next(iter);
2467                         }
2468                         g_object_unref(iter);
2469                         g_object_unref(traccount);
2470                 }
2471         }
2472
2473         /* Get account and set it into mail_operation */
2474         priv->account = modest_tny_folder_get_account (TNY_FOLDER(folder));
2475         priv->op_type = MODEST_MAIL_OPERATION_TYPE_DELETE;
2476         priv->status = MODEST_MAIL_OPERATION_STATUS_IN_PROGRESS;
2477
2478         /* remove message from folder */
2479         modest_mail_operation_notify_start (self);
2480
2481         tny_folder_remove_msgs (folder, remove_headers, &(priv->error));
2482         if (!priv->error) {
2483                 gboolean expunge, leave_on_server;
2484                 const gchar *account_name;
2485                 TnyAccount *account;
2486                 ModestTransportStoreProtocol account_proto;
2487
2488                 account = tny_folder_get_account (folder);
2489                 account_name = modest_tny_account_get_parent_modest_account_name_for_server_account (account);
2490                 leave_on_server =
2491                         modest_account_mgr_get_leave_on_server (modest_runtime_get_account_mgr (),
2492                                         account_name);
2493
2494                 account_proto = modest_protocol_info_get_transport_store_protocol (tny_account_get_proto (account));
2495
2496                 if (((account_proto == MODEST_PROTOCOL_STORE_POP) && !leave_on_server) ||
2497                     modest_tny_folder_is_remote_folder (folder) == FALSE)
2498                         expunge = TRUE;
2499                 else
2500                         expunge = FALSE;
2501
2502                 /* Sync folder */
2503                 tny_folder_sync_async(folder, expunge, NULL, NULL, NULL);
2504
2505                 g_object_unref (account);
2506         }
2507
2508
2509         /* Set status */
2510         if (!priv->error)
2511                 priv->status = MODEST_MAIL_OPERATION_STATUS_SUCCESS;
2512         else
2513                 priv->status = MODEST_MAIL_OPERATION_STATUS_FAILED;
2514
2515         /* Free */
2516         g_object_unref (remove_headers);
2517         g_object_unref (header);
2518         g_object_unref (iter);
2519         g_object_unref (G_OBJECT (folder));
2520
2521         /* Notify about operation end */
2522         modest_mail_operation_notify_end (self);
2523 }
2524
2525 static void
2526 notify_progress_of_multiple_messages (ModestMailOperation *self,
2527                                       TnyStatus *status,
2528                                       gint *last_total_bytes,
2529                                       gint *sum_total_bytes,
2530                                       gint total_bytes,
2531                                       gboolean increment_done)
2532 {
2533         ModestMailOperationPrivate *priv;
2534         ModestMailOperationState *state;
2535         gboolean is_num_bytes;
2536
2537         priv =  MODEST_MAIL_OPERATION_GET_PRIVATE (self);
2538
2539         /* We know that tinymail sends us information about
2540            transferred bytes with this particular message */
2541         is_num_bytes = (g_ascii_strcasecmp (status->message, "Retrieving message") == 0);
2542
2543         state = modest_mail_operation_clone_state (self);
2544         if (is_num_bytes && !((status->position == 1) && (status->of_total == 100))) {
2545                 /* We know that we're in a different message when the
2546                    total number of bytes to transfer is different. Of
2547                    course it could fail if we're transferring messages
2548                    of the same size, but this is a workarround */
2549                 if (status->of_total != *last_total_bytes) {
2550                         /* We need to increment the done when there is
2551                            no information about each individual
2552                            message, we need to do this in message
2553                            transfers, and we don't do it for getting
2554                            messages */
2555                         if (increment_done)
2556                                 priv->done++;
2557                         *sum_total_bytes += *last_total_bytes;
2558                         *last_total_bytes = status->of_total;
2559                 }
2560                 state->bytes_done += status->position + *sum_total_bytes;
2561                 state->bytes_total = total_bytes;
2562
2563                 /* Notify the status change. Only notify about changes
2564                    referred to bytes */
2565                 g_signal_emit (G_OBJECT (self), signals[PROGRESS_CHANGED_SIGNAL],
2566                                0, state, NULL);
2567         }
2568
2569         g_slice_free (ModestMailOperationState, state);
2570 }
2571
2572 static void
2573 transfer_msgs_status_cb (GObject *obj,
2574                          TnyStatus *status,
2575                          gpointer user_data)
2576 {
2577         XFerMsgAsyncHelper *helper;
2578
2579         g_return_if_fail (status != NULL);
2580         g_return_if_fail (status->code == TNY_FOLDER_STATUS_CODE_XFER_MSGS);
2581
2582         helper = (XFerMsgAsyncHelper *) user_data;
2583         g_return_if_fail (helper != NULL);
2584
2585         /* Notify progress */
2586         notify_progress_of_multiple_messages (helper->mail_op, status, &(helper->last_total_bytes),
2587                                               &(helper->sum_total_bytes), helper->total_bytes, TRUE);
2588 }
2589
2590
2591 static void
2592 transfer_msgs_cb (TnyFolder *folder, gboolean cancelled, GError *err, gpointer user_data)
2593 {
2594         XFerMsgAsyncHelper *helper;
2595         ModestMailOperation *self;
2596         ModestMailOperationPrivate *priv;
2597         TnyIterator *iter = NULL;
2598         TnyHeader *header = NULL;
2599
2600         helper = (XFerMsgAsyncHelper *) user_data;
2601         self = helper->mail_op;
2602
2603         priv = MODEST_MAIL_OPERATION_GET_PRIVATE (self);
2604
2605         if (err) {
2606                 priv->error = g_error_copy (err);
2607                 priv->done = 0;
2608                 priv->status = MODEST_MAIL_OPERATION_STATUS_FAILED;
2609         } else if (cancelled) {
2610                 priv->status = MODEST_MAIL_OPERATION_STATUS_CANCELED;
2611                 g_set_error (&(priv->error), MODEST_MAIL_OPERATION_ERROR,
2612                              MODEST_MAIL_OPERATION_ERROR_ITEM_NOT_FOUND,
2613                              _("Error trying to refresh the contents of %s"),
2614                              tny_folder_get_name (folder));
2615         } else {
2616                 priv->done = 1;
2617                 priv->status = MODEST_MAIL_OPERATION_STATUS_SUCCESS;
2618
2619                 /* Update folder counts */
2620                 tny_folder_poke_status (folder);
2621                 tny_folder_poke_status (helper->dest_folder);
2622         }
2623
2624
2625         /* Mark headers as deleted and seen */
2626         if ((helper->delete) &&
2627             (priv->status == MODEST_MAIL_OPERATION_STATUS_SUCCESS)) {
2628                 iter = tny_list_create_iterator (helper->headers);
2629                 while (!tny_iterator_is_done (iter)) {
2630                         header = TNY_HEADER (tny_iterator_get_current (iter));
2631                         tny_header_set_flag (header, TNY_HEADER_FLAG_DELETED);
2632                         tny_header_set_flag (header, TNY_HEADER_FLAG_SEEN);
2633                         g_object_unref (header);
2634
2635                         tny_iterator_next (iter);
2636                 }
2637
2638         }
2639
2640
2641         /* Notify about operation end */
2642         modest_mail_operation_notify_end (self);
2643
2644         /* If user defined callback function was defined, call it */
2645         if (helper->user_callback) {
2646                 /* This is not a GDK lock because we are a Tinymail callback and
2647                  * Tinymail already acquires the Gdk lock */
2648
2649                 /* no gdk_threads_enter (), CHECKED */
2650                 helper->user_callback (self, helper->user_data);
2651                 /* no gdk_threads_leave (), CHECKED */
2652         }
2653
2654         /* Free */
2655         if (helper->headers)
2656                 g_object_unref (helper->headers);
2657         if (helper->dest_folder)
2658                 g_object_unref (helper->dest_folder);
2659         if (helper->mail_op)
2660                 g_object_unref (helper->mail_op);
2661         if (folder)
2662                 g_object_unref (folder);
2663         if (iter)
2664                 g_object_unref (iter);
2665         g_slice_free (XFerMsgAsyncHelper, helper);
2666 }
2667
2668 static guint
2669 compute_message_list_size (TnyList *headers)
2670 {
2671         TnyIterator *iter;
2672         guint size = 0;
2673
2674         iter = tny_list_create_iterator (headers);
2675         while (!tny_iterator_is_done (iter)) {
2676                 TnyHeader *header = TNY_HEADER (tny_iterator_get_current (iter));
2677                 size += tny_header_get_message_size (header);
2678                 g_object_unref (header);
2679                 tny_iterator_next (iter);
2680         }
2681         g_object_unref (iter);
2682
2683         return size;
2684 }
2685
2686 static guint
2687 compute_message_array_size (GPtrArray *headers)
2688 {
2689         guint size = 0;
2690         gint i;
2691
2692         for (i = 0; i < headers->len; i++) {
2693                 TnyHeader *header = TNY_HEADER (g_ptr_array_index (headers, i));
2694                 size += tny_header_get_message_size (header);
2695         }
2696
2697         return size;
2698 }
2699
2700
2701 void
2702 modest_mail_operation_xfer_msgs (ModestMailOperation *self,
2703                                  TnyList *headers,
2704                                  TnyFolder *folder,
2705                                  gboolean delete_original,
2706                                  XferAsyncUserCallback user_callback,
2707                                  gpointer user_data)
2708 {
2709         ModestMailOperationPrivate *priv = NULL;
2710         TnyIterator *iter = NULL;
2711         TnyFolder *src_folder = NULL;
2712         XFerMsgAsyncHelper *helper = NULL;
2713         TnyHeader *header = NULL;
2714         ModestTnyFolderRules rules = 0;
2715
2716         g_return_if_fail (self && MODEST_IS_MAIL_OPERATION (self));
2717         g_return_if_fail (headers && TNY_IS_LIST (headers));
2718         g_return_if_fail (folder && TNY_IS_FOLDER (folder));
2719
2720         priv = MODEST_MAIL_OPERATION_GET_PRIVATE(self);
2721         priv->total = tny_list_get_length (headers);
2722         priv->done = 0;
2723         priv->status = MODEST_MAIL_OPERATION_STATUS_IN_PROGRESS;
2724         priv->op_type = MODEST_MAIL_OPERATION_TYPE_RECEIVE;
2725
2726         /* Apply folder rules */
2727         rules = modest_tny_folder_get_rules (TNY_FOLDER (folder));
2728         if (rules & MODEST_FOLDER_RULES_FOLDER_NON_WRITEABLE) {
2729                 /* Set status failed and set an error */
2730                 priv->status = MODEST_MAIL_OPERATION_STATUS_FAILED;
2731                 g_set_error (&(priv->error), MODEST_MAIL_OPERATION_ERROR,
2732                              MODEST_MAIL_OPERATION_ERROR_FOLDER_RULES,
2733                              _CS("ckct_ib_unable_to_paste_here"));
2734                 /* Notify the queue */
2735                 modest_mail_operation_notify_end (self);
2736                 return;
2737         }
2738
2739         /* Get source folder */
2740         iter = tny_list_create_iterator (headers);
2741         header = TNY_HEADER (tny_iterator_get_current (iter));
2742         if (header) {
2743                 src_folder = tny_header_get_folder (header);
2744                 g_object_unref (header);
2745         }
2746         g_object_unref (iter);
2747
2748         if (src_folder == NULL) {
2749                 /* Notify the queue */
2750                 modest_mail_operation_notify_end (self);
2751
2752                 g_warning ("%s: cannot find folder from header", __FUNCTION__);
2753                 return;
2754         }
2755
2756
2757         /* Check folder source and destination */
2758         if (src_folder == folder) {
2759                 /* Set status failed and set an error */
2760                 priv->status = MODEST_MAIL_OPERATION_STATUS_FAILED;
2761                 g_set_error (&(priv->error), MODEST_MAIL_OPERATION_ERROR,
2762                              MODEST_MAIL_OPERATION_ERROR_BAD_PARAMETER,
2763                              _("mail_in_ui_folder_copy_target_error"));
2764
2765                 /* Notify the queue */
2766                 modest_mail_operation_notify_end (self);
2767
2768                 /* Free */
2769                 g_object_unref (src_folder);
2770                 return;
2771         }
2772
2773         /* Create the helper */
2774         helper = g_slice_new0 (XFerMsgAsyncHelper);
2775         helper->mail_op = g_object_ref(self);
2776         helper->dest_folder = g_object_ref(folder);
2777         helper->headers = g_object_ref(headers);
2778         helper->user_callback = user_callback;
2779         helper->user_data = user_data;
2780         helper->delete = delete_original;
2781         helper->last_total_bytes = 0;
2782         helper->sum_total_bytes = 0;
2783         helper->total_bytes = compute_message_list_size (headers);
2784
2785         /* Get account and set it into mail_operation */
2786         priv->account = modest_tny_folder_get_account (src_folder);
2787
2788         /* Transfer messages */
2789         modest_mail_operation_notify_start (self);
2790         tny_folder_transfer_msgs_async (src_folder,
2791                                         headers,
2792                                         folder,
2793                                         delete_original,
2794                                         transfer_msgs_cb,
2795                                         transfer_msgs_status_cb,
2796                                         helper);
2797 }
2798
2799
2800 static void
2801 on_refresh_folder (TnyFolder   *folder,
2802                    gboolean     cancelled,
2803                    GError     *error,
2804                    gpointer     user_data)
2805 {
2806         RefreshAsyncHelper *helper = NULL;
2807         ModestMailOperation *self = NULL;
2808         ModestMailOperationPrivate *priv = NULL;
2809
2810         helper = (RefreshAsyncHelper *) user_data;
2811         self = helper->mail_op;
2812         priv = MODEST_MAIL_OPERATION_GET_PRIVATE(self);
2813
2814         g_return_if_fail(priv!=NULL);
2815
2816         if (error) {
2817                 priv->error = g_error_copy (error);
2818                 priv->status = MODEST_MAIL_OPERATION_STATUS_FAILED;
2819                 goto out;
2820         }
2821
2822         if (cancelled) {
2823                 priv->status = MODEST_MAIL_OPERATION_STATUS_CANCELED;
2824                 g_set_error (&(priv->error), MODEST_MAIL_OPERATION_ERROR,
2825                              MODEST_MAIL_OPERATION_ERROR_ITEM_NOT_FOUND,
2826                              _("Error trying to refresh the contents of %s"),
2827                              tny_folder_get_name (folder));
2828                 goto out;
2829         }
2830
2831         priv->status = MODEST_MAIL_OPERATION_STATUS_SUCCESS;
2832  out:
2833
2834         /* Call user defined callback, if it exists */
2835         if (helper->user_callback) {
2836
2837                 /* This is not a GDK lock because we are a Tinymail callback and
2838                  * Tinymail already acquires the Gdk lock */
2839                 helper->user_callback (self, folder, helper->user_data);
2840         }
2841
2842         /* Free */
2843         g_slice_free (RefreshAsyncHelper, helper);
2844
2845         /* Notify about operation end */
2846         modest_mail_operation_notify_end (self);
2847         g_object_unref(self);
2848 }
2849
2850 static void
2851 on_refresh_folder_status_update (GObject *obj,
2852                                  TnyStatus *status,
2853                                  gpointer user_data)
2854 {
2855         RefreshAsyncHelper *helper = NULL;
2856         ModestMailOperation *self = NULL;
2857         ModestMailOperationPrivate *priv = NULL;
2858         ModestMailOperationState *state;
2859
2860         g_return_if_fail (user_data != NULL);
2861         g_return_if_fail (status != NULL);
2862         g_return_if_fail (status->code == TNY_FOLDER_STATUS_CODE_REFRESH);
2863
2864         helper = (RefreshAsyncHelper *) user_data;
2865         self = helper->mail_op;
2866         g_return_if_fail (MODEST_IS_MAIL_OPERATION(self));
2867
2868         priv = MODEST_MAIL_OPERATION_GET_PRIVATE(self);
2869
2870         priv->done = status->position;
2871         priv->total = status->of_total;
2872
2873         state = modest_mail_operation_clone_state (self);
2874
2875         /* This is not a GDK lock because we are a Tinymail callback and
2876          * Tinymail already acquires the Gdk lock */
2877         g_signal_emit (G_OBJECT (self), signals[PROGRESS_CHANGED_SIGNAL], 0, state, NULL);
2878
2879         g_slice_free (ModestMailOperationState, state);
2880 }
2881
2882 void
2883 modest_mail_operation_refresh_folder  (ModestMailOperation *self,
2884                                        TnyFolder *folder,
2885                                        RefreshAsyncUserCallback user_callback,
2886                                        gpointer user_data)
2887 {
2888         ModestMailOperationPrivate *priv = NULL;
2889         RefreshAsyncHelper *helper = NULL;
2890
2891         priv = MODEST_MAIL_OPERATION_GET_PRIVATE(self);
2892
2893         priv->status = MODEST_MAIL_OPERATION_STATUS_IN_PROGRESS;
2894
2895         /* Get account and set it into mail_operation */
2896         priv->account = modest_tny_folder_get_account  (folder);
2897         priv->op_type = MODEST_MAIL_OPERATION_TYPE_RECEIVE;
2898
2899         /* Create the helper */
2900         helper = g_slice_new0 (RefreshAsyncHelper);
2901         helper->mail_op = g_object_ref(self);
2902         helper->user_callback = user_callback;
2903         helper->user_data = user_data;
2904
2905         /* Refresh the folder. TODO: tinymail could issue a status
2906            updates before the callback call then this could happen. We
2907            must review the design */
2908         modest_mail_operation_notify_start (self);
2909         tny_folder_refresh_async (folder,
2910                                   on_refresh_folder,
2911                                   on_refresh_folder_status_update,
2912                                   helper);
2913 }
2914
2915
2916 static void
2917 modest_mail_operation_notify_start (ModestMailOperation *self)
2918 {
2919         ModestMailOperationPrivate *priv = NULL;
2920
2921         g_return_if_fail (self);
2922
2923         priv = MODEST_MAIL_OPERATION_GET_PRIVATE(self);
2924
2925         /* Ensure that all the fields are filled correctly */
2926         g_return_if_fail (priv->op_type != MODEST_MAIL_OPERATION_TYPE_UNKNOWN);
2927
2928         /* Notify the observers about the mail operation. We do not
2929            wrapp this emission because we assume that this function is
2930            always called from within the main lock */
2931         g_signal_emit (G_OBJECT (self), signals[OPERATION_STARTED_SIGNAL], 0, NULL);
2932 }
2933
2934 /**
2935  *
2936  * It's used by the mail operation queue to notify the observers
2937  * attached to that signal that the operation finished. We need to use
2938  * that because tinymail does not give us the progress of a given
2939  * operation when it finishes (it directly calls the operation
2940  * callback).
2941  */
2942 static void
2943 modest_mail_operation_notify_end (ModestMailOperation *self)
2944 {
2945         ModestMailOperationPrivate *priv = NULL;
2946
2947         g_return_if_fail (self);
2948
2949         priv = MODEST_MAIL_OPERATION_GET_PRIVATE(self);
2950
2951         /* Notify the observers about the mail operation end. We do
2952            not wrapp this emission because we assume that this
2953            function is always called from within the main lock */
2954         g_signal_emit (G_OBJECT (self), signals[OPERATION_FINISHED_SIGNAL], 0, NULL);
2955
2956         /* Remove the error user data */
2957         if (priv->error_checking_user_data && priv->error_checking_user_data_destroyer)
2958                 priv->error_checking_user_data_destroyer (priv->error_checking_user_data);
2959 }
2960
2961 TnyAccount *
2962 modest_mail_operation_get_account (ModestMailOperation *self)
2963 {
2964         ModestMailOperationPrivate *priv = NULL;
2965
2966         g_return_val_if_fail (self, NULL);
2967
2968         priv = MODEST_MAIL_OPERATION_GET_PRIVATE(self);
2969
2970         return (priv->account) ? g_object_ref (priv->account) : NULL;
2971 }
2972
2973 void
2974 modest_mail_operation_noop (ModestMailOperation *self)
2975 {
2976         ModestMailOperationPrivate *priv = NULL;
2977
2978         g_return_if_fail (self);
2979
2980         priv = MODEST_MAIL_OPERATION_GET_PRIVATE(self);
2981         priv->status = MODEST_MAIL_OPERATION_STATUS_SUCCESS;
2982         priv->op_type = MODEST_MAIL_OPERATION_TYPE_INFO;
2983         priv->done = 0;
2984         priv->total = 0;
2985
2986         /* This mail operation does nothing actually */
2987         modest_mail_operation_notify_start (self);
2988         modest_mail_operation_notify_end (self);
2989 }