temp
[apps/agl-service-homescreen.git] / src / homescreen.cpp
index 892fcba..c9ad6ef 100644 (file)
@@ -19,6 +19,8 @@
 #endif
 #include <memory>
 #include <algorithm>
+#include <unordered_map>
+#include <list>
 #include "hs-helper.h"
 #include "hs-clientmanager.h"
 #include "hs-appinfo.h"
@@ -30,6 +32,23 @@ const char _display_message[] = "display_message";
 const char _reply_message[] = "reply_message";
 const char _keyData[] = "data";
 const char _keyId[] = "id";
+const char _keyHandshake[] = "handshake";
+const char _keyTimes[] = "times";
+const char _keySleep[] = "sleep";
+const char _hs_conf_json[] = "hs-conf.json";
+const char _lastmode_json[] = "lastmode.json";
+
+struct hs_config {
+    struct json_object *hs_conf;
+    struct json_object *lastmode;
+};
+static struct hs_config g_hs_config;
+
+const char _wm_event[] = "windowmanager/screenUpdated";
+static void screenUpdateCb(void *closure, const char *event, struct json_object* obj, afb_api_t api)
+{
+    AFB_WARNING("windowmanager/screenUpdated callback. obj=%s.", json_object_to_json_string(obj));
+}
 
 struct hs_instance {
   HS_ClientManager *client_manager;   // the connection session manager
@@ -37,6 +56,10 @@ struct hs_instance {
 
   hs_instance() : client_manager(HS_ClientManager::instance()), app_info(HS_AppInfo::instance()) {}
   int init(afb_api_t api);
+  void setEventHook(const char *event, const event_hook_func f);
+  void onEvent(afb_api_t api, const char *event, struct json_object *object);
+private:
+  std::unordered_map<std::string, std::list<event_hook_func>> event_hook_list;
 };
 
 /**
@@ -64,11 +87,95 @@ int hs_instance::init(afb_api_t api)
     }
     app_info->init(api);
 
+    struct json_object *handshake_obj;
+    if(json_object_object_get_ex(g_hs_config.hs_conf, _keyHandshake, &handshake_obj) == 0) {
+        AFB_ERROR("get handshake failed.");
+        return -1;
+    }
+    else {
+        struct json_object *times_obj, *sleep_obj;
+        json_object_object_get_ex(handshake_obj, _keyTimes, &times_obj);
+        json_object_object_get_ex(handshake_obj, _keySleep, &sleep_obj);
+        AFB_WARNING("get handshake times=%d, sleep=%d", json_object_get_int(times_obj), json_object_get_int(sleep_obj));
+    }
+
     return 0;
 }
 
+/**
+ * set event hook
+ *
+ * #### Parameters
+ *  - event  : event name
+ *  - f : hook function
+ *
+ * #### Return
+ * Nothing
+ */
+void hs_instance::setEventHook(const char *event, const event_hook_func f)
+{
+    if(event == nullptr || f == nullptr) {
+        AFB_WARNING("argument is null.");
+        return;
+    }
+
+    std::string ev(event);
+    auto it = event_hook_list.find(ev);
+    if(it != event_hook_list.end()) {
+        it->second.push_back(f);
+    }
+    else {
+        std::list<event_hook_func> l;
+        l.push_back(f);
+        event_hook_list[ev] = std::move(l);
+    }
+}
+
+/**
+ * onEvent function
+ *
+ * #### Parameters
+ *  - api : the api serving the request
+ *  - event  : event name
+ *  - object : event json object
+ *
+ * #### Return
+ * Nothing
+ */
+void hs_instance::onEvent(afb_api_t api, const char *event, struct json_object *object)
+{
+    std::string ev(event);
+    auto it = event_hook_list.find(ev);
+    if(it != event_hook_list.end()) {
+        for(auto &ref : it->second) {
+            if(ref(api, event, object))
+                break;
+        }
+    }
+}
+
 static struct hs_instance *g_hs_instance;
 
+/**
+ * set event hook
+ *
+ * #### Parameters
+ *  - event  : event name
+ *  - f : hook function pointer
+ *
+ * #### Return
+ * Nothing
+ */
+void setEventHook(const char *event, const event_hook_func f)
+{
+    if(g_hs_instance == nullptr) {
+        AFB_ERROR("g_hs_instance is null.");
+        return;
+    }
+
+    g_hs_instance->setEventHook(event, f);
+}
+
 /*
 ********** Method of HomeScreen Service (API) **********
 */
@@ -455,8 +562,20 @@ static const afb_verb_t verbs[]= {
  */
 static int preinit(afb_api_t api)
 {
-   AFB_DEBUG("binding preinit (was register)");
-   return 0;
+    AFB_DEBUG("binding preinit (was register)");
+    auto rootdir = std::string(getenv("AFM_APP_INSTALL_DIR"));
+    auto path = rootdir + "/etc/" + _hs_conf_json;
+    if(readJsonFile(path.c_str(), &g_hs_config.hs_conf) < 0) {
+        AFB_ERROR("read %s failed.", _hs_conf_json);
+        return -1;
+    }
+
+    path = rootdir + "/etc/" + _lastmode_json;
+    if(readJsonFile(path.c_str(), &g_hs_config.lastmode) < 0) {
+        AFB_ERROR("read %s failed.", _lastmode_json);
+        return -1;
+    }
+    return 0;
 }
 
 /**
@@ -503,8 +622,8 @@ static int init(afb_api_t api)
  */
 static void onevent(afb_api_t api, const char *event, struct json_object *object)
 {
-    AFB_DEBUG("on_event %s", event);
-    g_hs_instance->app_info->onEvent(api, event, object);
+    AFB_INFO("on_event %s", event);
+    g_hs_instance->onEvent(api, event, object);
 }
 
 const afb_binding_t afbBindingExport = {