#include "filter.h"
#include "automaton.h"
#include "folder.h"
+#include "filtering.h"
#include "pixmaps/continue.xpm"
#include "pixmaps/complete.xpm"
/* external incorporating program */
if ((pid = fork()) < 0) {
perror("fork");
- inc_autocheck_timer_set();
+ inc_autocheck_timer_set();
return;
}
}
inc_finished(mainwin);
- inc_autocheck_timer_set();
+ inc_autocheck_timer_set();
}
static void inc_account_mail(PrefsAccount *account, MainWindow *mainwin)
if (!list) {
inc_autocheck_timer_set();
return;
- }
+ }
for (; list != NULL; list = list->next) {
IncSession *session;
if (!queue_list) {
inc_autocheck_timer_set();
return;
- }
+ }
inc_dialog = inc_progress_dialog_create();
inc_dialog->queue_list = queue_list;
inc_progress_dialog_clear(inc_dialog);
+ gtk_clist_moveto(clist, num, 0, 1.0, 0.0);
+
pop3_state->user = g_strdup(pop3_state->ac_prefs->userid);
if (pop3_state->ac_prefs->passwd)
pop3_state->pass =
if (sockinfo->state == CONN_LOOKUPFAILED ||
sockinfo->state == CONN_FAILED) {
atm->timeout_tag = 0;
- pop3_automaton_terminate(sockinfo->sock, atm);
log_warning(_("Can't connect to POP3 server: %s:%d\n"),
sockinfo->hostname, sockinfo->port);
manage_window_focus_in(inc_dialog->dialog->window, NULL, NULL);
alertpanel_error(_("Can't connect to POP3 server: %s:%d"),
sockinfo->hostname, sockinfo->port);
manage_window_focus_out(inc_dialog->dialog->window, NULL, NULL);
+ pop3_automaton_terminate(sockinfo, atm);
return FALSE;
} else if (sockinfo->state == CONN_ESTABLISHED) {
atm->timeout_tag = 0;
- atm->tag = gdk_input_add(sockinfo->sock,
- atm->state[atm->num].condition,
- automaton_input_cb, atm);
+ atm->tag = sock_gdk_input_add(sockinfo,
+ atm->state[atm->num].condition,
+ automaton_input_cb, atm);
return FALSE;
} else {
return TRUE;
case POP3_GETAUTH_PASS_RECV:
case POP3_GETAUTH_APOP_SEND:
case POP3_GETAUTH_APOP_RECV:
- progress_dialog_set_label(dialog, _("Authorizing..."));
+ progress_dialog_set_label(dialog, _("Authorizing..."));
break;
case POP3_GETRANGE_STAT_SEND:
case POP3_GETRANGE_STAT_RECV:
FolderItem *inbox;
FolderItem *dropfolder;
gint val;
+ gint msgnum;
if (state->ac_prefs->inbox) {
inbox = folder_find_item_from_path(state->ac_prefs->inbox);
return -1;
}
- if (state->ac_prefs->filter_on_recv) {
- dropfolder =
- filter_get_dest_folder(prefs_common.fltlist, file);
- if (!dropfolder) dropfolder = inbox;
- else if (!strcmp(dropfolder->path, FILTER_NOT_RECEIVE)) {
- g_warning(_("a message won't be received\n"));
- return 1;
- }
- } else
+ if (prefs_filtering == NULL) {
+ /* old filtering */
+ if (state->ac_prefs->filter_on_recv) {
+ dropfolder =
+ filter_get_dest_folder(prefs_common.fltlist, file);
+ if (!dropfolder) dropfolder = inbox;
+ else if (!strcmp(dropfolder->path, FILTER_NOT_RECEIVE)) {
+ g_warning(_("a message won't be received\n"));
+ return 1;
+ }
+ } else
+ dropfolder = inbox;
+ } else {
+ /* new filtering */
dropfolder = inbox;
+ }
val = GPOINTER_TO_INT(g_hash_table_lookup
(state->folder_table, dropfolder));
GINT_TO_POINTER(1));
}
- if (folder_item_add_msg(dropfolder, file) < 0) {
+ if ((msgnum = folder_item_add_msg(dropfolder, file, TRUE)) < 0) {
unlink(file);
return -1;
}
- unlink(file);
+ if (prefs_filtering != NULL) {
+ /* new filtering */
+ if (state->ac_prefs->filter_on_recv) {
+ filter_message(prefs_filtering, dropfolder, msgnum,
+ state->folder_table);
+ }
+ }
+
return 0;
}
{
gint msgs, size;
gint lockfd;
- gchar tmp_mbox[256] = "/tmp/tmpmboxXXXXXX";
+ gchar tmp_mbox[MAXPATHLEN + 1];
GHashTable *folder_table = NULL;
g_return_val_if_fail(dest != NULL, -1);
if ((lockfd = lock_mbox(mbox, LOCK_FLOCK)) < 0)
return -1;
- if (mktemp(tmp_mbox) == NULL)
- return -1;
+ g_snprintf(tmp_mbox, sizeof(tmp_mbox), "%s%ctmpmbox%d",
+ get_rc_dir(), G_DIR_SEPARATOR, (gint)mbox);
if (copy_mbox(mbox, tmp_mbox) < 0)
return -1;