add handshake loop

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

diff --git a/src/homescreen.cpp b/src/homescreen.cpp
index 142007f..b3980b2 100644 (file)
--- a/src/homescreen.cpp
+++ b/src/homescreen.cpp
@@ -22,6 +22,7 @@
 #include <algorithm>
 #include <unordered_map>
 #include <list>
+#include <thread>
 #include "hs-helper.h"
 #include "hs-clientmanager.h"
 #include "hs-appinfo.h"
@@ -39,7 +40,8 @@ const char _keyId[] = "id";
 
 struct hs_handshake {
     hs_handshake(int times, int sleep) : m_times(times), m_sleep(sleep) {}
-    int start(afb_api_t api) const;
+    int start(afb_api_t api);
+    void handshake_loop(afb_api_t api);
 
     enum HandshakeStatus {
         Handshake_Idle = 0,
@@ -72,6 +74,10 @@ int hs_handshake::hs_sts = hs_handshake::Handshake_Idle;
  */
 void handshake_subscribe_callback(struct json_object *obj, const char *error, const char *info)
 {
+    AFB_NOTICE("subscribe handshake reply: obj=%s, error=%s, info=%s", json_object_to_json_string(obj), error, info);
+    if(hs_handshake::hs_sts == hs_handshake::Handshake_Over) {
+        return;
+    }
     if(error == nullptr) {
         hs_handshake::hs_sts =  hs_handshake::Handshake_WaitEvent;
     }
@@ -94,6 +100,7 @@ void handshake_subscribe_callback(struct json_object *obj, const char *error, co
  */
 int on_handshake_event(afb_api_t api, const char *event, struct json_object *object)
 {
+    AFB_NOTICE("received handshake event from windowmanager.");
     hs_handshake::hs_sts =  hs_handshake::Handshake_Over;
     return 1;
 }
@@ -105,15 +112,32 @@ int on_handshake_event(afb_api_t api, const char *event, struct json_object *obj
  * - api : the api
  *
  * #### Return
- * None
  * 0 : handshake success
- * -1 : handshake fail
+ * other : handshake fail
  * 
  */
-int hs_handshake::start(afb_api_t api) const
+int hs_handshake::start(afb_api_t api)
 {
-    int ret = -1;
+    AFB_NOTICE("start handshake with windowmanager.");
     setEventHook(sub_event.c_str(), on_handshake_event);
+
+    std::thread th(&hs_handshake::handshake_loop, this, api);
+    th.detach();
+    return 0;
+}
+
+/**
+ * handshake loop
+ *
+ * #### Parameters
+ * - api : the api
+ *
+ * #### Return
+ * None
+ *
+ */
+void hs_handshake::handshake_loop(afb_api_t api)
+{
     int count = 0;
     do {
         // try to subscribe handshake event
@@ -126,15 +150,14 @@ int hs_handshake::start(afb_api_t api) const
 
         // wait handshake event
         if(hs_handshake::hs_sts == hs_handshake::Handshake_Over) {
-            ret = 0;
             break;
         }
 
         ++count;
         usleep(m_sleep*1000);
     } while(count < m_times);
-
-    return ret;
+    AFB_NOTICE("handshake over, count=%d.", count);
+    HS_AppRecover::instance()->startRecovery(api);
 }
 
 struct hs_instance {
@@ -183,6 +206,13 @@ int hs_instance::init(afb_api_t api)
         return -1;
     }
 
+    if(app_recover == nullptr) {
+        AFB_ERROR("app_recover is nullptr.");
+        return -1;
+    }
+    app_recover->init(api);
+    app_recover->setRecoverMap(hs_config.getRecoverMap());
+
     const struct handshake_info *h = hs_config.getHandshakeInfo();
     struct hs_handshake handshake(h->times, h->sleep);
     if(handshake.start(api) < 0) {
@@ -190,13 +220,6 @@ int hs_instance::init(afb_api_t api)
         return -1;
     }
 
-    if(app_recover == nullptr) {
-        AFB_ERROR("app_recover is nullptr.");
-        return -1;
-    }
-    app_recover->init(api);
-    app_recover->startRecovery(api, hs_config.getRecoverMap());
-
     return 0;
 }
 
@@ -628,6 +651,72 @@ static void getRunnables(afb_req_t request)
     afb_req_success_f(request, res, "homescreen binder unsubscribe success.");
 }
 
+/**
+ * registerShortcut event
+ *
+ * #### Parameters
+ *  - value  : the json contents to MenuBar.
+ *    {"application_id":"homescreen","parameter":{"shortcut_id":"dashboard@0.1","shortcut_name":"Dashboard","postion": 1}}
+ *
+ * #### Return
+ * None
+ *
+ */
+static void registerShortcut(afb_req_t request)
+{
+    int ret = 0;
+    const char* value = afb_req_value(request, _application_id);
+    if (value) {
+        ret = g_hs_instance->client_manager->handleRequest(request, __FUNCTION__, value);
+    }
+    else {
+        ret = AFB_EVENT_BAD_REQUEST;
+    }
+
+    if (ret) {
+        afb_req_fail_f(request, "failed", "called %s, Unknown parameter", __FUNCTION__);
+    }
+    else {
+        struct json_object *res = json_object_new_object();
+        hs_add_object_to_json_object_func(res, __FUNCTION__, 2,
+          _error,  ret);
+        afb_req_success(request, res, "afb_event_push event [registerShortcut]");
+    }
+}
+
+/**
+ * updateShortcut event
+ *
+ * #### Parameters
+ *  - value  : homescreen shortcut json contents.
+ *    {"application_id":"launcher","parameter":{"shortcut":[{"shortcut_id":"hvac","shortcut_name":"HVAC"},...]}}
+ *
+ * #### Return
+ * None
+ *
+ */
+static void updateShortcut(afb_req_t request)
+{
+    int ret = 0;
+    const char* value = afb_req_value(request, _application_id);
+    if (value) {
+        ret = g_hs_instance->client_manager->handleRequest(request, __FUNCTION__, value);
+    }
+    else {
+        ret = AFB_EVENT_BAD_REQUEST;
+    }
+
+    if (ret) {
+        afb_req_fail_f(request, "failed", "called %s, Unknown parameter", __FUNCTION__);
+    }
+    else {
+        struct json_object *res = json_object_new_object();
+        hs_add_object_to_json_object_func(res, __FUNCTION__, 2,
+          _error,  ret);
+        afb_req_success(request, res, "afb_event_push event [updateShortcut]");
+    }
+}
+
 /*
  * array of the verbs exported to afb-daemon
  */
@@ -644,7 +733,9 @@ static const afb_verb_t verbs[]= {
     { .verb="unsubscribe",       .callback=unsubscribe            },
     { .verb="showNotification",  .callback=showNotification       },
     { .verb="showInformation",   .callback=showInformation        },
+    { .verb="registerShortcut",  .callback=registerShortcut       },
     { .verb="getRunnables",      .callback=getRunnables           },
+    { .verb="updateShortcut",    .callback=updateShortcut         },
     {NULL } /* marker for end of the array */
 };
 
@@ -682,6 +773,7 @@ static int init(afb_api_t api)
         AFB_WARNING( "g_hs_instance isn't null.");
         delete g_hs_instance->client_manager;
         delete g_hs_instance->app_info;
+        delete g_hs_instance->app_recover;
         delete g_hs_instance;
         g_hs_instance = nullptr;
     }