94 lines
2.7 KiB
TypeScript
94 lines
2.7 KiB
TypeScript
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 {
|
|
console.log(smartsocketRefArg.socketFunctions);
|
|
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);
|
|
}
|
|
}
|