Add API package

ts/classes.smarthomeexchangeapiclient.ts

@@ -0,0 +1,81 @@
+import * as plugins from './plugins.js';
+
+export interface IShxApiClientOptions {
+  hubUrl?: string;
+  useSocket?: boolean;
+}
+
+export class SmarthomeExchangeApiClient {
+  private hubUrl: string;
+  public typedrouter = new plugins.typedrequest.TypedRouter();
+  public typedsocketClient?: plugins.typedsocket.TypedSocket;
+
+  constructor(optionsArg: IShxApiClientOptions = {}) {
+    this.hubUrl = (optionsArg.hubUrl || 'http://localhost:8080').replace(/\/$/, '');
+  }
+
+  private get httpEndpoint() {
+    return `${this.hubUrl}/typedrequest`;
+  }
+
+  private createWsRequest<T extends plugins.typedRequestInterfaces.ITypedRequest>(operationArg: string) {
+    return this.typedsocketClient?.createTypedRequest<T>(operationArg);
+  }
+
+  private createHttpRequest<T extends plugins.typedRequestInterfaces.ITypedRequest>(operationArg: string) {
+    return new plugins.typedrequest.TypedRequest<T>(this.httpEndpoint, operationArg);
+  }
+
+  private async fire<T extends plugins.typedRequestInterfaces.ITypedRequest>(
+    operationArg: string,
+    payloadArg: T['request']
+  ): Promise<T['response']> {
+    const wsRequest = this.createWsRequest<T>(operationArg);
+    if (wsRequest) {
+      return wsRequest.fire(payloadArg);
+    }
+    return this.createHttpRequest<T>(operationArg).fire(payloadArg);
+  }
+
+  public async start() {
+    this.typedsocketClient = await plugins.typedsocket.TypedSocket.createClient(
+      this.typedrouter,
+      this.hubUrl
+    );
+  }
+
+  public async stop() {
+    await this.typedsocketClient?.stop();
+    this.typedsocketClient = undefined;
+  }
+
+  public async listDevices(requestArg: plugins.shxInterfaces.request.IReq_ListDevices['request'] = {}) {
+    return this.fire<plugins.shxInterfaces.request.IReq_ListDevices>('listDevices', requestArg);
+  }
+
+  public async listAgents() {
+    return this.fire<plugins.shxInterfaces.request.IReq_ListAgents>('listAgents', {});
+  }
+
+  public async listTools(requestArg: plugins.shxInterfaces.request.IReq_ListTools['request'] = {}) {
+    return this.fire<plugins.shxInterfaces.request.IReq_ListTools>('listTools', requestArg);
+  }
+
+  public async getHomeSnapshot() {
+    return this.fire<plugins.shxInterfaces.request.IReq_GetHomeSnapshot>('getHomeSnapshot', {});
+  }
+
+  public async executeToolPlan(planArg: plugins.shxInterfaces.data.IToolPlan) {
+    return this.fire<plugins.shxInterfaces.request.IReq_ExecuteToolPlan>('executeToolPlan', {
+      plan: planArg,
+    });
+  }
+
+  public async listApprovals(requestArg: plugins.shxInterfaces.request.IReq_ListApprovals['request'] = {}) {
+    return this.fire<plugins.shxInterfaces.request.IReq_ListApprovals>('listApprovals', requestArg);
+  }
+
+  public async submitApproval(requestArg: plugins.shxInterfaces.request.IReq_SubmitApproval['request']) {
+    return this.fire<plugins.shxInterfaces.request.IReq_SubmitApproval>('submitApproval', requestArg);
+  }
+}

ts/index.ts

@@ -0,0 +1 @@
+export * from './classes.smarthomeexchangeapiclient.js';

ts/plugins.ts

@@ -0,0 +1,16 @@
+// Project scope
+import * as shxInterfaces from '@smarthome.exchange/interfaces';
+
+export { shxInterfaces };
+
+// @api.global scope
+import * as typedrequest from '@api.global/typedrequest';
+import * as typedRequestInterfaces from '@api.global/typedrequest-interfaces';
+import * as typedsocket from '@api.global/typedsocket';
+
+export { typedrequest, typedRequestInterfaces, typedsocket };
+
+// @push.rocks scope
+import * as smartpromise from '@push.rocks/smartpromise';
+
+export { smartpromise };