2006-02-24 [wwp] 2.0.0cvs81
[claws.git] / src / filtering.c
index 85e8bbbd223b0ed9b454f9a297a39f4f4a2b1c1d..164cafc8b1d9493ff367566a6a365cfa9d6851e1 100644 (file)
@@ -1,6 +1,6 @@
 /*
  * Sylpheed -- a GTK+ based, lightweight, and fast e-mail client
- * Copyright (C) 1999-2002 Hiroyuki Yamamoto & The Sylpheed Claws Team
+ * Copyright (C) 1999-2006 Hiroyuki Yamamoto & The Sylpheed Claws Team
  *
  * This program is free software; you can redistribute it and/or modify
  * it under the terms of the GNU General Public License as published by
  *
  * You should have received a copy of the GNU General Public License
  * along with this program; if not, write to the Free Software
- * Foundation, Inc., 59 Temple Place - Suite 330, Boston, MA 02111-1307, USA.
+ * Foundation, Inc., 51 Franklin Street, Fifth Floor, Boston, MA 02110-1301, USA.
  */
 
 #include "defs.h"
+#include <glib.h>
+#include <glib/gi18n.h>
 #include <ctype.h>
 #include <string.h>
 #include <stdlib.h>
 #include <errno.h>
 #include <gtk/gtk.h>
 #include <stdio.h>
-#include "intl.h"
+
 #include "utils.h"
 #include "procheader.h"
 #include "matcher.h"
@@ -81,12 +83,14 @@ void filteringaction_free(FilteringAction * action)
        g_free(action);
 }
 
-FilteringProp * filteringprop_new(MatcherList * matchers,
+FilteringProp * filteringprop_new(const gchar *name,
+                                 MatcherList * matchers,
                                  GSList * action_list)
 {
        FilteringProp * filtering;
 
        filtering = g_new0(FilteringProp, 1);
+       filtering->name = name ? g_strdup(name): NULL;
        filtering->matchers = matchers;
        filtering->action_list = action_list;
 
@@ -106,6 +110,7 @@ static FilteringAction * filteringaction_copy(FilteringAction * src)
        else 
                new->destination = NULL;
        new->labelcolor = src->labelcolor;
+       new->score = src->score;
 
         return new;
 }
@@ -139,6 +144,8 @@ FilteringProp * filteringprop_copy(FilteringProp *src)
                     filteringaction_copy(filtering_action));
         }
 
+       new->name = g_strdup(src->name);
+
        return new;
 }
 
@@ -152,9 +159,84 @@ void filteringprop_free(FilteringProp * prop)
         for (tmp = prop->action_list ; tmp != NULL ; tmp = tmp->next) {
                 filteringaction_free(tmp->data);
         }
+       g_free(prop->name);
        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
@@ -179,11 +261,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:
@@ -196,9 +277,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:
@@ -240,20 +322,19 @@ 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
                                            : COMPOSE_TO);
 
                val = compose_send(compose);
-               gtk_widget_destroy(compose->window);
 
                return val == 0 ? TRUE : FALSE;
 
        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
@@ -261,7 +342,6 @@ static gboolean filteringaction_apply(FilteringAction * action, MsgInfo * info)
                                             COMPOSE_TO);
 
                val = compose_send(compose);
-               gtk_widget_destroy(compose->window);
                
                return val == 0 ? TRUE : FALSE;
 
@@ -290,6 +370,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;
        }
@@ -448,6 +532,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;