aboutsummaryrefslogtreecommitdiffstats
path: root/mail/mail-send-recv.c
diff options
context:
space:
mode:
Diffstat (limited to 'mail/mail-send-recv.c')
-rw-r--r--mail/mail-send-recv.c531
1 files changed, 0 insertions, 531 deletions
diff --git a/mail/mail-send-recv.c b/mail/mail-send-recv.c
deleted file mode 100644
index 088339575f..0000000000
--- a/mail/mail-send-recv.c
+++ /dev/null
@@ -1,531 +0,0 @@
-/* -*- Mode: C; tab-width: 8; indent-tabs-mode: t; c-basic-offset: 8 -*- */
-/*
- * Authors: Michael Zucchi <NotZed@ximian.com>
- *
- * Copyright 2001 Ximian, Inc. (www.ximian.com)
- *
- * 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.
- *
- */
-
-#include <stdio.h>
-#include <string.h>
-
-#include "filter/filter-context.h"
-#include "filter/filter-filter.h"
-#include "camel/camel-filter-driver.h"
-#include "camel/camel-folder.h"
-#include "camel/camel-session.h"
-
-#include "evolution-storage.h"
-
-#include "mail.h"
-#include "mail-mt.h"
-#include "mail-config.h"
-#include "mail-session.h"
-#include "mail-tools.h"
-#include "mail-ops.h"
-
-/* for the dialogue stuff */
-#include <glib.h>
-#include <gtk/gtk.h>
-#include <libgnomeui/gnome-stock.h>
-#include <libgnomeui/gnome-dialog.h>
-
-/* send/receive email */
-
-/* ********************************************************************** */
-/* This stuff below is independent of the stuff above */
-
-/* this stuff is used to keep track of which folders filters have accessed, and
- what not. the thaw/refreeze thing doesn't really seem to work though */
-struct _folder_info {
- char *uri;
- CamelFolder *folder;
- time_t update;
- int count; /* how many times updated, to slow it down as we go, if we have lots */
-};
-
-struct _send_data {
- GList *infos;
-
- int active; /* how many still active */
-
- GnomeDialog *gd;
- int cancelled;
-
- CamelFolder *inbox; /* since w'ere never asked to uypdate this one, do it ourselves */
- time_t inbox_update;
-
- GMutex *lock;
- GHashTable *folders;
-};
-
-typedef enum {
- SEND_RECEIVE, /* receiver */
- SEND_SEND, /* sender */
- SEND_UPDATE, /* imap-like 'just update folder info' */
-} send_info_t ;
-
-typedef enum {
- SEND_ACTIVE,
- SEND_CANCELLED,
- SEND_COMPLETE
-} send_state_t;
-
-struct _send_info {
- send_info_t type; /* 0 = fetch, 1 = send */
- CamelCancel *cancel;
- char *uri;
- int keep;
- send_state_t state;
- GtkProgressBar *bar;
- GtkButton *stop;
- time_t update;
- struct _send_data *data;
-};
-
-static void
-receive_cancel(GtkButton *button, struct _send_info *info)
-{
- if (info->state == SEND_ACTIVE) {
- camel_cancel_cancel(info->cancel);
- gtk_progress_set_format_string((GtkProgress *)info->bar, _("Cancelling ..."));
- info->state = SEND_CANCELLED;
- }
- gtk_widget_set_sensitive((GtkWidget *)info->stop, FALSE);
-}
-
-static void
-free_folder_info(void *key, struct _folder_info *info, void *data)
-{
- camel_object_unref((CamelObject *)info->folder);
- g_free(info->uri);
-}
-
-static void
-free_info_data(void *datain)
-{
- struct _send_data *data = datain;
- GList *list = data->infos;
-
- while (list) {
- struct _send_info *info = list->data;
- g_free(info->uri);
- camel_cancel_unref(info->cancel);
- list = list->next;
- }
-
- g_list_free(data->infos);
- g_hash_table_foreach(data->folders, (GHFunc)free_folder_info, NULL);
- g_hash_table_destroy(data->folders);
- g_mutex_free(data->lock);
- if (data->inbox)
- camel_object_unref((CamelObject *)data->inbox);
- g_free(data);
-}
-
-static void
-dialogue_clicked(GnomeDialog *gd, int button, struct _send_data *data)
-{
- GList *scan;
-
- switch(button) {
- case 0: /* ok */
- gnome_dialog_close(gd);
- break;
- case 1:
- printf("cancelled whole thing\n");
- if (!data->cancelled) {
- data->cancelled = TRUE;
- scan = data->infos;
- while (scan) {
- struct _send_info *info = scan->data;
- receive_cancel(info->stop, info);
- scan = scan->next;
- }
- }
- gnome_dialog_set_sensitive(gd, 1, FALSE);
- break;
- }
-}
-
-static struct _send_data *build_dialogue(GSList *sources, CamelFolder *outbox, const char *destination)
-{
- GnomeDialog *gd;
- GtkFrame *frame;
- GtkTable *table;
- int row;
- GList *list = NULL;
- struct _send_data *data;
- GtkLabel *label;
- GtkProgressBar *bar;
- GtkButton *stop;
- struct _send_info *info;
-
- data = g_malloc0(sizeof(*data));
- data->lock = g_mutex_new();
- data->folders = g_hash_table_new(g_str_hash, g_str_equal);
- data->inbox = mail_tool_get_local_inbox(NULL);
-
- gd = (GnomeDialog *)gnome_dialog_new(_("Send & Receive mail"), GNOME_STOCK_BUTTON_OK, GNOME_STOCK_BUTTON_CANCEL, NULL);
- gnome_dialog_set_sensitive(gd, 0, FALSE);
-
- frame= (GtkFrame *)gtk_frame_new(_("Receiving"));
- gtk_box_pack_start((GtkBox *)gd->vbox, (GtkWidget *)frame, TRUE, TRUE, 0);
- table = (GtkTable *)gtk_table_new(g_slist_length(sources), 3, FALSE);
- gtk_container_add((GtkContainer *)frame, (GtkWidget *)table);
- gtk_widget_show((GtkWidget *)frame);
-
- row = 0;
- while (sources) {
- MailConfigService *source = sources->data;
-
- if (!source->url) {
- sources = sources->next;
- continue;
- }
-
- info = g_malloc0(sizeof(*info));
- /* imap is handled differently */
- if (!strncmp(source->url, "imap:", 5))
- info->type = SEND_UPDATE;
- else
- info->type = SEND_RECEIVE;
- printf("adding source %s\n", source->url);
-
- label = (GtkLabel *)gtk_label_new(source->url);
- bar = (GtkProgressBar *)gtk_progress_bar_new();
- stop = (GtkButton *)gnome_stock_button(GNOME_STOCK_BUTTON_CANCEL);
-
- gtk_progress_set_show_text((GtkProgress *)bar, TRUE);
- if (info->type == SEND_UPDATE) {
- gtk_progress_set_format_string((GtkProgress *)bar, _("Updating ..."));
- } else {
- gtk_progress_set_format_string((GtkProgress *)bar, _("Waiting ..."));
- }
-
- gtk_table_attach(table, (GtkWidget *)label, 0, 1, row, row+1, GTK_EXPAND|GTK_FILL, 0, 3, 1);
- gtk_table_attach(table, (GtkWidget *)bar, 1, 2, row, row+1, GTK_EXPAND|GTK_FILL, 0, 3, 1);
- gtk_table_attach(table, (GtkWidget *)stop, 2, 3, row, row+1, GTK_EXPAND|GTK_FILL, 0, 3, 1);
-
- info->bar = bar;
- info->uri = g_strdup(source->url);
- info->keep = source->keep_on_server;
- info->cancel = camel_cancel_new();
- info->stop = stop;
- info->data = data;
- info->state = SEND_ACTIVE;
- data->active++;
-
- list = g_list_prepend(list, info);
-
- gtk_signal_connect((GtkObject *)stop, "clicked", receive_cancel, info);
- sources = sources->next;
- row++;
- }
-
- gtk_widget_show_all((GtkWidget *)table);
-
- if (outbox) {
- frame= (GtkFrame *)gtk_frame_new(_("Sending"));
- gtk_box_pack_start((GtkBox *)gd->vbox, (GtkWidget *)frame, TRUE, TRUE, 0);
- table = (GtkTable *)gtk_table_new(1, 3, FALSE);
- gtk_container_add((GtkContainer *)frame, (GtkWidget *)table);
- gtk_widget_show((GtkWidget *)frame);
-
- info = g_malloc0(sizeof(*info));
- info->type = SEND_SEND;
- printf("adding dest %s\n", destination);
-
- label = (GtkLabel *)gtk_label_new(destination);
- bar = (GtkProgressBar *)gtk_progress_bar_new();
- stop = (GtkButton *)gnome_stock_button(GNOME_STOCK_BUTTON_CANCEL);
-
- gtk_progress_set_format_string((GtkProgress *)bar, _("Waiting ..."));
- gtk_progress_set_show_text((GtkProgress *)bar, TRUE);
-
- gtk_table_attach(table, (GtkWidget *)label, 0, 1, row, row+1, GTK_EXPAND|GTK_FILL, 0, 3, 1);
- gtk_table_attach(table, (GtkWidget *)bar, 1, 2, row, row+1, GTK_EXPAND|GTK_FILL, 0, 3, 1);
- gtk_table_attach(table, (GtkWidget *)stop, 2, 3, row, row+1, GTK_EXPAND|GTK_FILL, 0, 3, 1);
-
- info->bar = bar;
- info->uri = g_strdup(destination);
- info->keep = FALSE;
- info->cancel = camel_cancel_new();
- info->stop = stop;
- info->data = data;
- info->state = SEND_ACTIVE;
- data->active++;
-
- list = g_list_prepend(list, info);
-
- gtk_signal_connect((GtkObject *)stop, "clicked", receive_cancel, info);
- gtk_widget_show_all((GtkWidget *)table);
- }
-
- gtk_widget_show((GtkWidget *)gd);
-
- gtk_signal_connect((GtkObject *)gd, "clicked", dialogue_clicked, data);
-
- data->infos = list;
- data->gd = gd;
- gtk_object_set_data_full((GtkObject *)gd, "info_data", data, free_info_data);
-
- return data;
-}
-
-static void
-update_folders(char *uri, struct _folder_info *info, void *data)
-{
- time_t now = *((time_t *)data);
-
- printf("checking update for folder: %s\n", info->uri);
-
- /* let it flow through to the folders every 10 seconds */
- /* we back off slowly as we progress */
- if (now > info->update+10+info->count*5) {
- printf("upating a folder: %s\n", info->uri);
- camel_folder_thaw(info->folder);
- camel_folder_freeze(info->folder);
- info->update = now;
- info->count++;
- }
-}
-
-/* for forwarding stuff to the gui thread */
-struct _status_msg {
- struct _mail_msg msg;
- char *desc;
- int pc;
- struct _send_info *info;
-};
-
-static void
-do_show_status(struct _mail_msg *mm)
-{
- struct _status_msg *m = (struct _status_msg *)mm;
-
- gtk_progress_set_percentage((GtkProgress *)m->info->bar, (gfloat)(m->pc/100.0));
- gtk_progress_set_format_string((GtkProgress *)m->info->bar, m->desc);
-}
-
-static void
-do_free_status(struct _mail_msg *mm)
-{
- struct _status_msg *m = (struct _status_msg *)mm;
-
- g_free(m->desc);
-}
-
-struct _mail_msg_op status_op = {
- NULL,
- do_show_status,
- NULL,
- do_free_status,
-};
-
-static void
-receive_status (CamelFilterDriver *driver, enum camel_filter_status_t status, int pc, const char *desc, void *data)
-{
- struct _send_info *info = data;
- time_t now;
- struct _status_msg *m;
-
- /* only update every second */
- now = time(0);
- if (now <= info->update)
- return;
-
- info->update = now;
-
- /* let it flow through to the folder, every now and then too? */
- g_hash_table_foreach(info->data->folders, (GHFunc)update_folders, &now);
-
- if (info->data->inbox && now > info->data->inbox_update+20) {
- printf("updating inbox too\n");
- /* this doesn't seem to work right :( */
- camel_folder_thaw(info->data->inbox);
- camel_folder_freeze(info->data->inbox);
- info->data->inbox_update = now;
- }
-
- /* we just pile them onto the port, assuming it can handle it.
- We could also have a receiver port and see if they've been processed
- yet, so if this is necessary its not too hard to add */
- /* the mail_gui_port receiver will free everything for us */
- switch (status) {
- case CAMEL_FILTER_STATUS_START:
- case CAMEL_FILTER_STATUS_END:
- m = mail_msg_new(&status_op, NULL, sizeof(*m));
- m->desc = g_strdup(desc);
- m->pc = pc;
- m->info = info;
- e_msgport_put(mail_gui_port, (EMsg *)m);
- break;
- default:
- break;
- }
-}
-
-/* when receive/send is complete */
-static void
-receive_done (char *uri, void *data)
-{
- struct _send_info *info = data;
-
- gtk_progress_set_percentage((GtkProgress *)info->bar, (gfloat)1.0);
-
- switch(info->state) {
- case SEND_CANCELLED:
- gtk_progress_set_format_string((GtkProgress *)info->bar, _("Cancelled."));
- break;
- default:
- info->state = SEND_COMPLETE;
- gtk_progress_set_format_string((GtkProgress *)info->bar, _("Complete."));
- }
-
- gtk_widget_set_sensitive((GtkWidget *)info->stop, FALSE);
-
- info->data->active--;
- if (info->data->active == 0) {
- gnome_dialog_set_sensitive(info->data->gd, 0, TRUE);
- gnome_dialog_set_sensitive(info->data->gd, 1, FALSE);
- }
-}
-
-/* same for updating */
-static void
-receive_update_done(CamelStore *store, void *data)
-{
- receive_done("", data);
-}
-
-/* although we dont do anythign smart here yet, there is no need for this interface to
- be available to anyone else.
- This can also be used to hook into which folders are being updated, and occasionally
- let them refresh */
-static CamelFolder *
-receive_get_folder(CamelFilterDriver *d, const char *uri, void *data, CamelException *ex)
-{
- struct _send_info *info = data;
- CamelFolder *folder;
- struct _folder_info *oldinfo;
- char *oldkey;
-
- g_mutex_lock(info->data->lock);
- folder = g_hash_table_lookup(info->data->folders, uri);
- g_mutex_unlock(info->data->lock);
- if (folder) {
- camel_object_ref((CamelObject *)folder);
- return folder;
- }
- folder = mail_tool_uri_to_folder(uri, ex);
- if (!folder)
- return NULL;
-
- /* we recheck that the folder hasn't snuck in while we were loading it ... */
- /* and we assume the newer one is the same, but unref the old one anyway */
- g_mutex_lock(info->data->lock);
-
- /* NotZed: I added this ref here, if I'm wrong feel free to remove it */
- camel_object_ref (CAMEL_OBJECT (folder));
-
- if (g_hash_table_lookup_extended(info->data->folders, uri, (void **)&oldkey, (void **)&oldinfo)) {
- camel_object_unref((CamelObject *)oldinfo->folder);
- oldinfo->folder = folder;
- } else {
- oldinfo = g_malloc0(sizeof(*oldinfo));
- oldinfo->folder = folder;
- oldinfo->uri = g_strdup(uri);
- g_hash_table_insert(info->data->folders, oldinfo->uri, oldinfo);
- }
- g_mutex_unlock(info->data->lock);
-
- return folder;
-}
-
-void mail_send_receive(void)
-{
- GSList *sources;
- GList *scan;
- FilterContext *fc;
- struct _send_data *data;
- extern CamelFolder *outbox_folder;
- const MailConfigAccount *account;
- CamelStore *store;
- CamelException *ex;
-
- sources = mail_config_get_sources();
- if (!sources)
- return;
- account = mail_config_get_default_account();
- if (!account || !account->transport)
- return;
-
- fc = mail_load_filter_context();
-
- /* what to do about pop before smtp ?
- Well, probably hook into receive_done or receive_status on
- the right pop account, and when it is, then kick off the
- smtp one. */
- data = build_dialogue(sources, outbox_folder, account->transport->url);
- scan = data->infos;
- while (scan) {
- struct _send_info *info = scan->data;
-
- switch(info->type) {
- case SEND_RECEIVE:
- mail_fetch_mail(info->uri, info->keep,
- fc, FILTER_SOURCE_INCOMING,
- info->cancel,
- receive_get_folder, info,
- receive_status, info,
- receive_done, info);
- break;
- case SEND_SEND:
- /* todo, store the folder in info? */
- mail_send_queue(outbox_folder, info->uri,
- fc, FILTER_SOURCE_OUTGOING,
- info->cancel,
- receive_get_folder, info,
- receive_status, info,
- receive_done, info);
- break;
- case SEND_UPDATE:
- /* FIXME: error reporting? */
- ex = camel_exception_new();
- store = camel_session_get_store(session, info->uri, ex);
- if (store) {
- EvolutionStorage *storage = mail_lookup_storage(store);
- if (storage) {
- mail_update_subfolders(store, storage, receive_update_done, info);
- gtk_object_unref((GtkObject *)storage);
- } else {
- receive_done("", info);
- }
- camel_object_unref((CamelObject *)store);
- } else {
- receive_done("", info);
- }
- camel_exception_free(ex);
- break;
- }
- scan = scan->next;
- }
-
- gtk_object_unref((GtkObject *)fc);
-}
-