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);
+GSList *mbox_get_num_list(Folder *folder, FolderItem *item);
+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)
FILE *lockfp;
lockfile = g_strdup_printf("%s.%d", base, getpid());
- if ((lockfp = fopen(lockfile, "w")) == NULL) {
+ if ((lockfp = fopen(lockfile, "wb")) == NULL) {
FILE_OP_ERROR(lockfile, "fopen");
g_warning(_("can't create lock file %s\n"), lockfile);
g_warning(_("use 'flock' instead of 'file' if possible.\n"));
FILE * f;
mailfile * mf;
- f = fopen(filename, "r");
+ f = fopen(filename, "rb");
if (f == NULL) {
mailfile_error = MAILFILE_ERROR_FILE_NOT_FOUND;
int bread;
FILE * handle;
- handle = fopen(filename, "r");
+ handle = fopen(filename, "rb");
if (handle == NULL) {
mailfile_error = MAILFILE_ERROR_FILE_NOT_FOUND;
{
FILE * handle;
- handle = fopen(filename, "r");
+ handle = fopen(filename, "rb");
while (elt) {
struct _message m = elt->data;
}
}
- msginfo = procheader_file_parse(fp, flags, FALSE, FALSE);
+ msginfo = procheader_parse_stream(fp, flags, FALSE, FALSE);
if (!msginfo) return NULL;
{
FILE * fp;
- fp = fopen(filename, "r");
+ fp = fopen(filename, "rb");
if (fp == NULL)
return;
mbox_purge_deleted(mbox_path);
- fp = fopen(mbox_path, "r");
+ fp = fopen(mbox_path, "rb");
if (fp == NULL) {
g_free(mbox_path);
if (mbox_path == NULL)
return FALSE;
- src = fopen(mbox_path, "r");
+ src = fopen(mbox_path, "rb");
if (src == NULL) {
g_free(mbox_path);
return FALSE;
fseek(src, offset, SEEK_SET);
- dest = fopen(dest_filename, "w");
+ dest = fopen(dest_filename, "wb");
if (dest == NULL) {
mbox_unlock_file(src, mbox_path);
fclose(src);
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))
if (dest->last_num < 0) return -1;
}
- src_fp = fopen(file, "r");
+ src_fp = fopen(file, "rb");
if (src_fp == NULL) {
return -1;
}
if (mbox_path == NULL)
return -1;
- dest_fp = fopen(mbox_path, "a");
+ dest_fp = fopen(mbox_path, "ab");
if (dest_fp == NULL) {
fclose(src_fp);
g_free(mbox_path);
if (stat(file, &s) < 0) {
mbox_unlock_file(dest_fp, mbox_path);
- g_warning(_("unvalid file - %s.\n"), file);
+ g_warning(_("invalid file - %s.\n"), file);
fclose(dest_fp);
fclose(src_fp);
g_free(mbox_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);
if (mbox_path == NULL)
return -1;
- fp = fopen(mbox_path, "w");
+ fp = fopen(mbox_path, "wb");
if (fp == NULL) {
g_free(mbox_path);
return -1;
debug_print(_("save modification - %s\n"), mbox);
- mbox_fp = fopen(mbox, "r+");
+ mbox_fp = fopen(mbox, "rb+");
mbox_lockwrite_file(mbox_fp, mbox);
mbox_cache_synchronize_from_file(mbox_fp, mbox, TRUE);
new = g_strconcat(mbox, ".", itos((int) mbox), NULL);
- new_fp = fopen(new, "w");
+ new_fp = fopen(new, "wb");
if (change_file_mode_rw(new_fp, new) < 0) {
FILE_OP_ERROR(new, "chmod");
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;
}
debug_print(_("purge deleted messages - %s\n"), mbox);
- mbox_fp = fopen(mbox, "r+");
+ mbox_fp = fopen(mbox, "rb+");
mbox_lockwrite_file(mbox_fp, mbox);
mbox_cache_synchronize_from_file(mbox_fp, mbox, TRUE);
new = g_strconcat(mbox, ".", itos((int) mbox), NULL);
- new_fp = fopen(new, "w");
+ new_fp = fopen(new, "wb");
if (change_file_mode_rw(new_fp, new) < 0) {
FILE_OP_ERROR(new, "chmod");
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;
}
+GSList *mbox_get_num_list(Folder *folder, FolderItem *item)
+{
+ GSList *mlist;
+ GList * l;
+ FILE * fp;
+ gchar * mbox_path;
+
+ mlist = NULL;
+
+ mbox_path = mbox_folder_get_path(item);
+
+ if (mbox_path == NULL)
+ return NULL;
+
+ mbox_purge_deleted(mbox_path);
+
+ fp = fopen(mbox_path, "rb");
+
+ if (fp == NULL) {
+ g_free(mbox_path);
+ return NULL;
+ }
+
+ 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));
+ } else {
+ MSG_SET_PERM_FLAGS(msg->flags, MSG_REALLY_DELETED);
+ }
+ }
+
+ mbox_unlock_file(fp, mbox_path);
+
+ g_free(mbox_path);
+
+ fclose(fp);
+
+ return mlist;
+}
+
+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;
+}
+