#include <telepathy-glib/account-manager.h>
#include <telepathy-glib/interfaces.h>
+#include <telepathy-glib/simple-observer.h>
#include <telepathy-glib/util.h>
#include "empathy-tp-chat.h"
static EmpathyChatroomManager *chatroom_manager_singleton = NULL;
+static void observe_channels_cb (TpSimpleObserver *observer,
+ TpAccount *account,
+ TpConnection *connection,
+ GList *channels,
+ TpChannelDispatchOperation *dispatch_operation,
+ GList *requests,
+ TpObserveChannelsContext *context,
+ gpointer user_data);
+
#define GET_PRIV(obj) EMPATHY_GET_PRIV (obj, EmpathyChatroomManager)
typedef struct
{
/* source id of the autosave timer */
gint save_timer_id;
gboolean ready;
+ GFileMonitor *monitor;
+ gboolean writing;
+
+ TpBaseClient *observer;
} EmpathyChatroomManagerPriv;
enum {
priv = GET_PRIV (manager);
+ priv->writing = TRUE;
+
doc = xmlNewDoc ((const xmlChar *) "1.0");
root = xmlNewNode (NULL, (const xmlChar *) "chatrooms");
xmlDocSetRootElement (doc, root);
xmlMemoryDump ();
+ priv->writing = FALSE;
return TRUE;
}
!chatroom_manager_file_parse (manager, priv->file))
return FALSE;
- priv->ready = TRUE;
- g_object_notify (G_OBJECT (manager), "ready");
+ if (!priv->ready)
+ {
+ priv->ready = TRUE;
+ g_object_notify (G_OBJECT (manager), "ready");
+ }
return TRUE;
}
}
static void
-chatroom_manager_finalize (GObject *object)
+chatroom_manager_dispose (GObject *object)
{
- EmpathyChatroomManager *self = EMPATHY_CHATROOM_MANAGER (object);
EmpathyChatroomManagerPriv *priv;
- GList *l;
priv = GET_PRIV (object);
- g_object_unref (priv->account_manager);
+ tp_clear_object (&priv->observer);
+ tp_clear_object (&priv->monitor);
- if (priv->save_timer_id > 0)
- {
- /* have to save before destroy the object */
- g_source_remove (priv->save_timer_id);
- priv->save_timer_id = 0;
- chatroom_manager_file_save (self);
- }
+ (G_OBJECT_CLASS (empathy_chatroom_manager_parent_class)->dispose) (object);
+}
+
+static void
+clear_chatrooms (EmpathyChatroomManager *self)
+{
+ EmpathyChatroomManagerPriv *priv = GET_PRIV (self);
+ GList *l;
for (l = priv->chatrooms; l != NULL; l = g_list_next (l))
{
g_signal_handlers_disconnect_by_func (chatroom, chatroom_changed_cb,
self);
+ g_signal_emit (self, signals[CHATROOM_REMOVED], 0, chatroom);
g_object_unref (chatroom);
}
g_list_free (priv->chatrooms);
+ priv->chatrooms = NULL;
+}
+
+static void
+chatroom_manager_finalize (GObject *object)
+{
+ EmpathyChatroomManager *self = EMPATHY_CHATROOM_MANAGER (object);
+ EmpathyChatroomManagerPriv *priv;
+
+ priv = GET_PRIV (object);
+
+ g_object_unref (priv->account_manager);
+
+ if (priv->save_timer_id > 0)
+ {
+ /* have to save before destroy the object */
+ g_source_remove (priv->save_timer_id);
+ priv->save_timer_id = 0;
+ chatroom_manager_file_save (self);
+ }
+
+ clear_chatrooms (self);
+
g_free (priv->file);
(G_OBJECT_CLASS (empathy_chatroom_manager_parent_class)->finalize) (object);
}
+static void
+file_changed_cb (GFileMonitor *monitor,
+ GFile *file,
+ GFile *other_file,
+ GFileMonitorEvent event_type,
+ gpointer user_data)
+{
+ EmpathyChatroomManager *self = user_data;
+ EmpathyChatroomManagerPriv *priv = GET_PRIV (self);
+
+ if (event_type != G_FILE_MONITOR_EVENT_CHANGES_DONE_HINT)
+ return;
+
+ if (priv->writing)
+ return;
+
+ DEBUG ("chatrooms file changed; reloading list");
+
+ clear_chatrooms (self);
+ chatroom_manager_get_all (self);
+}
+
static void
account_manager_ready_cb (GObject *source_object,
GAsyncResult *result,
gpointer user_data)
{
EmpathyChatroomManager *self = EMPATHY_CHATROOM_MANAGER (user_data);
+ EmpathyChatroomManagerPriv *priv = GET_PRIV (self);
TpAccountManager *manager = TP_ACCOUNT_MANAGER (source_object);
GError *error = NULL;
+ GFile *file = NULL;
if (!tp_account_manager_prepare_finish (manager, result, &error))
{
chatroom_manager_get_all (self);
+ /* Set up file monitor */
+ file = g_file_new_for_path (priv->file);
+
+ priv->monitor = g_file_monitor (file, 0, NULL, &error);
+ if (priv->monitor == NULL)
+ {
+ DEBUG ("Failed to create file monitor on %s: %s", priv->file,
+ error->message);
+
+ g_error_free (error);
+ goto out;
+ }
+
+ g_signal_connect (priv->monitor, "changed", G_CALLBACK (file_changed_cb),
+ self);
+
out:
+ tp_clear_object (&file);
g_object_unref (self);
}
GObject *obj;
EmpathyChatroomManager *self;
EmpathyChatroomManagerPriv *priv;
+ GError *error = NULL;
+ TpDBusDaemon *dbus;
if (chatroom_manager_singleton != NULL)
return g_object_ref (chatroom_manager_singleton);
g_free (dir);
}
+ dbus = tp_dbus_daemon_dup (&error);
+ if (dbus == NULL)
+ {
+ g_warning ("Failed to get TpDBusDaemon: %s", error->message);
+
+ g_error_free (error);
+ return obj;
+ }
+
+ /* Setup a room observer */
+ priv->observer = tp_simple_observer_new (dbus, TRUE,
+ "Empathy.ChatroomManager", TRUE, observe_channels_cb, self, NULL);
+
+ g_object_unref (dbus);
+
+ tp_base_client_take_observer_filter (priv->observer, tp_asv_new (
+ TP_PROP_CHANNEL_CHANNEL_TYPE, G_TYPE_STRING,
+ TP_IFACE_CHANNEL_TYPE_TEXT,
+ TP_PROP_CHANNEL_TARGET_HANDLE_TYPE, G_TYPE_UINT,
+ TP_HANDLE_TYPE_ROOM,
+ NULL));
+
+ tp_base_client_add_connection_features_varargs (priv->observer,
+ TP_CONNECTION_FEATURE_CAPABILITIES, NULL);
+
+ if (!tp_base_client_register (priv->observer, &error))
+ {
+ g_critical ("Failed to register Observer: %s", error->message);
+
+ g_error_free (error);
+ }
+
return obj;
}
object_class->constructor = empathy_chatroom_manager_constructor;
object_class->get_property = empathy_chatroom_manager_get_property;
object_class->set_property = empathy_chatroom_manager_set_property;
+ object_class->dispose = chatroom_manager_dispose;
object_class->finalize = chatroom_manager_finalize;
param_spec = g_param_spec_string (
return chatrooms;
}
-guint
-empathy_chatroom_manager_get_count (EmpathyChatroomManager *manager,
- TpAccount *account)
-{
- EmpathyChatroomManagerPriv *priv;
- GList *l;
- guint count = 0;
-
- g_return_val_if_fail (EMPATHY_IS_CHATROOM_MANAGER (manager), 0);
-
- priv = GET_PRIV (manager);
-
- if (!account)
- return g_list_length (priv->chatrooms);
-
- for (l = priv->chatrooms; l; l = l->next)
- {
- EmpathyChatroom *chatroom;
-
- chatroom = l->data;
-
- if (account == empathy_chatroom_get_account (chatroom))
- count++;
- }
-
- return count;
-}
-
static void
chatroom_manager_chat_destroyed_cb (EmpathyTpChat *chat,
gpointer manager)
}
}
-/* Called by EmpathyChatManager when we are handling a new group chat */
-void
-empathy_chatroom_manager_chat_handled (EmpathyChatroomManager *self,
- EmpathyTpChat *chat,
- TpAccount *account)
+static void
+observe_channels_cb (TpSimpleObserver *observer,
+ TpAccount *account,
+ TpConnection *connection,
+ GList *channels,
+ TpChannelDispatchOperation *dispatch_operation,
+ GList *requests,
+ TpObserveChannelsContext *context,
+ gpointer user_data)
{
- EmpathyChatroom *chatroom;
- const gchar *roomname;
+ EmpathyChatroomManager *self = user_data;
+ GList *l;
- roomname = empathy_tp_chat_get_id (chat);
+ for (l = channels; l != NULL; l = g_list_next (l))
+ {
+ TpChannel *channel = l->data;
+ EmpathyTpChat *tp_chat;
+ const gchar *roomname;
+ EmpathyChatroom *chatroom;
- chatroom = empathy_chatroom_manager_find (self, account, roomname);
+ if (tp_proxy_get_invalidated (channel) != NULL)
+ continue;
- if (chatroom == NULL)
- {
- chatroom = empathy_chatroom_new_full (account, roomname, roomname,
- FALSE);
- empathy_chatroom_set_tp_chat (chatroom, chat);
- empathy_chatroom_manager_add (self, chatroom);
- g_object_unref (chatroom);
- }
- else
- {
- empathy_chatroom_set_tp_chat (chatroom, chat);
+ tp_chat = empathy_tp_chat_new (account, channel);
+ roomname = empathy_tp_chat_get_id (tp_chat);
+ chatroom = empathy_chatroom_manager_find (self, account, roomname);
+
+ if (chatroom == NULL)
+ {
+ chatroom = empathy_chatroom_new_full (account, roomname, roomname,
+ FALSE);
+ empathy_chatroom_manager_add (self, chatroom);
+ g_object_unref (chatroom);
+ }
+
+ empathy_chatroom_set_tp_chat (chatroom, tp_chat);
+ g_object_unref (tp_chat);
+
+ /* A TpChat is always destroyed as it only gets unreffed after the channel
+ * has been invalidated in the dispatcher.. */
+ g_signal_connect (tp_chat, "destroy",
+ G_CALLBACK (chatroom_manager_chat_destroyed_cb),
+ self);
}
- /* A TpChat is always destroyed as it only gets unreffed after the channel
- * has been invalidated in the dispatcher.. */
- g_signal_connect (chat, "destroy",
- G_CALLBACK (chatroom_manager_chat_destroyed_cb),
- self);
+ tp_observe_channels_context_accept (context);
}
projects / empathy.git / blobdiff