feat: coded action app event service

Author: Sandeepan-Ghosh-0312

src/models/action-center/tasks.types.ts

@@ -244,3 +244,47 @@ export type TaskGetByIdOptions = BaseOptions
  * Options for getting users with task permissions
  */
 export type TaskGetUsersOptions = RequestOptions & PaginationOptions;
+
+export enum ActionCenterEventNames {
+  INIT = 'init',
+  COMPLETE = 'complete',
+  DATACHANGED = 'dataChanged',
+  LOADAPP = 'loadApp',
+  ERROR = 'error',
+  TOKENREFRESHED = 'tokenRefreshed',
+  LANGUAGECHANGED = 'languageChanged',
+  THEMECHANGED = 'themeChanged',
+}
+
+enum Theme {
+    autoTheme = 'autoTheme',
+    light = 'light',
+    dark = 'dark',
+    lighthc = 'light-hc',
+    darkhc = 'dark-hc',
+}
+
+export type ActionCenterData = {
+  taskId: number,
+  title: string,
+  status: TaskStatus,
+  isReadOnly: boolean,
+  data: any,
+  action: string,
+  organizationUnitId: number,
+  organizationUnitFullyQualifiedName: string,
+  baseUrl: string,
+  orgName: string,
+  tenantName: string,
+  token: string,
+  language: string,
+  theme: Theme,
+  newToken: string,
+  newLanguage: string,
+  newTheme: string,
+}
+
+export type ActionCenterEventResponsePayload = {
+  eventType: ActionCenterEventNames,
+  content: ActionCenterData,
+}

src/services/action-center/codedActionEventsService.ts

@@ -0,0 +1,72 @@
+import { ActionCenterData, ActionCenterEventResponsePayload, ActionCenterEventNames } from '../../models/action-center/tasks.types';
+
+export class TaskEventsService {
+  private messageListener: ((event: MessageEvent<ActionCenterEventResponsePayload>) => void) | null = null;
+  private parentOrigin = new URLSearchParams(window.location.search).get('basedomain');
+  private subscribedEvents = [ActionCenterEventNames.LOADAPP, ActionCenterEventNames.TOKENREFRESHED, ActionCenterEventNames.LANGUAGECHANGED, ActionCenterEventNames.THEMECHANGED];
+
+  initializeInActionCenter(): void {
+    this.sendMessageToParent(ActionCenterEventNames.INIT);
+  }
+
+  dataChanged(data: any): void {
+    this.sendMessageToParent(ActionCenterEventNames.DATACHANGED, data);
+  }
+
+  completeTask(actionTaken: string, data: any): void {
+    const content = {
+      data: data,
+      action: actionTaken,
+    };
+    this.sendMessageToParent(ActionCenterEventNames.COMPLETE, content);
+  }
+
+  getTaskDetailsFromActionCenter(callback: (data: ActionCenterData) => void): void {
+    if (this.isValidOrigin(this.parentOrigin) && this.messageListener === null) {
+      this.messageListener = (event: MessageEvent<ActionCenterEventResponsePayload>) => this.actionCenterEventCallback(event, callback);
+      window.addEventListener('message', this.messageListener);
+    }
+  }
+
+  cleanup(): void {
+    if (this.messageListener) {
+      window.removeEventListener('message', this.messageListener);
+      this.messageListener = null;
+    }
+  }
+
+  private sendMessageToParent(eventType: string, content?: any): void {
+    if (window.parent && this.isValidOrigin(this.parentOrigin)) {
+      try {
+        window.parent.postMessage(
+          { eventType, content },
+          this.parentOrigin!,
+        );
+      } catch (error) {
+        window.parent.postMessage(
+          {
+            eventType: ActionCenterEventNames.ERROR,
+            content: {
+              errorData: error,
+            }
+          },
+          this.parentOrigin!
+        );
+      }
+    }
+  }
+
+  private isValidOrigin(origin: string | null): boolean {
+    if (origin && (origin.endsWith('.uipath.com') || origin === 'http://localhost:4202')) {
+      return true;
+    }
+
+    return false;
+  }
+
+  private actionCenterEventCallback(event: MessageEvent<ActionCenterEventResponsePayload>, callback: (data: ActionCenterData) => void): void {
+    if (event.origin === this.parentOrigin && this.subscribedEvents.includes(event.data?.eventType)) {
+      callback(event.data?.content);
+    }
+  }
+}

src/uipath.ts

@@ -18,6 +18,7 @@ import { UiPathSDKConfig, hasOAuthConfig, hasSecretConfig } from './core/config/
 import { validateConfig, normalizeBaseUrl } from './core/config/config-utils';
 import { TokenManager } from './core/auth/token-manager';
 import { telemetryClient, trackEvent } from './core/telemetry';
+import { TaskEventsService } from './services/action-center/codedActionEventsService';
 
 type ServiceConstructor<T> = new (config: UiPathConfig, context: ExecutionContext, tokenManager: TokenManager) => T;
 
@@ -151,6 +152,10 @@ export class UiPath {
     return this.authService.getToken();
   }
 
+  public updateToken(token: string) {
+    return this.authService.authenticateWithSecret(token);
+  }
+
   private getService<T>(serviceConstructor: ServiceConstructor<T>): T {
     const serviceName = serviceConstructor.name;
     if (!this._services.has(serviceName)) {
@@ -205,6 +210,13 @@ export class UiPath {
     return this.getService(TaskService);
   }
 
+  /**
+   * Access to Task Events service
+   */
+  get taskEvents(): TaskEventsService {
+    return this.getService(TaskEventsService);
+  }
+
   /**
    * Access to Orchestrator Processes service
    */