import * as plugins from './smartsocket.plugins.js'; // import classes import { SocketConnection } from './smartsocket.classes.socketconnection.js'; import { Smartsocket } from './smartsocket.classes.smartsocket.js'; import { SmartsocketClient } from './smartsocket.classes.smartsocketclient.js'; // export interfaces /** * interface of the contructor options of class SocketFunction */ export interface ISocketFunctionConstructorOptions< T extends plugins.typedrequestInterfaces.ITypedRequest > { funcName: T['method']; funcDef: TFuncDef; } /** * interface of the Socket Function call, in other words the object that routes a call to a function */ export interface ISocketFunctionCallDataRequest< T extends plugins.typedrequestInterfaces.ITypedRequest > { funcName: T['method']; funcDataArg: T['request']; } /** * interface of the Socket Function call, in other words the object that routes a call to a function */ export interface ISocketFunctionCallDataResponse< T extends plugins.typedrequestInterfaces.ITypedRequest > { funcName: T['method']; funcDataArg: T['response']; } /** * interface for function definition of SocketFunction */ export type TFuncDef = ( dataArg: T['request'], connectionArg: SocketConnection ) => PromiseLike; // export classes /** * class that respresents a function that can be transparently called using a SocketConnection */ export class SocketFunction { // STATIC public static getSocketFunctionByName( smartsocketRefArg: Smartsocket | SmartsocketClient, functionNameArg: string ): SocketFunction { return smartsocketRefArg.socketFunctions.findSync((socketFunctionArg) => { return socketFunctionArg.name === functionNameArg; }); } // INSTANCE public name: string; public funcDef: TFuncDef; /** * the constructor for SocketFunction */ constructor(optionsArg: ISocketFunctionConstructorOptions) { this.name = optionsArg.funcName; this.funcDef = optionsArg.funcDef; } /** * invokes the function of this SocketFunction */ public async invoke( dataArg: ISocketFunctionCallDataRequest, socketConnectionArg: SocketConnection ): Promise> { if (dataArg.funcName === this.name) { const funcResponseData: ISocketFunctionCallDataResponse = { funcName: this.name, funcDataArg: await this.funcDef(dataArg.funcDataArg, socketConnectionArg), }; return funcResponseData; } else { throw new Error("SocketFunction.name does not match the data argument's .name!"); } } }