[DeviceHome][VD] Provides webapis.sso APIs

This patch introduces 2 sso API.
 - webapis.sso.getGuid(): string;
 - webapis.sso.getOspAccessToken(clientId: string, secret: string,
       resolve: Function, reject?: Function): void;
   . reject is optional

When the 'OspAccessToken' event is emitted from WRT side to the main
thread, then, it propagates the event to the all workers. But the worker
has registered 'OspAccessToken' event can only take it.
Like as this manner, message listener can be expanded for another
purpose later.

Related chromium-efl patch:
https://review.tizen.org/gerrit/#/c/platform/framework/web/chromium-efl/+/282600/

Change-Id: I5c941e66e2729dbbeeafbbdb35a803134ed4924b
Signed-off-by: DongHyun Song <dh81.song@samsung.com>

diff --git a/wrt_app/service/device_api_router.ts b/wrt_app/service/device_api_router.ts
index 7754a63debf8a9cd5eb5a675462eadd37a40a44d..c00692e4d1d9a546c1fe590bec60755f86736029 100644 (file)
--- a/wrt_app/service/device_api_router.ts
+++ b/wrt_app/service/device_api_router.ts
@@ -1,5 +1,6 @@
 import { wrt } from '../browser/wrt';
 import * as ServiceMessage from '../common/service_message';
+import { parentPort } from 'worker_threads';
 
 export class DeviceAPIRouter {
   currentApplication: any;
@@ -20,6 +21,7 @@ export class DeviceAPIRouter {
   permissions: string[];
   pkgApiVersion: string;
   messagePortInfo: any;
+  messageListeners: any;
 
   constructor(id: string, isGlobal: boolean) {
     this.id = id;
@@ -30,6 +32,7 @@ export class DeviceAPIRouter {
     this.permissions = [];
     this.pkgApiVersion = '';
     this.messagePortInfo = {};
+    this.messageListeners = {};
 
     this.initWebapis();
     if (isGlobal) {
@@ -114,9 +117,11 @@ export class DeviceAPIRouter {
       isRunningApp: { writable: false, enumerable: true },
       postPlainNotification: { writable: false, enumerable: true },
     });
+
     this.initMDEWebapis();
     this.initEdgeWebapis();
     this.initProductWebapis();
+    this.initSSOWebapis();
   }
 
   initMDEWebapis() {
@@ -184,6 +189,34 @@ export class DeviceAPIRouter {
     }
   }
 
+  initSSOWebapis() {
+    if (wrt.tv) {
+      global.webapis.sso = {};
+      global.webapis.sso.getGuid = () => {
+        return wrt.tv?.getSSOGuid() || '';
+      }
+      global.webapis.sso.getOspAccessToken = (clientId: string, secret: string, resolve: Function, reject?: Function) => {
+        parentPort?.postMessage({ type: 'register-message', listener: 'OspAccessToken' });
+        this.messageListeners['OspAccessToken'] = { resolve, reject };
+        return wrt.tv?.getOspAccessToken(clientId, secret) || '';
+      }
+      Object.defineProperties(global.webapis.sso, {
+        getGuid: { writable: false, enumerable: true },
+        getOspAccessToken: { writable: false, enumerable: true },
+      });
+    }
+  }
+
+  notifyMessage(notification: any) {
+    if (!this.messageListeners[notification.listener])
+      return;
+    console.debug(`notification.listener : ${notification.listener}`);
+    if (notification.data && notification.data.indexOf('error_code') > -1)
+      this.messageListeners[notification.listener].reject?.(notification.data);
+    else
+      this.messageListeners[notification.listener].resolve(notification.data);
+  }
+
   initProductWebapis() {
     // for TV profile
     if (wrt.tv && !global.webapis.productinfo) {

diff --git a/wrt_app/service/main.ts b/wrt_app/service/main.ts
index 7552ea9140fce41ad474f9059bdebf939f606699..e1ff2430cf8d66bac4f6d3fef0e507c6b5db6aea 100755 (executable)
--- a/wrt_app/service/main.ts
+++ b/wrt_app/service/main.ts
@@ -20,19 +20,24 @@ import '../common/init';
 import { wrt } from '../browser/wrt';
 import * as ServiceManager from './service_manager';
 
-wrt.on('start-service', (event: any, internal_id: string) => {
-  console.debug(`start service app : ${internal_id}`);
-  ServiceManager.startService(internal_id, '');
+wrt.on('start-service', (event: any, internalId: string) => {
+  console.debug(`start service app : ${internalId}`);
+  ServiceManager.startService(internalId, '');
 });
 
-wrt.on('stop-service', (event: any, internal_id: string) => {
-  console.debug(`stop service app : ${internal_id}`);
-  ServiceManager.stopService(internal_id);
+wrt.on('stop-service', (event: any, internalId: string) => {
+  console.debug(`stop service app : ${internalId}`);
+  ServiceManager.stopService(internalId);
 });
 
-wrt.on('builtin-service', (event: any, internal_id: string, service_name: string) => {
-  console.debug(`id: ${internal_id}, service_name: ${service_name}`);
-  ServiceManager.handleBuiltinService(internal_id, service_name);
+wrt.on('builtin-service', (event: any, internalId: string, serviceName: string) => {
+  console.debug(`id: ${internalId}, serviceName: ${serviceName}`);
+  ServiceManager.handleBuiltinService(internalId, serviceName);
+});
+
+wrt.on('message', (event: any, type: string, data: string) => {
+  console.debug(`onMessage : ${type} - ${data}`);
+  ServiceManager.notifyMessage(type, data);
 });
 
 wrt.on('quit', (event: any) => {

diff --git a/wrt_app/service/service_manager.ts b/wrt_app/service/service_manager.ts
index de807eb8869d61776f91e88f9ff9446eb316c1eb..a91715b839e760c899b51db2c58d2ddd01455ad7 100644 (file)
--- a/wrt_app/service/service_manager.ts
+++ b/wrt_app/service/service_manager.ts
@@ -5,8 +5,14 @@ import * as XWalkExtension from '../common/wrt_xwalk_extension';
 interface WorkerMap {
   [id: string]: any;
 }
+
+interface MessageObserver {
+  [id: string]: Set<string>;
+}
+
 let workers: WorkerMap = {};
 let dyingWorkerQueue: WorkerMap = {};
+let messageObservers: MessageObserver = {};
 
 Object.defineProperty(global, 'serviceType', {
   value: wrt.getServiceModel(),
@@ -46,10 +52,21 @@ function createWorker(id: string, startService: string, filename: string) {
       filename
     }
   });
-  workers[id].on('message', (message: string) => {
-    if (message === 'will-terminate') {
-      dyingWorkerQueue[id] = message;
-      checkDyingWorker();
+  workers[id].on('message', (message: any) => {
+    switch (message.type) {
+      case 'will-terminate':
+        delete messageObservers[id];
+        dyingWorkerQueue[id] = 'will-terminate';
+        checkDyingWorker();
+        break;
+      case 'register-message':
+        if (!messageObservers[id]) {
+          messageObservers[id] = new Set();
+        }
+        messageObservers[id].add(message.listener);
+        break;
+      default:
+        break;
     }
   });
   workers[id].on('exit', (code: number) => {
@@ -116,4 +133,16 @@ export function handleBuiltinService(serviceId: string, serviceName: string) {
     let startService = `${__dirname}/../service/builtins/${serviceName}.js`;
     createWorker(serviceId, startService, '');
   }
+}
+
+export function notifyMessage(listener: string, data: string) {
+  for (const id in messageObservers) {
+    if (messageObservers[id].has(listener)) {
+      console.debug(`notify message - ${listener}`);
+      if (workers[id]) {
+        const notification = { listener, data };
+        workers[id].postMessage({ type: 'notify-message', notification });
+      }
+    }
+  }
 }
\ No newline at end of file

diff --git a/wrt_app/service/service_runner.ts b/wrt_app/service/service_runner.ts
index 5f524c697b4bb70b991cdec07803a6f22f18fb0c..de15a91a8c094b2671cde37a02c8ac0fcaa644b7 100644 (file)
--- a/wrt_app/service/service_runner.ts
+++ b/wrt_app/service/service_runner.ts
@@ -54,6 +54,7 @@ let requestStopService = (id: string) => {
 let app: any = null;
 let dummyTimer: any;
 let periodLauncherAlive = 40; // 4s
+let deviceApiRouter: any = null;
 
 let checkLauncherAlive = (id: string) => {
   periodLauncherAlive--;
@@ -88,7 +89,7 @@ export function start(id: string, filename: string) {
   });
 
   console.debug(`serviceType : ${global['serviceType']}`)
-  new DeviceAPIRouter(id, isGlobalService());
+  deviceApiRouter = new DeviceAPIRouter(id, isGlobalService());
   printAppControlData(id);
   ServiceMessage.initConsoleMessageNotification(id);
 
@@ -157,15 +158,23 @@ function run() {
 
   parentPort?.on('message', (message) => {
     console.debug(`Received message type : ${message.type}`);
-    if (message.type === 'wake') {
-      app?.onRequest();
-    } else if (message.type === 'stop') {
-      stop(id);
-      setTimeout(() => {
-        XWalkExtension.cleanup();
-        parentPort?.postMessage("will-terminate");
-        parentPort?.close();
-      }, message.delay);
+    switch (message.type) {
+      case 'wake':
+        app?.onRequest();
+        break;
+      case 'stop':
+        stop(id);
+        setTimeout(() => {
+          XWalkExtension.cleanup();
+          parentPort?.postMessage({ type : 'will-terminate' });
+          parentPort?.close();
+        }, message.delay);
+        break;
+      case 'notify-message':
+        deviceApiRouter?.notifyMessage(message.notification);
+        break;
+      default:
+        break;
     }
   });
 }