return NULL;
}
+FolderItem *folder_get_default_outbox_for_class(FolderType type)
+{
+ GList *flist;
+
+ for (flist = folder_list; flist != NULL; flist = g_list_next(flist)) {
+ Folder * folder = FOLDER(flist->data);
+
+ if (folder == NULL)
+ continue;
+ if (folder->outbox == NULL)
+ continue;
+ if (folder->klass->type != type)
+ continue;
+
+ return folder->outbox;
+ }
+
+ return NULL;
+}
+
FolderItem *folder_get_default_draft(void)
{
GList *flist;
return NULL;
}
+FolderItem *folder_get_default_draft_for_class(FolderType type)
+{
+ GList *flist;
+
+ for (flist = folder_list; flist != NULL; flist = g_list_next(flist)) {
+ Folder * folder = FOLDER(flist->data);
+
+ if (folder == NULL)
+ continue;
+ if (folder->draft == NULL)
+ continue;
+ if (folder->klass->type != type)
+ continue;
+
+ return folder->draft;
+ }
+
+ return NULL;
+}
+
FolderItem *folder_get_default_queue(void)
{
GList *flist;
return NULL;
}
+FolderItem *folder_get_default_queue_for_class(FolderType type)
+{
+ GList *flist;
+
+ for (flist = folder_list; flist != NULL; flist = g_list_next(flist)) {
+ Folder * folder = FOLDER(flist->data);
+
+ if (folder == NULL)
+ continue;
+ if (folder->queue == NULL)
+ continue;
+ if (folder->klass->type != type)
+ continue;
+
+ return folder->queue;
+ }
+
+ return NULL;
+}
+
FolderItem *folder_get_default_trash(void)
{
GList *flist;
return NULL;
}
+FolderItem *folder_get_default_trash_for_class(FolderType type)
+{
+ GList *flist;
+
+ for (flist = folder_list; flist != NULL; flist = g_list_next(flist)) {
+ Folder * folder = FOLDER(flist->data);
+
+ if (folder == NULL)
+ continue;
+ if (folder->trash == NULL)
+ continue;
+ if (folder->klass->type != type)
+ continue;
+
+ return folder->trash;
+ }
+
+ return NULL;
+}
+
#define CREATE_FOLDER_IF_NOT_EXIST(member, dir, type) \
{ \
if (!folder->member) { \
return folder->klass->item_get_path(folder, item);
}
-void folder_item_set_default_flags(FolderItem *dest, MsgFlags *flags)
-{
- if (!(folder_has_parent_of_type(dest, F_OUTBOX) ||
- folder_has_parent_of_type(dest, F_QUEUE) ||
- folder_has_parent_of_type(dest, F_DRAFT) ||
- folder_has_parent_of_type(dest, F_TRASH))) {
- flags->perm_flags = MSG_NEW|MSG_UNREAD;
- } else {
- flags->perm_flags = 0;
- }
- if (FOLDER_TYPE(dest->folder) == F_MH) {
- if (folder_has_parent_of_type(dest, F_QUEUE)) {
- MSG_SET_TMP_FLAGS(*flags, MSG_QUEUED);
- } else if (folder_has_parent_of_type(dest, F_DRAFT)) {
- MSG_SET_TMP_FLAGS(*flags, MSG_DRAFT);
- }
- }
-}
-
static gint folder_sort_cache_list_by_msgnum(gconstpointer a, gconstpointer b)
{
MsgInfo *msginfo_a = (MsgInfo *) a;
return (gint_a - gint_b);
}
-void folder_item_process_open (FolderItem *item,
+static gint syncronize_flags(FolderItem *item, MsgInfoList *msglist)
+{
+ GRelation *relation;
+ gint ret = 0;
+ GSList *cur;
+
+ if(msglist == NULL)
+ return 0;
+ if(item->folder->klass->get_flags == NULL)
+ return 0;
+ if (item->no_select)
+ return 0;
+
+ relation = g_relation_new(2);
+ g_relation_index(relation, 0, g_direct_hash, g_direct_equal);
+ if ((ret = item->folder->klass->get_flags(
+ item->folder, item, msglist, relation)) == 0) {
+ GTuples *tuples;
+ MsgInfo *msginfo;
+ MsgPermFlags permflags = 0;
+ gboolean skip;
+
+ folder_item_update_freeze();
+ folder_item_set_batch(item, TRUE);
+ for (cur = msglist; cur != NULL; cur = g_slist_next(cur)) {
+ msginfo = (MsgInfo *) cur->data;
+
+ tuples = g_relation_select(relation, msginfo, 0);
+ skip = tuples->len < 1;
+ if (!skip)
+ permflags = GPOINTER_TO_INT(g_tuples_index(tuples, 0, 1));
+ g_tuples_destroy(tuples);
+ if (skip)
+ continue;
+
+ if (msginfo->flags.perm_flags != permflags) {
+ procmsg_msginfo_change_flags(msginfo,
+ permflags & ~msginfo->flags.perm_flags, 0,
+ ~permflags & msginfo->flags.perm_flags, 0);
+ }
+ }
+ folder_item_set_batch(item, FALSE);
+ folder_item_update_thaw();
+ }
+ g_relation_destroy(relation);
+
+ return ret;
+}
+
+static gint folder_item_syncronize_flags(FolderItem *item)
+{
+ MsgInfoList *msglist = NULL;
+ GSList *cur;
+ gint ret = 0;
+
+ g_return_val_if_fail(item != NULL, -1);
+ g_return_val_if_fail(item->folder != NULL, -1);
+ g_return_val_if_fail(item->folder->klass != NULL, -1);
+ if (item->no_select)
+ return -1;
+
+ item->scanning = TRUE;
+
+ if (item->cache == NULL)
+ folder_item_read_cache(item);
+
+ msglist = msgcache_get_msg_list(item->cache);
+
+ ret = syncronize_flags(item, msglist);
+
+ for (cur = msglist; cur != NULL; cur = g_slist_next(cur))
+ procmsg_msginfo_free((MsgInfo *) cur->data);
+
+ g_slist_free(msglist);
+
+ item->scanning = FALSE;
+
+ return ret;
+}
+
+static void folder_item_process_open (FolderItem *item,
void (*before_proc_func)(gpointer data),
void (*after_proc_func)(gpointer data),
gpointer data)
return msginfo;
}
-static gint syncronize_flags(FolderItem *item, MsgInfoList *msglist)
-{
- GRelation *relation;
- gint ret = 0;
- GSList *cur;
-
- if(msglist == NULL)
- return 0;
- if(item->folder->klass->get_flags == NULL)
- return 0;
- if (item->no_select)
- return 0;
-
- relation = g_relation_new(2);
- g_relation_index(relation, 0, g_direct_hash, g_direct_equal);
- if ((ret = item->folder->klass->get_flags(
- item->folder, item, msglist, relation)) == 0) {
- GTuples *tuples;
- MsgInfo *msginfo;
- MsgPermFlags permflags = 0;
- gboolean skip;
-
- folder_item_update_freeze();
- folder_item_set_batch(item, TRUE);
- for (cur = msglist; cur != NULL; cur = g_slist_next(cur)) {
- msginfo = (MsgInfo *) cur->data;
-
- tuples = g_relation_select(relation, msginfo, 0);
- skip = tuples->len < 1;
- if (!skip)
- permflags = GPOINTER_TO_INT(g_tuples_index(tuples, 0, 1));
- g_tuples_destroy(tuples);
- if (skip)
- continue;
-
- if (msginfo->flags.perm_flags != permflags) {
- procmsg_msginfo_change_flags(msginfo,
- permflags & ~msginfo->flags.perm_flags, 0,
- ~permflags & msginfo->flags.perm_flags, 0);
- }
- }
- folder_item_set_batch(item, FALSE);
- folder_item_update_thaw();
- }
- g_relation_destroy(relation);
-
- return ret;
-}
-
gint folder_item_scan_full(FolderItem *item, gboolean filtering)
{
Folder *folder;
if (do_filter) {
GSList *unfiltered;
+
+ folder_item_set_batch(item, TRUE);
procmsg_msglist_filter(newmsg_list, item->folder->account,
&to_filter, &unfiltered,
TRUE);
+ folder_item_set_batch(item, FALSE);
filtering_move_and_copy_msgs(newmsg_list);
if (to_filter != NULL) {
return folder_item_scan_full(item, TRUE);
}
-static void folder_item_scan_foreach_func(gpointer key, gpointer val,
- gpointer data)
-{
- folder_item_scan(FOLDER_ITEM(key));
-}
-
-void folder_item_scan_foreach(GHashTable *table)
-{
- g_hash_table_foreach(table, folder_item_scan_foreach_func, NULL);
-}
-
static void folder_count_total_cache_memusage(FolderItem *item, gpointer data)
{
gint *memusage = (gint *)data;
*memusage += msgcache_get_memory_usage(item->cache);
}
-gint folder_item_syncronize_flags(FolderItem *item)
-{
- MsgInfoList *msglist = NULL;
- GSList *cur;
- gint ret = 0;
-
- g_return_val_if_fail(item != NULL, -1);
- g_return_val_if_fail(item->folder != NULL, -1);
- g_return_val_if_fail(item->folder->klass != NULL, -1);
- if (item->no_select)
- return -1;
-
- item->scanning = TRUE;
-
- if (item->cache == NULL)
- folder_item_read_cache(item);
-
- msglist = msgcache_get_msg_list(item->cache);
-
- ret = syncronize_flags(item, msglist);
-
- for (cur = msglist; cur != NULL; cur = g_slist_next(cur))
- procmsg_msginfo_free((MsgInfo *) cur->data);
-
- g_slist_free(msglist);
-
- item->scanning = FALSE;
-
- return ret;
-}
-
static gint folder_cache_time_compare_func(gconstpointer a, gconstpointer b)
{
FolderItem *fa = (FolderItem *)a;
unreadmarkedcnt++;
if (MSG_IS_MARKED(msginfo->flags))
markedcnt++;
+ procmsg_msginfo_unset_flags(msginfo, MSG_FULLY_CACHED, 0);
}
item->new_msgs = newcnt;
item->unread_msgs = unreadcnt;
if (!item || !item->path || !item->cache)
return;
- if (FOLDER_TYPE(item->folder) == F_MH) {
- last_mtime = item->mtime;
- need_scan = item->folder->klass->scan_required(item->folder, item);
- }
+ last_mtime = item->mtime;
+ need_scan = item->folder->klass->scan_required(item->folder, item);
id = folder_item_get_identifier(item);
debug_print("Save cache for folder %s\n", id);
}
}
- if (!need_scan && FOLDER_TYPE(item->folder) == F_MH) {
+ if (!need_scan && item->folder->klass->set_mtime) {
if (item->mtime == last_mtime) {
- mh_set_mtime(item);
+ item->folder->klass->set_mtime(item->folder, item);
}
}
}
-gint folder_item_fetch_all_msg(FolderItem *item)
-{
- Folder *folder;
- GSList *mlist;
- GSList *cur;
- gint num = 0;
- gint ret = 0;
- gint total = 0;
-
- g_return_val_if_fail(item != NULL, -1);
- if (item->no_select)
- return -1;
-
- debug_print("fetching all messages in %s ...\n", item->path ? item->path : "(null)");
- statusbar_print_all(_("Fetching all messages in %s ...\n"), item->path ? item->path : "(null)");
-
- folder = item->folder;
-
- if (folder->ui_func)
- folder->ui_func(folder, item, folder->ui_func_data ?
- folder->ui_func_data : GINT_TO_POINTER(num));
-
- mlist = folder_item_get_msg_list(item);
-
- total = g_slist_length(mlist);
-
- for (cur = mlist; cur != NULL; cur = cur->next) {
- MsgInfo *msginfo = (MsgInfo *)cur->data;
- gchar *msg;
-
- statusbar_progress_all(num++,total, 10);
-
- if (folder->ui_func)
- folder->ui_func(folder, item,
- folder->ui_func_data ?
- folder->ui_func_data :
- GINT_TO_POINTER(num));
- if (num % 50 == 0)
- GTK_EVENTS_FLUSH();
-
- msg = folder_item_fetch_msg(item, msginfo->msgnum);
- if (!msg) {
- g_warning("Can't fetch message %d. Aborting.\n",
- msginfo->msgnum);
- ret = -1;
- break;
- }
- g_free(msg);
- }
-
- statusbar_progress_all(0,0,0);
- statusbar_pop_all();
- procmsg_msg_list_free(mlist);
-
- return ret;
-}
-
static gint folder_item_get_msg_num_by_file(FolderItem *dest, const gchar *file)
{
static HeaderEntry hentry[] = {{"Message-ID:", NULL, TRUE},
if (procmsg_msg_has_flagged_parent(dest, MSG_IGNORE_THREAD))
perm_flags |= MSG_IGNORE_THREAD;
+ /* unset FULLY_CACHED flags */
+ perm_flags &= ~MSG_FULLY_CACHED;
+
if (procmsg_msg_has_flagged_parent(dest, MSG_WATCH_THREAD))
perm_flags |= MSG_WATCH_THREAD;
if (source && source->tags) {
g_slist_free(dest->tags);
dest->tags = g_slist_copy(source->tags);
+ folder_item_commit_tags(dest->folder, dest, dest->tags, NULL);
}
}
if (!item->cache) folder_item_read_cache(item);
+ msginfo = msgcache_get_msg(item->cache, num);
+ if (msginfo && MSG_IS_LOCKED(msginfo->flags)) {
+ procmsg_msginfo_free(msginfo);
+ return -1;
+ }
ret = folder->klass->remove_msg(folder, item, num);
- msginfo = msgcache_get_msg(item->cache, num);
if (msginfo != NULL) {
remove_msginfo_from_cache(item, msginfo);
procmsg_msginfo_free(msginfo);
}
while (ret == 0 && msglist != NULL) {
MsgInfo *msginfo = (MsgInfo *)msglist->data;
- if (MSG_IS_LOCKED(msginfo->flags)) {
+ if (msginfo && MSG_IS_LOCKED(msginfo->flags)) {
msglist = msglist->next;
continue;
}
}
}
+void folder_item_commit_tags(FolderItem *item, MsgInfo *msginfo, GSList *tags_set, GSList *tags_unset)
+{
+ Folder *folder = NULL;
+
+ if (!msginfo)
+ return;
+ if (!item)
+ return;
+ if (!tags_set && !tags_unset)
+ return;
+
+ folder = item->folder;
+ if (!folder)
+ return;
+
+ if (folder->klass->commit_tags == NULL)
+ return;
+
+ folder->klass->commit_tags(item, msginfo, tags_set, tags_unset);
+}
+
gboolean folder_item_is_msg_changed(FolderItem *item, MsgInfo *msginfo)
{
Folder *folder;
return folder->klass->is_msg_changed(folder, item, msginfo);
}
+void folder_item_discard_cache(FolderItem *item)
+{
+ gchar *dir;
+ gchar *cache;
+
+ if (!item)
+ return;
+
+ if (item->cache) {
+ msgcache_destroy(item->cache);
+ item->cache = NULL;
+ }
+ dir = folder_item_get_path(item);
+ if (is_dir_exist(dir))
+ remove_all_numbered_files(dir);
+ g_free(dir);
+
+ cache = folder_item_get_cache_file(item);
+ if (is_file_exist(cache))
+ g_unlink(cache);
+ g_free(cache);
+
+}
+
static gchar *folder_item_get_cache_file(FolderItem *item)
{
gchar *path;
return filename;
}
-#define PUT_ESCAPE_STR(fp, attr, str) \
-{ \
- fputs(" " attr "=\"", fp); \
- xml_file_put_escape_str(fp, str); \
- fputs("\"", fp); \
-}
-
static gpointer folder_item_to_xml(gpointer nodedata, gpointer data)
{
FolderItem *item = (FolderItem *) nodedata;
debug_print("processing %s\n", item->name);
folder_item_update_freeze();
+ inc_lock();
+
mlist = folder_item_get_msg_list(item);
total = g_slist_length(mlist);
statusbar_print_all(_("Processing messages..."));
last_apply_per_account = prefs_common.apply_per_account_filtering_rules;
prefs_common.apply_per_account_filtering_rules = FILTERING_ACCOUNT_RULES_SKIP;
+ folder_item_set_batch(item, TRUE);
for (cur = mlist ; cur != NULL ; cur = cur->next) {
MsgInfo * msginfo;
if (curmsg % 1000 == 0)
GTK_EVENTS_FLUSH();
}
+ folder_item_set_batch(item, FALSE);
+
prefs_common.apply_per_account_filtering_rules = last_apply_per_account;
if (pre_global_processing || processing_list
statusbar_progress_all(0,0,0);
statusbar_pop_all();
+ inc_unlock();
+
folder_item_update_thaw();
}
if (!item)
return;
if (item->prefs->offlinesync && item->folder->klass->synchronise) {
- statusbar_print_all(_("Synchronising %s for offline use...\n"), item->path ? item->path : "(null)");
+ statuswindow_print_all(_("Synchronising %s for offline use...\n"), item->path ? item->path : "(null)");
item->folder->klass->synchronise(item,
item->prefs->offlinesync_days);
if (item->prefs->offlinesync_days > 0 &&
item->prefs->remove_old_bodies)
folder_item_clean_local_files(item, item->prefs->offlinesync_days);
- statusbar_pop_all();
+ statuswindow_pop_all();
}
}
folder->klass->get_sort_type(folder, sort_key, sort_type);
return TRUE;
}
-
-#undef PUT_ESCAPE_STR
projects / claws.git / blobdiff