fad68bbfec
* src/account.c * src/account.h * src/action.c * src/action.h * src/adbookbase.h * src/addr_compl.c * src/addr_compl.h * src/addrbook.c * src/addrcache.c * src/addrcache.h * src/addrcindex.c * src/addrcindex.h * src/addrclip.c * src/addrclip.h * src/addrdefs.h * src/addressadd.c * src/addressadd.h * src/addressbook.c * src/addressbook.h * src/addressbook_foldersel.c * src/addressbook_foldersel.h * src/addrgather.c * src/addrgather.h * src/addrharvest.c * src/addrharvest.h * src/addrindex.c * src/addrindex.h * src/addritem.c * src/addritem.h * src/addrquery.c * src/addrquery.h * src/addrselect.c * src/addrselect.h * src/alertpanel.c * src/alertpanel.h * src/browseldap.c * src/browseldap.h * src/codeconv.c * src/codeconv.h * src/compose.c * src/compose.h * src/customheader.c * src/customheader.h * src/displayheader.c * src/displayheader.h * src/editaddress.c * src/editaddress.h * src/editbook.c * src/editbook.h * src/editgroup.c * src/editgroup.h * src/editjpilot.c * src/editjpilot.h * src/editldap.c * src/editldap.h * src/editldap_basedn.c * src/editldap_basedn.h * src/editvcard.c * src/editvcard.h * src/exphtmldlg.c * src/exphtmldlg.h * src/expldifdlg.c * src/expldifdlg.h * src/export.c * src/export.h * src/exporthtml.c * src/exporthtml.h * src/exportldif.c * src/exportldif.h * src/filtering.c * src/filtering.h * src/folder.c * src/folder.h * src/folder_item_prefs.c * src/folder_item_prefs.h * src/foldersel.c * src/foldersel.h * src/folderutils.c * src/folderutils.h * src/folderview.c * src/folderview.h * src/grouplistdialog.c * src/grouplistdialog.h * src/headerview.c * src/html.c * src/html.h * src/image_viewer.c * src/image_viewer.h * src/imap.c * src/imap.h * src/imap_gtk.c * src/imap_gtk.h * src/import.c * src/import.h * src/importldif.c * src/importldif.h * src/importmutt.c * src/importmutt.h * src/importpine.c * src/importpine.h * src/inc.c * src/inc.h * src/jpilot.c * src/jpilot.h * src/ldapctrl.c * src/ldapctrl.h * src/ldaplocate.c * src/ldaplocate.h * src/ldapquery.c * src/ldapquery.h * src/ldapserver.c * src/ldapserver.h * src/ldaputil.c * src/ldaputil.h * src/ldif.c * src/ldif.h * src/main.c * src/main.h * src/mainwindow.c * src/mainwindow.h * src/manual.c * src/manual.h * src/mbox.c * src/message_search.c * src/message_search.h * src/messageview.c * src/messageview.h * src/mh.c * src/mh.h * src/mh_gtk.c * src/mh_gtk.h * src/mimeview.c * src/mimeview.h * src/msgcache.c * src/msgcache.h * src/mutt.c * src/mutt.h * src/news.c * src/news.h * src/news_gtk.c * src/news_gtk.h * src/partial_download.c * src/partial_download.h * src/pine.c * src/pine.h * src/pop.c * src/pop.h * src/prefs_account.c * src/prefs_account.h * src/prefs_actions.c * src/prefs_actions.h * src/prefs_common.c * src/prefs_common.h * src/prefs_compose_writing.c * src/prefs_compose_writing.h * src/prefs_customheader.c * src/prefs_customheader.h * src/prefs_display_header.c * src/prefs_display_header.h * src/prefs_filtering.c * src/prefs_filtering.h * src/prefs_filtering_action.c * src/prefs_filtering_action.h * src/prefs_folder_column.c * src/prefs_folder_column.h * src/prefs_folder_item.c * src/prefs_folder_item.h * src/prefs_fonts.c * src/prefs_fonts.h * src/prefs_gtk.c * src/prefs_gtk.h * src/prefs_image_viewer.c * src/prefs_image_viewer.h * src/prefs_matcher.c * src/prefs_matcher.h * src/prefs_message.c * src/prefs_msg_colors.c * src/prefs_msg_colors.h * src/prefs_other.c * src/prefs_quote.c * src/prefs_receive.c * src/prefs_send.c * src/prefs_spelling.c * src/prefs_spelling.h * src/prefs_summaries.c * src/prefs_summaries.h * src/prefs_summary_column.c * src/prefs_summary_column.h * src/prefs_template.c * src/prefs_template.h * src/prefs_themes.c * src/prefs_themes.h * src/prefs_toolbar.c * src/prefs_toolbar.h * src/prefs_wrapping.c * src/prefs_wrapping.h * src/privacy.c * src/privacy.h * src/procheader.c * src/procheader.h * src/procmime.c * src/procmime.h * src/procmsg.c * src/procmsg.h * src/quote_fmt.c * src/quote_fmt_parse.y * src/recv.c * src/recv.h * src/remotefolder.c * src/remotefolder.h * src/send_message.c * src/send_message.h * src/setup.c * src/setup.h * src/sourcewindow.c * src/sourcewindow.h * src/ssl_manager.c * src/ssl_manager.h * src/statusbar.c * src/statusbar.h * src/stock_pixmap.c * src/stock_pixmap.h * src/summary_search.c * src/summary_search.h * src/summaryview.c * src/summaryview.h * src/textview.c * src/textview.h * src/toolbar.c * src/toolbar.h * src/undo.c * src/undo.h * src/unmime.c * src/unmime.h * src/vcard.c * src/vcard.h * src/wizard.c * src/wizard.h * src/common/base64.c * src/common/base64.h * src/common/defs.h * src/common/hooks.c * src/common/hooks.h * src/common/log.c * src/common/log.h * src/common/mgutils.c * src/common/mgutils.h * src/common/nntp.c * src/common/nntp.h * src/common/passcrypt.c * src/common/passcrypt.h.in * src/common/plugin.c * src/common/plugin.h * src/common/prefs.c * src/common/prefs.h * src/common/progressindicator.c * src/common/progressindicator.h * src/common/quoted-printable.c * src/common/quoted-printable.h * src/common/session.c * src/common/session.h * src/common/smtp.c * src/common/smtp.h * src/common/socket.c * src/common/socket.h * src/common/ssl.c * src/common/ssl.h * src/common/ssl_certificate.c * src/common/ssl_certificate.h * src/common/stringtable.c * src/common/stringtable.h * src/common/template.c * src/common/template.h * src/common/timing.h * src/common/utils.c * src/common/utils.h * src/common/version.h.in * src/common/xml.c * src/common/xml.h * src/common/xmlprops.c * src/common/xmlprops.h * src/gtk/about.c * src/gtk/colorlabel.c * src/gtk/colorsel.c * src/gtk/colorsel.h * src/gtk/combobox.c * src/gtk/combobox.h * src/gtk/description_window.c * src/gtk/description_window.h * src/gtk/filesel.c * src/gtk/filesel.h * src/gtk/foldersort.c * src/gtk/foldersort.h * src/gtk/gtksctree.c * src/gtk/gtkutils.c * src/gtk/gtkutils.h * src/gtk/inputdialog.c * src/gtk/inputdialog.h * src/gtk/logwindow.c * src/gtk/logwindow.h * src/gtk/manage_window.c * src/gtk/manage_window.h * src/gtk/menu.c * src/gtk/menu.h * src/gtk/pluginwindow.c * src/gtk/pluginwindow.h * src/gtk/prefswindow.c * src/gtk/prefswindow.h * src/gtk/progressdialog.c * src/gtk/progressdialog.h * src/gtk/sslcertwindow.c * src/gtk/sslcertwindow.h * src/plugins/bogofilter/bogofilter.c * src/plugins/bogofilter/bogofilter.h * src/plugins/bogofilter/bogofilter_gtk.c * src/plugins/clamav/clamav_plugin.c * src/plugins/clamav/clamav_plugin.h * src/plugins/clamav/clamav_plugin_gtk.c * src/plugins/demo/demo.c * src/plugins/dillo_viewer/dillo_prefs.c * src/plugins/dillo_viewer/dillo_prefs.h * src/plugins/dillo_viewer/dillo_viewer.c * src/plugins/pgpcore/passphrase.c * src/plugins/pgpcore/passphrase.h * src/plugins/pgpcore/pgp_viewer.c * src/plugins/pgpcore/pgp_viewer.h * src/plugins/pgpcore/plugin.c * src/plugins/pgpcore/select-keys.c * src/plugins/pgpcore/select-keys.h * src/plugins/pgpcore/sgpgme.c * src/plugins/pgpcore/sgpgme.h * src/plugins/pgpinline/pgpinline.c * src/plugins/pgpinline/pgpinline.h * src/plugins/pgpinline/plugin.c * src/plugins/pgpmime/pgpmime.c * src/plugins/pgpmime/pgpmime.h * src/plugins/pgpmime/plugin.c * src/plugins/spamassassin/spamassassin.c * src/plugins/spamassassin/spamassassin.h * src/plugins/spamassassin/spamassassin_gtk.c * src/plugins/trayicon/trayicon.c it's 2007, update the year in the copyright headers
593 lines
13 KiB
C
593 lines
13 KiB
C
/*
|
|
* Sylpheed -- a GTK+ based, lightweight, and fast e-mail client
|
|
* Copyright (C) 1999-2007 Hiroyuki Yamamoto and the Claws Mail team
|
|
*
|
|
* 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., 51 Franklin Street, Fifth Floor, Boston, MA 02110-1301, USA.
|
|
*/
|
|
|
|
#ifdef HAVE_CONFIG_H
|
|
# include "config.h"
|
|
#endif
|
|
|
|
|
|
#define _GNU_SOURCE
|
|
#include <stdio.h>
|
|
|
|
#include "defs.h"
|
|
#include <glib.h>
|
|
#include <glib/gi18n.h>
|
|
#include <stdlib.h>
|
|
#include <unistd.h>
|
|
#include <string.h>
|
|
#include <fcntl.h>
|
|
#include <sys/file.h>
|
|
#include <ctype.h>
|
|
#include <time.h>
|
|
#include <errno.h>
|
|
|
|
#include "mbox.h"
|
|
#include "procmsg.h"
|
|
#include "folder.h"
|
|
#include "prefs_common.h"
|
|
#include "prefs_account.h"
|
|
#include "account.h"
|
|
#include "utils.h"
|
|
#include "filtering.h"
|
|
#include "alertpanel.h"
|
|
#include "statusbar.h"
|
|
|
|
#define MSGBUFSIZE 8192
|
|
|
|
#ifdef HAVE_FGETS_UNLOCKED
|
|
#define SC_FGETS fgets_unlocked
|
|
#define SC_FPUTS fputs_unlocked
|
|
#define SC_FPUTC fputc_unlocked
|
|
#else
|
|
#define SC_FGETS fgets
|
|
#define SC_FPUTS fputs
|
|
#define SC_FPUTC fputc
|
|
#endif
|
|
|
|
#define FPUTS_TO_TMP_ABORT_IF_FAIL(s) \
|
|
{ \
|
|
lines++; \
|
|
if (fputs(s, tmp_fp) == EOF) { \
|
|
g_warning("can't write to temporary file\n"); \
|
|
fclose(tmp_fp); \
|
|
fclose(mbox_fp); \
|
|
g_unlink(tmp_file); \
|
|
g_free(tmp_file); \
|
|
return -1; \
|
|
} \
|
|
}
|
|
|
|
gint proc_mbox(FolderItem *dest, const gchar *mbox, gboolean apply_filter,
|
|
PrefsAccount *account)
|
|
/* return values: -1 error, >=0 number of msgs added */
|
|
{
|
|
FILE *mbox_fp;
|
|
gchar buf[MSGBUFSIZE];
|
|
gchar *tmp_file;
|
|
gint msgs = 0;
|
|
gint lines;
|
|
MsgInfo *msginfo;
|
|
gboolean more;
|
|
GSList *to_filter = NULL, *filtered = NULL, *unfiltered = NULL, *cur, *to_add = NULL;
|
|
gboolean printed = FALSE;
|
|
FolderItem *dropfolder;
|
|
|
|
g_return_val_if_fail(dest != NULL, -1);
|
|
g_return_val_if_fail(mbox != NULL, -1);
|
|
|
|
debug_print("Getting messages from %s into %s...\n", mbox, dest->path);
|
|
|
|
if ((mbox_fp = g_fopen(mbox, "rb")) == NULL) {
|
|
FILE_OP_ERROR(mbox, "fopen");
|
|
alertpanel_error(_("Could not open mbox file:\n%s\n"), mbox);
|
|
return -1;
|
|
}
|
|
|
|
/* ignore empty lines on the head */
|
|
do {
|
|
if (fgets(buf, sizeof(buf), mbox_fp) == NULL) {
|
|
g_warning("can't read mbox file.\n");
|
|
fclose(mbox_fp);
|
|
return -1;
|
|
}
|
|
} while (buf[0] == '\n' || buf[0] == '\r');
|
|
|
|
if (strncmp(buf, "From ", 5) != 0) {
|
|
g_warning("invalid mbox format: %s\n", mbox);
|
|
fclose(mbox_fp);
|
|
return -1;
|
|
}
|
|
|
|
tmp_file = get_tmp_file();
|
|
|
|
folder_item_update_freeze();
|
|
|
|
if (apply_filter)
|
|
dropfolder = folder_get_default_processing();
|
|
else
|
|
dropfolder = dest;
|
|
|
|
do {
|
|
FILE *tmp_fp;
|
|
gint empty_lines;
|
|
gint msgnum;
|
|
|
|
if (msgs > 0 && msgs%500 == 0) {
|
|
if (printed)
|
|
statusbar_pop_all();
|
|
statusbar_print_all(_("Importing from mbox... (%d mails imported)"), msgs);
|
|
printed=TRUE;
|
|
GTK_EVENTS_FLUSH();
|
|
}
|
|
|
|
if ((tmp_fp = g_fopen(tmp_file, "wb")) == NULL) {
|
|
FILE_OP_ERROR(tmp_file, "fopen");
|
|
g_warning("can't open temporary file\n");
|
|
fclose(mbox_fp);
|
|
g_free(tmp_file);
|
|
return -1;
|
|
}
|
|
if (change_file_mode_rw(tmp_fp, tmp_file) < 0) {
|
|
FILE_OP_ERROR(tmp_file, "chmod");
|
|
}
|
|
|
|
empty_lines = 0;
|
|
lines = 0;
|
|
more = FALSE;
|
|
|
|
/* process all lines from mboxrc file */
|
|
while (fgets(buf, sizeof(buf), mbox_fp) != NULL) {
|
|
int offset;
|
|
|
|
/* eof not reached, expect more lines */
|
|
more = TRUE;
|
|
|
|
/* eat empty lines */
|
|
if (buf[0] == '\n' || buf[0] == '\r') {
|
|
empty_lines++;
|
|
continue;
|
|
}
|
|
|
|
/* From separator or quoted From */
|
|
offset = 0;
|
|
/* detect leading '>' char(s) */
|
|
while ((buf[offset] == '>')) {
|
|
offset++;
|
|
}
|
|
if (!strncmp(buf+offset, "From ", 5)) {
|
|
/* From separator: */
|
|
if (offset == 0) {
|
|
/* expect next mbox item */
|
|
break;
|
|
}
|
|
|
|
/* quoted From: */
|
|
/* flush any eaten empty line */
|
|
if (empty_lines > 0) {
|
|
while (empty_lines-- > 0) {
|
|
FPUTS_TO_TMP_ABORT_IF_FAIL("\n");
|
|
}
|
|
empty_lines = 0;
|
|
}
|
|
/* store the unquoted line */
|
|
FPUTS_TO_TMP_ABORT_IF_FAIL(buf + 1);
|
|
continue;
|
|
}
|
|
|
|
/* other line */
|
|
/* flush any eaten empty line */
|
|
if (empty_lines > 0) {
|
|
while (empty_lines-- > 0) {
|
|
FPUTS_TO_TMP_ABORT_IF_FAIL("\n");
|
|
}
|
|
empty_lines = 0;
|
|
}
|
|
/* store the line itself */
|
|
FPUTS_TO_TMP_ABORT_IF_FAIL(buf);
|
|
}
|
|
/* end of mbox item or end of mbox */
|
|
|
|
/* flush any eaten empty line (but the last one) */
|
|
if (empty_lines > 0) {
|
|
while (--empty_lines > 0) {
|
|
FPUTS_TO_TMP_ABORT_IF_FAIL("\n");
|
|
}
|
|
}
|
|
|
|
/* more emails to expect? */
|
|
more = !feof(mbox_fp);
|
|
|
|
/* warn if email part is empty (it's the minimum check
|
|
we can do */
|
|
if (lines == 0) {
|
|
g_warning("malformed mbox: %s: message %d is empty\n", mbox, msgs);
|
|
fclose(tmp_fp);
|
|
fclose(mbox_fp);
|
|
g_unlink(tmp_file);
|
|
return -1;
|
|
}
|
|
|
|
if (fclose(tmp_fp) == EOF) {
|
|
FILE_OP_ERROR(tmp_file, "fclose");
|
|
g_warning("can't write to temporary file\n");
|
|
fclose(mbox_fp);
|
|
g_unlink(tmp_file);
|
|
g_free(tmp_file);
|
|
return -1;
|
|
}
|
|
|
|
if (apply_filter) {
|
|
if ((msgnum = folder_item_add_msg(dropfolder, tmp_file, NULL, TRUE)) < 0) {
|
|
fclose(mbox_fp);
|
|
g_unlink(tmp_file);
|
|
g_free(tmp_file);
|
|
return -1;
|
|
}
|
|
msginfo = folder_item_get_msginfo(dropfolder, msgnum);
|
|
to_filter = g_slist_prepend(to_filter, msginfo);
|
|
} else {
|
|
MsgFileInfo *finfo = g_new0(MsgFileInfo, 1);
|
|
finfo->file = tmp_file;
|
|
|
|
to_add = g_slist_prepend(to_add, finfo);
|
|
tmp_file = get_tmp_file();
|
|
|
|
/* flush every 500 */
|
|
if (msgs > 0 && msgs % 500 == 0) {
|
|
folder_item_add_msgs(dropfolder, to_add, TRUE);
|
|
procmsg_message_file_list_free(to_add);
|
|
to_add = NULL;
|
|
}
|
|
}
|
|
msgs++;
|
|
} while (more);
|
|
|
|
if (printed)
|
|
statusbar_pop_all();
|
|
|
|
if (apply_filter) {
|
|
procmsg_msglist_filter(to_filter, account,
|
|
&filtered, &unfiltered, TRUE);
|
|
|
|
filtering_move_and_copy_msgs(to_filter);
|
|
for (cur = filtered; cur; cur = g_slist_next(cur)) {
|
|
MsgInfo *info = (MsgInfo *)cur->data;
|
|
procmsg_msginfo_free(info);
|
|
}
|
|
|
|
unfiltered = g_slist_reverse(unfiltered);
|
|
folder_item_move_msgs(dest, unfiltered);
|
|
for (cur = unfiltered; cur; cur = g_slist_next(cur)) {
|
|
MsgInfo *info = (MsgInfo *)cur->data;
|
|
procmsg_msginfo_free(info);
|
|
}
|
|
|
|
g_slist_free(unfiltered);
|
|
g_slist_free(filtered);
|
|
g_slist_free(to_filter);
|
|
} else if (to_add) {
|
|
folder_item_add_msgs(dropfolder, to_add, TRUE);
|
|
procmsg_message_file_list_free(to_add);
|
|
to_add = NULL;
|
|
}
|
|
|
|
folder_item_update_thaw();
|
|
|
|
g_free(tmp_file);
|
|
fclose(mbox_fp);
|
|
debug_print("%d messages found.\n", msgs);
|
|
|
|
return msgs;
|
|
}
|
|
|
|
gint lock_mbox(const gchar *base, LockType type)
|
|
{
|
|
#ifdef G_OS_UNIX
|
|
gint retval = 0;
|
|
|
|
if (type == LOCK_FILE) {
|
|
gchar *lockfile, *locklink;
|
|
gint retry = 0;
|
|
FILE *lockfp;
|
|
|
|
lockfile = g_strdup_printf("%s.%d", base, getpid());
|
|
if ((lockfp = g_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");
|
|
g_free(lockfile);
|
|
return -1;
|
|
}
|
|
|
|
fprintf(lockfp, "%d\n", getpid());
|
|
fclose(lockfp);
|
|
|
|
locklink = g_strconcat(base, ".lock", NULL);
|
|
while (link(lockfile, locklink) < 0) {
|
|
FILE_OP_ERROR(lockfile, "link");
|
|
if (retry >= 5) {
|
|
g_warning("can't create %s\n", lockfile);
|
|
g_unlink(lockfile);
|
|
g_free(lockfile);
|
|
return -1;
|
|
}
|
|
if (retry == 0)
|
|
g_warning("mailbox is owned by another"
|
|
" process, waiting...\n");
|
|
retry++;
|
|
sleep(5);
|
|
}
|
|
g_unlink(lockfile);
|
|
g_free(lockfile);
|
|
} else if (type == LOCK_FLOCK) {
|
|
gint lockfd;
|
|
gboolean fcntled = FALSE;
|
|
#if HAVE_FCNTL_H && !defined(G_OS_WIN32)
|
|
struct flock fl;
|
|
fl.l_type = F_WRLCK;
|
|
fl.l_whence = SEEK_SET;
|
|
fl.l_start = 0;
|
|
fl.l_len = 0;
|
|
#endif
|
|
|
|
#if HAVE_FLOCK
|
|
if ((lockfd = open(base, O_RDWR)) < 0) {
|
|
#else
|
|
if ((lockfd = open(base, O_RDWR)) < 0) {
|
|
#endif
|
|
FILE_OP_ERROR(base, "open");
|
|
return -1;
|
|
}
|
|
|
|
#if HAVE_FCNTL_H && !defined(G_OS_WIN32)
|
|
if (fcntl(lockfd, F_SETLK, &fl) == -1) {
|
|
g_warning("can't fnctl %s (%s)", base, strerror(errno));
|
|
return -1;
|
|
} else {
|
|
fcntled = TRUE;
|
|
}
|
|
#endif
|
|
|
|
#if HAVE_FLOCK
|
|
if (flock(lockfd, LOCK_EX|LOCK_NB) < 0 && !fcntled) {
|
|
perror("flock");
|
|
#else
|
|
#if HAVE_LOCKF
|
|
if (lockf(lockfd, F_TLOCK, 0) < 0 && !fcntled) {
|
|
perror("lockf");
|
|
#else
|
|
{
|
|
#endif
|
|
#endif /* HAVE_FLOCK */
|
|
g_warning("can't lock %s\n", base);
|
|
if (close(lockfd) < 0)
|
|
perror("close");
|
|
return -1;
|
|
}
|
|
retval = lockfd;
|
|
} else {
|
|
g_warning("invalid lock type\n");
|
|
return -1;
|
|
}
|
|
|
|
return retval;
|
|
#else
|
|
return -1;
|
|
#endif /* G_OS_UNIX */
|
|
}
|
|
|
|
gint unlock_mbox(const gchar *base, gint fd, LockType type)
|
|
{
|
|
if (type == LOCK_FILE) {
|
|
gchar *lockfile;
|
|
|
|
lockfile = g_strconcat(base, ".lock", NULL);
|
|
if (g_unlink(lockfile) < 0) {
|
|
FILE_OP_ERROR(lockfile, "unlink");
|
|
g_free(lockfile);
|
|
return -1;
|
|
}
|
|
g_free(lockfile);
|
|
|
|
return 0;
|
|
} else if (type == LOCK_FLOCK) {
|
|
gboolean fcntled = FALSE;
|
|
#if HAVE_FCNTL_H && !defined(G_OS_WIN32)
|
|
struct flock fl;
|
|
fl.l_type = F_UNLCK;
|
|
fl.l_whence = SEEK_SET;
|
|
fl.l_start = 0;
|
|
fl.l_len = 0;
|
|
|
|
if (fcntl(fd, F_SETLK, &fl) == -1) {
|
|
g_warning("can't fnctl %s", base);
|
|
return -1;
|
|
} else {
|
|
fcntled = TRUE;
|
|
}
|
|
#endif
|
|
#if HAVE_FLOCK
|
|
if (flock(fd, LOCK_UN) < 0 && !fcntled) {
|
|
perror("flock");
|
|
#else
|
|
#if HAVE_LOCKF
|
|
if (lockf(fd, F_ULOCK, 0) < 0 && !fcntled) {
|
|
perror("lockf");
|
|
#else
|
|
{
|
|
#endif
|
|
#endif /* HAVE_FLOCK */
|
|
g_warning("can't unlock %s\n", base);
|
|
if (close(fd) < 0)
|
|
perror("close");
|
|
return -1;
|
|
}
|
|
|
|
if (close(fd) < 0) {
|
|
perror("close");
|
|
return -1;
|
|
}
|
|
|
|
return 0;
|
|
}
|
|
|
|
g_warning("invalid lock type\n");
|
|
return -1;
|
|
}
|
|
|
|
gint copy_mbox(const gchar *src, const gchar *dest)
|
|
{
|
|
return copy_file(src, dest, TRUE);
|
|
}
|
|
|
|
void empty_mbox(const gchar *mbox)
|
|
{
|
|
FILE *fp;
|
|
|
|
if ((fp = g_fopen(mbox, "wb")) == NULL) {
|
|
FILE_OP_ERROR(mbox, "fopen");
|
|
g_warning("can't truncate mailbox to zero.\n");
|
|
return;
|
|
}
|
|
fclose(fp);
|
|
}
|
|
|
|
gint export_list_to_mbox(GSList *mlist, const gchar *mbox)
|
|
/* return values: -2 skipped, -1 error, 0 OK */
|
|
{
|
|
GSList *cur;
|
|
MsgInfo *msginfo;
|
|
FILE *msg_fp;
|
|
FILE *mbox_fp;
|
|
gchar buf[BUFFSIZE];
|
|
gint msgs = 1, total = g_slist_length(mlist);
|
|
if (g_file_test(mbox, G_FILE_TEST_EXISTS) == TRUE) {
|
|
if (alertpanel_full(_("Overwrite mbox file"),
|
|
_("This file already exists. Do you want to overwrite it?"),
|
|
GTK_STOCK_CANCEL, _("Overwrite"), NULL, FALSE,
|
|
NULL, ALERT_WARNING, G_ALERTDEFAULT)
|
|
!= G_ALERTALTERNATE) {
|
|
return -2;
|
|
}
|
|
}
|
|
|
|
if ((mbox_fp = g_fopen(mbox, "wb")) == NULL) {
|
|
FILE_OP_ERROR(mbox, "fopen");
|
|
alertpanel_error(_("Could not create mbox file:\n%s\n"), mbox);
|
|
return -1;
|
|
}
|
|
|
|
#ifdef HAVE_FGETS_UNLOCKED
|
|
flockfile(mbox_fp);
|
|
#endif
|
|
|
|
statusbar_print_all(_("Exporting to mbox..."));
|
|
for (cur = mlist; cur != NULL; cur = cur->next) {
|
|
int len;
|
|
msginfo = (MsgInfo *)cur->data;
|
|
|
|
msg_fp = procmsg_open_message(msginfo);
|
|
if (!msg_fp) {
|
|
continue;
|
|
}
|
|
|
|
#ifdef HAVE_FGETS_UNLOCKED
|
|
flockfile(msg_fp);
|
|
#endif
|
|
strncpy2(buf,
|
|
msginfo->from ? msginfo->from :
|
|
cur_account && cur_account->address ?
|
|
cur_account->address : "unknown",
|
|
sizeof(buf));
|
|
extract_address(buf);
|
|
|
|
fprintf(mbox_fp, "From %s %s",
|
|
buf, ctime(&msginfo->date_t));
|
|
|
|
buf[0] = '\0';
|
|
|
|
/* write email to mboxrc */
|
|
while (SC_FGETS(buf, sizeof(buf), msg_fp) != NULL) {
|
|
/* quote any From, >From, >>From, etc., according to mbox format specs */
|
|
int offset;
|
|
|
|
offset = 0;
|
|
/* detect leading '>' char(s) */
|
|
while ((buf[offset] == '>')) {
|
|
offset++;
|
|
}
|
|
if (!strncmp(buf+offset, "From ", 5))
|
|
SC_FPUTC('>', mbox_fp);
|
|
SC_FPUTS(buf, mbox_fp);
|
|
}
|
|
|
|
/* force last line to end w/ a newline */
|
|
len = strlen(buf);
|
|
if (len > 0) {
|
|
len--;
|
|
if ((buf[len] != '\n') && (buf[len] != '\r'))
|
|
SC_FPUTC('\n', mbox_fp);
|
|
}
|
|
|
|
/* add a trailing empty line */
|
|
SC_FPUTC('\n', mbox_fp);
|
|
|
|
#ifdef HAVE_FGETS_UNLOCKED
|
|
funlockfile(msg_fp);
|
|
#endif
|
|
fclose(msg_fp);
|
|
statusbar_progress_all(msgs++,total, 500);
|
|
if (msgs%500 == 0)
|
|
GTK_EVENTS_FLUSH();
|
|
}
|
|
statusbar_progress_all(0,0,0);
|
|
statusbar_pop_all();
|
|
|
|
#ifdef HAVE_FGETS_UNLOCKED
|
|
funlockfile(mbox_fp);
|
|
#endif
|
|
fclose(mbox_fp);
|
|
|
|
return 0;
|
|
}
|
|
|
|
/* read all messages in SRC, and store them into one MBOX file. */
|
|
/* return values: -2 skipped, -1 error, 0 OK */
|
|
gint export_to_mbox(FolderItem *src, const gchar *mbox)
|
|
{
|
|
GSList *mlist;
|
|
gint ret;
|
|
|
|
g_return_val_if_fail(src != NULL, -1);
|
|
g_return_val_if_fail(src->folder != NULL, -1);
|
|
g_return_val_if_fail(mbox != NULL, -1);
|
|
|
|
debug_print("Exporting messages from %s into %s...\n",
|
|
src->path, mbox);
|
|
|
|
mlist = folder_item_get_msg_list(src);
|
|
|
|
folder_item_update_freeze();
|
|
ret = export_list_to_mbox(mlist, mbox);
|
|
folder_item_update_thaw();
|
|
|
|
procmsg_msg_list_free(mlist);
|
|
|
|
return ret;
|
|
}
|