GNOME.org
 

[gnome-flashback/wip/segeiger/inputmethods: 38/39] libinputsources: initial implementation for GfIBusManager

commit 5d659bd6a23af5b6ffe34d8da1018fbb4ece5fdb
Author: Sebastian Geiger <sbastig gmx net>
Date:   Mon Sep 14 15:20:49 2015 +0200

    libinputsources: initial implementation for GfIBusManager

 configure.ac                                       |    7 +-
 gnome-flashback/libinput-sources/Makefile.am       |    2 +
 gnome-flashback/libinput-sources/gf-ibus-manager.c |  381 ++++++++++++++++++++
 gnome-flashback/libinput-sources/gf-ibus-manager.h |   39 ++
 .../libinput-sources/gf-input-sources.c            |   48 +++-
 5 files changed, 472 insertions(+), 5 deletions(-)
---
diff --git a/configure.ac b/configure.ac
index 10b96ec..3994286 100644
--- a/configure.ac
+++ b/configure.ac
@@ -41,6 +41,7 @@ GLIB_REQUIRED=2.44.0
 GSETTINGS_DESKTOP_SCHEMAS_REQUIRED=3.12.0
 POLKIT_AGENT_REQUIRED=0.97
 POLKIT_GOBJECT_REQUIRED=0.97
+IBUS_REQUIRED=1.5.10
 
 PKG_CHECK_MODULES(GNOME_FLASHBACK, gtk+-3.0 >= $GTK_REQUIRED dbus-glib-1)
 AC_SUBST(GNOME_FLASHBACK_CFLAGS)
@@ -70,9 +71,9 @@ PKG_CHECK_MODULES(IDLE_MONITOR, gtk+-3.0 >= $GTK_REQUIRED x11 xext)
 AC_SUBST(IDLE_MONITOR_CFLAGS)
 AC_SUBST(IDLE_MONITOR_LIBS)
 
-PKG_CHECK_MODULES([INPUT_SOURCES], [gtk+-3.0 >= $GTK_REQUIRED])
-AC_SUBST([INPUT_SOURCES_CFLAGS])
-AC_SUBST([INPUT_SOURCES_LIBS])
+PKG_CHECK_MODULES(INPUT_SOURCES, gtk+-3.0 >= $GTK_REQUIRED ibus-1.0 >= $IBUS_REQUIRED)
+AC_SUBST(INPUT_SOURCES_CFLAGS)
+AC_SUBST(INPUT_SOURCES_LIBS)
 
 PKG_CHECK_MODULES(POLKIT, gtk+-3.0 >= $GTK_REQUIRED glib-2.0 >= $GLIB_REQUIRED polkit-agent-1 >= 
$POLKIT_AGENT_REQUIRED polkit-gobject-1 >= $POLKIT_GOBJECT_REQUIRED)
 AC_SUBST(POLKIT_CFLAGS)
diff --git a/gnome-flashback/libinput-sources/Makefile.am b/gnome-flashback/libinput-sources/Makefile.am
index 3622bb9..8e7722c 100644
--- a/gnome-flashback/libinput-sources/Makefile.am
+++ b/gnome-flashback/libinput-sources/Makefile.am
@@ -14,6 +14,8 @@ libinput_sources_la_CFLAGS = \
 libinput_sources_la_SOURCES = \
        gf-input-sources.c \
        gf-input-sources.h \
+       gf-ibus-manager.c \
+       gf-ibus-manager.h \
        $(NULL)
 
 libinput_sources_la_LDFLAGS = \
diff --git a/gnome-flashback/libinput-sources/gf-ibus-manager.c 
b/gnome-flashback/libinput-sources/gf-ibus-manager.c
new file mode 100644
index 0000000..bc1adea
--- /dev/null
+++ b/gnome-flashback/libinput-sources/gf-ibus-manager.c
@@ -0,0 +1,381 @@
+/*
+ * Copyright (C) 2015 Sebastian Geiger
+ *
+ * This program is free software: you can redistribute it and/or modify
+ * it under the terms of the GNU General Public License as published by
+ * the Free Software Foundation, either version 3 of the License, or
+ * (at your option) any later version.
+ *
+ * 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 General Public License for more details.
+ *
+ * You should have received a copy of the GNU General Public License
+ * along with this program. If not, see <http://www.gnu.org/licenses/>.
+ */
+
+/**
+ * This coded is based on js/ibusManager.js from GNOME Shell
+ */
+
+#include "config.h"
+
+#include "gf-ibus-manager.h"
+
+#include <glib/gi18n-lib.h>
+
+struct _GfIBusManager
+{
+    GObject parent;
+
+    IBusBus *ibus;
+    GHashTable *engines; // maps an engine name to an engine (char* to IBusEngine*)
+    IBusPanelService *panelService;
+    GSubprocess *ibusDaemonSubprocess;
+
+    gboolean ready;
+    gulong registerPropertiesSignalId;
+    guint preloadEnginesTimerId;
+
+    const gchar *currentEngineName;
+
+    /* stores the ids to be used by the timeout callback in preload_engines */
+    char **engineIds;
+
+};
+
+G_DEFINE_TYPE (GfIBusManager, gf_ibus_manager, G_TYPE_OBJECT)
+
+static void spawn (GfIBusManager *manager);
+static void initEngines (IBusBus *ibus, GAsyncResult *result,
+                         GfIBusManager *manager);
+static void initPanelService (IBusBus *ibus, GAsyncResult *result,
+                              GfIBusManager *manager);
+static void setContentType (IBusPanelService *panelService, guint purpose, guint hints,
+                            GfIBusManager *manager);
+
+enum {
+    GF_IBUS_MANAGER_READY,
+    GF_IBUS_MANAGER_PROPERTIES_REGISTERED,
+    GF_IBUS_MANAGER_PROPERTY_UPDATED,
+    GF_IBUS_MANAGER_SET_CONTENT_TYPE,
+    LAST_SIGNAL
+};
+
+static guint gf_ibus_manager_signals[LAST_SIGNAL] = { 0 };
+
+#define GF_IBUS_MANAGER_MAX_INPUT_SOURCE_ACTIVATION_TIME 4000
+#define GF_IBUS_MANAGER_PRELOAD_ENGINES_DELAY_TIME 30
+
+static void
+onConnected (IBusBus *ibus, GfIBusManager *manager)
+{
+    g_return_if_fail (manager->ibus);
+
+    ibus_bus_list_engines_async (manager->ibus, -1, NULL, (GAsyncReadyCallback) initEngines, manager);
+
+    ibus_bus_request_name_async (manager->ibus,
+                                 IBUS_SERVICE_PANEL,
+                                 IBUS_BUS_NAME_FLAG_REPLACE_EXISTING,
+                                 -1,
+                                 NULL,
+                                 (GAsyncReadyCallback) initPanelService,
+                                 manager);
+}
+
+static void
+onDisconnected (IBusBus *ibus, GfIBusManager *manager)
+{
+    if (manager->panelService) {
+        g_object_unref (manager->panelService);
+        manager->panelService = NULL;
+    }
+
+    // FIXME: something about the candidatePopup, we will ignore that for now.
+    // this.candidatePopup.setPanelService(null);
+
+    manager->engines = NULL;
+    manager->ready = FALSE;
+    manager->registerPropertiesSignalId = 0;
+    manager->currentEngineName = NULL;
+
+    g_signal_emit (manager, gf_ibus_manager_signals[GF_IBUS_MANAGER_READY], 0, FALSE);
+
+    spawn (manager);
+}
+
+static void
+on_register_properties (IBusPanelService *panelService, IBusPropList *properties, GfIBusManager *manager) {
+    if (!ibus_prop_list_get (properties, 0)) {
+        return;
+    }
+
+    g_signal_handler_disconnect (panelService, manager->registerPropertiesSignalId);
+    manager->registerPropertiesSignalId = 0;
+
+    g_signal_emit (manager, GF_IBUS_MANAGER_PROPERTIES_REGISTERED, 0, manager->currentEngineName, 
properties);
+}
+
+static void
+onEngineChanged (GfIBusManager *manager, const gchar *engineName)
+{
+    if (!manager->ready) {
+        return;
+    }
+
+    manager->currentEngineName = engineName;
+
+    if (manager->registerPropertiesSignalId != 0) {
+        return;
+    }
+
+    manager->registerPropertiesSignalId =
+            g_signal_connect (manager->panelService, "register-properties", G_CALLBACK 
(on_register_properties), manager);
+}
+
+static void
+updateReadiness (GfIBusManager *manager)
+{
+    manager->ready = g_hash_table_size (manager->engines) > 0 && manager->panelService != NULL;
+    g_signal_emit (manager, gf_ibus_manager_signals[GF_IBUS_MANAGER_READY], 0, manager->ready);
+}
+
+static void
+add_to_engines (IBusEngineDesc *engineDescription, GfIBusManager *manager)
+{
+    const char* name = ibus_engine_desc_get_name (engineDescription);
+    g_hash_table_insert (manager->engines, (gpointer) name, engineDescription);
+}
+
+static void
+initEngines (IBusBus *ibus, GAsyncResult *result, GfIBusManager *manager)
+{
+    GError *error = NULL;
+    GList *engineList = ibus_bus_list_engines_async_finish (ibus, result, &error);
+    if (engineList) {
+        g_list_foreach (engineList, (GFunc) add_to_engines, manager);
+        updateReadiness (manager);
+    } else {
+        onDisconnected (manager->ibus, manager);
+    }
+}
+
+static void
+updateProperty (IBusPanelService *panelService, IBusProperty *property, GfIBusManager *manager)
+{
+    g_signal_emit (manager, GF_IBUS_MANAGER_PROPERTY_UPDATED, 0, manager->currentEngineName, property);
+}
+
+static void
+get_global_engine_callback (IBusBus *ibus, guint i, GAsyncResult *result, GfIBusManager *manager)
+{
+    GError *error = NULL;
+    IBusEngineDesc *engineDescription = ibus_bus_get_global_engine_async_finish (ibus, result, &error);
+    if (error) {
+        g_log ("gnome-flashback", G_LOG_LEVEL_ERROR,
+               _("Could not get result for 'ibus_bus_get_global_async': %s"),
+               error->message);
+        onDisconnected (manager->ibus, manager);
+        g_error_free (error);
+    }
+
+    if (!engineDescription) {
+        return;
+    }
+    onEngineChanged (manager, ibus_engine_desc_get_name (engineDescription));
+
+}
+
+static gboolean
+preload_engines_callback (gpointer user_data)
+{
+    GfIBusManager *manager;
+    g_return_val_if_fail (GF_IS_IBUS_MANAGER (user_data), G_SOURCE_REMOVE);
+
+    manager = GF_IBUS_MANAGER (user_data);
+    ibus_bus_preload_engines_async (manager->ibus, (const gchar *const *) manager->engineIds, -1, NULL, 
NULL, NULL);
+    manager->preloadEnginesTimerId = 0;
+    manager->engineIds = NULL;
+    return G_SOURCE_REMOVE;
+}
+
+static void
+initPanelService (IBusBus *ibus, GAsyncResult *result, GfIBusManager *manager)
+{
+    GError *error = NULL;
+    gboolean success = ibus_bus_request_name_async_finish (ibus, result, &error);
+    if (error) {
+        g_log ("gnome-flashback", G_LOG_LEVEL_ERROR,
+               _("Could not get result for 'ibus_bus_request_name_async': %s"), error->message);
+        onDisconnected (manager->ibus, manager);
+        g_error_free (error);
+    }
+
+    if (success) {
+        //FIXME: what to do about the object_path: IBus.PATH_PANEL that is passed to the panel service 
constructor in Javascript?
+        manager->panelService = ibus_panel_service_new (ibus_bus_get_connection (manager->ibus));
+
+        //FIXME: something about the candidatePopup, we deal with it later.
+        //this.candidatePopup.setPanelService (this.panelService);
+
+        g_signal_connect (manager->panelService, "update-property", G_CALLBACK (updateProperty), manager);
+        g_signal_connect (manager->panelService, "set-content-type", G_CALLBACK (setContentType), manager);
+
+        ibus_bus_get_global_engine_async (manager->ibus, -1, NULL, (GAsyncReadyCallback) 
get_global_engine_callback, manager);
+        updateReadiness (manager);
+    } else {
+        onDisconnected (manager->ibus, manager);
+    }
+}
+
+void
+setContentType (IBusPanelService *panelService, guint purpose, guint hints, GfIBusManager *manager)
+{
+    g_signal_emit (manager, gf_ibus_manager_signals[GF_IBUS_MANAGER_SET_CONTENT_TYPE], purpose, hints, 
manager);
+}
+
+static void
+spawn (GfIBusManager *manager)
+{
+    // start a new subprocess for ibus-daemon
+    GError *error = NULL;
+    manager->ibusDaemonSubprocess = g_subprocess_new (G_SUBPROCESS_FLAGS_NONE, &error, "ibus-daemon", 
"--xim", "--panel", "disabled", NULL);
+    if (error) {
+        g_log ("gnome-flashback", G_LOG_LEVEL_ERROR, _("Failed to launch ibus-daemon: %s"), error->message);
+        g_error_free (error);
+    }
+}
+
+static void
+gf_ibus_manager_dispose (GObject *object)
+{
+    GfIBusManager *manager = GF_IBUS_MANAGER (object);
+
+    g_clear_object (&manager->ibusDaemonSubprocess);
+}
+
+static void
+gf_ibus_manager_class_init (GfIBusManagerClass *manager_class)
+{
+    GObjectClass *objectClass = G_OBJECT_CLASS (manager_class);
+    objectClass->dispose = gf_ibus_manager_dispose;
+
+    gf_ibus_manager_signals[GF_IBUS_MANAGER_READY] =
+            g_signal_new ("ready",
+                          G_TYPE_FROM_CLASS (manager_class),
+                          G_SIGNAL_RUN_LAST,
+                          0 /* closure */,
+                          NULL /* accumulator */,
+                          NULL /* accumulator data */,
+                          NULL,
+                          G_TYPE_NONE /* return_type */,
+                          1    /* n_params */,
+                          G_TYPE_BOOLEAN /* param_types */);
+
+    gf_ibus_manager_signals[GF_IBUS_MANAGER_PROPERTIES_REGISTERED] =
+            g_signal_new ("properties-registered",
+                          G_TYPE_FROM_CLASS (manager_class),
+                          G_SIGNAL_RUN_LAST,
+                          0 /* offset */,
+                          NULL /* accumulator */,
+                          NULL /* accumulator data */,
+                          NULL /* marshaller */,
+                          G_TYPE_NONE /* return_type */,
+                          2    /* n_params */,
+                          G_TYPE_STRING, IBUS_TYPE_PROP_LIST /* param_types */);
+
+    gf_ibus_manager_signals[GF_IBUS_MANAGER_PROPERTY_UPDATED] =
+            g_signal_new ("property-updated",
+                          G_TYPE_FROM_CLASS (manager_class),
+                          G_SIGNAL_RUN_LAST,
+                          0 /* offset */,
+                          NULL /* accumulator */,
+                          NULL /* accumulator data */,
+                          NULL /* marshaller */,
+                          G_TYPE_NONE /* return_type */,
+                          2    /* n_params */,
+                          G_TYPE_STRING, IBUS_TYPE_PROPERTY /* param_types */);
+
+    gf_ibus_manager_signals[GF_IBUS_MANAGER_SET_CONTENT_TYPE] =
+            g_signal_new ("set-content-type",
+                          G_TYPE_FROM_CLASS (manager_class),
+                          G_SIGNAL_RUN_LAST,
+                          0 /* offset */,
+                          NULL /* accumulator */,
+                          NULL /* accumulator data */,
+                          NULL /* marshaller */,
+                          G_TYPE_NONE /* return_type */,
+                          2    /* n_params */,
+                          G_TYPE_UINT, G_TYPE_UINT/* param_types */);
+}
+
+static void
+gf_ibus_manager_init (GfIBusManager *manager)
+{
+    manager->engines = g_hash_table_new (g_str_hash, g_str_equal);
+
+    ibus_init ();
+
+    // candidate popup
+
+    manager->ibus = ibus_bus_new_async ();
+    g_signal_connect (manager->ibus, "connected", G_CALLBACK (onConnected), manager);
+    g_signal_connect (manager->ibus, "disconnected", G_CALLBACK (onDisconnected), manager);
+    // Need to set this to get 'global-engine-changed' emissions
+    ibus_bus_set_watch_ibus_signal (manager->ibus, TRUE);
+    g_signal_connect (manager->ibus, "global-engine-changed", G_CALLBACK (onEngineChanged), manager);
+
+    spawn (manager);
+}
+
+IBusEngineDesc *
+gf_ibus_manager_get_engine_description (GfIBusManager *manager, const char* id) {
+    g_return_val_if_fail (manager->engines, NULL);
+
+    if (!manager->ready) {
+        return NULL;
+    }
+
+    return g_hash_table_lookup (manager->engines, id);
+}
+
+void
+gf_ibus_manager_set_engine (GfIBusManager *manager, const char* id, GAsyncReadyCallback callback)
+{
+    if (!manager->ready) {
+        if (callback)
+            callback(G_OBJECT (manager), NULL, NULL);
+        return;
+    }
+
+    ibus_bus_set_global_engine_async (manager->ibus,
+                                      id,
+                                      GF_IBUS_MANAGER_MAX_INPUT_SOURCE_ACTIVATION_TIME,
+                                      NULL,
+                                      callback,
+                                      manager);
+}
+
+void
+gf_ibus_manager_preload_engines (GfIBusManager *manager, gchar **ids)
+{
+    if (!manager->ibus || g_strv_length (ids) == 0) {
+        return;
+    }
+
+    if (manager->preloadEnginesTimerId != 0) {
+        g_source_remove (manager->preloadEnginesTimerId);
+        manager->preloadEnginesTimerId = 0;
+    }
+
+    manager->engineIds = ids;
+    manager->preloadEnginesTimerId = g_timeout_add (GF_IBUS_MANAGER_PRELOAD_ENGINES_DELAY_TIME,
+                                                    preload_engines_callback, manager);
+}
+
+GfIBusManager *
+gf_ibus_manager_new (void)
+{
+    return g_object_new (GF_TYPE_IBUS_MANAGER, NULL);
+}
\ No newline at end of file
diff --git a/gnome-flashback/libinput-sources/gf-ibus-manager.h 
b/gnome-flashback/libinput-sources/gf-ibus-manager.h
new file mode 100644
index 0000000..e79bf24
--- /dev/null
+++ b/gnome-flashback/libinput-sources/gf-ibus-manager.h
@@ -0,0 +1,39 @@
+/*
+ * Copyright (C) 2015 Alberts Muktupāvels
+ *
+ * This program is free software: you can redistribute it and/or modify
+ * it under the terms of the GNU General Public License as published by
+ * the Free Software Foundation, either version 3 of the License, or
+ * (at your option) any later version.
+ *
+ * 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 General Public License for more details.
+ *
+ * You should have received a copy of the GNU General Public License
+ * along with this program. If not, see <http://www.gnu.org/licenses/>.
+ */
+
+#ifndef GNOME_FLASHBACK_GFIBUSMANAGER_H
+#define GNOME_FLASHBACK_GFIBUSMANAGER_H
+
+#include <glib.h>
+#include <glib-object.h>
+#include <ibus-1.0/ibus.h>
+
+#define GF_TYPE_IBUS_MANAGER gf_ibus_manager_get_type ()
+G_DECLARE_FINAL_TYPE (GfIBusManager, gf_ibus_manager, GF, IBUS_MANAGER, GObject)
+
+GfIBusManager *gf_ibus_manager_new (void);
+
+void
+gf_ibus_manager_preload_engines (GfIBusManager *manager, gchar **ids);
+
+void
+gf_ibus_manager_set_engine (GfIBusManager *manager, const char* id, GAsyncReadyCallback callback);
+
+IBusEngineDesc *
+gf_ibus_manager_get_engine_description (GfIBusManager *manager, const char* id);
+
+#endif
diff --git a/gnome-flashback/libinput-sources/gf-input-sources.c 
b/gnome-flashback/libinput-sources/gf-input-sources.c
index bd02248..6926ffe 100644
--- a/gnome-flashback/libinput-sources/gf-input-sources.c
+++ b/gnome-flashback/libinput-sources/gf-input-sources.c
@@ -18,22 +18,66 @@
 #include "config.h"
 
 #include "gf-input-sources.h"
+#include "gf-ibus-manager.h"
 
 struct _GfInputSources
 {
   GObject parent;
+
+  GfIBusManager *manager;
 };
 
 G_DEFINE_TYPE (GfInputSources, gf_input_sources, G_TYPE_OBJECT)
 
 static void
-gf_input_sources_class_init (GfInputSourcesClass *input_sources_class)
+ready_callback (GfIBusManager *manager,
+                gboolean ready,
+                gpointer user_data)
+{
+    g_warning ("ready_callback: %s", ready ? "true" : "false");
+}
+
+static void
+properties_registered (GfIBusManager *manager,
+                       gchar* currentEngineName,
+                       IBusPropList *propertyList,
+                       gpointer user_data)
+{
+    g_warning ("properties_registered");
+}
+
+static void
+property_updated (GfIBusManager *manager,
+                  gchar *currentEngineName,
+                  IBusProperty *property,
+                  gpointer user_data)
 {
+    g_warning ("property_updated");
 }
 
 static void
-gf_input_sources_init (GfInputSources *input_sources)
+set_content_type (GfIBusManager *manager,
+                  guint purpose,
+                  guint hint,
+                  gpointer user_data)
 {
+    g_warning ("set_content_type");
+}
+
+
+static void
+gf_input_sources_class_init (GfInputSourcesClass *sources_class)
+{
+}
+
+static void
+gf_input_sources_init (GfInputSources *sources) {
+  sources->manager = gf_ibus_manager_new ();
+
+  g_signal_connect(sources->manager, "ready", G_CALLBACK (ready_callback), sources);
+  g_signal_connect(sources->manager, "properties-registered", G_CALLBACK (properties_registered), sources);
+  g_signal_connect(sources->manager, "property-updated", G_CALLBACK (property_updated), sources);
+  g_signal_connect(sources->manager, "set-content-type", G_CALLBACK (set_content_type), sources);
 }
 
 GfInputSources *
[Date Prev][Date Next]   [Thread Prev][Thread Next]   [Thread Index] [Date Index] [Author Index]