2006-04-06 [mones] 2.1.0cvs7

[claws.git] / src / filtering.c

diff --git a/src/filtering.c b/src/filtering.c
index 1d3617a3e5727e15990fd60bef6156df27a71530..6437f86ae3f59b7f9a4203248c96f7dfc8f70f40 100644 (file)
--- a/src/filtering.c
+++ b/src/filtering.c
@@ -78,8 +78,7 @@ FilteringAction * filteringaction_new(int type, int account_id,
 void filteringaction_free(FilteringAction * action)
 {
        g_return_if_fail(action);
-       if (action->destination)
-               g_free(action->destination);
+       g_free(action->destination);
        g_free(action);
 }
 
@@ -163,6 +162,80 @@ void filteringprop_free(FilteringProp * prop)
        g_free(prop);
 }
 
+void filtering_move_and_copy_msg(MsgInfo *msginfo)
+{
+       GSList *list = g_slist_append(NULL, msginfo);
+       filtering_move_and_copy_msgs(list);
+       g_slist_free(list);
+}
+
+/* move and copy messages by batches to be faster on IMAP */
+void filtering_move_and_copy_msgs(GSList *msgs)
+{
+       GSList *messages = g_slist_copy(msgs);
+       FolderItem *last_item = NULL;
+       gboolean is_copy = FALSE, is_move = FALSE;
+       
+       while (messages) {
+               GSList *batch = NULL, *cur;
+               gint found = 0;
+               debug_print("%d messages to filter\n", g_slist_length(messages));
+               for (cur = messages; cur; cur = cur->next) {
+                       MsgInfo *info = (MsgInfo *)cur->data;
+                       if (last_item == NULL) {
+                               last_item = info->to_filter_folder;
+                       }
+                       if (last_item == NULL)
+                               continue;
+                       debug_print("for %s\n", folder_item_get_path(last_item));
+                       if (!is_copy && !is_move) {
+                               if (info->is_copy)
+                                       is_copy = TRUE;
+                               else if (info->is_move)
+                                       is_move = TRUE;
+                       }
+                       found++;
+                       if (info->to_filter_folder == last_item 
+                       &&  info->is_copy == is_copy
+                       &&  info->is_move == is_move) {
+                               batch = g_slist_append(batch, info);
+                       }
+               }
+               if (found == 0) {
+                       debug_print("no more messages to move/copy\n");
+                       break;
+               }
+               for (cur = batch; cur; cur = cur->next) {
+                       MsgInfo *info = (MsgInfo *)cur->data;
+                       messages = g_slist_remove(messages, info);
+               }
+               if (g_slist_length(batch)) {
+                       MsgInfo *info = (MsgInfo *)batch->data;
+                       debug_print("%s %d messages to %s\n",
+                               is_copy?"copying":"moving",
+                               g_slist_length(batch),
+                               folder_item_get_path(last_item));
+                       if (is_copy && last_item != info->folder) {
+                               folder_item_copy_msgs(last_item, batch);
+                       } else if (is_move && last_item != info->folder) {
+                               if (folder_item_move_msgs(last_item, batch) < 0)
+                                       folder_item_move_msgs(
+                                               folder_get_default_inbox(), 
+                                               batch);
+                       }
+                       /* we don't reference the msginfos, because caller will do */
+                       g_slist_free(batch);
+                       batch = NULL;
+               }
+               last_item = NULL;
+               is_copy = FALSE;
+               is_move = FALSE;
+               debug_print("%d messages remaining\n", g_slist_length(messages));
+       }
+       /* we don't reference the msginfos, because caller will do */
+       g_slist_free(messages);
+}
+
 /*
   fitleringaction_apply
   runs the action on one MsgInfo
@@ -187,11 +260,10 @@ static gboolean filteringaction_apply(FilteringAction * action, MsgInfo * info)
                        return FALSE;
                }
                
-               if (folder_item_move_msg(dest_folder, info) == -1) {
-                       debug_print("*** could not move message\n");
-                       return FALSE;
-               }       
-
+               /* mark message to be moved */          
+               info->is_move = TRUE;
+               info->to_filter_folder = dest_folder;
+               debug_print("set to move to %s\n", folder_item_get_path(dest_folder));
                return TRUE;
 
        case MATCHACTION_COPY:
@@ -204,9 +276,10 @@ static gboolean filteringaction_apply(FilteringAction * action, MsgInfo * info)
                        return FALSE;
                }
 
-               if (folder_item_copy_msg(dest_folder, info) == -1)
-                       return FALSE;
-
+               /* mark message to be copied */         
+               info->is_copy = TRUE;
+               info->to_filter_folder = dest_folder;
+               debug_print("set to copy to %s\n", folder_item_get_path(dest_folder));
                return TRUE;
 
        case MATCHACTION_DELETE:
@@ -248,7 +321,7 @@ static gboolean filteringaction_apply(FilteringAction * action, MsgInfo * info)
                account = account_find_from_id(action->account_id);
                compose = compose_forward(account, info,
                        action->type == MATCHACTION_FORWARD ? FALSE : TRUE,
-                       NULL, TRUE);
+                       NULL, TRUE, TRUE);
                compose_entry_append(compose, action->destination,
                                     compose->account->protocol == A_NNTP
                                            ? COMPOSE_NEWSGROUPS
@@ -260,7 +333,7 @@ static gboolean filteringaction_apply(FilteringAction * action, MsgInfo * info)
 
        case MATCHACTION_REDIRECT:
                account = account_find_from_id(action->account_id);
-               compose = compose_redirect(account, info);
+               compose = compose_redirect(account, info, TRUE);
                if (compose->account->protocol == A_NNTP)
                        break;
                else
@@ -296,6 +369,10 @@ static gboolean filteringaction_apply(FilteringAction * action, MsgInfo * info)
                 info->hidden = TRUE;
                 return TRUE;
 
+       case MATCHACTION_IGNORE:
+                procmsg_msginfo_set_flags(info, MSG_IGNORE_THREAD, 0);
+                return TRUE;
+
        default:
                break;
        }
@@ -454,6 +531,7 @@ gchar *filteringaction_to_string(gchar *dest, gint destlen, FilteringAction *act
        case MATCHACTION_MARK_AS_UNREAD:
        case MATCHACTION_STOP:
        case MATCHACTION_HIDE:
+       case MATCHACTION_IGNORE:
                g_snprintf(dest, destlen, "%s", command_str);
                return dest;