smartsocket/ts/smartsocket.classes.socketfunction.ts

import * as plugins from './smartsocket.plugins';

// import classes
import { Objectmap } from '@pushrocks/lik';
import { SocketRole } from './smartsocket.classes.socketrole';
import { SocketConnection } from './smartsocket.classes.socketconnection';
import { Smartsocket } from './smartsocket.classes.smartsocket';
import { SmartsocketClient } from './smartsocket.classes.smartsocketclient';

// export interfaces

/**
 * interface of the contructor options of class SocketFunction
 */
export interface ISocketFunctionConstructorOptions {
  funcName: string;
  funcDef: TFuncDef;
  allowedRoles: SocketRole[]; // all roles that are allowed to execute a SocketFunction
}

/**
 * interface of the Socket Function call, in other words the object that routes a call to a function
 */
export interface ISocketFunctionCall {
  funcName: string;
  funcDataArg: any;
}

/**
 * interface for function definition of SocketFunction
 */
export type TFuncDef = (dataArg: any, connectionArg: SocketConnection) => PromiseLike<any>;

// 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.find(socketFunctionArg => {
      return socketFunctionArg.name === functionNameArg;
    });
  }

  // INSTANCE
  public name: string;
  public funcDef: TFuncDef;
  public roles: SocketRole[];

  /**
   * the constructor for SocketFunction
   */
  constructor(optionsArg: ISocketFunctionConstructorOptions) {
    this.name = optionsArg.funcName;
    this.funcDef = optionsArg.funcDef;
    this.roles = optionsArg.allowedRoles;
    for (const socketRoleArg of this.roles) {
      this._notifyRole(socketRoleArg);
    }
  }

  /**
   * invokes the function of this SocketFunction
   */
  public invoke(dataArg: ISocketFunctionCall, socketConnectionArg: SocketConnection): Promise<any> {
    const done = plugins.smartpromise.defer();
    if (dataArg.funcName === this.name) {
      this.funcDef(dataArg.funcDataArg, socketConnectionArg).then((resultData: any) => {
        const funcResponseData: ISocketFunctionCall = {
          funcName: this.name,
          funcDataArg: resultData
        };
        done.resolve(funcResponseData);
      });
    } else {
      throw new Error("SocketFunction.name does not match the data argument's .name!");
    }
    return done.promise;
  }

  /**
   * notifies a role about access to this SocketFunction
   */
  private _notifyRole(socketRoleArg: SocketRole) {
    socketRoleArg.addSocketFunction(this);
  }
}