diff options
Diffstat (limited to 'camel/providers/imap4/camel-imap4-folder.c')
| -rw-r--r-- | camel/providers/imap4/camel-imap4-folder.c | 1178 |
1 files changed, 0 insertions, 1178 deletions
diff --git a/camel/providers/imap4/camel-imap4-folder.c b/camel/providers/imap4/camel-imap4-folder.c deleted file mode 100644 index 9326dd418f..0000000000 --- a/camel/providers/imap4/camel-imap4-folder.c +++ /dev/null @@ -1,1178 +0,0 @@ -/* -*- Mode: C; tab-width: 8; indent-tabs-mode: t; c-basic-offset: 8 -*- */ -/* Camel - * Copyright (C) 1999-2004 Jeffrey Stedfast - * - * 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 - * the Free Software Foundation; either version 2 of the License, or - * (at your option) any later version. - * - * This program is distributed in the hope that it will be useful, - * but WITHOUT ANY WARRANTY; without even the implied warranty of - * MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the - * GNU General Public License for more details. - * - * You should have received a copy of the GNU General Public License - * along with this program; if not, write to the Free Software - * Foundation, Inc., 59 Temple Street #330, Boston, MA 02111-1307, USA. - */ - - -#ifdef HAVE_CONFIG_H -#include <config.h> -#endif - -#include <glib.h> - -#include <stdio.h> -#include <stdlib.h> -#include <string.h> -#include <sys/types.h> -#include <sys/stat.h> -#include <dirent.h> -#include <unistd.h> -#include <fcntl.h> -#include <errno.h> -#include <time.h> - -#include <camel/camel-utf8.h> -#include <camel/camel-private.h> -#include <camel/camel-file-utils.h> -#include <camel/camel-mime-message.h> -#include <camel/camel-stream-mem.h> -#include <camel/camel-stream-filter.h> -#include <camel/camel-mime-filter-crlf.h> -#include <camel/camel-i18n.h> - -#include "camel-imap4-utils.h" -#include "camel-imap4-store.h" -#include "camel-imap4-engine.h" -#include "camel-imap4-folder.h" -#include "camel-imap4-stream.h" -#include "camel-imap4-command.h" -#include "camel-imap4-summary.h" -#include "camel-imap4-search.h" - -#define d(x) x - -static GSList *imap4_folder_props = NULL; - -static CamelProperty imap4_prop_list[] = { - { CAMEL_IMAP4_FOLDER_SYNC_OFFLINE, "sync_offline", N_("Copy folder content locally for offline operation") }, -}; - -static void camel_imap4_folder_class_init (CamelIMAP4FolderClass *klass); -static void camel_imap4_folder_init (CamelIMAP4Folder *folder, CamelIMAP4FolderClass *klass); -static void camel_imap4_folder_finalize (CamelObject *object); - -static int imap4_getv (CamelObject *object, CamelException *ex, CamelArgGetV *args); -static int imap4_setv (CamelObject *object, CamelException *ex, CamelArgV *args); - -static void imap4_sync (CamelFolder *folder, gboolean expunge, CamelException *ex); -static void imap4_refresh_info (CamelFolder *folder, CamelException *ex); -static void imap4_expunge (CamelFolder *folder, CamelException *ex); -static CamelMimeMessage *imap4_get_message (CamelFolder *folder, const char *uid, CamelException *ex); -static void imap4_append_message (CamelFolder *folder, CamelMimeMessage *message, - const CamelMessageInfo *info, char **appended_uid, CamelException *ex); -static void imap4_transfer_messages_to (CamelFolder *src, GPtrArray *uids, CamelFolder *dest, - GPtrArray **transferred_uids, gboolean move, CamelException *ex); -static GPtrArray *imap4_search_by_expression (CamelFolder *folder, const char *expr, CamelException *ex); -static GPtrArray *imap4_search_by_uids (CamelFolder *folder, const char *expr, GPtrArray *uids, CamelException *ex); -static void imap4_search_free (CamelFolder *folder, GPtrArray *uids); - - -static CamelFolderClass *parent_class = NULL; - - -CamelType -camel_imap4_folder_get_type (void) -{ - static CamelType type = 0; - - if (!type) { - type = camel_type_register (CAMEL_FOLDER_TYPE, - "CamelIMAP4Folder", - sizeof (CamelIMAP4Folder), - sizeof (CamelIMAP4FolderClass), - (CamelObjectClassInitFunc) camel_imap4_folder_class_init, - NULL, - (CamelObjectInitFunc) camel_imap4_folder_init, - (CamelObjectFinalizeFunc) camel_imap4_folder_finalize); - } - - return type; -} - -static void -camel_imap4_folder_class_init (CamelIMAP4FolderClass *klass) -{ - CamelFolderClass *folder_class = (CamelFolderClass *) klass; - CamelObjectClass *object_class = (CamelObjectClass *) klass; - int i; - - parent_class = (CamelFolderClass *) camel_type_get_global_classfuncs (CAMEL_FOLDER_TYPE); - - for (i = 0; i < G_N_ELEMENTS (imap4_prop_list); i++) { - imap4_prop_list[i].description = _(imap4_prop_list[i].description); - imap4_folder_props = g_slist_prepend (imap4_folder_props, &imap4_prop_list[i]); - } - - object_class->getv = imap4_getv; - object_class->setv = imap4_setv; - - folder_class->sync = imap4_sync; - folder_class->refresh_info = imap4_refresh_info; - folder_class->expunge = imap4_expunge; - folder_class->get_message = imap4_get_message; - folder_class->append_message = imap4_append_message; - folder_class->transfer_messages_to = imap4_transfer_messages_to; - folder_class->search_by_expression = imap4_search_by_expression; - folder_class->search_by_uids = imap4_search_by_uids; - folder_class->search_free = imap4_search_free; -} - -static void -camel_imap4_folder_init (CamelIMAP4Folder *folder, CamelIMAP4FolderClass *klass) -{ - ((CamelFolder *) folder)->folder_flags |= CAMEL_FOLDER_HAS_SUMMARY_CAPABILITY | CAMEL_FOLDER_HAS_SEARCH_CAPABILITY; - - folder->sync_offline = FALSE; - folder->utf7_name = NULL; - folder->cachedir = NULL; - folder->search = NULL; -} - -static void -camel_imap4_folder_finalize (CamelObject *object) -{ - CamelIMAP4Folder *folder = (CamelIMAP4Folder *) object; - - camel_object_unref (folder->search); - - if (folder->cache) - camel_object_unref (folder->cache); - - g_free (folder->utf7_name); - g_free (folder->cachedir); -} - -static int -imap4_getv (CamelObject *object, CamelException *ex, CamelArgGetV *args) -{ - CamelArgGetV props; - int i, count = 0; - guint32 tag; - - for (i = 0; i <args->argc; i++) { - CamelArgGet *arg = &args->argv[i]; - - tag = arg->tag; - - switch (tag & CAMEL_ARG_TAG) { - case CAMEL_OBJECT_ARG_PERSISTENT_PROPERTIES: - case CAMEL_FOLDER_ARG_PROPERTIES: - props.argc = 1; - props.argv[0] = *arg; - ((CamelObjectClass *) parent_class)->getv (object, ex, &props); - *arg->ca_ptr = g_slist_concat (*arg->ca_ptr, g_slist_copy (imap4_folder_props)); - break; - case CAMEL_IMAP4_FOLDER_ARG_SYNC_OFFLINE: - *arg->ca_int = ((CamelIMAP4Folder *) object)->sync_offline; - break; - default: - count++; - continue; - } - - arg->tag = (tag & CAMEL_ARG_TYPE) | CAMEL_ARG_IGNORE; - } - - if (count) - return ((CamelObjectClass *) parent_class)->getv (object, ex, args); - - return 0; -} - -static int -imap4_setv (CamelObject *object, CamelException *ex, CamelArgV *args) -{ - CamelIMAP4Folder *folder = (CamelIMAP4Folder *) object; - gboolean save = FALSE; - guint32 tag; - int i; - - for (i = 0; i < args->argc; i++) { - CamelArg *arg = &args->argv[i]; - - tag = arg->tag; - - switch (tag & CAMEL_ARG_TAG) { - case CAMEL_IMAP4_FOLDER_ARG_SYNC_OFFLINE: - if (folder->sync_offline != arg->ca_int) { - folder->sync_offline = arg->ca_int; - save = TRUE; - } - break; - default: - continue; - } - - arg->tag = (tag & CAMEL_ARG_TYPE) | CAMEL_ARG_IGNORE; - } - - if (save) - camel_object_state_write (object); - - return ((CamelObjectClass *) parent_class)->setv (object, ex, args); -} - - -static char * -imap_get_summary_filename (const char *path) -{ - /* /path/to/imap/summary */ - return g_build_filename (path, "summary", NULL); -} - -static char * -imap_build_filename (const char *toplevel_dir, const char *full_name) -{ - const char *inptr = full_name; - int subdirs = 0; - char *path, *p; - - if (*full_name == '\0') - return g_strdup (toplevel_dir); - - while (*inptr != '\0') { - if (*inptr == '/') - subdirs++; - inptr++; - } - - path = g_malloc (strlen (toplevel_dir) + (inptr - full_name) + (12 * subdirs) + 2); - p = g_stpcpy (path, toplevel_dir); - - if (p[-1] != '/') - *p++ = '/'; - - inptr = full_name; - while (*inptr != '\0') { - while (*inptr != '/' && *inptr != '\0') - *p++ = *inptr++; - - if (*inptr == '/') { - p = g_stpcpy (p, "/subfolders/"); - inptr++; - - /* strip extranaeous '/'s */ - while (*inptr == '/') - inptr++; - } - } - - *p = '\0'; - - return path; -} - -static char * -imap_store_build_filename (void *store, const char *full_name) -{ - CamelIMAP4Store *imap_store = (CamelIMAP4Store *) store; - char *toplevel_dir; - char *path; - - toplevel_dir = g_strdup_printf ("%s/folders", imap_store->storage_path); - path = imap_build_filename (toplevel_dir, full_name); - g_free (toplevel_dir); - - return path; -} - - -CamelFolder * -camel_imap4_folder_new (CamelStore *store, const char *full_name, CamelException *ex) -{ - CamelIMAP4Folder *imap_folder; - char *utf7_name, *name, *p; - CamelFolder *folder; - char *path; - char sep; - - if (!(p = strrchr (full_name, '/'))) - p = (char *) full_name; - else - p++; - - name = g_alloca (strlen (p) + 1); - strcpy (name, p); - - utf7_name = g_alloca (strlen (full_name) + 1); - strcpy (utf7_name, full_name); - - sep = camel_imap4_get_path_delim (((CamelIMAP4Store *) store)->summary, full_name); - if (sep != '/') { - p = utf7_name; - while (*p != '\0') { - if (*p == '/') - *p = sep; - p++; - } - } - - utf7_name = camel_utf8_utf7 (utf7_name); - - folder = (CamelFolder *) (imap_folder = (CamelIMAP4Folder *) camel_object_new (CAMEL_TYPE_IMAP4_FOLDER)); - camel_folder_construct (folder, store, full_name, name); - imap_folder->utf7_name = utf7_name; - - folder->summary = camel_imap4_summary_new (folder); - imap_folder->cachedir = imap_store_build_filename (store, folder->full_name); - camel_mkdir (imap_folder->cachedir, 0777); - - imap_folder->cache = camel_data_cache_new (imap_folder->cachedir, 0, NULL); - - path = imap_get_summary_filename (imap_folder->cachedir); - camel_folder_summary_set_filename (folder->summary, path); - g_free (path); - - imap_folder->search = camel_imap4_search_new (((CamelIMAP4Store *) store)->engine, imap_folder->cachedir); - - if (camel_session_is_online (((CamelService *) store)->session)) { - /* we don't care if the summary loading fails here */ - camel_folder_summary_load (folder->summary); - - if (camel_imap4_engine_select_folder (((CamelIMAP4Store *) store)->engine, folder, ex) == -1) { - camel_object_unref (folder); - folder = NULL; - } - - if (folder && camel_imap4_summary_flush_updates (folder->summary, ex) == -1) { - camel_object_unref (folder); - folder = NULL; - } - } else { - /* we *do* care if summary loading fails here though */ - if (camel_folder_summary_load (folder->summary) == -1) { - camel_exception_setv (ex, CAMEL_EXCEPTION_FOLDER_INVALID_PATH, - _("Cannot access folder `%s': %s"), - full_name, g_strerror (ENOENT)); - - camel_object_unref (folder); - folder = NULL; - } - } - - return folder; -} - -const char * -camel_imap4_folder_utf7_name (CamelIMAP4Folder *folder) -{ - return folder->utf7_name; -} - - -static struct { - const char *name; - guint32 flag; -} imap4_flags[] = { - { "\\Answered", CAMEL_MESSAGE_ANSWERED }, - { "\\Deleted", CAMEL_MESSAGE_DELETED }, - { "\\Draft", CAMEL_MESSAGE_DRAFT }, - { "\\Flagged", CAMEL_MESSAGE_FLAGGED }, - /*{ "$Forwarded", CAMEL_MESSAGE_FORWARDED },*/ - { "\\Seen", CAMEL_MESSAGE_SEEN }, -}; - - -static int -imap4_sync_flag (CamelFolder *folder, GPtrArray *infos, char onoff, const char *flag, CamelException *ex) -{ - CamelIMAP4Engine *engine = ((CamelIMAP4Store *) folder->parent_store)->engine; - CamelIMAP4Command *ic; - int i, id, retval = 0; - char *set = NULL; - - for (i = 0; i < infos->len; ) { - i += camel_imap4_get_uid_set (engine, folder->summary, infos, i, 30 + strlen (flag), &set); - - ic = camel_imap4_engine_queue (engine, folder, "UID STORE %s %cFLAGS.SILENT (%s)\r\n", set, onoff, flag); - while ((id = camel_imap4_engine_iterate (engine)) < ic->id && id != -1) - ; - - g_free (set); - - if (id == -1 || ic->status != CAMEL_IMAP4_COMMAND_COMPLETE) { - camel_exception_xfer (ex, &ic->ex); - camel_imap4_command_unref (ic); - - return -1; - } - - switch (ic->result) { - case CAMEL_IMAP4_RESULT_NO: - /* FIXME: would be good to save the NO reason into the err message */ - camel_exception_setv (ex, CAMEL_EXCEPTION_SYSTEM, - _("Cannot sync flags to folder `%s': Unknown"), - folder->full_name); - retval = -1; - break; - case CAMEL_IMAP4_RESULT_BAD: - camel_exception_setv (ex, CAMEL_EXCEPTION_SYSTEM, - _("Cannot sync flags to folder `%s': Bad command"), - folder->full_name); - retval = -1; - break; - } - - camel_imap4_command_unref (ic); - - if (retval == -1) - return -1; - } - - return 0; -} - -static int -imap4_sync_changes (CamelFolder *folder, GPtrArray *sync, CamelException *ex) -{ - CamelIMAP4MessageInfo *iinfo; - GPtrArray *on_set, *off_set; - CamelMessageInfo *info; - flags_diff_t diff; - int retval = 0; - int i, j; - - if (folder->permanent_flags == 0) - return 0; - - on_set = g_ptr_array_new (); - off_set = g_ptr_array_new (); - - /* construct commands to sync system and user flags */ - for (i = 0; i < G_N_ELEMENTS (imap4_flags); i++) { - if (!(imap4_flags[i].flag & folder->permanent_flags)) - continue; - - for (j = 0; j < sync->len; j++) { - iinfo = (CamelIMAP4MessageInfo *) (info = sync->pdata[j]); - camel_imap4_flags_diff (&diff, iinfo->server_flags, iinfo->info.flags); - if (diff.changed & imap4_flags[i].flag) { - if (diff.bits & imap4_flags[i].flag) { - g_ptr_array_add (on_set, info); - } else { - g_ptr_array_add (off_set, info); - } - } - } - - if (on_set->len > 0) { - if ((retval = imap4_sync_flag (folder, on_set, '+', imap4_flags[i].name, ex)) == -1) - break; - - g_ptr_array_set_size (on_set, 0); - } - - if (off_set->len > 0) { - if ((retval = imap4_sync_flag (folder, off_set, '-', imap4_flags[i].name, ex)) == -1) - break; - - g_ptr_array_set_size (off_set, 0); - } - } - - g_ptr_array_free (on_set, TRUE); - g_ptr_array_free (off_set, TRUE); - - if (retval == -1) - return-1; - - for (i = 0; i < sync->len; i++) { - iinfo = (CamelIMAP4MessageInfo *) (info = sync->pdata[i]); - iinfo->info.flags &= ~CAMEL_MESSAGE_FOLDER_FLAGGED; - iinfo->server_flags = iinfo->info.flags & folder->permanent_flags; - } - - return 0; -} - -static void -imap4_sync (CamelFolder *folder, gboolean expunge, CamelException *ex) -{ - CamelIMAP4Engine *engine = ((CamelIMAP4Store *) folder->parent_store)->engine; - CamelSession *session = ((CamelService *) folder->parent_store)->session; - CamelIMAP4MessageInfo *iinfo; - CamelMessageInfo *info; - CamelIMAP4Command *ic; - flags_diff_t diff; - GPtrArray *sync; - int id, max, i; - int retval; - - if (!camel_session_is_online (session)) - return; - - CAMEL_SERVICE_LOCK (folder->parent_store, connect_lock); - - /* gather a list of changes to sync to the server */ - sync = g_ptr_array_new (); - max = camel_folder_summary_count (folder->summary); - for (i = 0; i < max; i++) { - iinfo = (CamelIMAP4MessageInfo *) (info = camel_folder_summary_index (folder->summary, i)); - if (iinfo->info.flags & CAMEL_MESSAGE_FOLDER_FLAGGED) { - camel_imap4_flags_diff (&diff, iinfo->server_flags, iinfo->info.flags); - diff.changed &= folder->permanent_flags; - - /* weed out flag changes that we can't sync to the server */ - if (!diff.changed) - camel_message_info_free(info); - else - g_ptr_array_add (sync, info); - } else { - camel_message_info_free(info); - } - } - - if (sync->len > 0) { - retval = imap4_sync_changes (folder, sync, ex); - - for (i = 0; i < sync->len; i++) - camel_message_info_free(sync->pdata[i]); - - g_ptr_array_free (sync, TRUE); - - if (retval == -1) - goto done; - } else { - g_ptr_array_free (sync, TRUE); - } - - if (expunge) { - ic = camel_imap4_engine_queue (engine, folder, "EXPUNGE\r\n"); - while ((id = camel_imap4_engine_iterate (engine)) < ic->id && id != -1) - ; - - switch (ic->result) { - case CAMEL_IMAP4_RESULT_OK: - camel_imap4_summary_flush_updates (folder->summary, ex); - break; - case CAMEL_IMAP4_RESULT_NO: - /* FIXME: would be good to save the NO reason into the err message */ - camel_exception_setv (ex, CAMEL_EXCEPTION_SYSTEM, - _("Cannot expunge folder `%s': Unknown"), - folder->full_name); - break; - case CAMEL_IMAP4_RESULT_BAD: - camel_exception_setv (ex, CAMEL_EXCEPTION_SYSTEM, - _("Cannot expunge folder `%s': Bad command"), - folder->full_name); - break; - } - - camel_imap4_command_unref (ic); - } else { - camel_imap4_summary_flush_updates (folder->summary, ex); - } - - camel_folder_summary_save (folder->summary); - - done: - - CAMEL_SERVICE_UNLOCK (folder->parent_store, connect_lock); -} - -static void -imap4_expunge (CamelFolder *folder, CamelException *ex) -{ - imap4_sync (folder, TRUE, ex); -} - -static void -imap4_refresh_info (CamelFolder *folder, CamelException *ex) -{ - CamelIMAP4Engine *engine = ((CamelIMAP4Store *) folder->parent_store)->engine; - CamelSession *session = ((CamelService *) folder->parent_store)->session; - CamelFolder *selected = (CamelFolder *) engine->folder; - CamelIMAP4Command *ic; - int id; - - if (!camel_session_is_online (session)) - return; - - CAMEL_SERVICE_LOCK (folder->parent_store, connect_lock); - - if (folder != selected) { - if (camel_imap4_engine_select_folder (engine, folder, ex) == -1) - goto done; - - ((CamelIMAP4Summary *) folder->summary)->update_flags = TRUE; - } else { - ic = camel_imap4_engine_queue (engine, NULL, "NOOP\r\n"); - while ((id = camel_imap4_engine_iterate (engine)) < ic->id && id != -1) - ; - - if (id == -1 || ic->status != CAMEL_IMAP4_COMMAND_COMPLETE) - camel_exception_xfer (ex, &ic->ex); - - camel_imap4_command_unref (ic); - - if (camel_exception_is_set (ex)) - goto done; - } - - camel_imap4_summary_flush_updates (folder->summary, ex); - - done: - - CAMEL_SERVICE_UNLOCK (folder->parent_store, connect_lock); -} - -static int -untagged_fetch (CamelIMAP4Engine *engine, CamelIMAP4Command *ic, guint32 index, camel_imap4_token_t *token, CamelException *ex) -{ - CamelFolderSummary *summary = ((CamelFolder *) engine->folder)->summary; - CamelStream *fstream, *stream = ic->user_data; - CamelFolderChangeInfo *changes; - CamelIMAP4MessageInfo *iinfo; - CamelMessageInfo *info; - CamelMimeFilter *crlf; - guint32 flags; - - if (camel_imap4_engine_next_token (engine, token, ex) == -1) - return -1; - - /* parse the FETCH response list */ - if (token->token != '(') { - camel_imap4_utils_set_unexpected_token_error (ex, engine, token); - return -1; - } - - do { - if (camel_imap4_engine_next_token (engine, token, ex) == -1) - goto exception; - - if (token->token == ')' || token->token == '\n') - break; - - if (token->token != CAMEL_IMAP4_TOKEN_ATOM) - goto unexpected; - - if (!strcmp (token->v.atom, "BODY[")) { - if (camel_imap4_engine_next_token (engine, token, ex) == -1) - goto exception; - - if (token->token != ']') - goto unexpected; - - if (camel_imap4_engine_next_token (engine, token, ex) == -1) - goto exception; - - if (token->token != CAMEL_IMAP4_TOKEN_LITERAL) - goto unexpected; - - fstream = (CamelStream *) camel_stream_filter_new_with_stream (stream); - crlf = camel_mime_filter_crlf_new (CAMEL_MIME_FILTER_CRLF_DECODE, CAMEL_MIME_FILTER_CRLF_MODE_CRLF_ONLY); - camel_stream_filter_add ((CamelStreamFilter *) fstream, crlf); - camel_object_unref (crlf); - - camel_stream_write_to_stream ((CamelStream *) engine->istream, fstream); - camel_stream_flush (fstream); - camel_object_unref (fstream); - } else if (!strcmp (token->v.atom, "UID")) { - if (camel_imap4_engine_next_token (engine, token, ex) == -1) - goto exception; - - if (token->token != CAMEL_IMAP4_TOKEN_NUMBER || token->v.number == 0) - goto unexpected; - } else if (!strcmp (token->v.atom, "FLAGS")) { - /* even though we didn't request this bit of information, it might be - * given to us if another client recently changed the flags... */ - if (camel_imap4_parse_flags_list (engine, &flags, ex) == -1) - goto exception; - - if ((info = camel_folder_summary_index (summary, index - 1))) { - iinfo = (CamelIMAP4MessageInfo *) info; - iinfo->info.flags = camel_imap4_merge_flags (iinfo->server_flags, iinfo->info.flags, flags); - iinfo->server_flags = flags; - - changes = camel_folder_change_info_new (); - camel_folder_change_info_change_uid (changes, camel_message_info_uid (info)); - camel_object_trigger_event (engine->folder, "folder_changed", changes); - camel_folder_change_info_free (changes); - - camel_message_info_free(info); - } - } else { - /* wtf? */ - fprintf (stderr, "huh? %s?...\n", token->v.atom); - } - } while (1); - - if (token->token != ')') { - fprintf (stderr, "expected ')' to close untagged FETCH response\n"); - goto unexpected; - } - - return 0; - - unexpected: - - camel_imap4_utils_set_unexpected_token_error (ex, engine, token); - - exception: - - return -1; -} - -static CamelMimeMessage * -imap4_get_message (CamelFolder *folder, const char *uid, CamelException *ex) -{ - CamelIMAP4Engine *engine = ((CamelIMAP4Store *) folder->parent_store)->engine; - CamelSession *session = ((CamelService *) folder->parent_store)->session; - CamelIMAP4Folder *imap_folder = (CamelIMAP4Folder *) folder; - CamelMimeMessage *message = NULL; - CamelStream *stream, *cache; - CamelIMAP4Command *ic; - int id; - - CAMEL_SERVICE_LOCK (folder->parent_store, connect_lock); - - if (imap_folder->cache && (stream = camel_data_cache_get (imap_folder->cache, "cache", uid, ex))) { - message = camel_mime_message_new (); - - if (camel_data_wrapper_construct_from_stream ((CamelDataWrapper *) message, stream) == -1) { - if (errno == EINTR) { - CAMEL_SERVICE_UNLOCK (folder->parent_store, connect_lock); - camel_exception_setv (ex, CAMEL_EXCEPTION_USER_CANCEL, _("User cancelled")); - camel_object_unref (message); - camel_object_unref (stream); - return NULL; - } else { - camel_exception_setv (ex, CAMEL_EXCEPTION_SYSTEM, _("Cannot get message %s: %s"), - uid, g_strerror (errno)); - camel_object_unref (message); - message = NULL; - } - } - - camel_object_unref (stream); - } - - if (message != NULL) { - CAMEL_SERVICE_UNLOCK (folder->parent_store, connect_lock); - return message; - } - - if (!camel_session_is_online (session)) { - CAMEL_SERVICE_UNLOCK (folder->parent_store, connect_lock); - camel_exception_set (ex, CAMEL_EXCEPTION_SERVICE_UNAVAILABLE, - _("This message is not available in offline mode.")); - return NULL; - } - - /* Note: While some hard-core IMAP extremists are probably - * going to flame me for fetching entire messages here, it's - * the *only* sure-fire way of working with all IMAP - * servers. There are numerous problems with fetching - * individual MIME parts from a good handful of IMAP servers - * which makes this a pain to do the Right Way (tm). For - * example: Courier-IMAP has "issues" parsing some multipart - * messages apparently, because BODY responses are often - * inaccurate. I'm also not very trusting of the free German - * IMAP hosting either (such as mail.gmx.net and imap.web.de) - * as they have proven themselves to be quite flakey wrt FETCH - * requests (they seem to be written exclusively for - * Outlook). Also, some IMAP servers such as GroupWise don't - * store mail in MIME format and so must re-construct the - * entire message in order to extract the requested part, so - * it is *mush* more efficient (generally) to just request the - * entire message anyway. */ - ic = camel_imap4_engine_queue (engine, folder, "UID FETCH %s BODY.PEEK[]\r\n", uid); - camel_imap4_command_register_untagged (ic, "FETCH", untagged_fetch); - ic->user_data = stream = camel_stream_mem_new (); - - while ((id = camel_imap4_engine_iterate (engine)) < ic->id && id != -1) - ; - - if (id == -1 || ic->status != CAMEL_IMAP4_COMMAND_COMPLETE) { - camel_exception_xfer (ex, &ic->ex); - camel_imap4_command_unref (ic); - camel_object_unref (stream); - goto done; - } - - switch (ic->result) { - case CAMEL_IMAP4_RESULT_OK: - camel_stream_reset (stream); - message = camel_mime_message_new (); - camel_data_wrapper_construct_from_stream ((CamelDataWrapper *) message, stream); - camel_stream_reset (stream); - - /* cache the message locally */ - if (imap_folder->cache && (cache = camel_data_cache_add (imap_folder->cache, "cache", uid, NULL))) { - if (camel_stream_write_to_stream (stream, cache) == -1 - || camel_stream_flush (cache) == -1) - camel_data_cache_remove (imap_folder->cache, "cache", uid, NULL); - camel_object_unref (cache); - } - - break; - case CAMEL_IMAP4_RESULT_NO: - /* FIXME: would be good to save the NO reason into the err message */ - camel_exception_setv (ex, CAMEL_EXCEPTION_SYSTEM, - _("Cannot get message %s from folder `%s': No such message"), - uid, folder->full_name); - break; - case CAMEL_IMAP4_RESULT_BAD: - camel_exception_setv (ex, CAMEL_EXCEPTION_SYSTEM, - _("Cannot get message %s from folder `%s': Bad command"), - uid, folder->full_name); - break; - } - - camel_imap4_command_unref (ic); - - camel_object_unref (stream); - - done: - - CAMEL_SERVICE_UNLOCK (folder->parent_store, connect_lock); - - return message; -} - -static char *tm_months[] = { - "Jan", "Feb", "Mar", "Apr", "May", "Jun", - "Jul", "Aug", "Sep", "Oct", "Nov", "Dec" -}; - -static void -imap4_append_message (CamelFolder *folder, CamelMimeMessage *message, - const CamelMessageInfo *info, char **appended_uid, CamelException *ex) -{ - CamelIMAP4Engine *engine = ((CamelIMAP4Store *) folder->parent_store)->engine; - CamelSession *session = ((CamelService *) folder->parent_store)->session; - CamelIMAP4Summary *summary = (CamelIMAP4Summary *) folder->summary; - const CamelIMAP4MessageInfo *iinfo = (const CamelIMAP4MessageInfo *)info; - CamelIMAP4RespCode *resp; - CamelIMAP4Command *ic; - CamelFolderInfo *fi; - CamelException lex; - char flags[100], *p; - char date[50]; - struct tm tm; - int id, i; - - if (appended_uid) - *appended_uid = NULL; - - if (!camel_session_is_online (session)) { - camel_exception_set (ex, CAMEL_EXCEPTION_SYSTEM, _("Cannot append messages to IMAP folders in offline mode.")); - return; - } - - CAMEL_SERVICE_LOCK (folder->parent_store, connect_lock); - - /* construct the option flags list */ - if (iinfo->info.flags & folder->permanent_flags) { - p = g_stpcpy (flags, " ("); - - for (i = 0; i < G_N_ELEMENTS (imap4_flags); i++) { - if ((iinfo->info.flags & imap4_flags[i].flag) & folder->permanent_flags) { - p = g_stpcpy (p, imap4_flags[i].name); - *p++ = ' '; - } - } - - p[-1] = ')'; - *p = '\0'; - } else { - flags[0] = '\0'; - } - - /* construct the optional date_time string */ - if (iinfo->info.date_received != (time_t) -1) { - int tzone; - -#ifdef HAVE_LOCALTIME_R - localtime_r (&info->date_received, &tm); -#else - memcpy (&tm, localtime (&iinfo->info.date_received), sizeof (tm)); -#endif - -#if defined (HAVE_TM_GMTOFF) - tzone = -tm.tm_gmtoff; -#elif defined (HAVE_TIMEZONE) - if (tm.tm_isdst > 0) { -#if defined (HAVE_ALTZONE) - tzone = altzone; -#else /* !defined (HAVE_ALTZONE) */ - tzone = (timezone - 3600); -#endif - } else { - tzone = timezone; - } -#else -#error Neither HAVE_TIMEZONE nor HAVE_TM_GMTOFF defined. Rerun autoheader, autoconf, etc. -#endif - - sprintf (date, " \"%02d-%s-%04d %02d:%02d:%02d %+05d\"", - tm.tm_mday, tm_months[tm.tm_mon], tm.tm_year + 1900, - tm.tm_hour, tm.tm_min, tm.tm_sec, tzone); - } else { - date[0] = '\0'; - } - - retry: - - if (engine->capa & CAMEL_IMAP4_CAPABILITY_UIDPLUS) - ic = camel_imap4_engine_queue (engine, NULL, "UID APPEND %F%s%s %L\r\n", flags, date, message); - else - ic = camel_imap4_engine_queue (engine, NULL, "APPEND %F%s%s %L\r\n", flags, date, message); - - while ((id = camel_imap4_engine_iterate (engine)) < ic->id && id != -1) - ; - - if (id == -1 || ic->status != CAMEL_IMAP4_COMMAND_COMPLETE) { - camel_exception_xfer (ex, &ic->ex); - camel_imap4_command_unref (ic); - CAMEL_SERVICE_UNLOCK (folder->parent_store, connect_lock); - return; - } - - switch (ic->result) { - case CAMEL_IMAP4_RESULT_OK: - if (!(engine->capa & CAMEL_IMAP4_CAPABILITY_UIDPLUS)) - break; - - if (!appended_uid) - break; - - for (i = 0; i < ic->resp_codes->len; i++) { - resp = ic->resp_codes->pdata[i]; - if (resp->code == CAMEL_IMAP4_RESP_CODE_APPENDUID) { - if (resp->v.appenduid.uidvalidity == summary->uidvalidity) - *appended_uid = g_strdup_printf ("%u", resp->v.appenduid.uid); - break; - } - } - break; - case CAMEL_IMAP4_RESULT_NO: - /* FIXME: can we give the user any more information? */ - camel_exception_setv (ex, CAMEL_EXCEPTION_SYSTEM, - _("Cannot append message to folder `%s': Unknown error"), - folder->full_name); - - for (i = 0; i < ic->resp_codes->len; i++) { - resp = ic->resp_codes->pdata[i]; - if (resp->code == CAMEL_IMAP4_RESP_CODE_TRYCREATE) { - char *parent_name, *p; - - parent_name = g_alloca (strlen (folder->full_name) + 1); - if (!(p = strrchr (parent_name, '/'))) - *parent_name = '\0'; - else - *p = '\0'; - - if (!(fi = camel_store_create_folder (folder->parent_store, parent_name, folder->name, &lex))) { - camel_exception_clear (&lex); - break; - } - - camel_store_free_folder_info (folder->parent_store, fi); - camel_imap4_command_unref (ic); - camel_exception_clear (ex); - goto retry; - } - } - - break; - case CAMEL_IMAP4_RESULT_BAD: - camel_exception_setv (ex, CAMEL_EXCEPTION_SYSTEM, - _("Cannot append message to folder `%s': Bad command"), - folder->full_name); - - break; - default: - g_assert_not_reached (); - } - - camel_imap4_command_unref (ic); - - CAMEL_SERVICE_UNLOCK (folder->parent_store, connect_lock); -} - - -static int -info_uid_sort (const CamelMessageInfo **info0, const CamelMessageInfo **info1) -{ - guint32 uid0, uid1; - - uid0 = strtoul (camel_message_info_uid (*info0), NULL, 10); - uid1 = strtoul (camel_message_info_uid (*info1), NULL, 10); - - if (uid0 == uid1) - return 0; - - return uid0 < uid1 ? -1 : 1; -} - -static void -imap4_transfer_messages_to (CamelFolder *src, GPtrArray *uids, CamelFolder *dest, - GPtrArray **transferred_uids, gboolean move, CamelException *ex) -{ - CamelIMAP4Engine *engine = ((CamelIMAP4Store *) src->parent_store)->engine; - CamelSession *session = ((CamelService *) src->parent_store)->session; - int i, j, n, id, dest_namelen; - CamelMessageInfo *info; - CamelIMAP4Command *ic; - GPtrArray *infos; - char *set; - - if (!camel_session_is_online (session)) { - if (move) - camel_exception_set (ex, CAMEL_EXCEPTION_SYSTEM, - _("Cannot move messages to or from IMAP folders in offline mode.")); - else - camel_exception_set (ex, CAMEL_EXCEPTION_SYSTEM, - _("Cannot copy messages to or from IMAP folders in offline mode.")); - - return; - } - - infos = g_ptr_array_new (); - for (i = 0; i < uids->len; i++) { - if (!(info = camel_folder_summary_uid (src->summary, uids->pdata[i]))) - continue; - - g_ptr_array_add (infos, info); - } - - if (infos->len == 0) { - g_ptr_array_free (infos, TRUE); - return; - } - - g_ptr_array_sort (infos, (GCompareFunc) info_uid_sort); - - CAMEL_SERVICE_LOCK (src->parent_store, connect_lock); - - dest_namelen = strlen (camel_imap4_folder_utf7_name ((CamelIMAP4Folder *) dest)); - - for (i = 0; i < infos->len; i += n) { - n = camel_imap4_get_uid_set (engine, src->summary, infos, i, 10 + dest_namelen, &set); - - ic = camel_imap4_engine_queue (engine, src, "UID COPY %s %F\r\n", set, dest); - while ((id = camel_imap4_engine_iterate (engine)) < ic->id && id != -1) - ; - - g_free (set); - - if (id == -1 || ic->status != CAMEL_IMAP4_COMMAND_COMPLETE) { - camel_exception_xfer (ex, &ic->ex); - camel_imap4_command_unref (ic); - g_free (set); - goto done; - } - - switch (ic->result) { - case CAMEL_IMAP4_RESULT_NO: - /* FIXME: would be good to save the NO reason into the err message */ - if (move) { - camel_exception_setv (ex, CAMEL_EXCEPTION_SYSTEM, - _("Cannot move messages from folder `%s' to folder `%s': Unknown"), - src->full_name, dest->full_name); - } else { - camel_exception_setv (ex, CAMEL_EXCEPTION_SYSTEM, - _("Cannot copy messages from folder `%s' to folder `%s': Unknown"), - src->full_name, dest->full_name); - } - - goto done; - case CAMEL_IMAP4_RESULT_BAD: - if (move) { - camel_exception_setv (ex, CAMEL_EXCEPTION_SYSTEM, - _("Cannot move messages from folder `%s' to folder `%s': Bad command"), - src->full_name, dest->full_name); - } else { - camel_exception_setv (ex, CAMEL_EXCEPTION_SYSTEM, - _("Cannot copy messages from folder `%s' to folder `%s': Bad command"), - src->full_name, dest->full_name); - } - - goto done; - } - - camel_imap4_command_unref (ic); - - if (move) { - for (j = i; j < n; j++) { - info = infos->pdata[j]; - camel_folder_set_message_flags (src, camel_message_info_uid (info), - CAMEL_MESSAGE_DELETED, CAMEL_MESSAGE_DELETED); - } - - camel_folder_summary_touch (src->summary); - } - } - - done: - - for (i = 0; i < infos->len; i++) - camel_message_info_free(infos->pdata[i]); - g_ptr_array_free (infos, TRUE); - - CAMEL_SERVICE_LOCK (src->parent_store, connect_lock); -} - -static GPtrArray * -imap4_search_by_expression (CamelFolder *folder, const char *expr, CamelException *ex) -{ - CamelIMAP4Folder *imap4_folder = (CamelIMAP4Folder *) folder; - GPtrArray *matches; - - CAMEL_SERVICE_LOCK(folder->parent_store, connect_lock); - - camel_folder_search_set_folder (imap4_folder->search, folder); - matches = camel_folder_search_search (imap4_folder->search, expr, NULL, ex); - - CAMEL_SERVICE_UNLOCK(folder->parent_store, connect_lock); - - return matches; -} - -static GPtrArray * -imap4_search_by_uids (CamelFolder *folder, const char *expr, GPtrArray *uids, CamelException *ex) -{ - CamelIMAP4Folder *imap4_folder = (CamelIMAP4Folder *) folder; - GPtrArray *matches; - - if (uids->len == 0) - return g_ptr_array_new (); - - CAMEL_SERVICE_LOCK(folder->parent_store, connect_lock); - - camel_folder_search_set_folder (imap4_folder->search, folder); - matches = camel_folder_search_search (imap4_folder->search, expr, uids, ex); - - CAMEL_SERVICE_UNLOCK(folder->parent_store, connect_lock); - - return matches; -} - -static void -imap4_search_free (CamelFolder *folder, GPtrArray *uids) -{ - CamelIMAP4Folder *imap4_folder = (CamelIMAP4Folder *) folder; - - g_return_if_fail (imap4_folder->search); - - CAMEL_SERVICE_LOCK(folder->parent_store, connect_lock); - - camel_folder_search_free_result (imap4_folder->search, uids); - - CAMEL_SERVICE_UNLOCK(folder->parent_store, connect_lock); -} |