/* * 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 * * * Authors: * JP Rosevear * Mike Kestner * * Copyright (C) 1999-2008 Novell, Inc. (www.novell.com) * */ #ifdef HAVE_CONFIG_H #include #endif #include #include #include #include #include #include #include #include "itip-utils.h" #include "e-meeting-utils.h" #include "e-meeting-attendee.h" #include "e-meeting-store.h" #define ROW_VALID(store, row) \ (row >= 0 && row < store->priv->attendees->len) #define E_MEETING_STORE_GET_PRIVATE(obj) \ (G_TYPE_INSTANCE_GET_PRIVATE \ ((obj), E_TYPE_MEETING_STORE, EMeetingStorePrivate)) struct _EMeetingStorePrivate { GPtrArray *attendees; gint stamp; ECal *client; icaltimezone *zone; gchar *fb_uri; GPtrArray *refresh_queue; GHashTable *refresh_data; GMutex *mutex; guint refresh_idle_id; guint num_threads; guint num_queries; }; #define BUF_SIZE 1024 typedef struct _EMeetingStoreQueueData EMeetingStoreQueueData; struct _EMeetingStoreQueueData { EMeetingStore *store; EMeetingAttendee *attendee; gboolean refreshing; EMeetingTime start; EMeetingTime end; gchar buffer[BUF_SIZE]; GString *string; GPtrArray *call_backs; GPtrArray *data; }; enum { PROP_0, PROP_CLIENT, PROP_FREE_BUSY_TEMPLATE, PROP_TIMEZONE }; /* Forward Declarations */ static void ems_tree_model_init (GtkTreeModelIface *iface); G_DEFINE_TYPE_WITH_CODE ( EMeetingStore, e_meeting_store, GTK_TYPE_LIST_STORE, G_IMPLEMENT_INTERFACE (E_TYPE_EXTENSIBLE, NULL) G_IMPLEMENT_INTERFACE (GTK_TYPE_TREE_MODEL, ems_tree_model_init)) static icalparameter_cutype text_to_type (const gchar *type) { if (!e_util_utf8_strcasecmp (type, _("Individual"))) return ICAL_CUTYPE_INDIVIDUAL; else if (!e_util_utf8_strcasecmp (type, _("Group"))) return ICAL_CUTYPE_GROUP; else if (!e_util_utf8_strcasecmp (type, _("Resource"))) return ICAL_CUTYPE_RESOURCE; else if (!e_util_utf8_strcasecmp (type, _("Room"))) return ICAL_CUTYPE_ROOM; else return ICAL_CUTYPE_NONE; } static gchar * type_to_text (icalparameter_cutype type) { switch (type) { case ICAL_CUTYPE_INDIVIDUAL: return _("Individual"); case ICAL_CUTYPE_GROUP: return _("Group"); case ICAL_CUTYPE_RESOURCE: return _("Resource"); case ICAL_CUTYPE_ROOM: return _("Room"); default: return _("Unknown"); } return NULL; } static icalparameter_role text_to_role (const gchar *role) { if (!e_util_utf8_strcasecmp (role, _("Chair"))) return ICAL_ROLE_CHAIR; else if (!e_util_utf8_strcasecmp (role, _("Required Participant"))) return ICAL_ROLE_REQPARTICIPANT; else if (!e_util_utf8_strcasecmp (role, _("Optional Participant"))) return ICAL_ROLE_OPTPARTICIPANT; else if (!e_util_utf8_strcasecmp (role, _("Non-Participant"))) return ICAL_ROLE_NONPARTICIPANT; else return ICAL_ROLE_NONE; } static gchar * role_to_text (icalparameter_role role) { switch (role) { case ICAL_ROLE_CHAIR: return _("Chair"); case ICAL_ROLE_REQPARTICIPANT: return _("Required Participant"); case ICAL_ROLE_OPTPARTICIPANT: return _("Optional Participant"); case ICAL_ROLE_NONPARTICIPANT: return _("Non-Participant"); default: return _("Unknown"); } } static gboolean text_to_boolean (const gchar *role) { if (!e_util_utf8_strcasecmp (role, _("Yes"))) return TRUE; else return FALSE; } static gchar * boolean_to_text (gboolean b) { if (b) return _("Yes"); else return _("No"); } static icalparameter_partstat text_to_partstat (const gchar *partstat) { if (!e_util_utf8_strcasecmp (partstat, _("Needs Action"))) return ICAL_PARTSTAT_NEEDSACTION; else if (!e_util_utf8_strcasecmp (partstat, _("Accepted"))) return ICAL_PARTSTAT_ACCEPTED; else if (!e_util_utf8_strcasecmp (partstat, _("Declined"))) return ICAL_PARTSTAT_DECLINED; else if (!e_util_utf8_strcasecmp (partstat, _("Tentative"))) return ICAL_PARTSTAT_TENTATIVE; else if (!e_util_utf8_strcasecmp (partstat, _("Delegated"))) return ICAL_PARTSTAT_DELEGATED; else if (!e_util_utf8_strcasecmp (partstat, _("Completed"))) return ICAL_PARTSTAT_COMPLETED; else if (!e_util_utf8_strcasecmp (partstat, _("In Process"))) return ICAL_PARTSTAT_INPROCESS; else return ICAL_PARTSTAT_NONE; } static gchar * partstat_to_text (icalparameter_partstat partstat) { switch (partstat) { case ICAL_PARTSTAT_NEEDSACTION: return _("Needs Action"); case ICAL_PARTSTAT_ACCEPTED: return _("Accepted"); case ICAL_PARTSTAT_DECLINED: return _("Declined"); case ICAL_PARTSTAT_TENTATIVE: return _("Tentative"); case ICAL_PARTSTAT_DELEGATED: return _("Delegated"); case ICAL_PARTSTAT_COMPLETED: return _("Completed"); case ICAL_PARTSTAT_INPROCESS: return _("In Process"); case ICAL_PARTSTAT_NONE: default: return _("Unknown"); } } static GtkTreeModelFlags get_flags (GtkTreeModel *model) { g_return_val_if_fail (E_IS_MEETING_STORE (model), 0); return GTK_TREE_MODEL_ITERS_PERSIST | GTK_TREE_MODEL_LIST_ONLY; } static gint get_n_columns (GtkTreeModel *model) { g_return_val_if_fail (E_IS_MEETING_STORE (model), 0); return E_MEETING_STORE_COLUMN_COUNT; } static GType get_column_type (GtkTreeModel *model, gint col) { g_return_val_if_fail (E_IS_MEETING_STORE (model), G_TYPE_INVALID); switch (col) { case E_MEETING_STORE_ADDRESS_COL: case E_MEETING_STORE_MEMBER_COL: case E_MEETING_STORE_TYPE_COL: case E_MEETING_STORE_ROLE_COL: case E_MEETING_STORE_RSVP_COL: case E_MEETING_STORE_DELTO_COL: case E_MEETING_STORE_DELFROM_COL: case E_MEETING_STORE_STATUS_COL: case E_MEETING_STORE_CN_COL: case E_MEETING_STORE_LANGUAGE_COL: case E_MEETING_STORE_ATTENDEE_COL: return G_TYPE_STRING; case E_MEETING_STORE_ATTENDEE_UNDERLINE_COL: return PANGO_TYPE_UNDERLINE; default: return G_TYPE_INVALID; } } static gboolean get_iter (GtkTreeModel *model, GtkTreeIter *iter, GtkTreePath *path) { gint row; g_return_val_if_fail (E_IS_MEETING_STORE (model), FALSE); g_return_val_if_fail (gtk_tree_path_get_depth (path) > 0, FALSE); row = gtk_tree_path_get_indices (path) [0]; if (!ROW_VALID (E_MEETING_STORE (model), row)) return FALSE; iter->stamp = E_MEETING_STORE (model)->priv->stamp; iter->user_data = GINT_TO_POINTER (row); return TRUE; } static GtkTreePath * get_path (GtkTreeModel *model, GtkTreeIter *iter) { gint row; GtkTreePath *result; g_return_val_if_fail (E_IS_MEETING_STORE (model), NULL); g_return_val_if_fail (iter->stamp == E_MEETING_STORE (model)->priv->stamp, NULL); row = GPOINTER_TO_INT (iter->user_data); g_return_val_if_fail (ROW_VALID (E_MEETING_STORE (model), row), NULL); result = gtk_tree_path_new (); gtk_tree_path_append_index (result, row); return result; } static void get_value (GtkTreeModel *model, GtkTreeIter *iter, gint col, GValue *value) { EMeetingStore *store; EMeetingAttendee *attendee; const gchar *cn; gint row; g_return_if_fail (E_IS_MEETING_STORE (model)); g_return_if_fail (col >= 0 && col < E_MEETING_STORE_COLUMN_COUNT); row = GPOINTER_TO_INT (iter->user_data); store = E_MEETING_STORE (model); g_return_if_fail (iter->stamp == store->priv->stamp); g_return_if_fail (ROW_VALID (E_MEETING_STORE (model), row)); attendee = g_ptr_array_index (store->priv->attendees, row); switch (col) { case E_MEETING_STORE_ADDRESS_COL: g_value_init (value, G_TYPE_STRING); g_value_set_string ( value, itip_strip_mailto ( e_meeting_attendee_get_address (attendee))); break; case E_MEETING_STORE_MEMBER_COL: g_value_init (value, G_TYPE_STRING); g_value_set_string ( value, e_meeting_attendee_get_member (attendee)); break; case E_MEETING_STORE_TYPE_COL: g_value_init (value, G_TYPE_STRING); g_value_set_string ( value, type_to_text ( e_meeting_attendee_get_cutype (attendee))); break; case E_MEETING_STORE_ROLE_COL: g_value_init (value, G_TYPE_STRING); g_value_set_string ( value, role_to_text ( e_meeting_attendee_get_role (attendee))); break; case E_MEETING_STORE_RSVP_COL: g_value_init (value, G_TYPE_STRING); g_value_set_string ( value, boolean_to_text ( e_meeting_attendee_get_rsvp (attendee))); break; case E_MEETING_STORE_DELTO_COL: g_value_init (value, G_TYPE_STRING); g_value_set_string ( value, itip_strip_mailto ( e_meeting_attendee_get_delto (attendee))); break; case E_MEETING_STORE_DELFROM_COL: g_value_init (value, G_TYPE_STRING); g_value_set_string ( value, itip_strip_mailto ( e_meeting_attendee_get_delfrom (attendee))); break; case E_MEETING_STORE_STATUS_COL: g_value_init (value, G_TYPE_STRING); g_value_set_string ( value, partstat_to_text ( e_meeting_attendee_get_status (attendee))); break; case E_MEETING_STORE_CN_COL: g_value_init (value, G_TYPE_STRING); g_value_set_string ( value, e_meeting_attendee_get_cn (attendee)); break; case E_MEETING_STORE_LANGUAGE_COL: g_value_init (value, G_TYPE_STRING); g_value_set_string ( value, e_meeting_attendee_get_language (attendee)); break; case E_MEETING_STORE_ATTENDEE_COL: g_value_init (value, G_TYPE_STRING); cn = e_meeting_attendee_get_cn (attendee); if (strcmp (cn, "")) g_value_set_string (value, cn); else g_value_set_string ( value, itip_strip_mailto ( e_meeting_attendee_get_address (attendee))); break; case E_MEETING_STORE_ATTENDEE_UNDERLINE_COL: cn = e_meeting_attendee_get_cn (attendee); g_value_init (value, PANGO_TYPE_UNDERLINE); g_value_set_enum ( value, strcmp ("", cn) == 0 ? PANGO_UNDERLINE_NONE : PANGO_UNDERLINE_SINGLE); } } static gboolean iter_next (GtkTreeModel *model, GtkTreeIter *iter) { gint row; g_return_val_if_fail (E_IS_MEETING_STORE (model), FALSE); g_return_val_if_fail (iter->stamp == E_MEETING_STORE (model)->priv->stamp, FALSE); row = GPOINTER_TO_INT (iter->user_data) + 1; iter->user_data = GINT_TO_POINTER (row); return ROW_VALID (E_MEETING_STORE (model), row); } static gboolean iter_children (GtkTreeModel *model, GtkTreeIter *iter, GtkTreeIter *parent) { EMeetingStore *store; g_return_val_if_fail (E_IS_MEETING_STORE (model), FALSE); store = E_MEETING_STORE (model); if (parent || store->priv->attendees->len <= 0) return FALSE; iter->stamp = store->priv->stamp; iter->user_data = GINT_TO_POINTER (0); return TRUE; } static gboolean iter_has_child (GtkTreeModel *model, GtkTreeIter *iter) { return FALSE; } static gint iter_n_children (GtkTreeModel *model, GtkTreeIter *iter) { g_return_val_if_fail (E_IS_MEETING_STORE (model), -1); if (!iter) return E_MEETING_STORE (model)->priv->attendees->len; g_return_val_if_fail (iter->stamp == E_MEETING_STORE (model)->priv->stamp, -1); return 0; } static gboolean iter_nth_child (GtkTreeModel *model, GtkTreeIter *iter, GtkTreeIter *parent, gint n) { EMeetingStore *store; g_return_val_if_fail (E_IS_MEETING_STORE (model), FALSE); store = E_MEETING_STORE (model); if (parent || !ROW_VALID (store, n)) return FALSE; iter->stamp = store->priv->stamp; iter->user_data = GINT_TO_POINTER (n); return TRUE; } static gboolean iter_parent (GtkTreeModel *model, GtkTreeIter *iter, GtkTreeIter *child) { return FALSE; } static void ems_tree_model_init (GtkTreeModelIface *iface) { iface->get_flags = get_flags; iface->get_n_columns = get_n_columns; iface->get_column_type = get_column_type; iface->get_iter = get_iter; iface->get_path = get_path; iface->get_value = get_value; iface->iter_next = iter_next; iface->iter_children = iter_children; iface->iter_has_child = iter_has_child; iface->iter_n_children = iter_n_children; iface->iter_nth_child = iter_nth_child; iface->iter_parent = iter_parent; } void e_meeting_store_set_value (EMeetingStore *store, gint row, gint col, const gchar *val) { icalparameter_cutype type; EMeetingAttendee *attendee = g_ptr_array_index (store->priv->attendees, row); switch (col) { case E_MEETING_STORE_ADDRESS_COL: if (val != NULL && *((gchar *)val)) e_meeting_attendee_set_address ( attendee, g_strdup_printf ( "MAILTO:%s", (gchar *) val)); break; case E_MEETING_STORE_MEMBER_COL: e_meeting_attendee_set_member (attendee, g_strdup (val)); break; case E_MEETING_STORE_TYPE_COL: type = text_to_type (val); e_meeting_attendee_set_cutype (attendee, text_to_type (val)); if (type == ICAL_CUTYPE_RESOURCE) { e_meeting_attendee_set_role (attendee, ICAL_ROLE_NONPARTICIPANT); } break; case E_MEETING_STORE_ROLE_COL: e_meeting_attendee_set_role (attendee, text_to_role (val)); break; case E_MEETING_STORE_RSVP_COL: e_meeting_attendee_set_rsvp (attendee, text_to_boolean (val)); break; case E_MEETING_STORE_DELTO_COL: e_meeting_attendee_set_delto (attendee, g_strdup (val)); break; case E_MEETING_STORE_DELFROM_COL: e_meeting_attendee_set_delfrom (attendee, g_strdup (val)); break; case E_MEETING_STORE_STATUS_COL: e_meeting_attendee_set_status (attendee, text_to_partstat (val)); break; case E_MEETING_STORE_CN_COL: e_meeting_attendee_set_cn (attendee, g_strdup (val)); break; case E_MEETING_STORE_LANGUAGE_COL: e_meeting_attendee_set_language (attendee, g_strdup (val)); break; } } static void refresh_queue_remove (EMeetingStore *store, EMeetingAttendee *attendee) { EMeetingStorePrivate *priv; EMeetingStoreQueueData *qdata; priv = store->priv; /* Free the queue data */ qdata = g_hash_table_lookup ( priv->refresh_data, itip_strip_mailto ( e_meeting_attendee_get_address (attendee))); if (qdata) { g_mutex_lock (priv->mutex); g_hash_table_remove ( priv->refresh_data, itip_strip_mailto ( e_meeting_attendee_get_address (attendee))); g_mutex_unlock (priv->mutex); g_ptr_array_free (qdata->call_backs, TRUE); g_ptr_array_free (qdata->data, TRUE); g_free (qdata); } /* Unref the attendee */ g_ptr_array_remove (priv->refresh_queue, attendee); g_object_unref (attendee); } static void meeting_store_set_property (GObject *object, guint property_id, const GValue *value, GParamSpec *pspec) { switch (property_id) { case PROP_CLIENT: e_meeting_store_set_client ( E_MEETING_STORE (object), g_value_get_object (value)); return; case PROP_FREE_BUSY_TEMPLATE: e_meeting_store_set_free_busy_template ( E_MEETING_STORE (object), g_value_get_string (value)); return; case PROP_TIMEZONE: e_meeting_store_set_timezone ( E_MEETING_STORE (object), g_value_get_pointer (value)); return; } G_OBJECT_WARN_INVALID_PROPERTY_ID (object, property_id, pspec); } static void meeting_store_get_property (GObject *object, guint property_id, GValue *value, GParamSpec *pspec) { switch (property_id) { case PROP_CLIENT: g_value_set_object ( value, e_meeting_store_get_client ( E_MEETING_STORE (object))); return; case PROP_FREE_BUSY_TEMPLATE: g_value_set_string ( value, e_meeting_store_get_free_busy_template ( E_MEETING_STORE (object))); return; case PROP_TIMEZONE: g_value_set_pointer ( value, e_meeting_store_get_timezone ( E_MEETING_STORE (object))); return; } G_OBJECT_WARN_INVALID_PROPERTY_ID (object, property_id, pspec); } static void meeting_store_finalize (GObject *object) { EMeetingStorePrivate *priv; gint i; priv = E_MEETING_STORE_GET_PRIVATE (object); for (i = 0; i < priv->attendees->len; i++) g_object_unref (g_ptr_array_index (priv->attendees, i)); g_ptr_array_free (priv->attendees, TRUE); if (priv->client != NULL) g_object_unref (priv->client); while (priv->refresh_queue->len > 0) refresh_queue_remove ( E_MEETING_STORE (object), g_ptr_array_index (priv->refresh_queue, 0)); g_ptr_array_free (priv->refresh_queue, TRUE); g_hash_table_destroy (priv->refresh_data); if (priv->refresh_idle_id) g_source_remove (priv->refresh_idle_id); g_free (priv->fb_uri); g_mutex_free (priv->mutex); /* Chain up to parent's finalize() method. */ G_OBJECT_CLASS (e_meeting_store_parent_class)->finalize (object); } static void e_meeting_store_class_init (EMeetingStoreClass *class) { GObjectClass *object_class; g_type_class_add_private (class, sizeof (EMeetingStorePrivate)); object_class = G_OBJECT_CLASS (class); object_class->set_property = meeting_store_set_property; object_class->get_property = meeting_store_get_property; object_class->finalize = meeting_store_finalize; g_object_class_install_property ( object_class, PROP_CLIENT, g_param_spec_object ( "client", "Client", NULL, E_TYPE_CAL, G_PARAM_READWRITE)); g_object_class_install_property ( object_class, PROP_FREE_BUSY_TEMPLATE, g_param_spec_string ( "free-busy-template", "Free/Busy Template", NULL, NULL, G_PARAM_READWRITE)); g_object_class_install_property ( object_class, PROP_TIMEZONE, g_param_spec_pointer ( "timezone", "Timezone", NULL, G_PARAM_READWRITE)); } static void e_meeting_store_init (EMeetingStore *store) { store->priv = E_MEETING_STORE_GET_PRIVATE (store); store->priv->attendees = g_ptr_array_new (); store->priv->refresh_queue = g_ptr_array_new (); store->priv->refresh_data = g_hash_table_new (g_str_hash, g_str_equal); store->priv->mutex = g_mutex_new (); store->priv->num_queries = 0; e_extensible_load_extensions (E_EXTENSIBLE (store)); } GObject * e_meeting_store_new (void) { return g_object_new (E_TYPE_MEETING_STORE, NULL); } ECal * e_meeting_store_get_client (EMeetingStore *store) { g_return_val_if_fail (E_IS_MEETING_STORE (store), NULL); return store->priv->client; } void e_meeting_store_set_client (EMeetingStore *store, ECal *client) { g_return_if_fail (E_IS_MEETING_STORE (store)); if (client != NULL) { g_return_if_fail (E_IS_CAL (client)); g_object_ref (client); } if (store->priv->client != NULL) g_object_unref (store->priv->client); store->priv->client = client; g_object_notify (G_OBJECT (store), "client"); } const gchar * e_meeting_store_get_free_busy_template (EMeetingStore *store) { g_return_val_if_fail (E_IS_MEETING_STORE (store), NULL); return store->priv->fb_uri; } void e_meeting_store_set_free_busy_template (EMeetingStore *store, const gchar *free_busy_template) { g_return_if_fail (E_IS_MEETING_STORE (store)); g_free (store->priv->fb_uri); store->priv->fb_uri = g_strdup (free_busy_template); g_object_notify (G_OBJECT (store), "free-busy-template"); } icaltimezone * e_meeting_store_get_timezone (EMeetingStore *store) { g_return_val_if_fail (E_IS_MEETING_STORE (store), NULL); return store->priv->zone; } void e_meeting_store_set_timezone (EMeetingStore *store, icaltimezone *timezone) { g_return_if_fail (E_IS_MEETING_STORE (store)); store->priv->zone = timezone; g_object_notify (G_OBJECT (store), "timezone"); } static void attendee_changed_cb (EMeetingAttendee *attendee, gpointer data) { EMeetingStore *store = E_MEETING_STORE (data); GtkTreePath *path; GtkTreeIter iter; gint row = -1, i; for (i = 0; i < store->priv->attendees->len; i++) { if (attendee == g_ptr_array_index (store->priv->attendees, i)) { row = i; break; } } if (row == -1) return; path = gtk_tree_path_new (); gtk_tree_path_append_index (path, row); get_iter (GTK_TREE_MODEL (store), &iter, path); gtk_tree_model_row_changed (GTK_TREE_MODEL (store), path, &iter); gtk_tree_path_free (path); } void e_meeting_store_add_attendee (EMeetingStore *store, EMeetingAttendee *attendee) { GtkTreePath *path; GtkTreeIter iter; g_return_if_fail (E_IS_MEETING_STORE (store)); g_object_ref (attendee); g_ptr_array_add (store->priv->attendees, attendee); g_signal_connect (attendee, "changed", G_CALLBACK (attendee_changed_cb), store); path = gtk_tree_path_new (); gtk_tree_path_append_index (path, store->priv->attendees->len - 1); get_iter (GTK_TREE_MODEL (store), &iter, path); gtk_tree_model_row_inserted (GTK_TREE_MODEL (store), path, &iter); gtk_tree_path_free (path); } EMeetingAttendee * e_meeting_store_add_attendee_with_defaults (EMeetingStore *store) { EMeetingAttendee *attendee; gchar *str; attendee = E_MEETING_ATTENDEE (e_meeting_attendee_new ()); e_meeting_attendee_set_address (attendee, g_strdup ("")); e_meeting_attendee_set_member (attendee, g_strdup ("")); str = g_strdup (_("Individual")); e_meeting_attendee_set_cutype (attendee, text_to_type (str)); g_free (str); str = g_strdup (_("Required Participant")); e_meeting_attendee_set_role (attendee, text_to_role (str)); g_free (str); str = g_strdup (_("Yes")); e_meeting_attendee_set_rsvp (attendee, text_to_boolean (str)); g_free (str); e_meeting_attendee_set_delto (attendee, g_strdup ("")); e_meeting_attendee_set_delfrom (attendee, g_strdup ("")); str = g_strdup (_("Needs Action")); e_meeting_attendee_set_status (attendee, text_to_partstat (str)); g_free (str); e_meeting_attendee_set_cn (attendee, g_strdup ("")); e_meeting_attendee_set_language (attendee, g_strdup ("en")); e_meeting_store_add_attendee (store, attendee); return attendee; } void e_meeting_store_remove_attendee (EMeetingStore *store, EMeetingAttendee *attendee) { gint i, row = -1; GtkTreePath *path; for (i = 0; i < store->priv->attendees->len; i++) { if (attendee == g_ptr_array_index (store->priv->attendees, i)) { row = i; break; } } if (row != -1) { path = gtk_tree_path_new (); gtk_tree_path_append_index (path, row); gtk_tree_model_row_deleted (GTK_TREE_MODEL (store), path); gtk_tree_path_free (path); g_ptr_array_remove_index (store->priv->attendees, row); g_object_unref (attendee); } } void e_meeting_store_remove_all_attendees (EMeetingStore *store) { gint i, j, k; for (i = 0, j = e_meeting_store_count_actual_attendees (store), k = 0; i < j; i++) { /* Always try to remove the attendee at index 0 since it is the only one that will * continue to exist until all attendees are removed. */ EMeetingAttendee *attendee = g_ptr_array_index (store->priv->attendees, k); GtkTreePath *path = gtk_tree_path_new (); gtk_tree_path_append_index (path, k); gtk_tree_model_row_deleted (GTK_TREE_MODEL (store), path); gtk_tree_path_free (path); g_ptr_array_remove_index (store->priv->attendees, k); g_object_unref (attendee); } } EMeetingAttendee * e_meeting_store_find_attendee (EMeetingStore *store, const gchar *address, gint *row) { EMeetingAttendee *attendee; gint i; if (address == NULL) return NULL; for (i = 0; i < store->priv->attendees->len; i++) { const gchar *attendee_address; attendee = g_ptr_array_index (store->priv->attendees, i); attendee_address = e_meeting_attendee_get_address (attendee); if (attendee_address && !g_ascii_strcasecmp ( itip_strip_mailto (attendee_address), itip_strip_mailto (address))) { if (row != NULL) *row = i; return attendee; } } return NULL; } EMeetingAttendee * e_meeting_store_find_attendee_at_row (EMeetingStore *store, gint row) { g_return_val_if_fail (E_IS_MEETING_STORE (store), NULL); g_return_val_if_fail (ROW_VALID (store, row), NULL); return g_ptr_array_index (store->priv->attendees, row); } GtkTreePath * e_meeting_store_find_attendee_path (EMeetingStore *store, EMeetingAttendee *attendee) { GtkTreePath *path; gint row = -1, i; for (i = 0; i < store->priv->attendees->len; i++) { if (attendee == g_ptr_array_index (store->priv->attendees, i)) { row = i; break; } } if (row == -1) return NULL; path = gtk_tree_path_new (); gtk_tree_path_append_index (path, row); return path; } gint e_meeting_store_count_actual_attendees (EMeetingStore *store) { g_return_val_if_fail (E_IS_MEETING_STORE (store), 0); return store->priv->attendees->len; } const GPtrArray * e_meeting_store_get_attendees (EMeetingStore *store) { g_return_val_if_fail (E_IS_MEETING_STORE (store), NULL); return store->priv->attendees; } static icaltimezone * find_zone (icalproperty *ip, icalcomponent *tz_top_level) { icalparameter *param; icalcomponent *sub_comp; const gchar *tzid; icalcompiter iter; if (tz_top_level == NULL) return NULL; param = icalproperty_get_first_parameter (ip, ICAL_TZID_PARAMETER); if (param == NULL) return NULL; tzid = icalparameter_get_tzid (param); iter = icalcomponent_begin_component (tz_top_level, ICAL_VTIMEZONE_COMPONENT); while ((sub_comp = icalcompiter_deref (&iter)) != NULL) { icalcomponent *clone; icalproperty *prop; const gchar *tz_tzid; prop = icalcomponent_get_first_property (sub_comp, ICAL_TZID_PROPERTY); tz_tzid = icalproperty_get_tzid (prop); if (!strcmp (tzid, tz_tzid)) { icaltimezone *zone; zone = icaltimezone_new (); clone = icalcomponent_new_clone (sub_comp); icaltimezone_set_component (zone, clone); return zone; } icalcompiter_next (&iter); } return NULL; } static void process_callbacks (EMeetingStoreQueueData *qdata) { EMeetingStore *store; gint i; store = qdata->store; for (i = 0; i < qdata->call_backs->len; i++) { EMeetingStoreRefreshCallback call_back; gpointer *data = NULL; call_back = g_ptr_array_index (qdata->call_backs, i); data = g_ptr_array_index (qdata->data, i); g_idle_add ((GSourceFunc) call_back, data); } g_mutex_lock (store->priv->mutex); store->priv->num_threads--; g_mutex_unlock (store->priv->mutex); refresh_queue_remove (qdata->store, qdata->attendee); g_object_unref (store); } static void process_free_busy_comp (EMeetingAttendee *attendee, icalcomponent *fb_comp, icaltimezone *zone, icalcomponent *tz_top_level) { icalproperty *ip; ip = icalcomponent_get_first_property (fb_comp, ICAL_DTSTART_PROPERTY); if (ip != NULL) { struct icaltimetype dtstart; icaltimezone *ds_zone; dtstart = icalproperty_get_dtstart (ip); if (!dtstart.is_utc) ds_zone = find_zone (ip, tz_top_level); else ds_zone = icaltimezone_get_utc_timezone (); icaltimezone_convert_time (&dtstart, ds_zone, zone); e_meeting_attendee_set_start_busy_range (attendee, dtstart.year, dtstart.month, dtstart.day, dtstart.hour, dtstart.minute); } ip = icalcomponent_get_first_property (fb_comp, ICAL_DTEND_PROPERTY); if (ip != NULL) { struct icaltimetype dtend; icaltimezone *de_zone; dtend = icalproperty_get_dtend (ip); if (!dtend.is_utc) de_zone = find_zone (ip, tz_top_level); else de_zone = icaltimezone_get_utc_timezone (); icaltimezone_convert_time (&dtend, de_zone, zone); e_meeting_attendee_set_end_busy_range (attendee, dtend.year, dtend.month, dtend.day, dtend.hour, dtend.minute); } ip = icalcomponent_get_first_property (fb_comp, ICAL_FREEBUSY_PROPERTY); while (ip != NULL) { icalparameter *param; struct icalperiodtype fb; EMeetingFreeBusyType busy_type = E_MEETING_FREE_BUSY_LAST; icalparameter_fbtype fbtype = ICAL_FBTYPE_BUSY; fb = icalproperty_get_freebusy (ip); param = icalproperty_get_first_parameter (ip, ICAL_FBTYPE_PARAMETER); if (param != NULL) fbtype = icalparameter_get_fbtype (param); switch (fbtype) { case ICAL_FBTYPE_BUSY: busy_type = E_MEETING_FREE_BUSY_BUSY; break; case ICAL_FBTYPE_BUSYUNAVAILABLE: busy_type = E_MEETING_FREE_BUSY_OUT_OF_OFFICE; break; case ICAL_FBTYPE_BUSYTENTATIVE: busy_type = E_MEETING_FREE_BUSY_TENTATIVE; break; case ICAL_FBTYPE_FREE: busy_type = E_MEETING_FREE_BUSY_FREE; break; default: break; } if (busy_type != E_MEETING_FREE_BUSY_LAST) { icaltimezone *utc_zone = icaltimezone_get_utc_timezone (); icaltimezone_convert_time (&fb.start, utc_zone, zone); icaltimezone_convert_time (&fb.end, utc_zone, zone); e_meeting_attendee_add_busy_period (attendee, fb.start.year, fb.start.month, fb.start.day, fb.start.hour, fb.start.minute, fb.end.year, fb.end.month, fb.end.day, fb.end.hour, fb.end.minute, busy_type); } ip = icalcomponent_get_next_property (fb_comp, ICAL_FREEBUSY_PROPERTY); } } static void process_free_busy (EMeetingStoreQueueData *qdata, gchar *text) { EMeetingStore *store = qdata->store; EMeetingStorePrivate *priv; EMeetingAttendee *attendee = qdata->attendee; icalcomponent *main_comp; icalcomponent_kind kind = ICAL_NO_COMPONENT; priv = store->priv; main_comp = icalparser_parse_string (text); if (main_comp == NULL) { process_callbacks (qdata); return; } kind = icalcomponent_isa (main_comp); if (kind == ICAL_VCALENDAR_COMPONENT) { icalcompiter iter; icalcomponent *tz_top_level, *sub_comp; tz_top_level = e_cal_util_new_top_level (); iter = icalcomponent_begin_component (main_comp, ICAL_VTIMEZONE_COMPONENT); while ((sub_comp = icalcompiter_deref (&iter)) != NULL) { icalcomponent *clone; clone = icalcomponent_new_clone (sub_comp); icalcomponent_add_component (tz_top_level, clone); icalcompiter_next (&iter); } iter = icalcomponent_begin_component (main_comp, ICAL_VFREEBUSY_COMPONENT); while ((sub_comp = icalcompiter_deref (&iter)) != NULL) { process_free_busy_comp (attendee, sub_comp, priv->zone, tz_top_level); icalcompiter_next (&iter); } icalcomponent_free (tz_top_level); } else if (kind == ICAL_VFREEBUSY_COMPONENT) { process_free_busy_comp (attendee, main_comp, priv->zone, NULL); } icalcomponent_free (main_comp); process_callbacks (qdata); } /* * Replace all instances of from_value in string with to_value * In the returned newly allocated string. */ static gchar * replace_string (gchar *string, const gchar *from_value, gchar *to_value) { gchar *replaced; gchar **split_uri; split_uri = g_strsplit (string, from_value, 0); replaced = g_strjoinv (to_value, split_uri); g_strfreev (split_uri); return replaced; } static void start_async_read (const gchar *uri, gpointer data); typedef struct { ECal *client; time_t startt; time_t endt; GList *users; GList *fb_data; gchar *fb_uri; gchar *email; EMeetingAttendee *attendee; EMeetingStoreQueueData *qdata; EMeetingStore *store; } FreeBusyAsyncData; #define USER_SUB "%u" #define DOMAIN_SUB "%d" static gboolean freebusy_async (gpointer data) { FreeBusyAsyncData *fbd = data; EMeetingAttendee *attendee = fbd->attendee; gchar *default_fb_uri = NULL; gchar *fburi = NULL; static GStaticMutex mutex = G_STATIC_MUTEX_INIT; EMeetingStorePrivate *priv = fbd->store->priv; if (fbd->client) { /* FIXME this a work around for getting all th free busy information for the users we should be able to get free busy asynchronously */ g_static_mutex_lock (&mutex); priv->num_queries++; e_cal_get_free_busy ( fbd->client, fbd->users, fbd->startt, fbd->endt, &(fbd->fb_data), NULL); priv->num_queries--; g_static_mutex_unlock (&mutex); g_list_foreach (fbd->users, (GFunc)g_free, NULL); g_list_free (fbd->users); if (fbd->fb_data != NULL) { ECalComponent *comp = fbd->fb_data->data; gchar *comp_str; comp_str = e_cal_component_get_as_string (comp); process_free_busy (fbd->qdata, comp_str); g_free (comp_str); return TRUE; } } /* Look for fburl's of attendee with no free busy info on server */ if (!e_meeting_attendee_is_set_address (attendee)) { process_callbacks (fbd->qdata); return TRUE; } /* Check for free busy info on the default server */ default_fb_uri = g_strdup (fbd->fb_uri); fburi = g_strdup (e_meeting_attendee_get_fburi (attendee)); if (fburi && !*fburi) { g_free (fburi); fburi = NULL; } if (fburi) { priv->num_queries++; start_async_read (fburi, fbd->qdata); g_free (fburi); } else if (default_fb_uri != NULL && !g_str_equal (default_fb_uri, "")) { gchar *tmp_fb_uri; gchar **split_email; split_email = g_strsplit (fbd->email, "@", 2); tmp_fb_uri = replace_string (default_fb_uri, USER_SUB, split_email[0]); g_free (default_fb_uri); default_fb_uri = replace_string (tmp_fb_uri, DOMAIN_SUB, split_email[1]); priv->num_queries++; start_async_read (default_fb_uri, fbd->qdata); g_free (tmp_fb_uri); g_strfreev (split_email); g_free (default_fb_uri); } else { process_callbacks (fbd->qdata); } return TRUE; } #undef USER_SUB #undef DOMAIN_SUB static gboolean refresh_busy_periods (gpointer data) { EMeetingStore *store = E_MEETING_STORE (data); EMeetingStorePrivate *priv; EMeetingAttendee *attendee = NULL; EMeetingStoreQueueData *qdata = NULL; gint i; GThread *thread; GError *error = NULL; FreeBusyAsyncData *fbd; priv = store->priv; /* Check to see if there are any remaining attendees in the queue */ for (i = 0; i < priv->refresh_queue->len; i++) { attendee = g_ptr_array_index (priv->refresh_queue, i); g_return_val_if_fail (attendee != NULL, FALSE); qdata = g_hash_table_lookup ( priv->refresh_data, itip_strip_mailto ( e_meeting_attendee_get_address (attendee))); if (!qdata) continue; if (!qdata->refreshing) break; } /* The everything in the queue is being refreshed */ if (i >= priv->refresh_queue->len) { priv->refresh_idle_id = 0; return FALSE; } /* Indicate we are trying to refresh it */ qdata->refreshing = TRUE; /* We take a ref in case we get destroyed in the gui during a callback */ g_object_ref (qdata->store); fbd = g_new0 (FreeBusyAsyncData, 1); fbd->client = priv->client; fbd->attendee = attendee; fbd->users = NULL; fbd->fb_data = NULL; fbd->qdata = qdata; fbd->fb_uri = priv->fb_uri; fbd->store = store; fbd->email = g_strdup (itip_strip_mailto (e_meeting_attendee_get_address (attendee))); /* Check the server for free busy data */ if (priv->client) { struct icaltimetype itt; itt = icaltime_null_time (); itt.year = g_date_get_year (&qdata->start.date); itt.month = g_date_get_month (&qdata->start.date); itt.day = g_date_get_day (&qdata->start.date); itt.hour = qdata->start.hour; itt.minute = qdata->start.minute; fbd->startt = icaltime_as_timet_with_zone (itt, priv->zone); itt = icaltime_null_time (); itt.year = g_date_get_year (&qdata->end.date); itt.month = g_date_get_month (&qdata->end.date); itt.day = g_date_get_day (&qdata->end.date); itt.hour = qdata->end.hour; itt.minute = qdata->end.minute; fbd->endt = icaltime_as_timet_with_zone (itt, priv->zone); fbd->qdata = qdata; fbd->users = g_list_append (fbd->users, g_strdup (fbd->email)); } g_mutex_lock (store->priv->mutex); store->priv->num_threads++; g_mutex_unlock (store->priv->mutex); thread = g_thread_create ((GThreadFunc) freebusy_async, fbd, FALSE, &error); if (!thread) { /* do clean up stuff here */ g_list_foreach (fbd->users, (GFunc)g_free, NULL); g_list_free (fbd->users); g_free (fbd->email); priv->refresh_idle_id = 0; g_mutex_lock (store->priv->mutex); store->priv->num_threads--; g_mutex_unlock (store->priv->mutex); return FALSE; } return TRUE; } static void refresh_queue_add (EMeetingStore *store, gint row, EMeetingTime *start, EMeetingTime *end, EMeetingStoreRefreshCallback call_back, gpointer data) { EMeetingStorePrivate *priv; EMeetingAttendee *attendee; EMeetingStoreQueueData *qdata; gint i; priv = store->priv; attendee = g_ptr_array_index (priv->attendees, row); if ((attendee == NULL) || !strcmp (itip_strip_mailto ( e_meeting_attendee_get_address (attendee)), "")) return; /* check the queue if the attendee is already in there*/ for (i = 0; i < priv->refresh_queue->len; i++) { if (attendee == g_ptr_array_index (priv->refresh_queue, i)) return; if (!strcmp (e_meeting_attendee_get_address (attendee), e_meeting_attendee_get_address ( g_ptr_array_index (priv->refresh_queue, i)))) return; } g_mutex_lock (priv->mutex); qdata = g_hash_table_lookup ( priv->refresh_data, itip_strip_mailto ( e_meeting_attendee_get_address (attendee))); if (qdata == NULL) { qdata = g_new0 (EMeetingStoreQueueData, 1); qdata->store = store; qdata->attendee = attendee; e_meeting_attendee_clear_busy_periods (attendee); e_meeting_attendee_set_has_calendar_info (attendee, FALSE); qdata->start = *start; qdata->end = *end; qdata->string = g_string_new (NULL); qdata->call_backs = g_ptr_array_new (); qdata->data = g_ptr_array_new (); g_ptr_array_add (qdata->call_backs, call_back); g_ptr_array_add (qdata->data, data); g_hash_table_insert ( priv->refresh_data, (gpointer) itip_strip_mailto ( e_meeting_attendee_get_address (attendee)), qdata); } else { if (e_meeting_time_compare_times (start, &qdata->start) == -1) qdata->start = *start; if (e_meeting_time_compare_times (end, &qdata->end) == -1) qdata->end = *end; g_ptr_array_add (qdata->call_backs, call_back); g_ptr_array_add (qdata->data, data); } g_mutex_unlock (priv->mutex); g_object_ref (attendee); g_ptr_array_add (priv->refresh_queue, attendee); if (priv->refresh_idle_id == 0) priv->refresh_idle_id = g_idle_add (refresh_busy_periods, store); } static void async_read (GObject *source_object, GAsyncResult *res, gpointer data) { EMeetingStoreQueueData *qdata = data; GError *error = NULL; GInputStream *istream; gssize read; g_return_if_fail (source_object != NULL); g_return_if_fail (G_IS_INPUT_STREAM (source_object)); istream = G_INPUT_STREAM (source_object); read = g_input_stream_read_finish (istream, res, &error); if (error || read < 0) { g_warning ("Read finish failed: %s", error ? error->message : "Unknown error"); if (error) g_error_free (error); g_input_stream_close (istream, NULL, NULL); g_object_unref (istream); process_free_busy (qdata, qdata->string->str); return; } if (read == 0) { g_input_stream_close (istream, NULL, NULL); g_object_unref (istream); process_free_busy (qdata, qdata->string->str); } else { qdata->buffer[read] = '\0'; qdata->string = g_string_append (qdata->string, qdata->buffer); g_input_stream_read_async ( istream, qdata->buffer, BUF_SIZE - 1, G_PRIORITY_DEFAULT, NULL, async_read, qdata); } } static void start_async_read (const gchar *uri, gpointer data) { EMeetingStoreQueueData *qdata = data; GError *error = NULL; GFile *file; GInputStream *istream; g_return_if_fail (uri != NULL); g_return_if_fail (data != NULL); qdata->store->priv->num_queries--; file = g_file_new_for_uri (uri); g_return_if_fail (file != NULL); istream = G_INPUT_STREAM (g_file_read (file, NULL, &error)); if (error) { g_warning ("Unable to access free/busy url: %s", error->message); g_error_free (error); process_callbacks (qdata); return; } if (!istream) process_callbacks (qdata); else g_input_stream_read_async ( istream, qdata->buffer, BUF_SIZE - 1, G_PRIORITY_DEFAULT, NULL, async_read, qdata); } void e_meeting_store_refresh_all_busy_periods (EMeetingStore *store, EMeetingTime *start, EMeetingTime *end, EMeetingStoreRefreshCallback call_back, gpointer data) { gint i; g_return_if_fail (E_IS_MEETING_STORE (store)); for (i = 0; i < store->priv->attendees->len; i++) refresh_queue_add (store, i, start, end, call_back, data); } void e_meeting_store_refresh_busy_periods (EMeetingStore *store, gint row, EMeetingTime *start, EMeetingTime *end, EMeetingStoreRefreshCallback call_back, gpointer data) { g_return_if_fail (E_IS_MEETING_STORE (store)); refresh_queue_add (store, row, start, end, call_back, data); } guint e_meeting_store_get_num_queries (EMeetingStore *store) { g_return_val_if_fail (E_IS_MEETING_STORE (store), 0); return store->priv->num_queries; }