add handshake

[apps/agl-service-homescreen.git] / src / homescreen.cpp

diff --git a/src/homescreen.cpp b/src/homescreen.cpp
index eeba767..3e4ff8f 100644 (file)
--- a/src/homescreen.cpp
+++ b/src/homescreen.cpp
@@ -24,6 +24,8 @@
 #include "hs-helper.h"
 #include "hs-clientmanager.h"
 #include "hs-appinfo.h"
+#include "hs-config.h"
+#include <unistd.h>
 
 
 const char _error[] = "error";
@@ -32,25 +34,78 @@ const char _display_message[] = "display_message";
 const char _reply_message[] = "reply_message";
 const char _keyData[] = "data";
 const char _keyId[] = "id";
-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;
+struct hs_handshake {
+    hs_handshake(int times, int sleep) : m_times(times), m_sleep(sleep) {}
+    void start(afb_api_t api) const;
+
+    enum HandshakeStatus {
+        Handshake_Idle = 0,
+        Handshake_Subscribing,
+        Handshake_Subscribe_Fail,
+        Handshake_WaitEvent,
+        Handshake_Over
+    };
+    static int hs_sts;
+
+private:
+    const std::string sub_event = "windowmanager/handshake";
+    const int m_times;
+    const int m_sleep;
 };
-static struct hs_config g_hs_config;
+
+int hs_handshake::hs_sts = hs_handshake::Handshake_Idle;
+
+void handshake_subscribe_callback(struct json_object *obj, const char *error, const char *info)
+{
+    if(error == nullptr) {
+        hs_handshake::hs_sts =  hs_handshake::Handshake_WaitEvent;
+    }
+    else {
+        hs_handshake::hs_sts =  hs_handshake::Handshake_Subscribe_Fail;
+    }
+}
+
+int on_handshake_event(afb_api_t api, const char *event, struct json_object *object)
+{
+    hs_handshake::hs_sts =  hs_handshake::Handshake_Over;
+    return 1;
+}
+
+void hs_handshake::start(afb_api_t api) const
+{
+    setEventHook(sub_event.c_str(), on_handshake_event);
+    int count = 0;
+    do {
+        // try to subscribe handshake event
+        if(hs_handshake::hs_sts == hs_handshake::Handshake_Idle
+        || hs_handshake::hs_sts == hs_handshake::Handshake_Subscribe_Fail) {
+            hs_handshake::hs_sts = Handshake_Subscribing;
+            HS_WmProxy *wm_proxy = new HS_WmProxy();
+            wm_proxy->subscribe(api, HS_WmProxy::Event_Handshake, handshake_subscribe_callback);
+        }
+
+        // wait handshake event
+        if(hs_handshake::hs_sts == hs_handshake::Handshake_Over) {
+            break;
+        }
+
+        ++count;
+        usleep(m_sleep*1000);
+    } while(count < m_times);
+    AFB_WARNING("wait count is %d.", count);
+}
 
 struct hs_instance {
-  HS_ClientManager *client_manager;   // the connection session manager
-  HS_AppInfo *app_info;               // application info
+    HS_ClientManager *client_manager;   // the connection session manager
+    HS_AppInfo *app_info;               // application info
 
-  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);
+    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;
+    std::unordered_map<std::string, std::list<event_hook_func>> event_hook_list;
 };
 
 /**
@@ -67,17 +122,30 @@ private:
 int hs_instance::init(afb_api_t api)
 {
     if(client_manager == nullptr) {
-        AFB_ERROR("FATAL ERROR: client_manager is nullptr.");
+        AFB_ERROR("client_manager is nullptr.");
         return -1;
     }
     client_manager->init();
 
     if(app_info == nullptr) {
-        AFB_ERROR("FATAL ERROR: app_info is nullptr.");
+        AFB_ERROR("app_info is nullptr.");
         return -1;
     }
     app_info->init(api);
 
+    HS_Config hs_config;
+    if(hs_config.readConfig() < 0) {
+        AFB_ERROR("read config file failed.");
+        return -1;
+    }
+
+    // const struct handshake_info *h = hs_config.getHandshakeInfo();
+    // struct hs_handshake handshake(h->times, h->sleep);
+    // handshake.start(api);
+
+    // recover application
+
+
     return 0;
 }
 
@@ -542,18 +610,6 @@ static const afb_verb_t verbs[]= {
 static int preinit(afb_api_t api)
 {
     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;
 }