Impove event process
[apps/agl-service-homescreen.git] / src / homescreen.cpp
index b518139..c02f62b 100644 (file)
 #endif
 #include <memory>
 #include <algorithm>
+#include <unordered_map>
+#include <list>
 #include "hs-helper.h"
-#include "hmi-debug.h"
 #include "hs-clientmanager.h"
+#include "hs-appinfo.h"
 
 
 const char _error[] = "error";
-const char _application_name[] = "application_name";
+const char _application_id[] = "application_id";
 const char _display_message[] = "display_message";
 const char _reply_message[] = "reply_message";
+const char _keyData[] = "data";
+const char _keyId[] = "id";
 
-static HS_ClientManager* g_client_manager = HS_ClientManager::instance();
+struct hs_instance {
+  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);
+private:
+  std::unordered_map<std::string, std::list<event_hook_func>> event_hook_list;
+};
+
+/**
+ * init function
+ *
+ * #### Parameters
+ * - api : the api serving the request
+ *
+ * #### Return
+ * 0 : init success
+ * 1 : init fail
+ *
+ */
+int hs_instance::init(afb_api_t api)
+{
+    if(client_manager == nullptr) {
+        AFB_ERROR("FATAL ERROR: client_manager is nullptr.");
+        return -1;
+    }
+    client_manager->init();
+
+    if(app_info == nullptr) {
+        AFB_ERROR("FATAL ERROR: app_info is nullptr.");
+        return -1;
+    }
+    app_info->init(api);
+
+    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) **********
@@ -39,7 +155,7 @@ static void pingSample(afb_req_t request)
 {
    static int pingcount = 0;
    afb_req_success_f(request, json_object_new_int(pingcount), "Ping count = %d", pingcount);
-   HMI_NOTICE("homescreen-service","Verbosity macro at level notice invoked at ping invocation count = %d", pingcount);
+   AFB_DEBUG("Verbosity macro at level notice invoked at ping invocation count = %d", pingcount);
    pingcount++;
 }
 
@@ -49,7 +165,7 @@ static void pingSample(afb_req_t request)
  *
  * #### Parameters
  * Request key
- * - application_name   : application name
+ * - application_id   : application id
  *
  * #### Return
  * None
@@ -57,18 +173,32 @@ static void pingSample(afb_req_t request)
  */
 static void tap_shortcut (afb_req_t request)
 {
-    HMI_NOTICE("homescreen-service","called.");
-    int ret = g_client_manager->tap_shortcut(request);
-    if (ret != 0) {
-      afb_req_fail_f(request, "failed", "called %s, Unknown parameter", __FUNCTION__);
-      return;
+    AFB_DEBUG("called.");
+    int ret = 0;
+    const char* value = afb_req_value(request, _application_id);
+    if (value) {
+        AFB_INFO("request appid = %s.", value);
+        ret = g_hs_instance->client_manager->handleRequest(request, __FUNCTION__, value);
+        if(ret == AFB_REQ_NOT_STARTED_APPLICATION) {
+            std::string id = g_hs_instance->app_info->getAppProperty(value, _keyId);
+            HS_AfmMainProxy afm_proxy;
+            afm_proxy.start(request, id);
+            ret = 0;
+        }
+    }
+    else {
+        ret = AFB_EVENT_BAD_REQUEST;
     }
 
-    // response to HomeScreen
-    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 [tap_shortcut]");
+    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 [tap_shortcut]");
+    }
 }
 
 /**
@@ -84,19 +214,17 @@ static void tap_shortcut (afb_req_t request)
  */
 static void on_screen_message (afb_req_t request)
 {
-    HMI_NOTICE("homescreen-service","called.");
-
-    int ret = g_client_manager->on_screen_message(request);
-    if (ret != 0) {
-      afb_req_fail_f(request, "failed", "called %s, Unknown parameter", __FUNCTION__);
-      return;
+    AFB_DEBUG("called.");
+    int ret = g_hs_instance->client_manager->handleRequest(request, __FUNCTION__);
+    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 [on_screen_message]");
     }
-
-  // response to HomeScreen
-    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 [on_screen_message]");
 }
 
 /**
@@ -112,19 +240,17 @@ static void on_screen_message (afb_req_t request)
  */
 static void on_screen_reply (afb_req_t request)
 {
-    HMI_NOTICE("homescreen-service","called.");
-
-    int ret = g_client_manager->on_screen_reply(request);
-    if (ret != 0) {
-      afb_req_fail_f(request, "failed", "called %s, Unknown parameter", __FUNCTION__);
-      return;
+    AFB_DEBUG("called.");
+    int ret = g_hs_instance->client_manager->handleRequest(request, __FUNCTION__);
+    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 [on_screen_reply]");
     }
-
-  // response to HomeScreen
-    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 [on_screen_reply]");
 }
 
 /**
@@ -139,19 +265,25 @@ static void on_screen_reply (afb_req_t request)
  */
 static void subscribe(afb_req_t request)
 {
-    HMI_NOTICE("homescreen-service","called.");
+    AFB_DEBUG("called.");
+    int ret = 0;
+    std::string req_appid = std::move(get_application_id(request));
+    if(!req_appid.empty()) {
+        ret = g_hs_instance->client_manager->handleRequest(request, __FUNCTION__, req_appid.c_str());
+    }
+    else {
+        ret = AFB_EVENT_BAD_REQUEST;
+    }
 
-    int ret = g_client_manager->subscribe(request);
     if(ret) {
-      afb_req_fail_f(request, "afb_req_subscribe failed", "called %s.", __FUNCTION__);
-      return;
+        afb_req_fail_f(request, "afb_req_subscribe failed", "called %s.", __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_f(request, res, "homescreen binder subscribe.");
     }
-
-    /*create response json object*/
-    struct json_object *res = json_object_new_object();
-    hs_add_object_to_json_object_func(res, __FUNCTION__, 2,
-        _error, ret);
-    afb_req_success_f(request, res, "homescreen binder subscribe.");
 }
 
 /**
@@ -166,18 +298,206 @@ static void subscribe(afb_req_t request)
  */
 static void unsubscribe(afb_req_t request)
 {
-    HMI_NOTICE("homescreen-service","called.");
+    AFB_DEBUG("called.");
+    int ret = 0;
+    std::string req_appid = std::move(get_application_id(request));
+    if(!req_appid.empty()) {
+        ret = g_hs_instance->client_manager->handleRequest(request, __FUNCTION__, req_appid.c_str());
+    }
+    else {
+        ret = AFB_EVENT_BAD_REQUEST;
+    }
 
-    int ret = g_client_manager->unsubscribe(request);
     if(ret) {
-      afb_req_fail_f(request, "afb_req_unsubscribe failed", "called %s.", __FUNCTION__);
-      return;
+        afb_req_fail_f(request, "afb_req_unsubscribe failed", "called %s.", __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_f(request, res, "homescreen binder unsubscribe success.");
+    }
+}
+
+/**
+ * showWindow event
+ *
+ * #### Parameters
+ *  - request : the request
+ *
+ * #### Return
+ * None
+ *
+ */
+static void showWindow(afb_req_t request)
+{
+    AFB_DEBUG("called.");
+    int ret = 0;
+    const char* value = afb_req_value(request, _application_id);
+    if (value) {
+        ret = g_hs_instance->client_manager->handleRequest(request, __FUNCTION__, value);
+        if(ret == AFB_REQ_NOT_STARTED_APPLICATION) {
+            std::string id = g_hs_instance->app_info->getAppProperty(value, _keyId);
+            HS_AfmMainProxy afm_proxy;
+            afm_proxy.start(request, id);
+            ret = 0;
+        }
+    }
+    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 [showWindow]");
+    }
+}
+
+/**
+ * hideWindow event
+ *
+ * #### Parameters
+ *  - request : the request
+ *
+ * #### Return
+ * None
+ *
+ */
+static void hideWindow(afb_req_t request)
+{
+    AFB_DEBUG("called.");
+    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 [hideWindow]");
+    }
+}
+
+/**
+ * replyShowWindow event
+ *
+ * #### Parameters
+ *  - request : the request
+ *
+ * #### Return
+ *  None
+ *
+ */
+static void replyShowWindow(afb_req_t request)
+{
+    AFB_DEBUG("called.");
+    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 [replyShowWindow]");
+    }
+}
+
+/**
+ * showNotification event
+ *
+ * the contents to homescreen which display at top area.
+ *
+ * #### Parameters
+ *  - request : the request
+ *
+ * #### Return
+ * None
+ *
+ */
+static void showNotification(afb_req_t request)
+{
+    AFB_DEBUG("called.");
+    int ret = g_hs_instance->client_manager->handleRequest(request, __FUNCTION__, "homescreen");
+    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 [showNotification]");
+    }
+}
+
+/**
+ * showInformation event
+ *
+ * the contents to homescreen which display at bottom area.
+ *
+ * #### Parameters
+ *  - request : the request
+ *
+ * #### Return
+ * None
+ *
+ */
+static void showInformation(afb_req_t request)
+{
+    AFB_DEBUG("called.");
+    int ret = g_hs_instance->client_manager->handleRequest(request,  __FUNCTION__, "homescreen");
+    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 [showInformation]");
+    }
+}
+
+/**
+ * get runnables list
+ *
+ * #### Parameters
+ *  - request : the request
+ *
+ * #### Return
+ * None
+ *
+ */
+static void getRunnables(afb_req_t request)
+{
+    AFB_DEBUG("called.");
+    struct json_object* j_runnable = json_object_new_array();
+    g_hs_instance->app_info->getRunnables(&j_runnable);
 
     /*create response json object*/
     struct json_object *res = json_object_new_object();
-    hs_add_object_to_json_object_func(res, __FUNCTION__, 2,
-        _error, ret);
+    hs_add_object_to_json_object_func(res, __FUNCTION__, 2, _error, 0);
+    json_object_object_add(res, _keyData, j_runnable);
     afb_req_success_f(request, res, "homescreen binder unsubscribe success.");
 }
 
@@ -188,10 +508,16 @@ static const afb_verb_t verbs[]= {
     /* VERB'S NAME                 FUNCTION TO CALL                  */
     { .verb="ping",              .callback=pingSample             },
     { .verb="tap_shortcut",      .callback=tap_shortcut           },
+    { .verb="showWindow",        .callback=showWindow             },
+    { .verb="hideWindow",        .callback=hideWindow             },
+    { .verb="replyShowWindow",   .callback=replyShowWindow        },
     { .verb="on_screen_message", .callback=on_screen_message      },
     { .verb="on_screen_reply",   .callback=on_screen_reply        },
     { .verb="subscribe",         .callback=subscribe              },
     { .verb="unsubscribe",       .callback=unsubscribe            },
+    { .verb="showNotification",  .callback=showNotification       },
+    { .verb="showInformation",   .callback=showInformation        },
+    { .verb="getRunnables",      .callback=getRunnables           },
     {NULL } /* marker for end of the array */
 };
 
@@ -207,7 +533,7 @@ static const afb_verb_t verbs[]= {
  */
 static int preinit(afb_api_t api)
 {
-   HMI_NOTICE("homescreen-service","binding preinit (was register)");
+   AFB_DEBUG("binding preinit (was register)");
    return 0;
 }
 
@@ -223,11 +549,22 @@ static int preinit(afb_api_t api)
  */
 static int init(afb_api_t api)
 {
-    HMI_NOTICE("homescreen-service","binding init");
+    AFB_DEBUG("binding init");
 
-    g_client_manager->init();
+    if(g_hs_instance != nullptr) {
+        AFB_WARNING( "g_hs_instance isn't null.");
+        delete g_hs_instance->client_manager;
+        delete g_hs_instance->app_info;
+        delete g_hs_instance;
+        g_hs_instance = nullptr;
+    }
+    g_hs_instance = new hs_instance();
+    if(g_hs_instance == nullptr) {
+        AFB_ERROR( "Fatal Error: new g_hs_instance failed.");
+        return -1;
+    }
 
-    return 0;
+    return g_hs_instance->init(api);
 }
 
 /**
@@ -244,7 +581,8 @@ static int init(afb_api_t api)
  */
 static void onevent(afb_api_t api, const char *event, struct json_object *object)
 {
-   HMI_NOTICE("homescreen-service","on_event %s", event);
+    AFB_INFO("on_event %s", event);
+    g_hs_instance->onEvent(api, event, object);
 }
 
 const afb_binding_t afbBindingExport = {