/*
* This program is free software; you can redistribute it and/or
* modify it under the terms of the GNU Lesser General Public
* License as published by the Free Software Foundation; either
* version 2 of the License, or (at your option) version 3.
*
* 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
* Lesser General Public License for more details.
*
* You should have received a copy of the GNU Lesser General Public
* License along with the program; if not, see <http://www.gnu.org/licenses/>
*
*
* Authors:
* Federico Mena-Quintero <federico@ximian.com>
*
* Copyright (C) 1999-2008 Novell, Inc. (www.novell.com)
*
*/
#ifdef HAVE_CONFIG_H
#include <config.h>
#endif
#include <string.h>
#include <camel/camel.h>
#include <libecal/e-cal-client.h>
#include <libedataserver/e-url.h>
#include <libedataserver/e-data-server-util.h>
#include <libedataserverui/e-passwords.h>
#include <libedataserverui/e-client-utils.h>
#include "alarm.h"
#include "alarm-notify.h"
#include "alarm-queue.h"
#include "config-data.h"
#define APPLICATION_ID "org.gnome.EvolutionAlarmNotify"
struct _AlarmNotifyPrivate {
/* Mapping from EUri's to LoadedClient structures */
/* FIXME do we need per source type uri hashes? or perhaps we
just need to hash based on source */
GHashTable *uri_client_hash[E_CAL_CLIENT_SOURCE_TYPE_LAST];
ESourceList *source_lists[E_CAL_CLIENT_SOURCE_TYPE_LAST];
ESourceList *selected_calendars;
GMutex *mutex;
};
typedef struct {
AlarmNotify *an;
ESourceList *source_list;
GList *removals;
} ProcessRemovalsData;
G_DEFINE_TYPE (AlarmNotify, alarm_notify, GTK_TYPE_APPLICATION)
static void
process_removal_in_hash (const gchar *uri,
gpointer value,
ProcessRemovalsData *prd)
{
GSList *groups, *sources, *p, *q;
gboolean found = FALSE;
/* search the list of selected calendars */
groups = e_source_list_peek_groups (prd->source_list);
for (p = groups; p != NULL; p = p->next) {
ESourceGroup *group = E_SOURCE_GROUP (p->data);
sources = e_source_group_peek_sources (group);
for (q = sources; q != NULL; q = q->next) {
ESource *source = E_SOURCE (q->data);
gchar *source_uri;
const gchar *completion = e_source_get_property (source, "alarm");
source_uri = e_source_get_uri (source);
if (strcmp (source_uri, uri) == 0)
if (!completion || !g_ascii_strcasecmp (completion, "true"))
found = TRUE;
g_free (source_uri);
if (found)
return;
}
}
/* not found, so list it for removal */
prd->removals = g_list_prepend (prd->removals, (gpointer) uri);
}
static void
alarm_notify_list_changed_cb (ESourceList *source_list,
AlarmNotify *an)
{
GSList *groups, *sources, *p, *q;
ECalClientSourceType source_type = E_CAL_CLIENT_SOURCE_TYPE_LAST;
ProcessRemovalsData prd;
GList *l;
gint i;
g_signal_handlers_block_by_func (
source_list, alarm_notify_list_changed_cb, an);
/* Figure out the source type */
for (i = 0; i < E_CAL_CLIENT_SOURCE_TYPE_LAST; i++) {
if (source_list == an->priv->source_lists[i]) {
source_type = i;
break;
}
}
if (source_type == E_CAL_CLIENT_SOURCE_TYPE_LAST)
return;
/* process the additions */
groups = e_source_list_peek_groups (source_list);
for (p = groups; p != NULL; p = p->next) {
ESourceGroup *group = E_SOURCE_GROUP (p->data);
sources = e_source_group_peek_sources (group);
for (q = sources; q != NULL; q = q->next) {
ESource *source = E_SOURCE (q->data);
gchar *uri;
const gchar *alarm = e_source_get_property (source, "alarm");
if (alarm && (!g_ascii_strcasecmp (alarm, "false") || !g_ascii_strcasecmp (alarm, "never")))
continue;
uri = e_source_get_uri (source);
if (!g_hash_table_lookup (an->priv->uri_client_hash[source_type], uri)) {
debug (("Adding Calendar %s", uri));
alarm_notify_add_calendar (an, source_type, source, FALSE);
}
g_free (uri);
}
}
/* process the removals */
prd.an = an;
prd.source_list = an->priv->source_lists[source_type];
prd.removals = NULL;
g_hash_table_foreach (an->priv->uri_client_hash[source_type], (GHFunc) process_removal_in_hash, &prd);
for (l = prd.removals; l; l = l->next) {
debug (("Removing Calendar %s", (gchar *)l->data));
alarm_notify_remove_calendar (an, source_type, l->data);
}
g_list_free (prd.removals);
g_signal_handlers_unblock_by_func (
source_list, alarm_notify_list_changed_cb, an);
}
static void
alarm_notify_load_calendars (AlarmNotify *an,
ECalClientSourceType source_type)
{
ESourceList *source_list;
GSList *groups, *sources, *p, *q;
if (!e_cal_client_get_sources (&source_list, source_type, NULL)) {
debug (("Cannont get sources"));
an->priv->source_lists[source_type] = NULL;
return;
}
groups = e_source_list_peek_groups (source_list);
for (p = groups; p != NULL; p = p->next) {
ESourceGroup *group = E_SOURCE_GROUP (p->data);
sources = e_source_group_peek_sources (group);
for (q = sources; q != NULL; q = q->next) {
ESource *source = E_SOURCE (q->data);
gchar *uri;
const gchar *alarm = e_source_get_property (source, "alarm");
if (alarm && (!g_ascii_strcasecmp (alarm, "false") || !g_ascii_strcasecmp (alarm, "never")))
continue;
uri = e_source_get_uri (source);
debug (("Loading Calendar %s", uri));
alarm_notify_add_calendar (an, source_type, source, FALSE);
g_free (uri);
}
}
e_source_list_sync (source_list, NULL);
g_signal_connect_object (
source_list, "changed",
G_CALLBACK (alarm_notify_list_changed_cb), an, 0);
an->priv->source_lists[source_type] = source_list;
}
static void
alarm_notify_dequeue_client (gpointer key,
ECalClient *client)
{
alarm_queue_remove_client (client, TRUE);
}
static void
alarm_notify_finalize (GObject *object)
{
AlarmNotifyPrivate *priv;
gint ii;
priv = ALARM_NOTIFY (object)->priv;
for (ii = 0; ii < E_CAL_CLIENT_SOURCE_TYPE_LAST; ii++) {
g_hash_table_foreach (
priv->uri_client_hash[ii],
(GHFunc) alarm_notify_dequeue_client, NULL);
g_hash_table_destroy (priv->uri_client_hash[ii]);
}
alarm_queue_done ();
alarm_done ();
e_passwords_shutdown ();
g_mutex_free (priv->mutex);
/* Chain up to parent's finalize() method. */
G_OBJECT_CLASS (alarm_notify_parent_class)->finalize (object);
}
static void
alarm_notify_startup (GApplication *application)
{
GtkIconTheme *icon_theme;
/* Chain up to parent's startup() method. */
G_APPLICATION_CLASS (alarm_notify_parent_class)->startup (application);
/* Keep the application running. */
g_application_hold (application);
config_data_init_debugging ();
/* FIXME Ideally we should not use Camel libraries in calendar,
* though it is the case currently for attachments. Remove
* this once that is fixed. */
/* Initialize Camel's type system. */
camel_object_get_type ();
icon_theme = gtk_icon_theme_get_default ();
gtk_icon_theme_append_search_path (icon_theme, EVOLUTION_ICONDIR);
}
static void
alarm_notify_class_init (AlarmNotifyClass *class)
{
GObjectClass *object_class;
GApplicationClass *application_class;
g_type_class_add_private (class, sizeof (AlarmNotifyPrivate));
object_class = G_OBJECT_CLASS (class);
object_class->finalize = alarm_notify_finalize;
application_class = G_APPLICATION_CLASS (class);
application_class->startup = alarm_notify_startup;
}
static void
alarm_notify_init (AlarmNotify *an)
{
gint ii;
an->priv = G_TYPE_INSTANCE_GET_PRIVATE (
an, TYPE_ALARM_NOTIFY, AlarmNotifyPrivate);
an->priv->mutex = g_mutex_new ();
an->priv->selected_calendars = config_data_get_calendars (
"/apps/evolution/calendar/sources");
for (ii = 0; ii < E_CAL_CLIENT_SOURCE_TYPE_LAST; ii++)
an->priv->uri_client_hash[ii] = g_hash_table_new_full (
g_str_hash, g_str_equal,
(GDestroyNotify) g_free,
(GDestroyNotify) g_object_unref);
alarm_queue_init (an);
for (ii = 0; ii < E_CAL_CLIENT_SOURCE_TYPE_LAST; ii++)
alarm_notify_load_calendars (an, ii);
}
ESourceList *
alarm_notify_get_selected_calendars (AlarmNotify *an)
{
return an->priv->selected_calendars;
}
/**
* alarm_notify_new:
*
* Creates a new #AlarmNotify object.
*
* Returns: a newly-created #AlarmNotify
**/
AlarmNotify *
alarm_notify_new (void)
{
return g_object_new (
TYPE_ALARM_NOTIFY,
"application-id", APPLICATION_ID, NULL);
}
static void
client_opened_cb (GObject *source_object, GAsyncResult *result, gpointer user_data)
{
AlarmNotifyPrivate *priv;
AlarmNotify *an = ALARM_NOTIFY (user_data);
EClient *client = NULL;
GError *error = NULL;
if (!e_client_utils_open_new_finish (E_SOURCE (source_object), result, &client, &error))
client = NULL;
priv = an->priv;
debug (("%s - Calendar Status %d%s%s%s", e_client_get_uri (client), error ? error->code : 0, error ? " (" : "", error ? error->message : "", error ? ")" : ""));
if (!error) {
ECalClient *cal_client = E_CAL_CLIENT (client);
g_hash_table_insert (priv->uri_client_hash[e_cal_client_get_source_type (cal_client)], g_strdup (e_client_get_uri (client)), cal_client);
/* to resolve floating DATE-TIME properly */
e_cal_client_set_default_timezone (cal_client, config_data_get_timezone ());
alarm_queue_add_client (cal_client);
} else {
g_error_free (error);
}
}
/**
* alarm_notify_add_calendar:
* @an: An alarm notification service.
* @uri: URI of the calendar to load.
* @load_afterwards: Whether this calendar should be loaded in the future
* when the alarm daemon starts up.
*
* Tells the alarm notification service to load a calendar and start monitoring
* its alarms. It can optionally be made to save the URI of this calendar so
* that it can be loaded in the future when the alarm daemon starts up.
**/
void
alarm_notify_add_calendar (AlarmNotify *an, ECalClientSourceType source_type, ESource *source, gboolean load_afterwards)
{
AlarmNotifyPrivate *priv;
EUri *e_uri;
gchar *str_uri;
gchar *pass_key;
g_return_if_fail (an != NULL);
g_return_if_fail (IS_ALARM_NOTIFY (an));
/* Make sure the key used in for getting password is properly generated for all types of backends */
priv = an->priv;
str_uri = e_source_get_uri (source);
e_uri = e_uri_new (str_uri);
if (e_source_get_property (source, "auth-type"))
pass_key = e_uri_to_string (e_uri, FALSE);
else
pass_key = g_strdup (str_uri);
e_uri_free (e_uri);
g_mutex_lock (an->priv->mutex);
/* See if we already know about this uri */
if (g_hash_table_lookup (priv->uri_client_hash[source_type], str_uri)) {
g_mutex_unlock (an->priv->mutex);
g_free (str_uri);
g_free (pass_key);
return;
}
/* if loading of this requires password and password is not currently availble in e-password
session skip this source loading. we do not really want to prompt for auth from alarm dameon*/
if (e_source_get_property (source, "auth")) {
if (!e_passwords_get_password (NULL, pass_key)) {
g_mutex_unlock (an->priv->mutex);
g_free (str_uri);
g_free (pass_key);
return;
}
}
debug (("%s - Calendar Open Async... %p", str_uri, source));
e_client_utils_open_new (source,
source_type == E_CAL_CLIENT_SOURCE_TYPE_EVENTS ? E_CLIENT_SOURCE_TYPE_EVENTS :
source_type == E_CAL_CLIENT_SOURCE_TYPE_TASKS ? E_CLIENT_SOURCE_TYPE_TASKS :
source_type == E_CAL_CLIENT_SOURCE_TYPE_MEMOS ? E_CLIENT_SOURCE_TYPE_MEMOS :
E_CLIENT_SOURCE_TYPE_LAST,
TRUE, NULL,
e_client_utils_authenticate_handler, NULL,
client_opened_cb, an);
g_free (str_uri);
g_free (pass_key);
g_mutex_unlock (an->priv->mutex);
}
void
alarm_notify_remove_calendar (AlarmNotify *an, ECalClientSourceType source_type, const gchar *str_uri)
{
AlarmNotifyPrivate *priv;
ECalClient *cal_client;
priv = an->priv;
cal_client = g_hash_table_lookup (priv->uri_client_hash[source_type], str_uri);
if (cal_client) {
debug (("Removing Client %p", cal_client));
alarm_queue_remove_client (cal_client, FALSE);
g_hash_table_remove (priv->uri_client_hash[source_type], str_uri);
}
}