2004-11-16 [colin] 0.9.12cvs148
[claws.git] / src / procmsg.c
index c941a993be63be097a1c21e701b73778981ef396..25ecebd0fea17a26648ff572c8fd48661071c4de 100644 (file)
@@ -1,6 +1,6 @@
 /*
  * Sylpheed -- a GTK+ based, lightweight, and fast e-mail client
- * Copyright (C) 1999-2003 Hiroyuki Yamamoto
+ * Copyright (C) 1999-2004 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
@@ -41,6 +41,7 @@
 #include "news.h"
 #include "hooks.h"
 #include "msgcache.h"
+#include "partial_download.h"
 
 GHashTable *procmsg_msg_hash_table_create(GSList *mlist)
 {
@@ -217,13 +218,11 @@ static GNode *subject_relation_lookup(GRelation *relation, MsgInfo *msginfo)
 /* return the reversed thread tree */
 GNode *procmsg_get_thread_tree(GSList *mlist)
 {
-       GNode *root, *parent, *node, *next, *last;
-       GNode *prev; /* CLAWS */
+       GNode *root, *parent, *node, *next;
        GHashTable *msgid_table;
        GRelation *subject_relation;
        MsgInfo *msginfo;
        const gchar *msgid;
-       const gchar *subject;
 
        root = g_node_new(NULL);
        msgid_table = g_hash_table_new(g_str_hash, g_str_equal);
@@ -254,7 +253,6 @@ GNode *procmsg_get_thread_tree(GSList *mlist)
 
        /* complete the unfinished threads */
        for (node = root->children; node != NULL; ) {
-               prev = node->prev;      /* CLAWS: need the last node */
                parent = NULL;
                next = node->next;
                msginfo = (MsgInfo *)node->data;
@@ -269,22 +267,18 @@ GNode *procmsg_get_thread_tree(GSList *mlist)
                                        (parent, parent->children, node);
                        }                               
                }
-               last = (next == NULL) ? prev : node;
                node = next;
        }
 
        if (prefs_common.thread_by_subject) {
-               for (node = last; node && node != NULL;) {
-                       next = node->prev;
+               for (node = root->children; node && node != NULL;) {
+                       next = node->next;
                        msginfo = (MsgInfo *) node->data;
                        
-                       /* may not parentize if parent was delivered after childs */
-                       if (subject != msginfo->subject)
-                               parent = subject_relation_lookup(subject_relation, msginfo);
-                       else
-                               parent = NULL; 
+                       parent = subject_relation_lookup(subject_relation, msginfo);
                        
-                       /* the node may already be threaded by IN-REPLY-TO, so go up in the tree to 
+                       /* the node may already be threaded by IN-REPLY-TO, so go up 
+                        * in the tree to 
                           find the parent node */
                        if (parent != NULL) {
                                if (g_node_is_ancestor(node, parent))
@@ -401,7 +395,7 @@ gchar *procmsg_get_message_file(MsgInfo *msginfo)
 
        filename = folder_item_fetch_msg(msginfo->folder, msginfo->msgnum);
        if (!filename)
-               g_warning("can't fetch message %d\n", msginfo->msgnum);
+               debug_print("can't fetch message %d\n", msginfo->msgnum);
 
        return filename;
 }
@@ -463,7 +457,8 @@ FILE *procmsg_open_message(MsgInfo *msginfo)
        if (!is_file_exist(file)) {
                g_free(file);
                file = procmsg_get_message_file(msginfo);
-               g_return_val_if_fail(file != NULL, NULL);
+               if (!file)
+                       return NULL;
        }
 
        if ((fp = fopen(file, "rb")) == NULL) {
@@ -556,7 +551,7 @@ void procmsg_get_filter_keyword(MsgInfo *msginfo, gchar **header, gchar **key,
                        SET_FILTER_KEY("header \"List-Id\"", H_LIST_ID);
                        extract_list_id_str(*key);
                } else if (hentry[H_X_SEQUENCE].body != NULL) {
-                       gchar *p;
+                       guchar *p;
 
                        SET_FILTER_KEY("X-Sequence", H_X_SEQUENCE);
                        p = *key;
@@ -605,15 +600,31 @@ void procmsg_get_filter_keyword(MsgInfo *msginfo, gchar **header, gchar **key,
        }
 }
 
-void procmsg_empty_trash(void)
+void procmsg_empty_trash(FolderItem *trash)
+{
+       FILE *fp;
+
+       if (trash && trash->total_msgs > 0) {
+               GSList *mlist = folder_item_get_msg_list(trash);
+               GSList *cur;
+               for (cur = mlist ; cur != NULL ; cur = cur->next) {
+                       MsgInfo * msginfo = (MsgInfo *) cur->data;
+                       partial_mark_for_delete(msginfo);
+                       procmsg_msginfo_free(msginfo);
+               }
+
+               folder_item_remove_all_msg(trash);
+       }
+}
+
+void procmsg_empty_all_trash(void)
 {
        FolderItem *trash;
        GList *cur;
 
        for (cur = folder_get_list(); cur != NULL; cur = cur->next) {
                trash = FOLDER(cur->data)->trash;
-               if (trash && trash->total_msgs > 0)
-                       folder_item_remove_all_msg(trash);
+               procmsg_empty_trash(trash);
        }
 }
 
@@ -717,7 +728,7 @@ gint procmsg_save_to_outbox(FolderItem *outbox, const gchar *file,
                gchar tmp[MAXPATHLEN + 1];
 
                g_snprintf(tmp, sizeof(tmp), "%s%ctmpmsg.out.%08x",
-                          get_rc_dir(), G_DIR_SEPARATOR, (guint)random());
+                          get_rc_dir(), G_DIR_SEPARATOR, (guint) rand());
                
                if (procmsg_remove_special_headers(file, tmp) !=0)
                        return -1;
@@ -749,7 +760,6 @@ gint procmsg_save_to_outbox(FolderItem *outbox, const gchar *file,
                        procmsg_msginfo_free(msginfo);          /* refcnt-- */
                }       
        }
-       folder_item_update(outbox, TRUE);
 
        return 0;
 }
@@ -847,6 +857,7 @@ MsgInfo *procmsg_msginfo_copy(MsgInfo *msginfo)
        MEMBCOPY(size);
        MEMBCOPY(mtime);
        MEMBCOPY(date_t);
+
        MEMBCOPY(flags);
 
        MEMBDUP(fromname);
@@ -871,6 +882,7 @@ MsgInfo *procmsg_msginfo_copy(MsgInfo *msginfo)
 
        MEMBCOPY(score);
        MEMBCOPY(threadscore);
+       MEMBDUP(plaintext_file);
 
        return newmsginfo;
 }
@@ -902,6 +914,17 @@ MsgInfo *procmsg_msginfo_get_full_info(MsgInfo *msginfo)
        if (!msginfo->returnreceiptto)
                msginfo->returnreceiptto = g_strdup
                        (full_msginfo->returnreceiptto);
+       if (!msginfo->partial_recv && full_msginfo->partial_recv)
+               msginfo->partial_recv = g_strdup
+                       (full_msginfo->partial_recv);
+       msginfo->total_size = full_msginfo->total_size;
+       if (!msginfo->account_server && full_msginfo->account_server)
+               msginfo->account_server = g_strdup
+                       (full_msginfo->account_server);
+       if (!msginfo->account_login && full_msginfo->account_login)
+               msginfo->account_login = g_strdup
+                       (full_msginfo->account_login);
+       msginfo->planned_download = full_msginfo->planned_download;
        procmsg_msginfo_free(full_msginfo);
 
        return procmsg_msginfo_new_ref(msginfo);
@@ -915,8 +938,6 @@ 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);
@@ -940,6 +961,12 @@ void procmsg_msginfo_free(MsgInfo *msginfo)
        g_free(msginfo->inreplyto);
        g_free(msginfo->xref);
 
+       g_free(msginfo->partial_recv);
+       g_free(msginfo->account_server);
+       g_free(msginfo->account_login);
+       
+       g_free(msginfo->plaintext_file);
+
        g_free(msginfo);
 }
 
@@ -1003,7 +1030,10 @@ enum
        Q_NEWS_ACCOUNT_ID  = 5,
        Q_SAVE_COPY_FOLDER = 6,
        Q_REPLY_MESSAGE_ID = 7,
-       Q_FWD_MESSAGE_ID   = 8
+       Q_FWD_MESSAGE_ID   = 8,
+       Q_PRIVACY_SYSTEM   = 9,
+       Q_ENCRYPT          = 10,
+       Q_ENCRYPT_DATA     = 11,
 };
 
 gint procmsg_send_message_queue(const gchar *file)
@@ -1017,6 +1047,9 @@ gint procmsg_send_message_queue(const gchar *file)
                                       {"SCF:",  NULL, FALSE},
                                       {"RMID:", NULL, FALSE},
                                       {"FMID:", NULL, FALSE},
+                                      {"X-Sylpheed-Privacy-System:", NULL, FALSE},
+                                      {"X-Sylpheed-Encrypt:", NULL, FALSE},
+                                      {"X-Sylpheed-Encrypt-Data:", NULL, FALSE},
                                       {NULL,    NULL, FALSE}};
        FILE *fp;
        gint filepos;
@@ -1028,6 +1061,9 @@ gint procmsg_send_message_queue(const gchar *file)
        gchar *savecopyfolder = NULL;
        gchar *replymessageid = NULL;
        gchar *fwdmessageid = NULL;
+       gchar *privacy_system = NULL;
+       gboolean encrypt = FALSE;
+       gchar *encrypt_data = NULL;
        gchar buf[BUFFSIZE];
        gint hnum;
        PrefsAccount *mailac = NULL, *newsac = NULL;
@@ -1072,10 +1108,50 @@ gint procmsg_send_message_queue(const gchar *file)
                case Q_FWD_MESSAGE_ID:
                        if (!fwdmessageid) fwdmessageid = g_strdup(p);
                        break;
+               case Q_PRIVACY_SYSTEM:
+                       if (!privacy_system) privacy_system = g_strdup(p);
+                       break;
+               case Q_ENCRYPT:
+                       if (p[0] == '1') encrypt = TRUE;
+                       break;
+               case Q_ENCRYPT_DATA:
+                       if (!encrypt_data) encrypt_data = g_strdup(p);
+                       break;
                }
        }
        filepos = ftell(fp);
 
+       if (encrypt) {
+               MimeInfo *mimeinfo;
+
+               fclose(fp);
+               
+               mimeinfo = procmime_scan_queue_file(file);
+               if (!privacy_encrypt(privacy_system, mimeinfo, encrypt_data)
+               || (fp = my_tmpfile()) == NULL
+               ||  procmime_write_mimeinfo(mimeinfo, fp) < 0) {
+                       if (fp)
+                               fclose(fp);
+                       procmime_mimeinfo_free_all(mimeinfo);
+                       g_free(from);
+                       g_free(smtpserver);
+                       slist_free_strings(to_list);
+                       g_slist_free(to_list);
+                       slist_free_strings(newsgroup_list);
+                       g_slist_free(newsgroup_list);
+                       g_free(savecopyfolder);
+                       g_free(replymessageid);
+                       g_free(fwdmessageid);
+                       g_free(privacy_system);
+                       g_free(encrypt_data);
+                       return -1;
+               }
+               
+               procmime_mimeinfo_free_all(mimeinfo);
+               rewind(fp);
+               filepos = 0;
+       }
+
        if (to_list) {
                debug_print("Sending message by mail\n");
                if (!from) {
@@ -1112,7 +1188,7 @@ gint procmsg_send_message_queue(const gchar *file)
        }
 
        fseek(fp, filepos, SEEK_SET);
-       if (newsgroup_list && (newsval == 0)) {
+       if (newsgroup_list && (mailval == 0)) {
                Folder *folder;
                gchar *tmp = NULL;
                FILE *tmpfp;
@@ -1155,12 +1231,6 @@ gint procmsg_send_message_queue(const gchar *file)
                g_free(tmp);
        }
 
-       slist_free_strings(to_list);
-       g_slist_free(to_list);
-       slist_free_strings(newsgroup_list);
-       g_slist_free(newsgroup_list);
-       g_free(from);
-       g_free(smtpserver);
        fclose(fp);
 
        /* save message to outbox */
@@ -1208,8 +1278,7 @@ gint procmsg_send_message_queue(const gchar *file)
                                if (replymessageid != NULL) {
                                        procmsg_msginfo_unset_flags(msginfo, MSG_FORWARDED, 0);
                                        procmsg_msginfo_set_flags(msginfo, MSG_REPLIED, 0);
-                               } 
-                               else {
+                               }  else {
                                        procmsg_msginfo_unset_flags(msginfo, MSG_REPLIED, 0);
                                        procmsg_msginfo_set_flags(msginfo, MSG_FORWARDED, 0);
                                }
@@ -1219,10 +1288,18 @@ gint procmsg_send_message_queue(const gchar *file)
                g_strfreev(tokens);
        }
 
+       g_free(from);
+       g_free(smtpserver);
+       slist_free_strings(to_list);
+       g_slist_free(to_list);
+       slist_free_strings(newsgroup_list);
+       g_slist_free(newsgroup_list);
        g_free(savecopyfolder);
        g_free(replymessageid);
        g_free(fwdmessageid);
-       
+       g_free(privacy_system);
+       g_free(encrypt_data);
+
        return (newsval != 0 ? newsval : mailval);
 }
 
@@ -1267,6 +1344,7 @@ void procmsg_msginfo_set_flags(MsgInfo *msginfo, MsgPermFlags perm_flags, MsgTmp
        FolderItem *item;
        MsgInfoUpdate msginfo_update;
        MsgPermFlags perm_flags_new, perm_flags_old;
+       MsgTmpFlags tmp_flags_old;
 
        g_return_if_fail(msginfo != NULL);
        item = msginfo->folder;
@@ -1286,14 +1364,19 @@ void procmsg_msginfo_set_flags(MsgInfo *msginfo, MsgPermFlags perm_flags, MsgTmp
 
                update_folder_msg_counts(item, msginfo, perm_flags_old);
 
+       }
+
+       /* Tmp flags handling */
+       tmp_flags_old = msginfo->flags.tmp_flags;
+       msginfo->flags.tmp_flags |= tmp_flags;
+
+       /* update notification */
+       if ((perm_flags_old != perm_flags_new) || (tmp_flags_old != msginfo->flags.tmp_flags)) {
                msginfo_update.msginfo = msginfo;
                msginfo_update.flags = MSGINFO_UPDATE_FLAGS;
                hooks_invoke(MSGINFO_UPDATE_HOOKLIST, &msginfo_update);
                folder_item_update(msginfo->folder, F_ITEM_UPDATE_MSGCNT);
        }
-
-       /* Tmp flags hanlding */
-       msginfo->flags.tmp_flags |= tmp_flags;
 }
 
 void procmsg_msginfo_unset_flags(MsgInfo *msginfo, MsgPermFlags perm_flags, MsgTmpFlags tmp_flags)
@@ -1301,6 +1384,7 @@ void procmsg_msginfo_unset_flags(MsgInfo *msginfo, MsgPermFlags perm_flags, MsgT
        FolderItem *item;
        MsgInfoUpdate msginfo_update;
        MsgPermFlags perm_flags_new, perm_flags_old;
+       MsgTmpFlags tmp_flags_old;
 
        g_return_if_fail(msginfo != NULL);
        item = msginfo->folder;
@@ -1324,7 +1408,16 @@ void procmsg_msginfo_unset_flags(MsgInfo *msginfo, MsgPermFlags perm_flags, MsgT
        }
 
        /* Tmp flags hanlding */
+       tmp_flags_old = msginfo->flags.tmp_flags;
        msginfo->flags.tmp_flags &= ~tmp_flags;
+
+       /* update notification */
+       if ((perm_flags_old != perm_flags_new) || (tmp_flags_old != msginfo->flags.tmp_flags)) {
+               msginfo_update.msginfo = msginfo;
+               msginfo_update.flags = MSGINFO_UPDATE_FLAGS;
+               hooks_invoke(MSGINFO_UPDATE_HOOKLIST, &msginfo_update);
+               folder_item_update(msginfo->folder, F_ITEM_UPDATE_MSGCNT);
+       }
 }
 
 /*!
@@ -1505,8 +1598,8 @@ gboolean procmsg_msginfo_filter(MsgInfo *msginfo)
                return TRUE;
 
        /* filter if enabled in prefs or move to inbox if not */
-       if((global_processing != NULL) &&
-          filter_message_by_msginfo(global_processing, msginfo))
+       if((filtering_rules != NULL) &&
+          filter_message_by_msginfo(filtering_rules, msginfo))
                return TRUE;
 
        return FALSE;