2 * Sylpheed -- a GTK+ based, lightweight, and fast e-mail client
3 * Copyright (C) 1999-2003 Hiroyuki Yamamoto
5 * This program is free software; you can redistribute it and/or modify
6 * it under the terms of the GNU General Public License as published by
7 * the Free Software Foundation; either version 2 of the License, or
8 * (at your option) any later version.
10 * This program is distributed in the hope that it will be useful,
11 * but WITHOUT ANY WARRANTY; without even the implied warranty of
12 * MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the
13 * GNU General Public License for more details.
15 * You should have received a copy of the GNU General Public License
16 * along with this program; if not, write to the Free Software
17 * Foundation, Inc., 59 Temple Place - Suite 330, Boston, MA 02111-1307, USA.
32 #include <sys/types.h>
40 # include <sys/time.h>
46 #include "procheader.h"
49 #include "mailmbox_folder.h"
50 #include "mailmbox_parse.h"
52 static Folder *s_mailmbox_folder_new(const gchar *name, const gchar *path);
54 static void mailmbox_folder_destroy(Folder *folder);
56 static FolderItem *mailmbox_folder_item_new(Folder *folder);
58 static void mailmbox_folder_item_destroy(Folder *folder, FolderItem *_item);
60 static gchar *mailmbox_item_get_path(Folder *folder, FolderItem *item);
62 static gint mailmbox_get_num_list(Folder *folder, FolderItem *item,
63 GSList **list, gboolean *old_uids_valid);
65 static MsgInfo *mailmbox_get_msginfo(Folder *folder,
66 FolderItem *item, gint num);
68 static GSList *mailmbox_get_msginfos(Folder *folder, FolderItem *item,
71 static gchar *s_mailmbox_fetch_msg(Folder *folder, FolderItem *item, gint num);
73 static gint mailmbox_add_msg(Folder *folder, FolderItem *dest,
74 const gchar *file, MsgFlags *flags);
76 static gint mailmbox_add_msgs(Folder *folder, FolderItem *dest,
80 static gint s_mailmbox_copy_msg(Folder *folder,
81 FolderItem *dest, MsgInfo *msginfo);
83 static gint mailmbox_copy_msgs(Folder *folder, FolderItem *dest,
84 MsgInfoList *msglist, GRelation *relation);
86 static gint mailmbox_remove_msg(Folder *folder, FolderItem *item, gint num);
88 static gint mailmbox_remove_all_msg(Folder *folder, FolderItem *item);
90 static FolderItem *mailmbox_create_folder(Folder *folder, FolderItem *parent,
93 static gboolean mailmbox_scan_required(Folder *folder, FolderItem *_item);
95 static gint mailmbox_rename_folder(Folder *folder,
96 FolderItem *item, const gchar *name);
98 static gint mailmbox_remove_folder(Folder *folder, FolderItem *item);
100 static gint mailmbox_create_tree(Folder *folder);
102 static FolderClass mailmbox_class =
108 /* Folder functions */
109 s_mailmbox_folder_new,
110 mailmbox_folder_destroy,
111 NULL, /* mailmbox_scan_tree, */
112 mailmbox_create_tree,
114 /* FolderItem functions */
115 mailmbox_folder_item_new,
116 mailmbox_folder_item_destroy,
117 mailmbox_item_get_path,
118 mailmbox_create_folder,
119 mailmbox_rename_folder,
120 mailmbox_remove_folder,
122 mailmbox_get_num_list,
126 mailmbox_scan_required,
128 /* Message functions */
129 mailmbox_get_msginfo,
130 mailmbox_get_msginfos,
131 s_mailmbox_fetch_msg,
137 mailmbox_remove_all_msg,
142 FolderClass *mailmbox_get_class(void)
144 return &mailmbox_class;
148 static void mailmbox_folder_init(Folder *folder,
149 const gchar *name, const gchar *path)
151 folder_local_folder_init(folder, name, path);
154 static Folder *s_mailmbox_folder_new(const gchar *name, const gchar *path)
158 folder = (Folder *)g_new0(MBOXFolder, 1);
159 folder->klass = &mailmbox_class;
160 mailmbox_folder_init(folder, name, path);
165 static void mailmbox_folder_destroy(Folder *folder)
167 folder_local_folder_destroy(LOCAL_FOLDER(folder));
170 typedef struct _MBOXFolderItem MBOXFolderItem;
171 struct _MBOXFolderItem
174 uint32_t old_max_uid;
175 struct mailmbox_folder * mbox;
178 static FolderItem *mailmbox_folder_item_new(Folder *folder)
180 MBOXFolderItem *item;
182 item = g_new0(MBOXFolderItem, 1);
184 item->old_max_uid = 0;
186 return (FolderItem *)item;
189 #define MAX_UID_FILE "max-uid"
191 void read_max_uid_value(FolderItem *item, uint32_t * pmax_uid)
199 path = folder_item_get_path(item);
200 file = g_strconcat(path, G_DIR_SEPARATOR_S, MAX_UID_FILE, NULL);
203 f = fopen(file, "r");
207 r = fread(&max_uid, sizeof(max_uid), 1, f);
215 * pmax_uid = max_uid;
218 void write_max_uid_value(FolderItem *item, uint32_t max_uid)
225 path = folder_item_get_path(item);
226 file = g_strconcat(path, G_DIR_SEPARATOR_S, MAX_UID_FILE, NULL);
229 f = fopen(file, "w");
233 r = fwrite(&max_uid, sizeof(max_uid), 1, f);
242 static void mailmbox_folder_item_destroy(Folder *folder, FolderItem *_item)
244 MBOXFolderItem *item = (MBOXFolderItem *)_item;
246 g_return_if_fail(item != NULL);
248 if (item->mbox != NULL) {
249 write_max_uid_value(_item, item->mbox->written_uid);
250 mailmbox_done(item->mbox);
255 static void mailmbox_folder_create_parent(const gchar * path)
257 if (!is_file_exist(path)) {
260 new_path = g_dirname(path);
261 if (new_path[strlen(new_path) - 1] == G_DIR_SEPARATOR)
262 new_path[strlen(new_path) - 1] = '\0';
264 if (!is_dir_exist(new_path))
265 make_dir_hier(new_path);
271 static gchar * mailmbox_folder_get_path(Folder *folder, FolderItem *item)
276 g_return_val_if_fail(item != NULL, NULL);
278 if (item->path && item->path[0] == G_DIR_SEPARATOR) {
279 mailmbox_folder_create_parent(item->path);
280 return g_strdup(item->path);
283 folder_path = g_strdup(LOCAL_FOLDER(item->folder)->rootpath);
284 g_return_val_if_fail(folder_path != NULL, NULL);
286 if (folder_path[0] == G_DIR_SEPARATOR) {
288 path = g_strconcat(folder_path, G_DIR_SEPARATOR_S,
292 path = g_strdup(folder_path);
295 path = g_strconcat(get_home_dir(), G_DIR_SEPARATOR_S,
296 folder_path, G_DIR_SEPARATOR_S,
299 path = g_strconcat(get_home_dir(), G_DIR_SEPARATOR_S,
305 mailmbox_folder_create_parent(path);
310 static int mailmbox_item_sync(FolderItem *_item, int validate_uid)
312 MBOXFolderItem *item = (MBOXFolderItem *)_item;
315 if (item->mbox == NULL) {
316 uint32_t written_uid;
320 read_max_uid_value(_item, &written_uid);
321 path = mailmbox_folder_get_path(_item->folder, _item);
322 r = mailmbox_init(path, 0, 0, written_uid, &item->mbox);
324 if (r != MAILMBOX_NO_ERROR)
329 r = mailmbox_validate_read_lock(item->mbox);
330 if (r != MAILMBOX_NO_ERROR) {
334 mailmbox_read_unlock(item->mbox);
337 r = mailmbox_validate_write_lock(item->mbox);
338 if (r != MAILMBOX_NO_ERROR) {
342 if (item->mbox->written_uid < item->mbox->max_uid) {
343 r = mailmbox_expunge_no_lock(item->mbox);
344 if (r != MAILMBOX_NO_ERROR)
347 mailmbox_write_unlock(item->mbox);
353 mailmbox_write_unlock(item->mbox);
358 static struct mailmbox_folder * get_mbox(FolderItem *_item, int validate_uid)
360 MBOXFolderItem *item = (MBOXFolderItem *)_item;
362 mailmbox_item_sync(_item, validate_uid);
367 static gint mailmbox_get_num_list(Folder *folder, FolderItem *item,
368 GSList **list, gboolean *old_uids_valid)
372 struct mailmbox_folder * mbox;
374 g_return_val_if_fail(item != NULL, -1);
376 debug_print("mbox_get_last_num(): Scanning %s ...\n", item->path);
378 *old_uids_valid = TRUE;
380 mbox = get_mbox(item, 1);
384 for(i = 0 ; i < carray_count(mbox->tab) ; i ++) {
385 struct mailmbox_msg_info * msg;
387 msg = carray_get(mbox->tab, i);
389 *list = g_slist_prepend(*list,
390 GINT_TO_POINTER(msg->uid));
398 static gchar *s_mailmbox_fetch_msg(Folder *folder, FolderItem *item, gint num)
403 struct mailmbox_folder * mbox;
409 g_return_val_if_fail(item != NULL, NULL);
410 g_return_val_if_fail(num > 0, NULL);
412 mbox = get_mbox(item, 0);
416 path = folder_item_get_path(item);
417 file = g_strconcat(path, G_DIR_SEPARATOR_S, itos(num), NULL);
419 if (is_file_exist(file)) {
423 r = mailmbox_fetch_msg(mbox, num, &data, &len);
424 if (r != MAILMBOX_NO_ERROR)
427 fprintf(stderr, file);
428 old_mask = umask(0077);
429 f = fopen(file, "w");
434 r = fwrite(data, 1, len, f);
454 static MsgInfo *mailmbox_parse_msg(uint32_t uid,
455 char * data, size_t len, FolderItem *item)
460 flags.perm_flags = MSG_NEW|MSG_UNREAD;
463 g_return_val_if_fail(item != NULL, NULL);
464 g_return_val_if_fail(data != NULL, NULL);
466 if (item->stype == F_QUEUE) {
467 MSG_SET_TMP_FLAGS(flags, MSG_QUEUED);
468 } else if (item->stype == F_DRAFT) {
469 MSG_SET_TMP_FLAGS(flags, MSG_DRAFT);
472 msginfo = procheader_parse_str(data, flags, FALSE, FALSE);
473 if (!msginfo) return NULL;
475 msginfo->msgnum = uid;
476 msginfo->folder = item;
481 static MsgInfo *mailmbox_get_msginfo(Folder *folder,
482 FolderItem *item, gint num)
488 struct mailmbox_folder * mbox;
490 g_return_val_if_fail(item != NULL, NULL);
491 g_return_val_if_fail(num > 0, NULL);
493 mbox = get_mbox(item, 0);
497 r = mailmbox_validate_read_lock(mbox);
498 if (r != MAILMBOX_NO_ERROR)
501 r = mailmbox_fetch_msg_headers_no_lock(mbox, num, &data, &len);
502 if (r != MAILMBOX_NO_ERROR)
505 msginfo = mailmbox_parse_msg(num, data, len, item);
509 msginfo->msgnum = num;
511 mailmbox_read_unlock(mbox);
516 mailmbox_read_unlock(mbox);
521 static GSList *mailmbox_get_msginfos(Folder *folder, FolderItem *item,
527 struct mailmbox_folder * mbox;
529 g_return_val_if_fail(item != NULL, NULL);
531 mbox = get_mbox(item, 0);
535 r = mailmbox_validate_read_lock(mbox);
536 if (r != MAILMBOX_NO_ERROR)
541 for (cur = msgnum_list ; cur != NULL ; cur = g_slist_next(cur)) {
547 num = GPOINTER_TO_INT(cur->data);
549 r = mailmbox_fetch_msg_headers_no_lock(mbox, num, &data, &len);
550 if (r != MAILMBOX_NO_ERROR)
553 msginfo = mailmbox_parse_msg(num, data, len, item);
557 msginfo->msgnum = num;
559 ret = g_slist_append(ret, msginfo);
562 mailmbox_read_unlock(mbox);
567 mailmbox_read_unlock(mbox);
574 static gint mailmbox_add_msg(Folder *folder, FolderItem *dest,
575 const gchar *file, MsgFlags *flags)
579 MsgFileInfo fileinfo;
581 g_return_val_if_fail(file != NULL, -1);
583 fileinfo.msginfo = NULL;
584 fileinfo.file = (gchar *)file;
585 fileinfo.flags = flags;
586 file_list.data = &fileinfo;
587 file_list.next = NULL;
589 ret = mailmbox_add_msgs(folder, dest, &file_list, NULL);
595 static gint mailmbox_add_msgs(Folder *folder, FolderItem *dest,
602 struct mailmbox_folder * mbox;
603 carray * append_list;
604 struct mailmbox_append_info append_info;
607 g_return_val_if_fail(dest != NULL, -1);
608 g_return_val_if_fail(file_list != NULL, -1);
610 mbox = get_mbox(dest, 0);
614 r = mailmbox_validate_write_lock(mbox);
615 if (r != MAILMBOX_NO_ERROR)
618 r = mailmbox_expunge_no_lock(mbox);
619 if (r != MAILMBOX_NO_ERROR)
624 append_list = carray_new(1);
625 if (append_list == NULL)
628 r = carray_set_size(append_list, 1);
632 carray_set(append_list, 0, &append_info);
634 for (cur = file_list; cur != NULL; cur = cur->next) {
636 struct stat stat_info;
639 struct mailmbox_msg_info * msg;
641 MsgFileInfo *fileinfo;
643 fileinfo = (MsgFileInfo *)cur->data;
645 fd = open(fileinfo->file, O_RDONLY);
649 r = fstat(fd, &stat_info);
653 len = stat_info.st_size;
654 data = mmap(NULL, len, PROT_READ, MAP_PRIVATE, fd, 0);
655 if (data == MAP_FAILED)
658 append_info.message = data;
659 append_info.size = len;
661 cur_token = mbox->mapping_size;
663 r = mailmbox_append_message_list_no_lock(mbox, append_list);
664 if (r != MAILMBOX_NO_ERROR)
672 r = mailmbox_parse_additionnal(mbox, &cur_token);
673 if (r != MAILMBOX_NO_ERROR)
676 msg = carray_get(mbox->tab, carray_count(mbox->tab) - 1);
678 if (relation != NULL)
679 g_relation_insert(relation, fileinfo,
680 GINT_TO_POINTER(msg->uid));
694 carray_free(append_list);
695 mailmbox_write_unlock(mbox);
700 carray_free(append_list);
702 mailmbox_write_unlock(mbox);
706 static gint s_mailmbox_copy_msg(Folder *folder,
707 FolderItem *dest, MsgInfo *msginfo)
711 g_return_val_if_fail(msginfo != NULL, -1);
713 msglist.data = msginfo;
716 return mailmbox_copy_msgs(folder, dest, &msglist, NULL);
719 static gint mailmbox_copy_msgs(Folder *folder, FolderItem *dest,
720 MsgInfoList *msglist, GRelation *relation)
726 g_return_val_if_fail(folder != NULL, -1);
727 g_return_val_if_fail(dest != NULL, -1);
728 g_return_val_if_fail(msglist != NULL, -1);
730 msginfo = (MsgInfo *)msglist->data;
731 g_return_val_if_fail(msginfo->folder != NULL, -1);
733 file_list = procmsg_get_message_file_list(msglist);
734 g_return_val_if_fail(file_list != NULL, -1);
736 ret = mailmbox_add_msgs(folder, dest, file_list, relation);
738 procmsg_message_file_list_free(file_list);
744 static gint mailmbox_remove_msg(Folder *folder, FolderItem *item, gint num)
746 struct mailmbox_folder * mbox;
749 g_return_val_if_fail(item != NULL, -1);
751 mbox = get_mbox(item, 0);
755 r = mailmbox_delete_msg(mbox, num);
756 if (r != MAILMBOX_NO_ERROR)
762 static gint mailmbox_remove_all_msg(Folder *folder, FolderItem *item)
764 struct mailmbox_folder * mbox;
768 g_return_val_if_fail(item != NULL, -1);
770 mbox = get_mbox(item, 0);
774 for(i = 0 ; i < carray_count(mbox->tab) ; i ++) {
775 struct mailmbox_msg_info * msg;
777 msg = carray_get(mbox->tab, i);
781 r = mailmbox_delete_msg(mbox, msg->uid);
782 if (r != MAILMBOX_NO_ERROR)
790 static gchar * mailmbox_get_new_path(FolderItem * parent, gchar * name)
794 if (strchr(name, G_DIR_SEPARATOR) == NULL) {
795 if (parent->path != NULL)
796 path = g_strconcat(parent->path, ".sbd", G_DIR_SEPARATOR_S, name, NULL);
798 path = g_strdup(name);
801 path = g_strdup(name);
806 static gchar * mailmbox_get_folderitem_name(gchar * name)
810 foldername = g_strdup(g_basename(name));
815 static FolderItem *mailmbox_create_folder(Folder *folder, FolderItem *parent,
819 FolderItem *new_item;
822 g_return_val_if_fail(folder != NULL, NULL);
823 g_return_val_if_fail(parent != NULL, NULL);
824 g_return_val_if_fail(name != NULL, NULL);
826 path = mailmbox_get_new_path(parent, (gchar *) name);
828 foldername = mailmbox_get_folderitem_name((gchar *) name);
830 new_item = folder_item_new(folder, foldername, path);
831 folder_item_append(parent, new_item);
833 if (!strcmp(name, "inbox")) {
834 new_item->stype = F_INBOX;
835 new_item->folder->inbox = new_item;
836 } else if (!strcmp(name, "outbox")) {
837 new_item->stype = F_OUTBOX;
838 new_item->folder->outbox = new_item;
839 } else if (!strcmp(name, "draft")) {
840 new_item->stype = F_DRAFT;
841 new_item->folder->draft = new_item;
842 } else if (!strcmp(name, "queue")) {
843 new_item->stype = F_QUEUE;
844 new_item->folder->queue = new_item;
845 } else if (!strcmp(name, "trash")) {
846 new_item->stype = F_TRASH;
847 new_item->folder->trash = new_item;
858 static gboolean mailmbox_scan_required(Folder *folder, FolderItem *_item)
860 struct mailmbox_folder * mbox;
861 MBOXFolderItem *item = (MBOXFolderItem *)_item;
864 g_return_val_if_fail(folder != NULL, FALSE);
865 g_return_val_if_fail(item != NULL, FALSE);
867 if (item->item.path == NULL)
870 mbox = get_mbox(_item, 0);
874 scan_required = (item->old_max_uid != item->mbox->max_uid);
876 item->old_max_uid = item->mbox->max_uid;
878 return scan_required;
882 static gint mailmbox_rename_folder(Folder *folder,
883 FolderItem *item, const gchar *name)
888 g_return_val_if_fail(folder != NULL, -1);
889 g_return_val_if_fail(item != NULL, -1);
890 g_return_val_if_fail(item->path != NULL, -1);
891 g_return_val_if_fail(name != NULL, -1);
893 path = mailmbox_get_new_path(item->parent, (gchar *) name);
894 foldername = mailmbox_get_folderitem_name((gchar *) name);
896 if (rename(item->path, path) == -1) {
899 g_warning("Cannot rename folder item");
907 item->name = foldername;
913 static gint mailmbox_remove_folder(Folder *folder, FolderItem *item)
915 g_return_val_if_fail(folder != NULL, -1);
916 g_return_val_if_fail(item != NULL, -1);
917 g_return_val_if_fail(item->path != NULL, -1);
919 folder_item_remove(item);
923 #define MAKE_DIR_IF_NOT_EXIST(dir) \
925 if (!is_dir_exist(dir)) { \
926 if (is_file_exist(dir)) { \
927 g_warning("File `%s' already exists.\n" \
928 "Can't create folder.", dir); \
931 if (mkdir(dir, S_IRWXU) < 0) { \
932 FILE_OP_ERROR(dir, "mkdir"); \
935 if (chmod(dir, S_IRWXU) < 0) \
936 FILE_OP_ERROR(dir, "chmod"); \
940 static gint mailmbox_create_tree(Folder *folder)
944 g_return_val_if_fail(folder != NULL, -1);
946 CHDIR_RETURN_VAL_IF_FAIL(get_home_dir(), -1);
947 rootpath = LOCAL_FOLDER(folder)->rootpath;
948 MAKE_DIR_IF_NOT_EXIST(rootpath);
949 CHDIR_RETURN_VAL_IF_FAIL(rootpath, -1);
954 #undef MAKE_DIR_IF_NOT_EXIST
957 static char * quote_mailbox(char * mb)
964 remaining = sizeof(path) - 1;
970 if (((* mb >= 'a') && (* mb <= 'z')) ||
971 ((* mb >= 'A') && (* mb <= 'Z')) ||
972 ((* mb >= '0') && (* mb <= '9'))) {
984 snprintf(p, 3, "%02x", (unsigned char) (* mb));
999 static gchar *mailmbox_item_get_path(Folder *folder, FolderItem *item)
1001 gchar *itempath, *path;
1004 if (item->path == NULL)
1007 if (folder->name == NULL)
1010 folderpath = quote_mailbox(folder->name);
1011 if (folderpath == NULL)
1013 itempath = quote_mailbox(item->path);
1014 if (itempath == NULL) {
1018 path = g_strconcat(get_mbox_cache_dir(),
1019 G_DIR_SEPARATOR_S, folderpath,
1020 G_DIR_SEPARATOR_S, itempath, NULL);