* src/procmsg.c
[claws.git] / src / procmsg.c
index 1ea38d82ca632ac3c48e56d5ba4216dfbbdbf3a0..8aee6db65a7fa04d51c135394c0344d9f352012b 100644 (file)
@@ -1,6 +1,6 @@
 /*
  * Sylpheed -- a GTK+ based, lightweight, and fast e-mail client
- * Copyright (C) 1999-2002 Hiroyuki Yamamoto
+ * Copyright (C) 1999-2003 Hiroyuki Yamamoto
  *
  * 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
 #include <glib.h>
 #include <stdio.h>
 #include <stdlib.h>
+#include <ctype.h>
 
 #include "intl.h"
 #include "main.h"
 #include "utils.h"
 #include "procmsg.h"
 #include "procheader.h"
-#include "send.h"
+#include "send_message.h"
 #include "procmime.h"
 #include "statusbar.h"
+#include "prefs_filtering.h"
+#include "filtering.h"
 #include "folder.h"
 #include "prefs_common.h"
 #include "account.h"
 #endif
 #include "alertpanel.h"
 #include "news.h"
-#include "imap.h"
 #include "hooks.h"
-
-typedef struct _FlagInfo       FlagInfo;
-
-struct _FlagInfo
-{
-       guint    msgnum;
-       MsgFlags flags;
-};
-
-static GHashTable *procmsg_read_mark_file      (const gchar    *folder);
-void   procmsg_msginfo_write_flags             (MsgInfo        *msginfo);
-static void procmsg_update_unread_children (MsgInfo *info, gboolean newly_marked);
+#include "msgcache.h"
 
 GHashTable *procmsg_msg_hash_table_create(GSList *mlist)
 {
@@ -100,241 +91,6 @@ GHashTable *procmsg_to_folder_hash_table_create(GSList *mlist)
        return msg_table;
 }
 
-static gint procmsg_read_cache_data_str(FILE *fp, gchar **str)
-{
-       gchar buf[BUFFSIZE];
-       gint ret = 0;
-       size_t len;
-
-       if (fread(&len, sizeof(len), 1, fp) == 1) {
-               if (len < 0)
-                       ret = -1;
-               else {
-                       gchar *tmp = NULL;
-
-                       while (len > 0) {
-                               size_t size = MIN(len, BUFFSIZE - 1);
-
-                               if (fread(buf, size, 1, fp) != 1) {
-                                       ret = -1;
-                                       if (tmp) g_free(tmp);
-                                       *str = NULL;
-                                       break;
-                               }
-
-                               buf[size] = '\0';
-                               if (tmp) {
-                                       *str = g_strconcat(tmp, buf, NULL);
-                                       g_free(tmp);
-                                       tmp = *str;
-                               } else
-                                       tmp = *str = g_strdup(buf);
-
-                               len -= size;
-                       }
-               }
-       } else
-               ret = -1;
-
-       if (ret < 0)
-               g_warning("Cache data is corrupted\n");
-
-       return ret;
-}
-
-#define READ_CACHE_DATA(data, fp) \
-{ \
-       if (procmsg_read_cache_data_str(fp, &data) < 0) { \
-               procmsg_msginfo_free(msginfo); \
-               break; \
-       } \
-}
-
-#define READ_CACHE_DATA_INT(n, fp) \
-{ \
-       if (fread(&n, sizeof(n), 1, fp) != 1) { \
-               g_warning("Cache data is corrupted\n"); \
-               procmsg_msginfo_free(msginfo); \
-               break; \
-       } \
-}
-
-GSList *procmsg_read_cache(FolderItem *item, gboolean scan_file)
-{
-       GSList *mlist = NULL;
-       GSList *last = NULL;
-       gchar *cache_file;
-       FILE *fp;
-       MsgInfo *msginfo;
-       MsgFlags default_flags;
-       gchar file_buf[BUFFSIZE];
-       gint ver;
-       guint num;
-       FolderType type;
-
-       g_return_val_if_fail(item != NULL, NULL);
-       g_return_val_if_fail(item->folder != NULL, NULL);
-       type = item->folder->type;
-
-       default_flags.perm_flags = MSG_NEW|MSG_UNREAD;
-       default_flags.tmp_flags = MSG_CACHED;
-       if (type == F_MH || type == F_IMAP) {
-               if (item->stype == F_QUEUE) {
-                       MSG_SET_TMP_FLAGS(default_flags, MSG_QUEUED);
-               } else if (item->stype == F_DRAFT) {
-                       MSG_SET_TMP_FLAGS(default_flags, MSG_DRAFT);
-               }
-       }
-       if (type == F_IMAP) {
-               MSG_SET_TMP_FLAGS(default_flags, MSG_IMAP);
-       } else if (type == F_NEWS) {
-               MSG_SET_TMP_FLAGS(default_flags, MSG_NEWS);
-       }
-
-       if (type == F_MH) {
-               gchar *path;
-
-               path = folder_item_get_path(item);
-               if (change_dir(path) < 0) {
-                       g_free(path);
-                       return NULL;
-               }
-               g_free(path);
-       }
-       cache_file = folder_item_get_cache_file(item);
-       if ((fp = fopen(cache_file, "rb")) == NULL) {
-               debug_print("\tNo cache file\n");
-               g_free(cache_file);
-               return NULL;
-       }
-       setvbuf(fp, file_buf, _IOFBF, sizeof(file_buf));
-       g_free(cache_file);
-
-       debug_print("\tReading summary cache...\n");
-
-       /* compare cache version */
-       if (fread(&ver, sizeof(ver), 1, fp) != 1 ||
-           CACHE_VERSION != ver) {
-               debug_print("Cache version is different. Discarding it.\n");
-               fclose(fp);
-               return NULL;
-       }
-
-       while (fread(&num, sizeof(num), 1, fp) == 1) {
-               msginfo = procmsg_msginfo_new();
-               msginfo->msgnum = num;
-               READ_CACHE_DATA_INT(msginfo->size, fp);
-               READ_CACHE_DATA_INT(msginfo->mtime, fp);
-               READ_CACHE_DATA_INT(msginfo->date_t, fp);
-               READ_CACHE_DATA_INT(msginfo->flags.tmp_flags, fp);
-
-               READ_CACHE_DATA(msginfo->fromname, fp);
-
-               READ_CACHE_DATA(msginfo->date, fp);
-               READ_CACHE_DATA(msginfo->from, fp);
-               READ_CACHE_DATA(msginfo->to, fp);
-               READ_CACHE_DATA(msginfo->cc, fp);
-               READ_CACHE_DATA(msginfo->newsgroups, fp);
-               READ_CACHE_DATA(msginfo->subject, fp);
-               READ_CACHE_DATA(msginfo->msgid, fp);
-               READ_CACHE_DATA(msginfo->inreplyto, fp);
-               READ_CACHE_DATA(msginfo->references, fp);
-                READ_CACHE_DATA(msginfo->xref, fp);
-
-
-               MSG_SET_PERM_FLAGS(msginfo->flags, default_flags.perm_flags);
-               MSG_SET_TMP_FLAGS(msginfo->flags, default_flags.tmp_flags);
-
-               /* if the message file doesn't exist or is changed,
-                  don't add the data */
-               if (type == F_MH && scan_file &&
-                   folder_item_is_msg_changed(item, msginfo))
-                       procmsg_msginfo_free(msginfo);
-               else {
-                       msginfo->folder = item;
-
-                       if (!mlist)
-                               last = mlist = g_slist_append(NULL, msginfo);
-                       else {
-                               last = g_slist_append(last, msginfo);
-                               last = last->next;
-                       }
-               }
-       }
-
-       fclose(fp);
-       debug_print("done.\n");
-
-       return mlist;
-}
-
-#undef READ_CACHE_DATA
-#undef READ_CACHE_DATA_INT
-
-void procmsg_set_flags(GSList *mlist, FolderItem *item)
-{
-       GSList *cur, *tmp;
-       gint newmsg = 0;
-       gint lastnum = 0;
-       gchar *markdir;
-       MsgInfo *msginfo;
-       GHashTable *mark_table;
-       MsgFlags *flags;
-
-       if (!mlist) return;
-       g_return_if_fail(item != NULL);
-       g_return_if_fail(item->folder != NULL);
-
-       debug_print("\tMarking the messages...\n");
-
-       markdir = folder_item_get_path(item);
-       if (!is_dir_exist(markdir))
-               make_dir_hier(markdir);
-
-       mark_table = procmsg_read_mark_file(markdir);
-       g_free(markdir);
-
-       if (!mark_table) return;
-
-       for (cur = mlist; cur != NULL; cur = cur->next) {
-               msginfo = (MsgInfo *)cur->data;
-
-               if (lastnum < msginfo->msgnum)
-                       lastnum = msginfo->msgnum;
-
-               flags = g_hash_table_lookup
-                       (mark_table, GUINT_TO_POINTER(msginfo->msgnum));
-
-               if (flags != NULL) {
-                       /* add the permanent flags only */
-                       msginfo->flags.perm_flags = flags->perm_flags;
-                       if (item->folder->type == F_IMAP) {
-                               MSG_SET_TMP_FLAGS(msginfo->flags, MSG_IMAP);
-                       } else if (item->folder->type == F_NEWS) {
-                               MSG_SET_TMP_FLAGS(msginfo->flags, MSG_NEWS);
-                       }
-               } else {
-                       /* not found (new message) */
-                       if (newmsg == 0) {
-                               for (tmp = mlist; tmp != cur; tmp = tmp->next)
-                                       MSG_UNSET_PERM_FLAGS
-                                               (((MsgInfo *)tmp->data)->flags,
-                                                MSG_NEW);
-                       }
-                       newmsg++;
-               }
-       }
-
-       item->last_num = lastnum;
-
-       debug_print("done.\n");
-       if (newmsg)
-               debug_print("\t%d new message(s)\n", newmsg);
-
-       hash_free_value_mem(mark_table);
-       g_hash_table_destroy(mark_table);
-}
-
 gint procmsg_get_last_num_in_msg_list(GSList *mlist)
 {
        GSList *cur;
@@ -362,180 +118,20 @@ void procmsg_msg_list_free(GSList *mlist)
        g_slist_free(mlist);
 }
 
-void procmsg_write_cache(MsgInfo *msginfo, FILE *fp)
-{
-       MsgTmpFlags flags = msginfo->flags.tmp_flags & MSG_CACHED_FLAG_MASK;
-
-       WRITE_CACHE_DATA_INT(msginfo->msgnum, fp);
-       WRITE_CACHE_DATA_INT(msginfo->size, fp);
-       WRITE_CACHE_DATA_INT(msginfo->mtime, fp);
-       WRITE_CACHE_DATA_INT(msginfo->date_t, fp);
-       WRITE_CACHE_DATA_INT(flags, fp);
-
-       WRITE_CACHE_DATA(msginfo->fromname, fp);
-
-       WRITE_CACHE_DATA(msginfo->date, fp);
-       WRITE_CACHE_DATA(msginfo->from, fp);
-       WRITE_CACHE_DATA(msginfo->to, fp);
-       WRITE_CACHE_DATA(msginfo->cc, fp);
-       WRITE_CACHE_DATA(msginfo->newsgroups, fp);
-       WRITE_CACHE_DATA(msginfo->subject, fp);
-       WRITE_CACHE_DATA(msginfo->msgid, fp);
-       WRITE_CACHE_DATA(msginfo->inreplyto, fp);
-       WRITE_CACHE_DATA(msginfo->references, fp);
-       WRITE_CACHE_DATA(msginfo->xref, fp);
-
-}
-
-void procmsg_write_flags(MsgInfo *msginfo, FILE *fp)
-{
-       MsgPermFlags flags = msginfo->flags.perm_flags;
-
-       WRITE_CACHE_DATA_INT(msginfo->msgnum, fp);
-       WRITE_CACHE_DATA_INT(flags, fp);
-}
-
-void procmsg_flush_mark_queue(FolderItem *item, FILE *fp)
-{
-       MsgInfo *flaginfo;
-
-       g_return_if_fail(item != NULL);
-       g_return_if_fail(fp != NULL);
-
-       while (item->mark_queue != NULL) {
-               flaginfo = (MsgInfo *)item->mark_queue->data;
-               procmsg_write_flags(flaginfo, fp);
-               procmsg_msginfo_free(flaginfo);
-               item->mark_queue = g_slist_remove(item->mark_queue, flaginfo);
-       }
-}
-
-void procmsg_add_flags(FolderItem *item, gint num, MsgFlags flags)
-{
-       FILE *fp;
-       gchar *path;
-       MsgInfo msginfo;
-
-       g_return_if_fail(item != NULL);
-
-       if (item->opened) {
-               MsgInfo *queue_msginfo;
-
-               queue_msginfo = g_new0(MsgInfo, 1);
-               queue_msginfo->msgnum = num;
-               queue_msginfo->flags = flags;
-               item->mark_queue = g_slist_append
-                       (item->mark_queue, queue_msginfo);
-               return;
-       }
-
-       path = folder_item_get_path(item);
-       g_return_if_fail(path != NULL);
-
-       if ((fp = procmsg_open_mark_file(path, TRUE)) == NULL) {
-               g_warning("can't open mark file\n");
-               g_free(path);
-               return;
-       }
-       g_free(path);
-
-       msginfo.msgnum = num;
-       msginfo.flags = flags;
-
-       procmsg_write_flags(&msginfo, fp);
-       fclose(fp);
-}
-
 struct MarkSum {
-       gint *new;
-       gint *unread;
-       gint *total;
+       gint *new_msgs;
+       gint *unread_msgs;
+       gint *total_msgs;
        gint *min;
        gint *max;
        gint first;
 };
 
-static GHashTable *procmsg_read_mark_file(const gchar *folder)
-{
-       FILE *fp;
-       GHashTable *mark_table = NULL;
-       gint num;
-       MsgFlags *flags;
-       MsgPermFlags perm_flags;
-
-       if ((fp = procmsg_open_mark_file(folder, FALSE)) == NULL)
-               return NULL;
-
-       mark_table = g_hash_table_new(NULL, g_direct_equal);
-
-       while (fread(&num, sizeof(num), 1, fp) == 1) {
-               if (fread(&perm_flags, sizeof(perm_flags), 1, fp) != 1) break;
-
-               flags = g_hash_table_lookup(mark_table, GUINT_TO_POINTER(num));
-               if (flags != NULL)
-                       g_free(flags);
-
-               flags = g_new0(MsgFlags, 1);
-               flags->perm_flags = perm_flags;
-    
-               if (!MSG_IS_REALLY_DELETED(*flags)) {
-                       g_hash_table_insert(mark_table, GUINT_TO_POINTER(num), flags);
-               } else {
-                       g_hash_table_remove(mark_table, GUINT_TO_POINTER(num));
-               }
-       }
-
-       fclose(fp);
-       return mark_table;
-}
-
-FILE *procmsg_open_mark_file(const gchar *folder, gboolean append)
-{
-       gchar *markfile;
-       FILE *fp;
-       gint ver;
-
-       markfile = g_strconcat(folder, G_DIR_SEPARATOR_S, MARK_FILE, NULL);
-
-       if ((fp = fopen(markfile, "rb")) == NULL)
-               debug_print("Mark file not found.\n");
-       else if (fread(&ver, sizeof(ver), 1, fp) != 1 || MARK_VERSION != ver) {
-               debug_print("Mark version is different (%d != %d). "
-                             "Discarding it.\n", ver, MARK_VERSION);
-               fclose(fp);
-               fp = NULL;
-       }
-
-       /* read mode */
-       if (append == FALSE) {
-               g_free(markfile);
-               return fp;
-       }
-
-       if (fp) {
-               /* reopen with append mode */
-               fclose(fp);
-               if ((fp = fopen(markfile, "ab")) == NULL)
-                       g_warning("Can't open mark file with append mode.\n");
-       } else {
-               /* open with overwrite mode if mark file doesn't exist or
-                  version is different */
-               if ((fp = fopen(markfile, "wb")) == NULL)
-                       g_warning("Can't open mark file with write mode.\n");
-               else {
-                       ver = MARK_VERSION;
-                       WRITE_CACHE_DATA_INT(ver, fp);
-               }
-       }
-
-       g_free(markfile);
-       return fp;
-}
-
 static gboolean procmsg_ignore_node(GNode *node, gpointer data)
 {
        MsgInfo *msginfo = (MsgInfo *)node->data;
        
+       procmsg_msginfo_unset_flags(msginfo, MSG_NEW | MSG_UNREAD, 0);
        procmsg_msginfo_set_flags(msginfo, MSG_IGNORE_THREAD, 0);
 
        return FALSE;
@@ -544,7 +140,7 @@ static gboolean procmsg_ignore_node(GNode *node, gpointer data)
 /* return the reversed thread tree */
 GNode *procmsg_get_thread_tree(GSList *mlist)
 {
-       GNode *root, *parent, *node, *next;
+       GNode *root, *parent, *node, *next, *last;
        GHashTable *msgid_table;
        GHashTable *subject_table;
        MsgInfo *msginfo;
@@ -566,6 +162,7 @@ GNode *procmsg_get_thread_tree(GSList *mlist)
                                parent = root;
                        } else {
                                if (MSG_IS_IGNORE_THREAD(((MsgInfo *)parent->data)->flags) && !MSG_IS_IGNORE_THREAD(msginfo->flags)) {
+                                       procmsg_msginfo_unset_flags(msginfo, MSG_NEW | MSG_UNREAD, 0);
                                        procmsg_msginfo_set_flags(msginfo, MSG_IGNORE_THREAD, 0);
                                }
                        }
@@ -577,20 +174,23 @@ GNode *procmsg_get_thread_tree(GSList *mlist)
                    g_hash_table_lookup(msgid_table, msgid) == NULL)
                        g_hash_table_insert(msgid_table, (gchar *)msgid, node);
 
-               subject = msginfo->subject;
-               found_subject = subject_table_lookup(subject_table,
-                                                    (gchar *) subject);
-               if (found_subject == NULL)
-                       subject_table_insert(subject_table, (gchar *) subject,
-                                            node);
-               else {
-                       /* replace if msg in table is older than current one 
-                        * can add here more stuff.  */
-                       if ( ((MsgInfo*)(found_subject->data))->date_t >
-                            ((MsgInfo*)(node->data))->date_t )  {
-                               subject_table_remove(subject_table, (gchar *) subject);
-                               subject_table_insert(subject_table, (gchar *) subject, node);
-                       }       
+               if (prefs_common.thread_by_subject) {
+                       subject  = msginfo->subject;
+                       subject += subject_get_reply_prefix_length(subject);
+                       found_subject = subject_table_lookup_clean(subject_table,
+                                                                  (gchar *) subject);
+                       if (found_subject == NULL)
+                               subject_table_insert_clean(subject_table, (gchar *) subject,
+                                                          node);
+                       else {
+                               /* replace if msg in table is older than current one 
+                                * can add here more stuff. */
+                                if ( ((MsgInfo*)(found_subject->data))->date_t > 
+                                     ((MsgInfo*)(node->data))->date_t )  {
+                                       subject_table_remove_clean(subject_table, (gchar *) subject);
+                                       subject_table_insert_clean(subject_table, (gchar *) subject, node);
+                               } 
+                       }
                }
        }
 
@@ -601,7 +201,10 @@ GNode *procmsg_get_thread_tree(GSList *mlist)
                parent = NULL;
                if (msginfo->inreplyto) 
                        parent = g_hash_table_lookup(msgid_table, msginfo->inreplyto);
-               if (parent && parent != node) {
+               /* node should not be the parent, and node should not be an ancestor
+                * of parent (circular reference) */
+               if (parent && parent != node 
+               && !g_node_is_ancestor(node, parent)) {
                        g_node_unlink(node);
                        g_node_insert_before
                                (parent, parent->children, node);
@@ -610,6 +213,7 @@ GNode *procmsg_get_thread_tree(GSList *mlist)
                                g_node_traverse(node, G_PRE_ORDER, G_TRAVERSE_ALL, -1, procmsg_ignore_node, NULL);
                        }
                }
+               last = node; /* CLAWS: need to have the last one for subject threading */
                node = next;
        }
 
@@ -617,13 +221,13 @@ GNode *procmsg_get_thread_tree(GSList *mlist)
         * threaded by subject line. we need to handle this in a special way to prevent
         * circular reference from a node that has already been threaded by IN-REPLY-TO
         * but is also in the subject line hash table */
-       for (node = root->children; node != NULL; ) {
-               next = node->next;
-               msginfo = (MsgInfo *) node->data;
-               parent = NULL;
-               if (subject_is_reply(msginfo->subject)) {
-                       parent = subject_table_lookup(subject_table,
-                                                     msginfo->subject);
+       if (prefs_common.thread_by_subject) {
+               for (node = last; node && node != NULL;) {
+                       next = node->prev;
+                       msginfo = (MsgInfo *) node->data;
+                       subject = msginfo->subject + subject_get_reply_prefix_length(msginfo->subject);
+                       parent = subject_table_lookup_clean(subject_table, (gchar *) subject);
+                       
                        /* the node may already be threaded by IN-REPLY-TO,
                           so go up in the tree to find the parent node */
                        if (parent != NULL) {
@@ -631,6 +235,15 @@ GNode *procmsg_get_thread_tree(GSList *mlist)
                                        parent = NULL;
                                if (parent == node)
                                        parent = NULL;
+                               /* Make new thread parent if too old compared to previous one; probably
+                                * breaks ignoring threads for subject threading. This still isn't
+                                * accurate because the tree isn't sorted by date. */   
+                               if (parent && abs(difftime(msginfo->date_t, ((MsgInfo *)parent->data)->date_t)) >
+                                               prefs_common.thread_by_subject_max_age * 3600 * 24) {
+                                       subject_table_remove_clean(subject_table, (gchar *) subject);
+                                       subject_table_insert_clean(subject_table, (gchar *) subject, node);
+                                       parent = NULL;
+                               }
                        }
 
                        if (parent) {
@@ -641,10 +254,10 @@ GNode *procmsg_get_thread_tree(GSList *mlist)
                                        g_node_traverse(node, G_PRE_ORDER, G_TRAVERSE_ALL, -1, procmsg_ignore_node, NULL);
                                }
                        }
-               }                                       
-               node = next;
-       }               
-
+                       node = next;
+               }       
+       }
+       
        g_hash_table_destroy(subject_table);
        g_hash_table_destroy(msgid_table);
 
@@ -659,6 +272,8 @@ void procmsg_move_messages(GSList *mlist)
 
        if (!mlist) return;
 
+       folder_item_update_freeze();
+
        for (cur = mlist; cur != NULL; cur = cur->next) {
                msginfo = (MsgInfo *)cur->data;
                if (!dest) {
@@ -673,12 +288,15 @@ void procmsg_move_messages(GSList *mlist)
                        dest = msginfo->to_folder;
                        movelist = g_slist_append(movelist, msginfo);
                }
+               procmsg_msginfo_set_to_folder(msginfo, NULL);
        }
 
        if (movelist) {
                folder_item_move_msgs_with_dest(dest, movelist);
                g_slist_free(movelist);
        }
+
+       folder_item_update_thaw();
 }
 
 void procmsg_copy_messages(GSList *mlist)
@@ -689,14 +307,7 @@ void procmsg_copy_messages(GSList *mlist)
 
        if (!mlist) return;
 
-       /* 
-       
-       Horrible: Scanning 2 times for every copy!
-
-       hash = procmsg_to_folder_hash_table_create(mlist);
-       folder_item_scan_foreach(hash);
-       g_hash_table_destroy(hash);
-       */
+       folder_item_update_freeze();
 
        for (cur = mlist; cur != NULL; cur = cur->next) {
                msginfo = (MsgInfo *)cur->data;
@@ -712,12 +323,15 @@ void procmsg_copy_messages(GSList *mlist)
                        dest = msginfo->to_folder;
                        copylist = g_slist_append(copylist, msginfo);
                }
+               procmsg_msginfo_set_to_folder(msginfo, NULL);
        }
 
        if (copylist) {
                folder_item_copy_msgs_with_dest(dest, copylist);
                g_slist_free(copylist);
        }
+
+       folder_item_update_thaw();
 }
 
 gchar *procmsg_get_message_file_path(MsgInfo *msginfo)
@@ -790,6 +404,7 @@ FILE *procmsg_open_message_decrypted(MsgInfo *msginfo, MimeInfo **mimeinfo)
 {
        FILE *fp;
        MimeInfo *mimeinfo_;
+       glong fpos;
 
        g_return_val_if_fail(msginfo != NULL, NULL);
 
@@ -811,6 +426,7 @@ FILE *procmsg_open_message_decrypted(MsgInfo *msginfo, MimeInfo **mimeinfo)
        if (MSG_IS_ENCRYPTED(msginfo->flags) &&
            !msginfo->plaintext_file &&
            !msginfo->decryption_failed) {
+               fpos = ftell(fp);
                rfc2015_decrypt_message(msginfo, mimeinfo_, fp);
                if (msginfo->plaintext_file &&
                    !msginfo->decryption_failed) {
@@ -823,6 +439,9 @@ FILE *procmsg_open_message_decrypted(MsgInfo *msginfo, MimeInfo **mimeinfo)
                                fclose(fp);
                                return NULL;
                        }
+               } else {
+                       if (fseek(fp, fpos, SEEK_SET) < 0)
+                               perror("fseek");
                }
        }
 
@@ -846,6 +465,112 @@ gboolean procmsg_msg_exist(MsgInfo *msginfo)
        return ret;
 }
 
+void procmsg_get_filter_keyword(MsgInfo *msginfo, gchar **header, gchar **key,
+                               PrefsFilterType type)
+{
+       static HeaderEntry hentry[] = {{"X-BeenThere:",    NULL, TRUE},
+                                      {"X-ML-Name:",      NULL, TRUE},
+                                      {"X-List:",         NULL, TRUE},
+                                      {"X-Mailing-list:", NULL, TRUE},
+                                      {"List-Id:",        NULL, TRUE},
+                                      {"X-Sequence:",     NULL, TRUE},
+                                      {NULL,              NULL, FALSE}};
+       enum
+       {
+               H_X_BEENTHERE    = 0,
+               H_X_ML_NAME      = 1,
+               H_X_LIST         = 2,
+               H_X_MAILING_LIST = 3,
+               H_LIST_ID        = 4,
+               H_X_SEQUENCE     = 5
+       };
+
+       FILE *fp;
+
+       g_return_if_fail(msginfo != NULL);
+       g_return_if_fail(header != NULL);
+       g_return_if_fail(key != NULL);
+
+       *header = NULL;
+       *key = NULL;
+
+       switch (type) {
+       case FILTER_BY_NONE:
+               return;
+       case FILTER_BY_AUTO:
+               if ((fp = procmsg_open_message(msginfo)) == NULL)
+                       return;
+               procheader_get_header_fields(fp, hentry);
+               fclose(fp);
+
+#define SET_FILTER_KEY(hstr, idx)      \
+{                                      \
+       *header = g_strdup(hstr);       \
+       *key = hentry[idx].body;        \
+       hentry[idx].body = NULL;        \
+}
+
+               if (hentry[H_X_BEENTHERE].body != NULL) {
+                       SET_FILTER_KEY("header \"X-BeenThere\"", H_X_BEENTHERE);
+               } else if (hentry[H_X_ML_NAME].body != NULL) {
+                       SET_FILTER_KEY("header \"X-ML-Name\"", H_X_ML_NAME);
+               } else if (hentry[H_X_LIST].body != NULL) {
+                       SET_FILTER_KEY("header \"X-List\"", H_X_LIST);
+               } else if (hentry[H_X_MAILING_LIST].body != NULL) {
+                       SET_FILTER_KEY("header \"X-Mailing-List\"", H_X_MAILING_LIST);
+               } else if (hentry[H_LIST_ID].body != NULL) {
+                       SET_FILTER_KEY("header \"List-Id\"", H_LIST_ID);
+                       extract_list_id_str(*key);
+               } else if (hentry[H_X_SEQUENCE].body != NULL) {
+                       gchar *p;
+
+                       SET_FILTER_KEY("X-Sequence", H_X_SEQUENCE);
+                       p = *key;
+                       while (*p != '\0') {
+                               while (*p != '\0' && !isspace(*p)) p++;
+                               while (isspace(*p)) p++;
+                               if (isdigit(*p)) {
+                                       *p = '\0';
+                                       break;
+                               }
+                       }
+                       g_strstrip(*key);
+               } else if (msginfo->subject) {
+                       *header = g_strdup("subject");
+                       *key = g_strdup(msginfo->subject);
+               }
+
+#undef SET_FILTER_KEY
+
+               g_free(hentry[H_X_BEENTHERE].body);
+               hentry[H_X_BEENTHERE].body = NULL;
+               g_free(hentry[H_X_ML_NAME].body);
+               hentry[H_X_ML_NAME].body = NULL;
+               g_free(hentry[H_X_LIST].body);
+               hentry[H_X_LIST].body = NULL;
+               g_free(hentry[H_X_MAILING_LIST].body);
+               hentry[H_X_MAILING_LIST].body = NULL;
+               g_free(hentry[H_LIST_ID].body);
+               hentry[H_LIST_ID].body = NULL;
+
+               break;
+       case FILTER_BY_FROM:
+               *header = g_strdup("from");
+               *key = g_strdup(msginfo->from);
+               break;
+       case FILTER_BY_TO:
+               *header = g_strdup("to");
+               *key = g_strdup(msginfo->to);
+               break;
+       case FILTER_BY_SUBJECT:
+               *header = g_strdup("subject");
+               *key = g_strdup(msginfo->subject);
+               break;
+       default:
+               break;
+       }
+}
+
 void procmsg_empty_trash(void)
 {
        FolderItem *trash;
@@ -853,14 +578,23 @@ void procmsg_empty_trash(void)
 
        for (cur = folder_get_list(); cur != NULL; cur = cur->next) {
                trash = FOLDER(cur->data)->trash;
-               if (trash && trash->total > 0)
+               if (trash && trash->total_msgs > 0)
                        folder_item_remove_all_msg(trash);
        }
 }
 
+/*!
+ *\brief       Send messages in queue
+ *
+ *\param       queue Queue folder to process
+ *\param       save_msgs Unused
+ *
+ *\return      Number of messages sent, negative if an error occurred
+ *             positive if no error occurred
+ */
 gint procmsg_send_queue(FolderItem *queue, gboolean save_msgs)
 {
-       gint ret = 0;
+       gint ret = 1, count = 0;
        GSList *list, *elem;
 
        if (!queue)
@@ -870,39 +604,42 @@ gint procmsg_send_queue(FolderItem *queue, gboolean save_msgs)
        folder_item_scan(queue);
        list = folder_item_get_msg_list(queue);
 
-
        for (elem = list; elem != NULL; elem = elem->next) {
                gchar *file;
                MsgInfo *msginfo;
                
                msginfo = (MsgInfo *)(elem->data);
-
-               file = folder_item_fetch_msg(queue, msginfo->msgnum);
-               if (file) {
-                       if (procmsg_send_message_queue(file) < 0) {
-                               g_warning("Sending queued message %d failed.\n", msginfo->msgnum);
-                               ret = -1;
-                       } else {
-                       /* CLAWS: 
-                        * We save in procmsg_send_message_queue because
-                        * we need the destination folder from the queue
-                        * header
-                                               
-                               if (save_msgs)
-                                       procmsg_save_to_outbox
-                                               (queue->folder->outbox,
-                                                file, TRUE);
-*/
-                               folder_item_remove_msg(queue, msginfo->msgnum);
+               if (!MSG_IS_LOCKED(msginfo->flags)) {
+                       file = folder_item_fetch_msg(queue, msginfo->msgnum);
+                       if (file) {
+                               if (procmsg_send_message_queue(file) < 0) {
+                                       g_warning("Sending queued message %d failed.\n", 
+                                                 msginfo->msgnum);
+                                       ret = -1;
+                               } else {
+                                       /* CLAWS: 
+                                        * We save in procmsg_send_message_queue because
+                                        * we need the destination folder from the queue
+                                        * header
+                                                       
+                                       if (save_msgs)
+                                               procmsg_save_to_outbox
+                                                       (queue->folder->outbox,
+                                                        file, TRUE);
+                                        */
+                                       count++; 
+                                       folder_item_remove_msg(queue, msginfo->msgnum);
+                               }
+                               g_free(file);
                        }
-                       g_free(file);
                }
+               /* FIXME: supposedly if only one message is locked, and queue
+                * is being flushed, the following free says something like 
+                * "freeing msg ## in folder (nil)". */
                procmsg_msginfo_free(msginfo);
        }
 
-       folder_update_item(queue, FALSE);
-
-       return ret;
+       return ret * count;
 }
 
 gint procmsg_remove_special_headers(const gchar *in, const gchar *out)
@@ -969,6 +706,7 @@ gint procmsg_save_to_outbox(FolderItem *outbox, const gchar *file,
            procmsg_msginfo_unset_flags(msginfo, ~0, 0);
            procmsg_msginfo_free(msginfo);
        }
+       folder_item_update(outbox, TRUE);
 
        return 0;
 }
@@ -1038,7 +776,7 @@ MsgInfo *procmsg_msginfo_new_ref(MsgInfo *msginfo)
        return msginfo;
 }
 
-MsgInfo *procmsg_msginfo_new()
+MsgInfo *procmsg_msginfo_new(void)
 {
        MsgInfo *newmsginfo;
 
@@ -1115,11 +853,11 @@ MsgInfo *procmsg_msginfo_get_full_info(MsgInfo *msginfo)
        full_msginfo->size = msginfo->size;
        full_msginfo->mtime = msginfo->mtime;
        full_msginfo->folder = msginfo->folder;
-       full_msginfo->to_folder = msginfo->to_folder;
 #if USE_GPGME
        full_msginfo->plaintext_file = g_strdup(msginfo->plaintext_file);
        full_msginfo->decryption_failed = msginfo->decryption_failed;
 #endif
+       procmsg_msginfo_set_to_folder(full_msginfo, msginfo->to_folder);
 
        return full_msginfo;
 }
@@ -1132,6 +870,13 @@ void procmsg_msginfo_free(MsgInfo *msginfo)
        if (msginfo->refcnt > 0)
                return;
 
+       debug_print("freeing msginfo %d in %s\n", msginfo->msgnum, msginfo->folder ? msginfo->folder->path : "(nil)");
+
+       if (msginfo->to_folder) {
+               msginfo->to_folder->op_count--;
+               folder_item_update(msginfo->to_folder, F_ITEM_UPDATE_MSGCNT);
+       }
+
        g_free(msginfo->fromspace);
        g_free(msginfo->references);
        g_free(msginfo->returnreceiptto);
@@ -1213,6 +958,7 @@ enum
        Q_NEWS_ACCOUNT_ID  = 5,
        Q_SAVE_COPY_FOLDER = 6,
        Q_REPLY_MESSAGE_ID = 7,
+       Q_FWD_MESSAGE_ID   = 8
 };
 
 gint procmsg_send_message_queue(const gchar *file)
@@ -1225,6 +971,7 @@ gint procmsg_send_message_queue(const gchar *file)
                                       {"NAID:", NULL, FALSE},
                                       {"SCF:",  NULL, FALSE},
                                       {"RMID:", NULL, FALSE},
+                                      {"FMID:", NULL, FALSE},
                                       {NULL,    NULL, FALSE}};
        FILE *fp;
        gint filepos;
@@ -1235,6 +982,7 @@ gint procmsg_send_message_queue(const gchar *file)
        GSList *newsgroup_list = NULL;
        gchar *savecopyfolder = NULL;
        gchar *replymessageid = NULL;
+       gchar *fwdmessageid = NULL;
        gchar buf[BUFFSIZE];
        gint hnum;
        PrefsAccount *mailac = NULL, *newsac = NULL;
@@ -1276,6 +1024,9 @@ gint procmsg_send_message_queue(const gchar *file)
                case Q_REPLY_MESSAGE_ID:
                        if (!replymessageid) replymessageid = g_strdup(p);
                        break;
+               case Q_FWD_MESSAGE_ID:
+                       if (!fwdmessageid) fwdmessageid = g_strdup(p);
+                       break;
                }
        }
        filepos = ftell(fp);
@@ -1316,18 +1067,6 @@ gint procmsg_send_message_queue(const gchar *file)
                                mailval = send_message_smtp(&tmp_ac, to_list, fp);
                        }
                }
-               if (mailval < 0) {
-                       if (!local)
-                               alertpanel_error(
-                                       _("Error occurred while sending the message to `%s'."),
-                                       mailac ? mailac->smtp_server : smtpserver);
-                       else
-                               alertpanel_error(
-                                       _("Error occurred while sending the message with command `%s'."),
-                                       (mailac && mailac->use_mail_command && 
-                                        mailac->mail_command && (*mailac->mail_command)) ? 
-                                               mailac->mail_command : prefs_common.extsend_cmd);
-               }
        }
 
        fseek(fp, filepos, SEEK_SET);
@@ -1395,17 +1134,25 @@ gint procmsg_send_message_queue(const gchar *file)
                procmsg_save_to_outbox(outbox, file, TRUE);
        }
 
-       if (replymessageid != NULL) {
+       if (replymessageid != NULL || fwdmessageid != NULL) {
                gchar **tokens;
                FolderItem *item;
                
-               tokens = g_strsplit(replymessageid, "\x7f", 0);
+               if (replymessageid != NULL)
+                       tokens = g_strsplit(replymessageid, "\x7f", 0);
+               else
+                       tokens = g_strsplit(fwdmessageid, "\x7f", 0);
                item = folder_find_item_from_identifier(tokens[0]);
                if (item != NULL) {
                        MsgInfo *msginfo;
                        
                        msginfo = folder_item_get_msginfo(item, atoi(tokens[1]));
-                       if ((msginfo != NULL) && (strcmp(msginfo->msgid, tokens[2]) != 0)) {
+                       
+                       /*!< note that if the message has no msgid (maybe it was invalid), 
+                       * we also refuse to do something with the reply to flag */
+                       if ((msginfo != NULL) && 
+                           (msginfo->msgid != NULL) &&
+                           (strcmp(msginfo->msgid, tokens[2]) != 0)) {
                                procmsg_msginfo_free(msginfo);
                                msginfo = NULL;
                        }
@@ -1415,9 +1162,14 @@ gint procmsg_send_message_queue(const gchar *file)
                        }
                        
                        if (msginfo != NULL) {
-                               procmsg_msginfo_unset_flags(msginfo, MSG_FORWARDED, 0);
-                               procmsg_msginfo_set_flags(msginfo, MSG_REPLIED, 0);
-
+                               if (replymessageid != NULL) {
+                                       procmsg_msginfo_unset_flags(msginfo, MSG_FORWARDED, 0);
+                                       procmsg_msginfo_set_flags(msginfo, MSG_REPLIED, 0);
+                               } 
+                               else {
+                                       procmsg_msginfo_unset_flags(msginfo, MSG_REPLIED, 0);
+                                       procmsg_msginfo_set_flags(msginfo, MSG_FORWARDED, 0);
+                               }
                                procmsg_msginfo_free(msginfo);
                        }
                }
@@ -1426,22 +1178,52 @@ gint procmsg_send_message_queue(const gchar *file)
 
        g_free(savecopyfolder);
        g_free(replymessageid);
+       g_free(fwdmessageid);
        
        return (newsval != 0 ? newsval : mailval);
 }
 
-#define CHANGE_FLAGS(msginfo) \
-{ \
-if (msginfo->folder->folder->change_flags != NULL) \
-msginfo->folder->folder->change_flags(msginfo->folder->folder, \
-                                     msginfo->folder, \
-                                     msginfo); \
+static void update_folder_msg_counts(FolderItem *item, MsgInfo *msginfo, MsgPermFlags old_flags)
+{
+       MsgPermFlags new_flags = msginfo->flags.perm_flags;
+
+       /* NEW flag */
+       if (!(old_flags & MSG_NEW) && (new_flags & MSG_NEW)) {
+               item->new_msgs++;
+       }
+
+       if ((old_flags & MSG_NEW) && !(new_flags & MSG_NEW)) {
+               item->new_msgs--;
+       }
+
+       /* UNREAD flag */
+       if (!(old_flags & MSG_UNREAD) && (new_flags & MSG_UNREAD)) {
+               item->unread_msgs++;
+               if (procmsg_msg_has_marked_parent(msginfo))
+                       item->unreadmarked_msgs++;
+       }
+
+       if ((old_flags & MSG_UNREAD) && !(new_flags & MSG_UNREAD)) {
+               item->unread_msgs--;
+               if (procmsg_msg_has_marked_parent(msginfo))
+                       item->unreadmarked_msgs--;
+       }
+       
+       /* MARK flag */
+       if (!(old_flags & MSG_MARKED) && (new_flags & MSG_MARKED)) {
+               procmsg_update_unread_children(msginfo, TRUE);
+       }
+
+       if ((old_flags & MSG_MARKED) && !(new_flags & MSG_MARKED)) {
+               procmsg_update_unread_children(msginfo, FALSE);
+       }
 }
 
 void procmsg_msginfo_set_flags(MsgInfo *msginfo, MsgPermFlags perm_flags, MsgTmpFlags tmp_flags)
 {
        FolderItem *item;
        MsgInfoUpdate msginfo_update;
+       MsgPermFlags perm_flags_new, perm_flags_old;
 
        g_return_if_fail(msginfo != NULL);
        item = msginfo->folder;
@@ -1449,167 +1231,92 @@ void procmsg_msginfo_set_flags(MsgInfo *msginfo, MsgPermFlags perm_flags, MsgTmp
        
        debug_print("Setting flags for message %d in folder %s\n", msginfo->msgnum, item->path);
 
-       /* if new flag is set */
-       if ((perm_flags & MSG_NEW) && !MSG_IS_NEW(msginfo->flags) &&
-          !MSG_IS_IGNORE_THREAD(msginfo->flags)) {
-               item->new++;
-               item->need_update = TRUE;
-       }
-
-       /* if unread flag is set */
-       if ((perm_flags & MSG_UNREAD) && !MSG_IS_UNREAD(msginfo->flags) &&
-          !MSG_IS_IGNORE_THREAD(msginfo->flags)) {
-               item->unread++;
-               item->need_update = TRUE;
-       }
-
-       if (!MSG_IS_UNREAD(msginfo->flags) &&(perm_flags & MSG_UNREAD)
-       && procmsg_msg_has_marked_parent(msginfo)) {
-               item->unreadmarked++;
-               item->need_update = TRUE;
-       }
-       
-       if (!MSG_IS_MARKED(msginfo->flags) && (perm_flags & MSG_MARKED)) {
-               procmsg_update_unread_children(msginfo, TRUE);
+       /* Perm Flags handling */
+       perm_flags_old = msginfo->flags.perm_flags;
+       perm_flags_new = msginfo->flags.perm_flags | perm_flags;
+       if ((perm_flags & MSG_IGNORE_THREAD) || (perm_flags_old & MSG_IGNORE_THREAD)) {
+               perm_flags_new &= ~(MSG_NEW | MSG_UNREAD);
        }
 
+       if (perm_flags_old != perm_flags_new) {
+               folder_item_change_msg_flags(msginfo->folder, msginfo, perm_flags_new);
 
-       /* if ignore thread flag is set */
-       if ((perm_flags & MSG_IGNORE_THREAD) && !MSG_IS_IGNORE_THREAD(msginfo->flags)) {
-               if (MSG_IS_NEW(msginfo->flags) || (perm_flags & MSG_NEW)) {
-                       item->new--;
-                       item->need_update = TRUE;
-               }
-               if (MSG_IS_UNREAD(msginfo->flags) || (perm_flags & MSG_UNREAD)) {
-                       item->unread--;
-                       item->need_update = TRUE;
-               }
-               if ((perm_flags & MSG_UNREAD) || (MSG_IS_UNREAD(msginfo->flags)
-               && procmsg_msg_has_marked_parent(msginfo))) {
-                       item->unreadmarked--;
-                       item->need_update = TRUE;
-               }
-               if ((perm_flags & MSG_MARKED) || (MSG_IS_MARKED(msginfo->flags)
-               && !MSG_IS_IGNORE_THREAD(msginfo->flags))) {
-                       procmsg_update_unread_children(msginfo, FALSE);
-               }
+               update_folder_msg_counts(item, msginfo, perm_flags_old);
 
+               msginfo_update.msginfo = msginfo;
+               hooks_invoke(MSGINFO_UPDATE_HOOKLIST, &msginfo_update);
+               folder_item_update(msginfo->folder, F_ITEM_UPDATE_MSGCNT);
        }
 
-       if (MSG_IS_IMAP(msginfo->flags))
-               imap_msg_set_perm_flags(msginfo, perm_flags);
-
-       msginfo->flags.perm_flags |= perm_flags;
+       /* Tmp flags hanlding */
        msginfo->flags.tmp_flags |= tmp_flags;
-
-       msginfo_update.msginfo = msginfo;
-       hooks_invoke(MSGINFO_UPDATE_HOOKLIST, &msginfo_update);
-
-       CHANGE_FLAGS(msginfo);
-       procmsg_msginfo_write_flags(msginfo);
 }
 
 void procmsg_msginfo_unset_flags(MsgInfo *msginfo, MsgPermFlags perm_flags, MsgTmpFlags tmp_flags)
 {
        FolderItem *item;
        MsgInfoUpdate msginfo_update;
+       MsgPermFlags perm_flags_new, perm_flags_old;
 
        g_return_if_fail(msginfo != NULL);
        item = msginfo->folder;
-       g_return_if_fail(item != NULL); 
+       g_return_if_fail(item != NULL);
        
        debug_print("Unsetting flags for message %d in folder %s\n", msginfo->msgnum, item->path);
 
-       /* if new flag is unset */
-       if ((perm_flags & MSG_NEW) && MSG_IS_NEW(msginfo->flags) &&
-          !MSG_IS_IGNORE_THREAD(msginfo->flags)) {
-               item->new--;
-               item->need_update = TRUE;
-       }
-
-       /* if unread flag is unset */
-       if ((perm_flags & MSG_UNREAD) && MSG_IS_UNREAD(msginfo->flags) &&
-          !MSG_IS_IGNORE_THREAD(msginfo->flags)) {
-               item->unread--;
-               item->need_update = TRUE;
-       }
+       /* Perm Flags handling */
+       perm_flags_old = msginfo->flags.perm_flags;
+       perm_flags_new = msginfo->flags.perm_flags & ~perm_flags;
        
-       if (MSG_IS_UNREAD(msginfo->flags) && (perm_flags & MSG_UNREAD)
-       && !MSG_IS_IGNORE_THREAD(msginfo->flags)
-       && procmsg_msg_has_marked_parent(msginfo)) {
-               item->unreadmarked--;
-               item->need_update = TRUE;
-       }
+       if (perm_flags_old != perm_flags_new) {
+               folder_item_change_msg_flags(msginfo->folder, msginfo, perm_flags_new);
 
-       if (MSG_IS_MARKED(msginfo->flags) && (perm_flags & MSG_MARKED)
-       && !MSG_IS_IGNORE_THREAD(msginfo->flags)) {
-               procmsg_update_unread_children(msginfo, FALSE);
-       }
-
-       /* if ignore thread flag is unset */
-       if ((perm_flags & MSG_IGNORE_THREAD) && MSG_IS_IGNORE_THREAD(msginfo->flags)) {
-               if (MSG_IS_NEW(msginfo->flags) && !(perm_flags & MSG_NEW)) {
-                       item->new++;
-                       item->need_update = TRUE;
-               }
-               if (MSG_IS_UNREAD(msginfo->flags) && !(perm_flags & MSG_UNREAD)) {
-                       item->unread++;
-                       item->need_update = TRUE;
-               }
-               if (MSG_IS_UNREAD(msginfo->flags) && !(perm_flags & MSG_UNREAD)
-               && procmsg_msg_has_marked_parent(msginfo)) {
-                       item->unreadmarked++;
-                       item->need_update = TRUE;
-               }
-               if (MSG_IS_MARKED(msginfo->flags) && !(perm_flags & MSG_MARKED)) {
-                       procmsg_update_unread_children(msginfo, TRUE);
-               }
+               update_folder_msg_counts(item, msginfo, perm_flags_old);
 
+               msginfo_update.msginfo = msginfo;
+               hooks_invoke(MSGINFO_UPDATE_HOOKLIST, &msginfo_update);
+               folder_item_update(msginfo->folder, F_ITEM_UPDATE_MSGCNT);
        }
 
-       if (MSG_IS_IMAP(msginfo->flags))
-               imap_msg_unset_perm_flags(msginfo, perm_flags);
-
-       msginfo->flags.perm_flags &= ~perm_flags;
+       /* Tmp flags hanlding */
        msginfo->flags.tmp_flags &= ~tmp_flags;
-
-       msginfo_update.msginfo = msginfo;
-       hooks_invoke(MSGINFO_UPDATE_HOOKLIST, &msginfo_update);
-
-       CHANGE_FLAGS(msginfo);
-       procmsg_msginfo_write_flags(msginfo);
-}
-
-void procmsg_msginfo_write_flags(MsgInfo *msginfo)
-{
-       gchar *destdir;
-       FILE *fp;
-
-       destdir = folder_item_get_path(msginfo->folder);
-       if (!is_dir_exist(destdir))
-               make_dir_hier(destdir);
-
-       if ((fp = procmsg_open_mark_file(destdir, TRUE))) {
-               procmsg_write_flags(msginfo, fp);
-               fclose(fp);
-       } else {
-               g_warning("Can't open mark file.\n");
-       }
-       
-       g_free(destdir);
 }
 
-gboolean procmsg_msg_has_marked_parent (MsgInfo *info)
+/*!
+ *\brief       check for flags (e.g. mark) in prior msgs of current thread
+ *
+ *\param       info Current message
+ *\param       perm_flags Flags to be checked
+ *\param       parentmsgs Hash of prior msgs to avoid loops
+ *
+ *\return      gboolean TRUE if perm_flags are found
+ */
+gboolean procmsg_msg_has_flagged_parent_real(MsgInfo *info,
+               MsgPermFlags perm_flags, GHashTable *parentmsgs)
 {
        MsgInfo *tmp;
+
        g_return_val_if_fail(info != NULL, FALSE);
+
        if (info != NULL && info->folder != NULL && info->inreplyto != NULL) {
-               tmp = folder_item_get_msginfo_by_msgid(info->folder, info->inreplyto);
-               if (tmp && MSG_IS_MARKED(tmp->flags)) {
+               tmp = folder_item_get_msginfo_by_msgid(info->folder,
+                               info->inreplyto);
+               if (tmp && (tmp->flags.perm_flags & perm_flags)) {
                        procmsg_msginfo_free(tmp);
                        return TRUE;
                } else if (tmp != NULL) {
-                       gboolean result = procmsg_msg_has_marked_parent(tmp);
+                       gboolean result;
+
+                       if (g_hash_table_lookup(parentmsgs, info)) {
+                               debug_print("loop detected: %s%c%d\n",
+                                       folder_item_get_path(info->folder),
+                                       G_DIR_SEPARATOR, info->msgnum);
+                               result = FALSE;
+                       } else {
+                               g_hash_table_insert(parentmsgs, info, "1");
+                               result = procmsg_msg_has_flagged_parent_real(
+                                   tmp, perm_flags, parentmsgs);
+                       }
                        procmsg_msginfo_free(tmp);
                        return result;
                } else {
@@ -1617,34 +1324,90 @@ gboolean procmsg_msg_has_marked_parent  (MsgInfo *info)
                }
        } else
                return FALSE;
-}      
+}
 
-GSList *procmsg_find_children (MsgInfo *info)
+/*!
+ *\brief       Callback for cleaning up hash of parentmsgs
+ */
+gboolean parentmsgs_hash_remove(gpointer key,
+                            gpointer value,
+                            gpointer user_data)
 {
-       GSList *children = NULL;
-       GSList *all, *cur;
-       
-       g_return_val_if_fail(info!=NULL, NULL);
+       return TRUE;
+}
+
+/*!
+ *\brief       Set up list of parentmsgs
+ *             See procmsg_msg_has_flagged_parent_real()
+ */
+gboolean procmsg_msg_has_flagged_parent(MsgInfo *info, MsgPermFlags perm_flags)
+{
+       gboolean result;
+       GHashTable *parentmsgs = g_hash_table_new(NULL, NULL); 
+
+       result = procmsg_msg_has_flagged_parent_real(info, perm_flags, parentmsgs);
+       g_hash_table_foreach_remove(parentmsgs, parentmsgs_hash_remove, NULL);
+       g_hash_table_destroy(parentmsgs);
+       return result;
+}
+
+/*!
+ *\brief       Check if msgs prior in thread are marked
+ *             See procmsg_msg_has_flagged_parent_real()
+ */
+gboolean procmsg_msg_has_marked_parent(MsgInfo *info)
+{
+       return procmsg_msg_has_flagged_parent(info, MSG_MARKED);
+}
+
+
+GSList *procmsg_find_children_func(MsgInfo *info, 
+                                  GSList *children, GSList *all)
+{
+       GSList *cur;
+
+       g_return_val_if_fail(info!=NULL, children);
        if (info->msgid == NULL)
-               return NULL;
-       all = folder_item_get_msg_list(info->folder);
+               return children;
+
        for (cur = all; cur != NULL; cur = g_slist_next(cur)) {
                MsgInfo *tmp = (MsgInfo *)cur->data;
                if (tmp->inreplyto && !strcmp(tmp->inreplyto, info->msgid)) {
-                       GSList *grand_children;
-                       children = g_slist_prepend(children, tmp);
-                       grand_children = procmsg_find_children(tmp);
-                       children = slist_concat_unique(children, grand_children);
-                       g_slist_free(grand_children);
+                       /* Check if message is already in the list */
+                       if ((children == NULL) || 
+                           (g_slist_index(children, tmp) == -1)) {
+                               children = g_slist_prepend(children,
+                                               procmsg_msginfo_new_ref(tmp));
+                               children = procmsg_find_children_func(tmp, 
+                                                       children, 
+                                                       all);
+                       }
                }
-               if (tmp && tmp != info)
-                       procmsg_msginfo_free(tmp);
        }
-       
        return children;
 }
 
-static void procmsg_update_unread_children (MsgInfo *info, gboolean newly_marked)
+GSList *procmsg_find_children (MsgInfo *info)
+{
+       GSList *children;
+       GSList *all, *cur;
+
+       g_return_val_if_fail(info!=NULL, NULL);
+       all = folder_item_get_msg_list(info->folder);
+       children = procmsg_find_children_func(info, NULL, all);
+       if (children != NULL) {
+               for (cur = all; cur != NULL; cur = g_slist_next(cur)) {
+                       /* this will not free the used pointers
+                          created with procmsg_msginfo_new_ref */
+                       procmsg_msginfo_free((MsgInfo *)cur->data);
+               }
+       }
+       g_slist_free(all);
+
+       return children;
+}
+
+void procmsg_update_unread_children(MsgInfo *info, gboolean newly_marked)
 {
        GSList *children = procmsg_find_children(info);
        GSList *cur;
@@ -1652,11 +1415,54 @@ static void procmsg_update_unread_children (MsgInfo *info, gboolean newly_marked
                MsgInfo *tmp = (MsgInfo *)cur->data;
                if(MSG_IS_UNREAD(tmp->flags) && !MSG_IS_IGNORE_THREAD(tmp->flags)) {
                        if(newly_marked) 
-                               info->folder->unreadmarked++;
+                               info->folder->unreadmarked_msgs++;
                        else
-                               info->folder->unreadmarked--;
-                       info->folder->need_update = TRUE;
+                               info->folder->unreadmarked_msgs--;
+                       folder_item_update(info->folder, F_ITEM_UPDATE_MSGCNT);
                }
                procmsg_msginfo_free(tmp);
        }
+       g_slist_free(children);
+}
+
+/**
+ * Set the destination folder for a copy or move operation
+ *
+ * \param msginfo The message which's destination folder is changed
+ * \param to_folder The destination folder for the operation
+ */
+void procmsg_msginfo_set_to_folder(MsgInfo *msginfo, FolderItem *to_folder)
+{
+       if(msginfo->to_folder != NULL) {
+               msginfo->to_folder->op_count--;
+               folder_item_update(msginfo->to_folder, F_ITEM_UPDATE_MSGCNT);
+       }
+       msginfo->to_folder = to_folder;
+       if(to_folder != NULL) {
+               to_folder->op_count++;
+               folder_item_update(msginfo->to_folder, F_ITEM_UPDATE_MSGCNT);
+       }
+}
+
+/**
+ * Apply filtering actions to the msginfo
+ *
+ * \param msginfo The MsgInfo describing the message that should be filtered
+ * \return TRUE if the message was moved and MsgInfo is now invalid,
+ *         FALSE otherwise
+ */
+gboolean procmsg_msginfo_filter(MsgInfo *msginfo)
+{
+       MailFilteringData mail_filtering_data;
+                       
+       mail_filtering_data.msginfo = msginfo;                  
+       if (hooks_invoke(MAIL_FILTERING_HOOKLIST, &mail_filtering_data))
+               return TRUE;
+
+       /* filter if enabled in prefs or move to inbox if not */
+       if((global_processing != NULL) &&
+          filter_message_by_msginfo(global_processing, msginfo))
+               return TRUE;
+
+       return FALSE;
 }