Files
evolution/mail/session.c
Not Zed a16344fff4 Fix for mail_get_message change, use queue thread.
2001-01-02  Not Zed  <NotZed@HelixCode.com>

	* mail-callbacks.c (view_msg): Fix for mail_get_message change,
	use queue thread.

	* folder-browser.c (done_message_selected): Fix mail_Get_message
	calls, use new thread.
	(do_message_selected): "

	* mail-ops.c (mail_get_message): Add a thread argument so callers
	can specify which queue it executes on.

	* mail-mt.c (mail_msg_free): Fix a free order problem.
	(mail_msg_destroy): Call mail_msg_free to do the work.
	(mail_msgport_replied): "
	(mail_msgport_replied): Check/display errors if we get them.
	(mail_msgport_received): If we have a describe function, say what
	we're doing, also set busy/unbusy.
	(mail_msgport_replied): Clear busy when we get a reply.
	(mail_get_password): Unset busy.
	(mail_msg_received): Set busy as we go.
	(mail_msg_destroy): Unset busy when done.
	(mail_status): Blah blah, new status interface, the other wans't
	workable with the way the shell api works.

2000-12-29  Not Zed  <NotZed@HelixCode.com>

	* folder-browser.c (do_message_selected): If we are reconfiguring,
	just keep polling till we are done (yeah kinda shitty, but easy).
	(folder_browser_set_uri): Clear reconfigure flag here.  ick.
	(got_folder): And here too.
	(on_right_click): Remove locking.
	(hide_sender): and here too.
	(hide_subject): And here.
	(on_right_click): If we are in reconfigure, then the whole menu is disabled.

	* mail-mt.c (status_busy_timeout): Clear the status_busy_timeout_id.

	* mail-local.c (local_storage_new_folder_cb): Made getting folders
	completely synchronous.  The shell expects it, and it was only
	synchronous before by a sideeffect.
	(do_reconfigure_folder): Remove locking stuff.
	(do_reconfigure_folder): Use our own much simpler copying routine
	than that stupid move_folder_contents thing.
	(update_progress): Use mail_status_message() instead.
	(do_reconfigure_folder): Set the reconfigure flag during
	reconfigure & set busy flag.
	(cleanup_reconfigure_folder): clear busy flag.

	* mail-tools.c (mail_tool_uri_to_folder): Remove the tool_lock
	stuff.
	(mail_tool_uri_to_folder_noex): Clear exception on exit.
	(mail_tool_move_folder_contents): Get rid of this really stupid
	function that is only used in one place.

	* component-factory.c (owner_set_cb): Use direct calls to get the
	folders, as this code must run synchronous.  Remove the event wait
	stuff.

	* mail-callbacks.c (edit_msg): Call mail_get_messages, and create
	the composers ourself.
	(do_edit_messages): get_messages callback, create the composers
	and connect to signals we need.
	(view_msg): Dont call do_view_messages, just call
	mail_get_messge for each to get them in parallel.
	(do_view_message): view a single message.

	* mail-ops.c (mail_edit_messages): Just use mail_get_messages
	for this operation.  Removed the other async operation stuff.
	Changed my mind, just removed entirely.
	(mail_do_view_messages): Removed.
	(mail_do_setup_folder): Removed.
	(mail_do_scan_subfolders): Make this run synchronously, as every
	caller expects it to (even if they didn't realise).

2000-12-28  Not Zed  <NotZed@HelixCode.com>

	* mail-callbacks.c (send_queued_mail): Dont expunge the folder
	here, but in send_queue, otherwise it might execute out of order.
	(expunge_folder): Remove the talbe prechange stuff, and infact
	references to the message_list folder, as we have our own folder.
	Also, dont allow expunge if we're already expunging.
	(expunged_folder): Clkear the expunging flag if we're finished.

	* folder-browser-factory.c (control_deactivate): Likewise here.
	Hrm, i thought this function required a callback, silly me.

	* mail-tools.c (mail_tool_make_message_attachment): Remov e
	locking.

	* folder-browser.c (on_message_selected): Use a timeout handler so
	we dont select immediately.
	(folder_browser_set_uri): Changed to use mail_get_folder.
	(got_folder): New callback called when get_folder is finished.
	(folder_browser_destroy): Use new sync interface.

	* mail-ops.c (mail_get_message): New function to asynchrounously
	get a message.
	: #define out mail_tool_camel_lock stuff entirely.
	(mail_get_folder): New function to asynchrounously get a folder.
	(mail_do_load_folder): Removed, replaced by more generic function
	above.
	(mail_do_display_message): Removed, replaced by the more generic
	funciton get_message.
	(mail_get_messages): New function to get a list of messages
	asynchronously.
	(mail_sync_folder): New interface to sync a folder async.
	(mail_expunge_folder): New interface for expunging folder, with
	callback.
	(do_send_queue): Remove lock stuff, and expunge if (and only if)
	successful, also sync the sent folder while we're at it.

	* session.c (mail_session_request_dialog): Changed to use new
	mail_get_password call.

	* mail-mt.[ch]: New threading/interthread messaging framework.

	* main.c (main): Init the message/thread system.

svn path=/trunk/; revision=7223
2001-01-03 01:18:21 +00:00

292 lines
6.1 KiB
C

/*
* mail-session.c: handles the session information and resource manipulation
*
* Author:
* Miguel de Icaza (miguel@gnu.org)
*
* (C) 2000 Helix Code, Inc. http://www.helixcode.com
*/
#include <config.h>
#include <gnome.h>
#include "mail.h"
#include "mail-session.h"
#include "mail-threads.h"
#include "mail-mt.h"
CamelSession *session;
static GHashTable *passwords;
static gboolean interaction_enabled;
static void
request_callback (gchar *string, gpointer data)
{
char **ans = data;
if (string)
*ans = g_strdup(string);
else
*ans = NULL;
}
char *
mail_session_request_dialog (const char *prompt, gboolean secret, const char *key,
gboolean async)
{
GtkWidget *dialog;
char *ans;
if (!passwords)
passwords = g_hash_table_new (g_str_hash, g_str_equal);
ans = g_hash_table_lookup (passwords, key);
if (ans)
return g_strdup (ans);
if (!interaction_enabled)
return NULL;
if (!async) {
dialog = gnome_request_dialog (secret, prompt, NULL, 0,
request_callback, &ans, NULL);
if (!dialog)
return NULL;
if (gnome_dialog_run_and_close (GNOME_DIALOG (dialog)) == -1 ||
ans == NULL)
return NULL;
} else {
if ((ans = mail_get_password ((char *) prompt, secret)) == NULL)
return NULL;
}
g_hash_table_insert (passwords, g_strdup (key), g_strdup (ans));
return ans;
}
static char *
auth_callback (CamelAuthCallbackMode mode, char *data, gboolean secret,
CamelService *service, char *item, CamelException *ex)
{
char *key, *ans, *url;
url = camel_url_to_string (service->url, FALSE);
key = g_strdup_printf ("%s:%s", url, item);
g_free (url);
if (mode == CAMEL_AUTHENTICATOR_TELL) {
if (!data) {
g_hash_table_remove (passwords, key);
g_free (key);
} else {
gpointer old_key, old_data;
if (g_hash_table_lookup_extended (passwords, key,
&old_key,
&old_data)) {
g_hash_table_insert (passwords, old_key, data);
g_free (old_data);
g_free (key);
} else
g_hash_table_insert (passwords, key, data);
}
return NULL;
}
ans = mail_session_request_dialog (data, secret, key, TRUE);
g_free (key);
if (!ans) {
camel_exception_set (ex, CAMEL_EXCEPTION_USER_CANCEL,
"User canceled operation.");
}
return ans;
}
static char *
decode_base64 (char *base64)
{
char *plain, *pad = "==";
int len, out, state, save;
len = strlen (base64);
plain = g_malloc0 (len);
state = save = 0;
out = base64_decode_step (base64, len, plain, &state, &save);
if (len % 4) {
base64_decode_step (pad, 4 - len % 4, plain + out,
&state, &save);
}
return plain;
}
static void
maybe_remember_password (gpointer key, gpointer password, gpointer url)
{
char *path, *key64, *pass64;
int len, state, save;
len = strlen (url);
if (strncmp (key, url, len) != 0)
return;
len = strlen (key);
key64 = g_malloc0 ((len + 2) * 4 / 3 + 1);
state = save = 0;
base64_encode_close (key, len, FALSE, key64, &state, &save);
path = g_strdup_printf ("/Evolution/Passwords/%s", key64);
g_free (key64);
len = strlen (password);
pass64 = g_malloc0 ((len + 2) * 4 / 3 + 1);
state = save = 0;
base64_encode_close (password, len, FALSE, pass64, &state, &save);
gnome_config_private_set_string (path, pass64);
g_free (path);
g_free (pass64);
}
void
mail_session_remember_password (const char *url)
{
g_hash_table_foreach (passwords, maybe_remember_password, (void *) url);
}
/* ******************** */
typedef struct _timeout_data_s {
CamelTimeoutCallback cb;
gpointer camel_data;
gboolean result;
} timeout_data_t;
static gchar *
describe_camel_timeout (gpointer in_data, gboolean gerund)
{
/* FIXME this is so wrong */
if (gerund)
return g_strdup ("Keeping connection alive");
else
return g_strdup ("Keep connection alive");
}
static void
noop_camel_timeout (gpointer in_data, gpointer op_data, CamelException *ex)
{
}
static void
do_camel_timeout (gpointer in_data, gpointer op_data, CamelException *ex)
{
timeout_data_t *td = (timeout_data_t *) in_data;
td->result = (td->cb) (td->camel_data);
}
static const mail_operation_spec spec_camel_timeout =
{
describe_camel_timeout,
0,
noop_camel_timeout,
do_camel_timeout,
noop_camel_timeout
};
static gboolean
camel_timeout (gpointer data)
{
timeout_data_t *td = (timeout_data_t *) data;
if (td->result == FALSE) {
g_free (td);
return FALSE;
}
mail_operation_queue (&spec_camel_timeout, td, FALSE);
return TRUE;
}
static guint
register_callback (guint32 interval, CamelTimeoutCallback cb, gpointer camel_data)
{
timeout_data_t *td;
/* We do this because otherwise the timeout can get called
* more often than the dispatch thread can get rid of it,
* leading to timeout calls piling up, and we don't have a
* good way to watch the return values. It's not cool.
*/
g_return_val_if_fail (interval > 1000, 0);
td = g_new (timeout_data_t, 1);
td->result = TRUE;
td->cb = cb;
td->camel_data = camel_data;
return gtk_timeout_add_full (interval, camel_timeout, NULL,
td, g_free);
}
static gboolean
remove_callback (guint handle)
{
gtk_timeout_remove (handle);
return TRUE;
}
/* ******************** */
void
mail_session_init (void)
{
char *camel_dir, *key, *value;
void *iter;
camel_init ();
camel_dir = g_strdup_printf ("%s/mail", evolution_dir);
session = camel_session_new (camel_dir, auth_callback,
register_callback, remove_callback);
g_free (camel_dir);
passwords = g_hash_table_new (g_str_hash, g_str_equal);
iter = gnome_config_private_init_iterator ("/Evolution/Passwords");
if (iter) {
while (gnome_config_iterator_next (iter, &key, &value)) {
g_hash_table_insert (passwords, decode_base64 (key),
decode_base64 (value));
g_free (key);
g_free (value);
}
}
}
void
mail_session_enable_interaction (gboolean enable)
{
interaction_enabled = enable;
}
static gboolean
free_entry (gpointer key, gpointer value, gpointer user_data)
{
g_free (key);
memset (value, 0, strlen (value));
g_free (value);
return TRUE;
}
void
mail_session_forget_passwords (BonoboUIComponent *uih, void *user_data,
const char *path)
{
g_hash_table_foreach_remove (passwords, free_entry, NULL);
gnome_config_private_clean_section ("/Evolution/Passwords");
gnome_config_sync ();
}