static gchar * mbox_get_new_path(FolderItem * parent, gchar * name);
static gchar * mbox_get_folderitem_name(gchar * name);
+MsgInfo *mbox_fetch_msginfo(Folder *folder, FolderItem *item, gint num);
+gint mbox_get_num_list(Folder *folder, FolderItem *item, GSList **list);
+gboolean mbox_check_msgnum_validity(Folder *folder, FolderItem *item);
+
Folder *mbox_folder_new(const gchar *name, const gchar *path)
{
Folder *folder;
static void mbox_folder_init(Folder *folder, const gchar *name, const gchar *path)
{
- folder_local_folder_init(folder, name, path);
-
folder->type = F_MBOX;
+ folder_local_folder_init(folder, name, path);
+
+/*
folder->get_msg_list = mbox_get_msg_list;
+*/
folder->fetch_msg = mbox_fetch_msg;
+ folder->fetch_msginfo = mbox_fetch_msginfo;
folder->add_msg = mbox_add_msg;
folder->copy_msg = mbox_copy_msg;
folder->remove_msg = mbox_remove_msg;
folder->remove_all_msg = mbox_remove_all_msg;
+/*
folder->scan = mbox_scan_folder;
+*/
+ folder->get_num_list = mbox_get_num_list;
folder->create_tree = mbox_create_tree;
folder->create_folder = mbox_create_folder;
folder->rename_folder = mbox_rename_folder;
folder->remove_folder = mbox_remove_folder;
+ folder->check_msgnum_validity
+ = mbox_check_msgnum_validity;
}
-static gchar * mbox_folder_create_parent(const gchar * path)
+static void mbox_folder_create_parent(const gchar * path)
{
if (!is_file_exist(path)) {
gchar * new_path;
}
}
- msginfo = procheader_file_parse(fp, flags, FALSE, FALSE);
+ msginfo = procheader_parse_stream(fp, flags, FALSE, FALSE);
if (!msginfo) return NULL;
mbox_cache_table = g_hash_table_new(g_str_hash, g_str_equal);
}
-static void mbox_cache_done()
-{
- g_hash_table_destroy(mbox_cache_table);
-}
-
static void mbox_cache_free_mbox(mboxcache * cache)
{
g_hash_table_remove(mbox_cache_table, cache->filename);
mbox_cache_get_msginfo(filename, mf->msg_list);
- debug_print(_("read mbox - %s\n"), filename);
+ debug_print("read mbox - %s\n", filename);
return cache;
}
mbox_cache_get_msginfo_from_file(fp, mf->msg_list);
- debug_print(_("read mbox from file - %s\n"), filename);
+ debug_print("read mbox from file - %s\n", filename);
return cache;
}
return cache->mf->count;
}
-static gint mbox_cache_get_mtime(gchar * filename)
-{
- mboxcache * cache;
-
- cache = mbox_cache_get_mbox(filename);
- if (cache == NULL)
- return -1;
- return cache->mtime;
-}
-
static GList * mbox_cache_get_msg_list(gchar * filename)
{
mboxcache * cache;
}
if (scan_new) {
- GList * l;
-
/*
if (strstr(filename, "trash") == 0)
printf("old_cache: %p %s\n", old_cache, filename);
gchar *filename;
g_return_val_if_fail(item != NULL, NULL);
- g_return_val_if_fail(num > 0 && num <= item->last_num, NULL);
path = folder_item_get_path(item);
if (!is_dir_exist(path))
msg = mbox_cache_get_msg(mbox_path, num);
g_free(mbox_path);
-
+
if (msg != NULL)
MSG_SET_PERM_FLAGS(msg->flags, MSG_REALLY_DELETED);
Folder * src_folder;
gchar * filename;
gint num;
- gchar * destdir;
- gchar * mbox_path;
- struct _message * msg;
CopyFlagsInfo * flags_info;
src_folder = msginfo->folder->folder;
item->total = total;
}
- debug_print(_("Last number in dir %s = %d\n"), mbox_path,
+ debug_print("Last number in dir %s = %d\n", mbox_path,
item->total);
item->last_num = n_msg;
g_free(mbox_path);
return FALSE;
if (!cache->modification) {
- debug_print(_("no modification - %s\n"), mbox);
+ debug_print("no modification - %s\n", mbox);
return FALSE;
}
- debug_print(_("save modification - %s\n"), mbox);
+ debug_print("save modification - %s\n", mbox);
mbox_fp = fopen(mbox, "rb+");
mbox_lockwrite_file(mbox_fp, mbox);
fclose(mbox_fp);
- debug_print(_("%i messages written - %s\n"), count, mbox);
+ debug_print("%i messages written - %s\n", count, mbox);
cache = mbox_cache_get_mbox(mbox);
for(l = msg_list ; l != NULL ; l = g_list_next(l)) {
struct _message * msg = (struct _message *) l->data;
- if (MSG_IS_INVALID(msg->flags) && MSG_IS_REALLY_DELETED(msg->flags)) {
+ if (!MSG_IS_INVALID(msg->flags) && MSG_IS_REALLY_DELETED(msg->flags)) {
modification = TRUE;
break;
}
}
if (!modification) {
- debug_print(_("no deleted messages - %s\n"), mbox);
+ debug_print("no deleted messages - %s\n", mbox);
return FALSE;
}
- debug_print(_("purge deleted messages - %s\n"), mbox);
+ debug_print("purge deleted messages - %s\n", mbox);
mbox_fp = fopen(mbox, "rb+");
mbox_lockwrite_file(mbox_fp, mbox);
fclose(mbox_fp);
- debug_print(_("%i messages written - %s\n"), count, mbox);
+ debug_print("%i messages written - %s\n", count, mbox);
mbox_cache_synchronize(mbox, FALSE);
foldername = mbox_get_folderitem_name((gchar *) name);
- new_item = folder_item_new(foldername, path);
+ new_item = folder_item_new(folder, foldername, path);
folder_item_append(parent, new_item);
if (!strcmp(name, "inbox")) {
return 0;
}
+gint mbox_get_num_list(Folder *folder, FolderItem *item, GSList **mlist)
+{
+ GList * l;
+ FILE * fp;
+ gchar * mbox_path;
+ gint nummsgs = 0;
+
+ mbox_path = mbox_folder_get_path(item);
+
+ if (mbox_path == NULL)
+ return -1;
+
+ mbox_purge_deleted(mbox_path);
+
+ fp = fopen(mbox_path, "rb");
+
+ if (fp == NULL) {
+ g_free(mbox_path);
+ return -1;
+ }
+
+ mbox_lockread_file(fp, mbox_path);
+
+ mbox_cache_synchronize_from_file(fp, mbox_path, TRUE);
+
+ item->last_num = mbox_cache_get_count(mbox_path);
+
+ for(l = mbox_cache_get_msg_list(mbox_path) ; l != NULL ;
+ l = g_list_next(l)) {
+ struct _message * msg;
+
+ msg = (struct _message *) l->data;
+
+ if (MSG_IS_INVALID(msg->flags) || !MSG_IS_REALLY_DELETED(msg->flags)) {
+ *mlist = g_slist_append(*mlist, GINT_TO_POINTER(msg->msgnum));
+ nummsgs++;
+ } else {
+ MSG_SET_PERM_FLAGS(msg->flags, MSG_REALLY_DELETED);
+ }
+ }
+
+ mbox_unlock_file(fp, mbox_path);
+
+ g_free(mbox_path);
+
+ fclose(fp);
+
+ return nummsgs;
+}
+
+MsgInfo *mbox_fetch_msginfo(Folder *folder, FolderItem *item, gint num)
+{
+ gchar *mbox_path;
+ struct _message *msg;
+ FILE *src;
+ MsgInfo *msginfo;
+
+ g_return_val_if_fail(folder != NULL, NULL);
+ g_return_val_if_fail(item != NULL, NULL);
+
+ mbox_path = mbox_folder_get_path(item);
+
+ g_return_val_if_fail(mbox_path != NULL, NULL);
+
+ src = fopen(mbox_path, "rb");
+ if (src == NULL) {
+ g_free(mbox_path);
+ return NULL;
+ }
+ mbox_lockread_file(src, mbox_path);
+ mbox_cache_synchronize_from_file(src, mbox_path, TRUE);
+
+ msg = mbox_cache_get_msg(mbox_path, num);
+ if (msg == NULL) {
+ mbox_unlock_file(src, mbox_path);
+ fclose(src);
+ g_free(mbox_path);
+ return NULL;
+ }
+
+ fseek(src, msg->header, SEEK_SET);
+ msginfo = mbox_parse_msg(src, msg, item);
+
+ mbox_unlock_file(src, mbox_path);
+ fclose(src);
+ g_free(mbox_path);
+
+ return msginfo;
+}
+
+gboolean mbox_check_msgnum_validity(Folder *folder, FolderItem *item)
+{
+ mboxcache * old_cache;
+ gboolean scan_new = TRUE;
+ struct stat s;
+ gchar *filename;
+
+ filename = mbox_folder_get_path(item);
+
+ old_cache = mbox_cache_get_mbox(filename);
+
+ if (old_cache != NULL) {
+ if (stat(filename, &s) < 0) {
+ FILE_OP_ERROR(filename, "stat");
+ } else if (old_cache->mtime == s.st_mtime) {
+ debug_print("Folder is not modified.\n");
+ scan_new = FALSE;
+ }
+ }
+
+ g_free(filename);
+
+ return !scan_new;
+}
+
projects / claws.git / blobdiff