Bug 726746 - Allow to auto-empty trash without needing to exit

1 files changed, 210 insertions, 1 deletions

diff --git a/mail/mail-send-recv.c b/mail/mail-send-recv.c
index a04c3a5c38..d6b0edd4c9 100644
--- a/mail/mail-send-recv.c
+++ b/mail/mail-send-recv.c
@@ -953,6 +953,126 @@ receive_get_folder (CamelFilterDriver *d,
 
 /* ********************************************************************** */
 
+static gboolean
+delete_junk_sync (CamelStore *store,
+		  GCancellable *cancellable,
+		  GError **error)
+{
+	CamelFolder *folder;
+	GPtrArray *uids;
+	guint32 flags;
+	guint32 mask;
+	guint ii;
+
+	g_return_val_if_fail (CAMEL_IS_STORE (store), FALSE);
+
+	folder = camel_store_get_junk_folder_sync (store, cancellable, error);
+	if (folder == NULL)
+		return FALSE;
+
+	uids = camel_folder_get_uids (folder);
+	flags = mask = CAMEL_MESSAGE_DELETED | CAMEL_MESSAGE_SEEN;
+
+	camel_folder_freeze (folder);
+
+	for (ii = 0; ii < uids->len; ii++) {
+		const gchar *uid = uids->pdata[ii];
+		camel_folder_set_message_flags (folder, uid, flags, mask);
+	}
+
+	camel_folder_thaw (folder);
+
+	camel_folder_free_uids (folder, uids);
+	g_object_unref (folder);
+
+	return TRUE;
+}
+
+struct TestShouldData
+{
+	gint64 last_delete_junk;
+	gint64 last_expunge;
+};
+
+static void
+test_should_delete_junk_or_expunge (CamelStore *store,
+				    gboolean *should_delete_junk,
+				    gboolean *should_expunge)
+{
+	static GMutex mutex;
+	static GHashTable *last_expunge = NULL;
+
+	GSettings *settings;
+	const gchar *uid;
+	gint64 trash_empty_date = 0, junk_empty_date = 0;
+	gint trash_empty_days = 0, junk_empty_days = 0;
+	gint64 now;
+
+	g_return_if_fail (CAMEL_IS_STORE (store));
+	g_return_if_fail (should_delete_junk != NULL);
+	g_return_if_fail (should_expunge != NULL);
+
+	*should_delete_junk = FALSE;
+	*should_expunge = FALSE;
+
+	uid = camel_service_get_uid (CAMEL_SERVICE (store));
+	g_return_if_fail (uid != NULL);
+
+	settings = g_settings_new ("org.gnome.evolution.mail");
+
+	now = time (NULL) / 60 / 60 / 24;
+
+	*should_delete_junk = g_settings_get_boolean (settings, "junk-empty-on-exit");
+	*should_expunge = g_settings_get_boolean (settings, "trash-empty-on-exit");
+
+	if (*should_delete_junk || *should_expunge) {
+		junk_empty_days = g_settings_get_int (settings, "junk-empty-on-exit-days");
+		junk_empty_date = g_settings_get_int (settings, "junk-empty-date");
+
+		trash_empty_days = g_settings_get_int (settings, "trash-empty-on-exit-days");
+		trash_empty_date = g_settings_get_int (settings, "trash-empty-date");
+
+		g_mutex_lock (&mutex);
+		if (!last_expunge) {
+			last_expunge = g_hash_table_new_full (g_str_hash, g_str_equal, g_free, g_free);
+		} else {
+			struct TestShouldData *tsd;
+
+			tsd = g_hash_table_lookup (last_expunge, uid);
+			if (tsd) {
+				junk_empty_date = tsd->last_delete_junk;
+				trash_empty_date = tsd->last_expunge;
+			}
+		}
+		g_mutex_unlock (&mutex);
+	}
+
+	*should_delete_junk = *should_delete_junk && junk_empty_days > 0 && junk_empty_date + junk_empty_days <= now;
+	*should_expunge = *should_expunge && trash_empty_days > 0 && trash_empty_date + trash_empty_days <= now;
+
+	if (*should_delete_junk || *should_expunge) {
+		struct TestShouldData *tsd;
+
+		if (*should_delete_junk)
+			junk_empty_date = now;
+		if (*should_expunge)
+			trash_empty_date = now;
+
+		g_mutex_lock (&mutex);
+		tsd = g_hash_table_lookup (last_expunge, uid);
+		if (!tsd) {
+			tsd = g_new0 (struct TestShouldData, 1);
+			g_hash_table_insert (last_expunge, g_strdup (uid), tsd);
+		}
+
+		tsd->last_delete_junk = junk_empty_date;
+		tsd->last_expunge = trash_empty_date;
+		g_mutex_unlock (&mutex);
+	}
+
+	g_object_unref (settings);
+}
+
 static void
 get_folders (CamelStore *store,
              GPtrArray *folders,
@@ -1006,6 +1126,7 @@ refresh_folders_exec (struct _refresh_folders_msg *m,
 	CamelFolder *folder;
 	gint i;
 	gboolean success;
+	gboolean delete_junk = FALSE, expunge = FALSE;
 	GError *local_error = NULL;
 	gulong handler_id = 0;
 
@@ -1023,12 +1144,19 @@ refresh_folders_exec (struct _refresh_folders_msg *m,
 
 	camel_operation_push_message (m->info->cancellable, _("Updating..."));
 
+	test_should_delete_junk_or_expunge (m->store, &delete_junk, &expunge);
+
+	if (delete_junk && !delete_junk_sync (m->store, cancellable, error)) {
+		camel_operation_pop_message (m->info->cancellable);
+		goto exit;
+	}
+
 	for (i = 0; i < m->folders->len; i++) {
 		folder = e_mail_session_uri_to_folder_sync (
 			E_MAIL_SESSION (m->info->session),
 			m->folders->pdata[i], 0,
 			cancellable, &local_error);
-		if (folder && camel_folder_synchronize_sync (folder, FALSE, cancellable, &local_error))
+		if (folder && camel_folder_synchronize_sync (folder, expunge, cancellable, &local_error))
 			camel_folder_refresh_info_sync (folder, cancellable, &local_error);
 
 		if (local_error != NULL) {
@@ -1169,6 +1297,85 @@ receive_update_got_store (CamelStore *store,
 	}
 }
 
+
+struct _refresh_local_store_msg {
+	MailMsg base;
+
+	CamelStore *store;
+	gboolean delete_junk;
+	gboolean expunge_trash;
+};
+
+static gchar *
+refresh_local_store_desc (struct _refresh_local_store_msg *m)
+{
+	const gchar *display_name;
+
+	display_name = camel_service_get_display_name (CAMEL_SERVICE (m->store));
+
+	if (m->delete_junk && m->expunge_trash)
+		return g_strdup_printf (_("Deleting junk and expunging trash at '%s'"), display_name);
+	else if (m->delete_junk)
+		return g_strdup_printf (_("Deleting junk at '%s'"), display_name);
+	else
+		return g_strdup_printf (_("Expunging trash at '%s'"), display_name);
+}
+
+static void
+refresh_local_store_exec (struct _refresh_local_store_msg *m,
+			  GCancellable *cancellable,
+			  GError **error)
+{
+	if (m->delete_junk && !delete_junk_sync (m->store, cancellable, error))
+		return;
+
+	if (m->expunge_trash) {
+		CamelFolder *trash;
+
+		trash = camel_store_get_trash_folder_sync (m->store, cancellable, error);
+
+		if (trash != NULL) {
+			e_mail_folder_expunge_sync (trash, cancellable, error);
+			g_object_unref (trash);
+		}
+	}
+}
+
+static void
+refresh_local_store_free (struct _refresh_local_store_msg *m)
+{
+	g_object_unref (m->store);
+}
+
+static MailMsgInfo refresh_local_store_info = {
+	sizeof (struct _refresh_local_store_msg),
+	(MailMsgDescFunc) refresh_local_store_desc,
+	(MailMsgExecFunc) refresh_local_store_exec,
+	(MailMsgDoneFunc) NULL,
+	(MailMsgFreeFunc) refresh_local_store_free
+};
+
+static void
+maybe_delete_junk_or_expunge_local_store (EMailSession *session)
+{
+	CamelStore *store;
+	gboolean delete_junk = FALSE, expunge_trash = FALSE;
+	struct _refresh_local_store_msg *m;
+
+	store = e_mail_session_get_local_store (session);
+	test_should_delete_junk_or_expunge (store, &delete_junk, &expunge_trash);
+
+	if (!delete_junk && !expunge_trash)
+		return;
+
+	m = mail_msg_new (&refresh_local_store_info);
+	m->store = g_object_ref (store);
+	m->delete_junk = delete_junk;
+	m->expunge_trash = expunge_trash;
+
+	mail_msg_unordered_push (m);
+}
+
 static CamelService *
 ref_default_transport (EMailSession *session)
 {
@@ -1241,6 +1448,8 @@ send_receive (GtkWindow *parent,
 	if (transport != NULL)
 		g_object_unref (transport);
 
+	maybe_delete_junk_or_expunge_local_store (session);
+
 	scan = g_list_copy (data->infos);
 
 	for (siter = scan; siter != NULL; siter = siter->next) {