/*
* Copyright (c) 2018 TOYOTA MOTOR CORPORATION
+ * Copyright (C) 2020 Konsulko Group
*
* Licensed under the Apache License, Version 2.0 (the "License");
* you may not use this file except in compliance with the License.
* limitations under the License.
*/
+#include <cstring>
+#include <algorithm>
+#include <cassert>
+#include "hs-proxy.h"
#include "hs-clientmanager.h"
-#include "hmi-debug.h"
+
+static const char _homescreen[] = "homescreen";
HS_ClientManager* HS_ClientManager::me = nullptr;
*/
int HS_ClientManager::init(void)
{
- HMI_NOTICE("homescreen-service","called.");
- // TODO : connect to windowmanger
- // get applist from appfw
-}
-
-/**
- * find HS_Client in client_list
- *
- * #### Parameters
- * - appid: app's id
- *
- * #### Return
- * found HS_Client pointer
- *
- */
-HS_Client* HS_ClientManager::find(std::string appid)
-{
- std::lock_guard<std::mutex> lock(this->mtx);
- HS_Client* p = nullptr;
- auto ip = client_list.find(appid);
- if(ip != client_list.end()) {
- p = client_list[appid];
- }
- return p;
-}
-
-/**
- * get HS_Client
- *
- * #### Parameters
- * - appid: app's id
- *
- * #### Return
- * found HS_Client pointer
- *
- */
-HS_Client* HS_ClientManager::getClient(afb_req req, std::string appid)
-{
- std::lock_guard<std::mutex> lock(this->mtx);
- HS_Client* p = nullptr;
- auto ip = client_list.find(appid);
- if(ip != client_list.end()) {
- p = client_list[appid];
- }
- else {
- appid2ctxt[appid] = createClientCtxt(req, appid);
- p = addClient(req, appid);
- }
- return p;
-}
-
-/**
- * get HS_Client pointers set
- *
- * #### Parameters
- * - Nothing
- *
- * #### Return
- * HS_Client pointers set
- *
- */
-std::vector<HS_Client*> HS_ClientManager::getAllClient(void)
-{
- std::lock_guard<std::mutex> lock(this->mtx);
- std::vector<HS_Client*> v;
- for(auto a : client_list)
- v.push_back(a.second);
- return v;
+ return 0;
}
/**
* HS_ClientCtxt pointer
*
*/
-HS_ClientCtxt* HS_ClientManager::createClientCtxt(afb_req req, std::string appid)
+HS_ClientCtxt* HS_ClientManager::createClientCtxt(afb_req_t req, std::string appid)
{
HS_ClientCtxt *ctxt = (HS_ClientCtxt *)afb_req_context_get(req);
if (!ctxt)
{
- HMI_NOTICE("homescreen-service", "create new session for %s", appid.c_str());
- HS_ClientCtxt *ctxt = new HS_ClientCtxt(appid.c_str());
+ AFB_INFO( "create new session for %s", appid.c_str());
+ ctxt = new HS_ClientCtxt(appid);
afb_req_session_set_LOA(req, 1);
afb_req_context_set(req, ctxt, cbRemoveClientCtxt);
+
+ appid2ctxt[appid] = ctxt;
}
+
return ctxt;
}
* HS_Client pointer
*
*/
-HS_Client* HS_ClientManager::addClient(afb_req req, std::string appid)
+HS_Client* HS_ClientManager::addClient(afb_req_t req, std::string appid)
{
return (client_list[appid] = new HS_Client(req, appid));
}
HS_ClientCtxt *ctxt = (HS_ClientCtxt *)data;
if(ctxt == nullptr)
{
- HMI_ERROR("homescreen-service", "data is nullptr");
+ AFB_WARNING( "data is nullptr");
return;
}
- HMI_NOTICE("homescreen-service", "remove app %s", ctxt->id.c_str());
+ AFB_INFO( "remove app %s", ctxt->id.c_str());
std::lock_guard<std::mutex> lock(this->mtx);
removeClient(ctxt->id);
delete appid2ctxt[ctxt->id];
appid2ctxt.erase(ctxt->id);
}
+
+static int
+is_application_running(afb_req_t request, std::string id)
+{
+ bool app_still_running = false;
+ struct json_object *jobj = nullptr;
+
+ HS_AfmMainProxy afm_proxy;
+
+ // note this is sync, so this might block if afm-system-daemon is down
+ afm_proxy.ps(request->api, &jobj);
+
+ if (jobj) {
+ const int len = json_object_array_length(jobj);
+ for (int i = 0; i < len; i++) {
+ struct json_object *aid;
+ struct json_object *item =
+ json_object_array_get_idx(jobj, i);
+
+ bool isFound = json_object_object_get_ex(item, "id", &aid);
+ if (isFound) {
+ const char *str_appid = json_object_get_string(aid);
+ if (strcmp(str_appid, id.c_str()) == 0) {
+ app_still_running = true;
+ break;
+ }
+ }
+ }
+ }
+
+ if (!app_still_running) {
+ // we don't remove it from the context list as we're haven't really subscribed,
+ // and we just need to remove it from client_list, which happens here. We also
+ // return AFB_REQ_NOT_STARTED_APPLICATION which will attempt to start it (again).
+ HS_ClientManager::instance()->removeClient(id);
+ return AFB_REQ_NOT_STARTED_APPLICATION;
+ }
+
+ return 0;
+}
+
+/**
+ * handle homescreen request
+ *
+ * #### Parameters
+ * - request : the request
+ * - verb : the verb name
+ * - appid : to which application
+ *
+ * #### Return
+ * 0 : success
+ * others : fail
+ *
+ */
+int HS_ClientManager::handleRequest(afb_req_t request, const char *verb, const char *appid)
+{
+ AFB_INFO("verb=[%s],appid=[%s].", verb, appid);
+ int ret = 0;
+ std::lock_guard<std::mutex> lock(this->mtx);
+ if(appid == nullptr) {
+ for(auto m : client_list) {
+ m.second->handleRequest(request, verb);
+ }
+ }
+ else {
+ std::string id(appid);
+ auto ip = client_list.find(id);
+ if(ip != client_list.end()) {
+ // for showWindow verb we need to verify if the app is (still)
+ // running, and return the appropriate value to attempt to start it
+ // again. This 'problem' is avoided if the application itself
+ // subscribes and with that process, to install a callback that
+ // automatically removes the application from client_list.
+ // That is exactly how "subscribe" verb is handled below.
+ if (strcasecmp(verb, "showWindow") == 0) {
+ ret = is_application_running(request, id);
+ if (ret == AFB_REQ_NOT_STARTED_APPLICATION) {
+ AFB_INFO("%s is not running. Will attempt to start it");
+ return ret;
+ }
+ }
+ AFB_INFO("%s found to be running. Forwarding request to the client");
+ ret = ip->second->handleRequest(request, verb);
+ }
+ else {
+ if(!strcasecmp(verb, "subscribe")) {
+ createClientCtxt(request, id);
+ HS_Client* client = addClient(request, id);
+ ret = client->handleRequest(request, "subscribe");
+ }
+ else {
+ AFB_NOTICE("not exist session");
+ ret = AFB_REQ_NOT_STARTED_APPLICATION;
+ }
+ }
+ }
+ return ret;
+}
+
+/**
+ * push event
+ *
+ * #### Parameters
+ * - event : the event want to push
+ * - param : the parameter contents of event
+ * - appid : the destination application's id
+ *
+ * #### Return
+ * 0 : success
+ * others : fail
+ *
+ */
+int HS_ClientManager::pushEvent(const char *event, struct json_object *param, std::string appid)
+{
+ if(event == nullptr) {
+ AFB_WARNING("event name is null.");
+ return -1;
+ }
+
+ std::lock_guard<std::mutex> lock(this->mtx);
+ if(appid.empty()) { // broadcast event to clients who subscribed this event
+ for(auto m : client_list) {
+ m.second->pushEvent(event, param);
+ }
+ }
+ else { // push event to specific client
+ auto ip = client_list.find(appid);
+ if(ip != client_list.end()) {
+ ip->second->pushEvent(event, param);
+ }
+ }
+
+ return 0;
+}
Code Review / apps / agl-service-homescreen.git / blobdiff