diff options
Diffstat (limited to 'src/ibusservice.c')
| -rw-r--r-- | src/ibusservice.c | 406 |
1 files changed, 406 insertions, 0 deletions
diff --git a/src/ibusservice.c b/src/ibusservice.c new file mode 100644 index 0000000..380e3ee --- /dev/null +++ b/src/ibusservice.c @@ -0,0 +1,406 @@ +/* vim:set et sts=4: */ +/* ibus - The Input Bus + * Copyright (C) 2008-2009 Huang Peng <shawn.p.huang@gmail.com> + * + * This library 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) any later version. + * + * This library 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 this library; if not, write to the + * Free Software Foundation, Inc., 59 Temple Place - Suite 330, + * Boston, MA 02111-1307, USA. + */ + +#include "ibusservice.h" +#include "ibusinternal.h" + +#define IBUS_SERVICE_GET_PRIVATE(o) \ + (G_TYPE_INSTANCE_GET_PRIVATE ((o), IBUS_TYPE_SERVICE, IBusServicePrivate)) + +enum { + IBUS_MESSAGE, + IBUS_SIGNAL, + LAST_SIGNAL, +}; + +enum { + PROP_0, + PROP_PATH +}; + +/* IBusServicePriv */ +struct _IBusServicePrivate { + gchar *path; + GList *connections; +}; +typedef struct _IBusServicePrivate IBusServicePrivate; + +static guint service_signals[LAST_SIGNAL] = { 0 }; + +/* functions prototype */ +static void ibus_service_class_init (IBusServiceClass *klass); +static void ibus_service_init (IBusService *service); +static void ibus_service_destroy (IBusService *service); +static void ibus_service_set_property (IBusService *service, + guint prop_id, + const GValue *value, + GParamSpec *pspec); +static void ibus_service_get_property (IBusService *service, + guint prop_id, + GValue *value, + GParamSpec *pspec); +static gboolean ibus_service_ibus_message (IBusService *service, + IBusConnection *connection, + IBusMessage *message); +static gboolean ibus_service_ibus_signal (IBusService *service, + IBusConnection *connection, + IBusMessage *message); + +static IBusObjectClass *parent_class = NULL; + +GType +ibus_service_get_type (void) +{ + static GType type = 0; + + static const GTypeInfo type_info = { + sizeof (IBusServiceClass), + (GBaseInitFunc) NULL, + (GBaseFinalizeFunc) NULL, + (GClassInitFunc) ibus_service_class_init, + NULL, /* class finalize */ + NULL, /* class data */ + sizeof (IBusService), + 0, + (GInstanceInitFunc) ibus_service_init, + }; + + if (type == 0) { + type = g_type_register_static (IBUS_TYPE_OBJECT, + "IBusService", + &type_info, + (GTypeFlags) 0); + } + return type; +} + +IBusService * +ibus_service_new (const gchar *path) +{ + GObject *obj; + obj = g_object_new (IBUS_TYPE_SERVICE, + "path", path, + NULL); + return IBUS_SERVICE (obj); +} + +static void +ibus_service_class_init (IBusServiceClass *klass) +{ + GObjectClass *gobject_class = G_OBJECT_CLASS (klass); + IBusObjectClass *ibus_object_class = IBUS_OBJECT_CLASS (klass); + + parent_class = (IBusObjectClass *) g_type_class_peek_parent (klass); + + g_type_class_add_private (klass, sizeof (IBusServicePrivate)); + + gobject_class->set_property = (GObjectSetPropertyFunc) ibus_service_set_property; + gobject_class->get_property = (GObjectGetPropertyFunc) ibus_service_get_property; + ibus_object_class->destroy = (IBusObjectDestroyFunc) ibus_service_destroy; + + klass->ibus_message = ibus_service_ibus_message; + klass->ibus_signal = ibus_service_ibus_signal; + + /* install properties */ + g_object_class_install_property ( + gobject_class, + PROP_PATH, + g_param_spec_string ( + "path", + "object path", + "The path of service object", + NULL, + G_PARAM_READWRITE | G_PARAM_CONSTRUCT_ONLY) + ); + + /* Install signals */ + service_signals[IBUS_MESSAGE] = + g_signal_new (I_("ibus-message"), + G_TYPE_FROM_CLASS (klass), + G_SIGNAL_RUN_LAST, + G_STRUCT_OFFSET (IBusServiceClass, ibus_message), + NULL, NULL, + ibus_marshal_BOOLEAN__POINTER_POINTER, + G_TYPE_BOOLEAN, + 2, + G_TYPE_POINTER, + G_TYPE_POINTER); + + service_signals[IBUS_SIGNAL] = + g_signal_new (I_("ibus-signal"), + G_TYPE_FROM_CLASS (klass), + G_SIGNAL_RUN_LAST, + G_STRUCT_OFFSET (IBusServiceClass, ibus_signal), + NULL, NULL, + ibus_marshal_BOOLEAN__POINTER_POINTER, + G_TYPE_BOOLEAN, + 2, + G_TYPE_POINTER, + G_TYPE_POINTER); + +} + +static void +ibus_service_init (IBusService *service) +{ + IBusServicePrivate *priv; + priv = IBUS_SERVICE_GET_PRIVATE (service); + + priv->path = NULL; + priv->connections = NULL; +} + +static void +ibus_service_destroy (IBusService *service) +{ + IBusServicePrivate *priv; + priv = IBUS_SERVICE_GET_PRIVATE (service); + + ibus_service_remove_from_all_connections (service); + + g_free (priv->path); + priv->path = NULL; + + IBUS_OBJECT_CLASS(parent_class)->destroy (IBUS_OBJECT (service)); +} + +static void +ibus_service_set_property (IBusService *service, + guint prop_id, const GValue *value, GParamSpec *pspec) +{ + IBusServicePrivate *priv; + priv = IBUS_SERVICE_GET_PRIVATE (service); + + switch (prop_id) { + case PROP_PATH: + priv->path = g_strdup (g_value_get_string (value)); + break; + default: + G_OBJECT_WARN_INVALID_PROPERTY_ID (service, prop_id, pspec); + } +} + +static void +ibus_service_get_property (IBusService *service, + guint prop_id, GValue *value, GParamSpec *pspec) +{ + switch (prop_id) { + case PROP_PATH: + g_value_set_string (value, ibus_service_get_path (service)); + break; + default: + G_OBJECT_WARN_INVALID_PROPERTY_ID (service, prop_id, pspec); + } +} + +const gchar * +ibus_service_get_path (IBusService *service) +{ + g_assert (IBUS_IS_SERVICE (service)); + + IBusServicePrivate *priv; + priv = IBUS_SERVICE_GET_PRIVATE (service); + + return priv->path; +} + +gboolean +ibus_service_handle_message (IBusService *service, + IBusConnection *connection, + IBusMessage *message) +{ + gboolean retval = FALSE; + g_return_val_if_fail (message != NULL, FALSE); + + g_signal_emit (service, service_signals[IBUS_MESSAGE], 0, connection, message, &retval); + return retval; +} + +static gboolean +ibus_service_ibus_message (IBusService *service, + IBusConnection *connection, + IBusMessage *message) +{ + if (ibus_message_is_method_call (message, "", "Destroy")) { + IBusMessage *reply; + reply = ibus_message_new_method_return (message); + ibus_connection_send (connection, reply); + ibus_message_unref (reply); + return TRUE; + } + return FALSE; +} + +static gboolean +ibus_service_ibus_signal (IBusService *service, + IBusConnection *connection, + IBusMessage *message) +{ + return FALSE; +} + + +gboolean +_service_message_function (IBusConnection *connection, + IBusMessage *message, + IBusService *service) +{ + return ibus_service_handle_message (service, connection, message); +} + +static void +_connection_destroy_cb (IBusConnection *connection, IBusService *service) +{ + g_assert (IBUS_IS_CONNECTION (connection)); + g_assert (IBUS_IS_SERVICE (service)); + + ibus_service_remove_from_connection (service, connection); +} + +gboolean +ibus_service_add_to_connection (IBusService *service, IBusConnection *connection) +{ + g_assert (IBUS_IS_SERVICE (service)); + g_assert (IBUS_IS_CONNECTION (connection)); + + gboolean retval; + IBusServicePrivate *priv; + priv = IBUS_SERVICE_GET_PRIVATE (service); + + g_return_val_if_fail (priv->path != NULL, FALSE); + g_return_val_if_fail (g_list_find (priv->connections, connection) == NULL, FALSE); + + g_object_ref (connection); + + retval = ibus_connection_register_object_path (connection, priv->path, + (IBusMessageFunc) _service_message_function, service); + if (!retval) { + g_object_unref (connection); + return FALSE; + } + + priv->connections = g_list_append (priv->connections, connection); + g_signal_connect (connection, + "destroy", + (GCallback) _connection_destroy_cb, + service); + + return retval; +} + +GList * +ibus_service_get_connections (IBusService *service) +{ + g_assert (IBUS_IS_SERVICE (service)); + + IBusServicePrivate *priv; + priv = IBUS_SERVICE_GET_PRIVATE (service); + + GList *l; + + l = g_list_copy (priv->connections); + g_list_foreach (l, (GFunc) g_object_ref, NULL); + return l; +} + +gboolean +ibus_service_remove_from_connection (IBusService *service, IBusConnection *connection) +{ + g_return_val_if_fail (IBUS_IS_SERVICE (service), FALSE); + g_return_val_if_fail (IBUS_IS_CONNECTION (connection), FALSE); + + IBusServicePrivate *priv; + priv = IBUS_SERVICE_GET_PRIVATE (service); + + g_assert (priv->path != NULL); + g_assert (g_list_find (priv->connections, connection) != NULL); + + gboolean retval; + retval = ibus_connection_unregister_object_path (connection, priv->path); + + if (!retval) { + return FALSE; + } + + g_signal_handlers_disconnect_by_func (connection, + (GCallback) _connection_destroy_cb, + service); + priv->connections = g_list_remove (priv->connections, connection); + g_object_unref (connection); + + return TRUE; +} + +gboolean +ibus_service_remove_from_all_connections (IBusService *service) +{ + g_return_val_if_fail (IBUS_IS_SERVICE (service), FALSE); + + IBusServicePrivate *priv; + priv = IBUS_SERVICE_GET_PRIVATE (service); + + GList *element = priv->connections; + while (element != NULL) { + IBusConnection *connection = IBUS_CONNECTION (element->data); + + gboolean retval; + retval = ibus_connection_unregister_object_path (connection, priv->path); + + g_signal_handlers_disconnect_by_func (connection, + (GCallback) _connection_destroy_cb, + service); + g_object_unref (connection); + element = element->next; + } + + g_list_free (priv->connections); + priv->connections = NULL; + return TRUE; +} + +gboolean +ibus_service_send_signal (IBusService *service, + const gchar *interface, + const gchar *name, + GType first_arg_type, + ...) +{ + g_assert (IBUS_IS_SERVICE (service)); + g_assert (name != NULL); + + gboolean retval; + va_list args; + GList *p; + + IBusServicePrivate *priv; + priv = IBUS_SERVICE_GET_PRIVATE (service); + + for (p = priv->connections; p != NULL; p = p->next) { + va_start (args, first_arg_type); + retval = ibus_connection_send_signal_valist ((IBusConnection *) p->data, + priv->path, + interface, + name, + first_arg_type, + args); + va_end (args); + } + return retval; +} |