2.0.2

fix(core): update
2.0.1
2022-03-24 20:17:04 +01:00 · 2022-03-24 20:17:04 +01:00 · 2022-03-24 12:52:29 +01:00 · 2022-03-24 12:52:28 +01:00 · 2022-03-14 22:40:56 +01:00 · 2022-03-14 22:40:55 +01:00
51 changed files with 15434 additions and 9758 deletions
--- a/.gitlab-ci.yml
+++ b/.gitlab-ci.yml
@ -12,6 +12,9 @@ stages:
  - release
  - metadata

+before_script:
+  - npm install -g @shipzone/npmci
+
 # ====================
 # security stage
 # ====================
@ -36,6 +39,7 @@ auditProductionDependencies:
    - npmci command npm audit --audit-level=high --only=prod --production
  tags:
    - docker
+  allow_failure: true

 auditDevDependencies:
  image: registry.gitlab.com/hosttoday/ht-docker-node:npmci
--- a/.snyk
+++ b/.snyk
@ -1,13 +0,0 @@
-# Snyk (https://snyk.io) policy file, patches or ignores known vulnerabilities.
-version: v1.13.5
-# ignores vulnerabilities until expiry date; change duration by modifying expiry date
-ignore:
-  SNYK-JS-JSYAML-173999:
-    - '@pushrocks/smartexpress > @pushrocks/smartfile > js-yaml':
-        reason: None given
-        expires: '2019-05-24T15:16:11.291Z'
-  SNYK-JS-JSYAML-174129:
-    - '@pushrocks/smartexpress > @pushrocks/smartfile > js-yaml':
-        reason: None given
-        expires: '2019-05-24T15:16:11.291Z'
-patch: {}
--- a/.vscode/launch.json
+++ b/.vscode/launch.json
@ -2,28 +2,10 @@
  "version": "0.2.0",
  "configurations": [
    {
-      "name": "current file",
-      "type": "node",
+      "command": "npm test",
+      "name": "Run npm test",
      "request": "launch",
-      "args": [
-        "${relativeFile}"
-      ],
-      "runtimeArgs": ["-r", "@gitzone/tsrun"],
-      "cwd": "${workspaceRoot}",
-      "protocol": "inspector",
-      "internalConsoleOptions": "openOnSessionStart"
-    },
-    {
-      "name": "test.ts",
-      "type": "node",
-      "request": "launch",
-      "args": [
-        "test/test.ts"
-      ],
-      "runtimeArgs": ["-r", "@gitzone/tsrun"],
-      "cwd": "${workspaceRoot}",
-      "protocol": "inspector",
-      "internalConsoleOptions": "openOnSessionStart"
+      "type": "node-terminal"
    }
  ]
 }
--- a/.vscode/settings.json
+++ b/.vscode/settings.json
@ -22,5 +22,6 @@
        }
      }
    }
-  ]
+  ],
+  "typescript.tsdk": "node_modules/typescript/lib"
 }
--- a/dist_ts/index.d.ts
+++ b/dist_ts/index.d.ts
@ -1,5 +0,0 @@
-export * from './smartsocket.classes.smartsocket';
-export * from './smartsocket.classes.smartsocketclient';
-export * from './smartsocket.classes.socketfunction';
-export * from './smartsocket.classes.socketrole';
-export * from './smartsocket.classes.socketconnection';
--- a/dist_ts/index.js
+++ b/dist_ts/index.js
@ -1,20 +0,0 @@
-"use strict";
-var __createBinding = (this && this.__createBinding) || (Object.create ? (function(o, m, k, k2) {
-    if (k2 === undefined) k2 = k;
-    Object.defineProperty(o, k2, { enumerable: true, get: function() { return m[k]; } });
-}) : (function(o, m, k, k2) {
-    if (k2 === undefined) k2 = k;
-    o[k2] = m[k];
-}));
-var __exportStar = (this && this.__exportStar) || function(m, exports) {
-    for (var p in m) if (p !== "default" && !exports.hasOwnProperty(p)) __createBinding(exports, m, p);
-};
-Object.defineProperty(exports, "__esModule", { value: true });
-// export main classes
-__exportStar(require("./smartsocket.classes.smartsocket"), exports);
-__exportStar(require("./smartsocket.classes.smartsocketclient"), exports);
-// export further classes and objects
-__exportStar(require("./smartsocket.classes.socketfunction"), exports);
-__exportStar(require("./smartsocket.classes.socketrole"), exports);
-__exportStar(require("./smartsocket.classes.socketconnection"), exports);
-//# sourceMappingURL=data:application/json;base64,eyJ2ZXJzaW9uIjozLCJmaWxlIjoiaW5kZXguanMiLCJzb3VyY2VSb290IjoiIiwic291cmNlcyI6WyIuLi90cy9pbmRleC50cyJdLCJuYW1lcyI6W10sIm1hcHBpbmdzIjoiOzs7Ozs7Ozs7Ozs7QUFBQSxzQkFBc0I7QUFDdEIsb0VBQWtEO0FBQ2xELDBFQUF3RDtBQUV4RCxxQ0FBcUM7QUFDckMsdUVBQXFEO0FBQ3JELG1FQUFpRDtBQUNqRCx5RUFBdUQifQ==
--- a/dist_ts/interfaces/connection.d.ts
+++ b/dist_ts/interfaces/connection.d.ts
@ -1,4 +0,0 @@
-export interface IRequestAuthPayload {
-    serverShortId: string;
-}
-export declare type TConnectionStatus = 'new' | 'connecting' | 'connected' | 'disconnecting' | 'disconnected';
--- a/dist_ts/interfaces/connection.js
+++ b/dist_ts/interfaces/connection.js
@ -1,3 +0,0 @@
-"use strict";
-Object.defineProperty(exports, "__esModule", { value: true });
-//# sourceMappingURL=data:application/json;base64,eyJ2ZXJzaW9uIjozLCJmaWxlIjoiY29ubmVjdGlvbi5qcyIsInNvdXJjZVJvb3QiOiIiLCJzb3VyY2VzIjpbIi4uLy4uL3RzL2ludGVyZmFjZXMvY29ubmVjdGlvbi50cyJdLCJuYW1lcyI6W10sIm1hcHBpbmdzIjoiIn0=
--- a/dist_ts/interfaces/index.d.ts
+++ b/dist_ts/interfaces/index.d.ts
@ -1 +0,0 @@
-export * from './connection';
--- a/dist_ts/interfaces/index.js
+++ b/dist_ts/interfaces/index.js
@ -1,14 +0,0 @@
-"use strict";
-var __createBinding = (this && this.__createBinding) || (Object.create ? (function(o, m, k, k2) {
-    if (k2 === undefined) k2 = k;
-    Object.defineProperty(o, k2, { enumerable: true, get: function() { return m[k]; } });
-}) : (function(o, m, k, k2) {
-    if (k2 === undefined) k2 = k;
-    o[k2] = m[k];
-}));
-var __exportStar = (this && this.__exportStar) || function(m, exports) {
-    for (var p in m) if (p !== "default" && !exports.hasOwnProperty(p)) __createBinding(exports, m, p);
-};
-Object.defineProperty(exports, "__esModule", { value: true });
-__exportStar(require("./connection"), exports);
-//# sourceMappingURL=data:application/json;base64,eyJ2ZXJzaW9uIjozLCJmaWxlIjoiaW5kZXguanMiLCJzb3VyY2VSb290IjoiIiwic291cmNlcyI6WyIuLi8uLi90cy9pbnRlcmZhY2VzL2luZGV4LnRzIl0sIm5hbWVzIjpbXSwibWFwcGluZ3MiOiI7Ozs7Ozs7Ozs7OztBQUFBLCtDQUE2QiJ9
--- a/dist_ts/smartsocket.classes.smartsocket.d.ts
+++ b/dist_ts/smartsocket.classes.smartsocket.d.ts
@ -1,45 +0,0 @@
-import * as plugins from './smartsocket.plugins';
-import { SocketConnection } from './smartsocket.classes.socketconnection';
-import { SocketFunction } from './smartsocket.classes.socketfunction';
-import { SocketRequest } from './smartsocket.classes.socketrequest';
-import { SocketRole } from './smartsocket.classes.socketrole';
-import * as SocketIO from 'socket.io';
-export interface ISmartsocketConstructorOptions {
-    port?: number;
-}
-export declare class Smartsocket {
-    /**
-     * a unique id to detect server restarts
-     */
-    shortId: string;
-    options: ISmartsocketConstructorOptions;
-    io: SocketIO.Server;
-    socketConnections: plugins.lik.ObjectMap<SocketConnection>;
-    socketRoles: plugins.lik.ObjectMap<SocketRole>;
-    socketFunctions: plugins.lik.ObjectMap<SocketFunction<any>>;
-    socketRequests: plugins.lik.ObjectMap<SocketRequest<any>>;
-    private socketServer;
-    constructor(optionsArg: ISmartsocketConstructorOptions);
-    setExternalServer(serverType: 'smartexpress', serverArg: any): Promise<void>;
-    /**
-     * starts smartsocket
-     */
-    start(): Promise<void>;
-    /**
-     * stops smartsocket
-     */
-    stop(): Promise<void>;
-    /**
-     * allows call to specific client.
-     */
-    clientCall<T extends plugins.typedrequestInterfaces.ITypedRequest>(functionNameArg: T['method'], dataArg: T['request'], targetSocketConnectionArg: SocketConnection): Promise<T['response']>;
-    /**
-     * adds socketRoles
-     */
-    addSocketRoles(socketRolesArray: SocketRole[]): void;
-    addSocketFunction(socketFunction: SocketFunction<any>): void;
-    /**
-     * the standard handler for new socket connections
-     */
-    private _handleSocketConnection;
-}
--- a/dist_ts/smartsocket.classes.smartsocket.js
+++ b/dist_ts/smartsocket.classes.smartsocket.js
@ -1,119 +0,0 @@
-"use strict";
-var __createBinding = (this && this.__createBinding) || (Object.create ? (function(o, m, k, k2) {
-    if (k2 === undefined) k2 = k;
-    Object.defineProperty(o, k2, { enumerable: true, get: function() { return m[k]; } });
-}) : (function(o, m, k, k2) {
-    if (k2 === undefined) k2 = k;
-    o[k2] = m[k];
-}));
-var __setModuleDefault = (this && this.__setModuleDefault) || (Object.create ? (function(o, v) {
-    Object.defineProperty(o, "default", { enumerable: true, value: v });
-}) : function(o, v) {
-    o["default"] = v;
-});
-var __importStar = (this && this.__importStar) || function (mod) {
-    if (mod && mod.__esModule) return mod;
-    var result = {};
-    if (mod != null) for (var k in mod) if (k !== "default" && Object.hasOwnProperty.call(mod, k)) __createBinding(result, mod, k);
-    __setModuleDefault(result, mod);
-    return result;
-};
-Object.defineProperty(exports, "__esModule", { value: true });
-exports.Smartsocket = void 0;
-const plugins = __importStar(require("./smartsocket.plugins"));
-// classes
-const smartsocket_classes_socketconnection_1 = require("./smartsocket.classes.socketconnection");
-const smartsocket_classes_socketrequest_1 = require("./smartsocket.classes.socketrequest");
-const smartsocket_classes_socketserver_1 = require("./smartsocket.classes.socketserver");
-const smartsocket_logging_1 = require("./smartsocket.logging");
-class Smartsocket {
-    constructor(optionsArg) {
-        /**
-         * a unique id to detect server restarts
-         */
-        this.shortId = plugins.smartunique.shortId();
-        this.socketConnections = new plugins.lik.ObjectMap();
-        this.socketRoles = new plugins.lik.ObjectMap();
-        this.socketFunctions = new plugins.lik.ObjectMap();
-        this.socketRequests = new plugins.lik.ObjectMap();
-        this.socketServer = new smartsocket_classes_socketserver_1.SocketServer(this);
-        this.options = optionsArg;
-    }
-    // tslint:disable-next-line:member-ordering
-    async setExternalServer(serverType, serverArg) {
-        await this.socketServer.setExternalServer(serverType, serverArg);
-    }
-    /**
-     * starts smartsocket
-     */
-    async start() {
-        this.io = plugins.socketIo(this.socketServer.getServerForSocketIo());
-        await this.socketServer.start();
-        this.io.on('connection', socketArg => {
-            this._handleSocketConnection(socketArg);
-        });
-    }
-    /**
-     * stops smartsocket
-     */
-    async stop() {
-        await plugins.smartdelay.delayFor(1000);
-        this.socketConnections.forEach((socketObjectArg) => {
-            smartsocket_logging_1.logger.log('info', `disconnect socket with >>alias ${socketObjectArg.alias}`);
-            socketObjectArg.socket.disconnect();
-        });
-        this.socketConnections.wipe();
-        this.io.close();
-        // stop the corresponging server
-        this.socketServer.stop();
-    }
-    // communication
-    /**
-     * allows call to specific client.
-     */
-    async clientCall(functionNameArg, dataArg, targetSocketConnectionArg) {
-        const socketRequest = new smartsocket_classes_socketrequest_1.SocketRequest(this, {
-            funcCallData: {
-                funcDataArg: dataArg,
-                funcName: functionNameArg
-            },
-            originSocketConnection: targetSocketConnectionArg,
-            shortId: plugins.smartunique.shortId(),
-            side: 'requesting'
-        });
-        const response = await socketRequest.dispatch();
-        const result = response.funcDataArg;
-        return result;
-    }
-    /**
-     * adds socketRoles
-     */
-    addSocketRoles(socketRolesArray) {
-        for (const socketRole of socketRolesArray) {
-            this.socketRoles.add(socketRole);
-        }
-        return;
-    }
-    addSocketFunction(socketFunction) {
-        this.socketFunctions.add(socketFunction);
-    }
-    /**
-     * the standard handler for new socket connections
-     */
-    async _handleSocketConnection(socketArg) {
-        const socketConnection = new smartsocket_classes_socketconnection_1.SocketConnection({
-            alias: undefined,
-            authenticated: false,
-            role: undefined,
-            side: 'server',
-            smartsocketHost: this,
-            socket: socketArg
-        });
-        smartsocket_logging_1.logger.log('info', 'Socket connected. Trying to authenticate...');
-        this.socketConnections.add(socketConnection);
-        await socketConnection.authenticate();
-        await socketConnection.listenToFunctionRequests();
-    }
-}
-exports.Smartsocket = Smartsocket;
-//# sourceMappingURL=data:application/json;base64,eyJ2ZXJzaW9uIjozLCJmaWxlIjoic21hcnRzb2NrZXQuY2xhc3Nlcy5zbWFydHNvY2tldC5qcyIsInNvdXJjZVJvb3QiOiIiLCJzb3VyY2VzIjpbIi4uL3RzL3NtYXJ0c29ja2V0LmNsYXNzZXMuc21hcnRzb2NrZXQudHMiXSwibmFtZXMiOltdLCJtYXBwaW5ncyI6Ijs7Ozs7Ozs7Ozs7Ozs7Ozs7Ozs7OztBQUFBLCtEQUFpRDtBQUVqRCxVQUFVO0FBQ1YsaUdBQTBFO0FBRTFFLDJGQUFvRTtBQUVwRSx5RkFBa0U7QUFJbEUsK0RBQStDO0FBTS9DLE1BQWEsV0FBVztJQWN0QixZQUFZLFVBQTBDO1FBYnREOztXQUVHO1FBQ0ksWUFBTyxHQUFHLE9BQU8sQ0FBQyxXQUFXLENBQUMsT0FBTyxFQUFFLENBQUM7UUFHeEMsc0JBQWlCLEdBQUcsSUFBSSxPQUFPLENBQUMsR0FBRyxDQUFDLFNBQVMsRUFBb0IsQ0FBQztRQUNsRSxnQkFBVyxHQUFHLElBQUksT0FBTyxDQUFDLEdBQUcsQ0FBQyxTQUFTLEVBQWMsQ0FBQztRQUN0RCxvQkFBZSxHQUFHLElBQUksT0FBTyxDQUFDLEdBQUcsQ0FBQyxTQUFTLEVBQXVCLENBQUM7UUFDbkUsbUJBQWMsR0FBRyxJQUFJLE9BQU8sQ0FBQyxHQUFHLENBQUMsU0FBUyxFQUFzQixDQUFDO1FBRWhFLGlCQUFZLEdBQUcsSUFBSSwrQ0FBWSxDQUFDLElBQUksQ0FBQyxDQUFDO1FBRzVDLElBQUksQ0FBQyxPQUFPLEdBQUcsVUFBVSxDQUFDO0lBQzVCLENBQUM7SUFFRCwyQ0FBMkM7SUFDcEMsS0FBSyxDQUFDLGlCQUFpQixDQUFDLFVBQTBCLEVBQUUsU0FBYztRQUN2RSxNQUFNLElBQUksQ0FBQyxZQUFZLENBQUMsaUJBQWlCLENBQUMsVUFBVSxFQUFFLFNBQVMsQ0FBQyxDQUFDO0lBQ25FLENBQUM7SUFFRDs7T0FFRztJQUNJLEtBQUssQ0FBQyxLQUFLO1FBQ2hCLElBQUksQ0FBQyxFQUFFLEdBQUcsT0FBTyxDQUFDLFFBQVEsQ0FBQyxJQUFJLENBQUMsWUFBWSxDQUFDLG9CQUFvQixFQUFFLENBQUMsQ0FBQztRQUNyRSxNQUFNLElBQUksQ0FBQyxZQUFZLENBQUMsS0FBSyxFQUFFLENBQUM7UUFDaEMsSUFBSSxDQUFDLEVBQUUsQ0FBQyxFQUFFLENBQUMsWUFBWSxFQUFFLFNBQVMsQ0FBQyxFQUFFO1lBQ25DLElBQUksQ0FBQyx1QkFBdUIsQ0FBQyxTQUFTLENBQUMsQ0FBQztRQUMxQyxDQUFDLENBQUMsQ0FBQztJQUNMLENBQUM7SUFFRDs7T0FFRztJQUNJLEtBQUssQ0FBQyxJQUFJO1FBQ2YsTUFBTSxPQUFPLENBQUMsVUFBVSxDQUFDLFFBQVEsQ0FBQyxJQUFJLENBQUMsQ0FBQztRQUN4QyxJQUFJLENBQUMsaUJBQWlCLENBQUMsT0FBTyxDQUFDLENBQUMsZUFBaUMsRUFBRSxFQUFFO1lBQ25FLDRCQUFNLENBQUMsR0FBRyxDQUNSLE1BQU0sRUFDTixrQ0FBa0MsZUFBZSxDQUFDLEtBQUssRUFBRSxDQUMxRCxDQUFDO1lBQ0YsZUFBZSxDQUFDLE1BQU0sQ0FBQyxVQUFVLEVBQUUsQ0FBQztRQUN0QyxDQUFDLENBQUMsQ0FBQztRQUNILElBQUksQ0FBQyxpQkFBaUIsQ0FBQyxJQUFJLEVBQUUsQ0FBQztRQUM5QixJQUFJLENBQUMsRUFBRSxDQUFDLEtBQUssRUFBRSxDQUFDO1FBRWhCLGdDQUFnQztRQUNoQyxJQUFJLENBQUMsWUFBWSxDQUFDLElBQUksRUFBRSxDQUFDO0lBQzNCLENBQUM7SUFFRCxnQkFBZ0I7SUFFaEI7O09BRUc7SUFDSSxLQUFLLENBQUMsVUFBVSxDQUNyQixlQUE0QixFQUM1QixPQUFxQixFQUNyQix5QkFBMkM7UUFFM0MsTUFBTSxhQUFhLEdBQUcsSUFBSSxpREFBYSxDQUFJLElBQUksRUFBRTtZQUMvQyxZQUFZLEVBQUU7Z0JBQ1osV0FBVyxFQUFFLE9BQU87Z0JBQ3BCLFFBQVEsRUFBRSxlQUFlO2FBQzFCO1lBQ0Qsc0JBQXNCLEVBQUUseUJBQXlCO1lBQ2pELE9BQU8sRUFBRSxPQUFPLENBQUMsV0FBVyxDQUFDLE9BQU8sRUFBRTtZQUN0QyxJQUFJLEVBQUUsWUFBWTtTQUNuQixDQUFDLENBQUM7UUFDSCxNQUFNLFFBQVEsR0FBdUMsTUFBTSxhQUFhLENBQUMsUUFBUSxFQUFFLENBQUM7UUFDcEYsTUFBTSxNQUFNLEdBQUcsUUFBUSxDQUFDLFdBQVcsQ0FBQztRQUNwQyxPQUFPLE1BQU0sQ0FBQztJQUNoQixDQUFDO0lBRUQ7O09BRUc7SUFDSSxjQUFjLENBQUMsZ0JBQThCO1FBQ2xELEtBQUssTUFBTSxVQUFVLElBQUksZ0JBQWdCLEVBQUU7WUFDekMsSUFBSSxDQUFDLFdBQVcsQ0FBQyxHQUFHLENBQUMsVUFBVSxDQUFDLENBQUM7U0FDbEM7UUFDRCxPQUFPO0lBQ1QsQ0FBQztJQUVNLGlCQUFpQixDQUFDLGNBQW1DO1FBQzFELElBQUksQ0FBQyxlQUFlLENBQUMsR0FBRyxDQUFDLGNBQWMsQ0FBQyxDQUFDO0lBQzNDLENBQUM7SUFFRDs7T0FFRztJQUNLLEtBQUssQ0FBQyx1QkFBdUIsQ0FBQyxTQUFrQztRQUN0RSxNQUFNLGdCQUFnQixHQUFxQixJQUFJLHVEQUFnQixDQUFDO1lBQzlELEtBQUssRUFBRSxTQUFTO1lBQ2hCLGFBQWEsRUFBRSxLQUFLO1lBQ3BCLElBQUksRUFBRSxTQUFTO1lBQ2YsSUFBSSxFQUFFLFFBQVE7WUFDZCxlQUFlLEVBQUUsSUFBSTtZQUNyQixNQUFNLEVBQUUsU0FBUztTQUNsQixDQUFDLENBQUM7UUFDSCw0QkFBTSxDQUFDLEdBQUcsQ0FBQyxNQUFNLEVBQUUsNkNBQTZDLENBQUMsQ0FBQztRQUNsRSxJQUFJLENBQUMsaUJBQWlCLENBQUMsR0FBRyxDQUFDLGdCQUFnQixDQUFDLENBQUM7UUFDN0MsTUFBTSxnQkFBZ0IsQ0FBQyxZQUFZLEVBQUUsQ0FBQztRQUN0QyxNQUFNLGdCQUFnQixDQUFDLHdCQUF3QixFQUFFLENBQUM7SUFDcEQsQ0FBQztDQUNGO0FBNUdELGtDQTRHQyJ9
--- a/dist_ts/smartsocket.classes.smartsocketclient.d.ts
+++ b/dist_ts/smartsocket.classes.smartsocketclient.d.ts
@ -1,53 +0,0 @@
-import * as plugins from './smartsocket.plugins';
-import * as interfaces from './interfaces';
-import { SocketConnection } from './smartsocket.classes.socketconnection';
-import { SocketFunction } from './smartsocket.classes.socketfunction';
-import { SocketRequest } from './smartsocket.classes.socketrequest';
-import { SocketRole } from './smartsocket.classes.socketrole';
-/**
- * interface for class SmartsocketClient
- */
-export interface ISmartsocketClientOptions {
-    port: number;
-    url: string;
-    alias: string;
-    role: string;
-    password: string;
-    autoReconnect?: boolean;
-}
-export declare class SmartsocketClient {
-    shortId: string;
-    remoteShortId: string;
-    alias: string;
-    socketRole: SocketRole;
-    socketConnection: SocketConnection;
-    serverUrl: string;
-    serverPort: number;
-    autoReconnect: boolean;
-    eventSubject: plugins.smartrx.rxjs.Subject<interfaces.TConnectionStatus>;
-    eventStatus: interfaces.TConnectionStatus;
-    socketFunctions: plugins.lik.ObjectMap<SocketFunction<any>>;
-    socketRequests: plugins.lik.ObjectMap<SocketRequest<any>>;
-    socketRoles: plugins.lik.ObjectMap<SocketRole>;
-    constructor(optionsArg: ISmartsocketClientOptions);
-    addSocketFunction(socketFunction: SocketFunction<any>): void;
-    /**
-     * connect the client to the server
-     */
-    connect(): Promise<unknown>;
-    /**
-     * disconnect from the server
-     */
-    disconnect(): Promise<void>;
-    /**
-     * try a reconnection
-     */
-    tryDebouncedReconnect(): Promise<void>;
-    /**
-     * dispatches a server call
-     * @param functionNameArg
-     * @param dataArg
-     */
-    serverCall<T extends plugins.typedrequestInterfaces.ITypedRequest>(functionNameArg: T['method'], dataArg: T['request']): Promise<T['response']>;
-    private updateStatus;
-}
--- a/dist_ts/smartsocket.classes.smartsocketclient.js
+++ b/dist_ts/smartsocket.classes.smartsocketclient.js
--- a/dist_ts/smartsocket.classes.socketconnection.d.ts
+++ b/dist_ts/smartsocket.classes.socketconnection.d.ts
@ -1,55 +0,0 @@
-/// <reference types="socket.io-client" />
-import * as plugins from './smartsocket.plugins';
-import * as interfaces from './interfaces';
-import { Smartsocket } from './smartsocket.classes.smartsocket';
-import { SocketRole } from './smartsocket.classes.socketrole';
-import * as SocketIO from 'socket.io';
-import { SmartsocketClient } from './smartsocket.classes.smartsocketclient';
-/**
- * defines is a SocketConnection is server or client side. Important for mesh setups.
- */
-export declare type TSocketConnectionSide = 'server' | 'client';
-/**
- * interface for constructor of class SocketConnection
- */
-export interface ISocketConnectionConstructorOptions {
-    alias: string;
-    authenticated: boolean;
-    role: SocketRole;
-    side: TSocketConnectionSide;
-    smartsocketHost: Smartsocket | SmartsocketClient;
-    socket: SocketIO.Socket | SocketIOClient.Socket;
-}
-/**
- * interface for authentication data
- */
-export interface ISocketConnectionAuthenticationObject {
-    role: 'coreflowContainer';
-    password: 'somePassword';
-    alias: 'coreflow1';
-}
-export declare let allSocketConnections: plugins.lik.ObjectMap<SocketConnection>;
-/**
- * class SocketConnection represents a websocket connection
- */
-export declare class SocketConnection {
-    alias: string;
-    side: TSocketConnectionSide;
-    authenticated: boolean;
-    role: SocketRole;
-    smartsocketRef: Smartsocket | SmartsocketClient;
-    socket: SocketIO.Socket | SocketIOClient.Socket;
-    eventSubject: plugins.smartrx.rxjs.Subject<interfaces.TConnectionStatus>;
-    eventStatus: interfaces.TConnectionStatus;
-    constructor(optionsArg: ISocketConnectionConstructorOptions);
-    /**
-     * authenticate the socket
-     */
-    authenticate(): Promise<unknown>;
-    /**
-     * listen to function requests
-     */
-    listenToFunctionRequests(): Promise<unknown>;
-    disconnect(): Promise<void>;
-    private updateStatus;
-}
--- a/dist_ts/smartsocket.classes.socketconnection.js
+++ b/dist_ts/smartsocket.classes.socketconnection.js
--- a/dist_ts/smartsocket.classes.socketfunction.d.ts
+++ b/dist_ts/smartsocket.classes.socketfunction.d.ts
@ -1,52 +0,0 @@
-import * as plugins from './smartsocket.plugins';
-import { SocketRole } from './smartsocket.classes.socketrole';
-import { SocketConnection } from './smartsocket.classes.socketconnection';
-import { Smartsocket } from './smartsocket.classes.smartsocket';
-import { SmartsocketClient } from './smartsocket.classes.smartsocketclient';
-/**
- * interface of the contructor options of class SocketFunction
- */
-export interface ISocketFunctionConstructorOptions<T extends plugins.typedrequestInterfaces.ITypedRequest> {
-    funcName: T['method'];
-    funcDef: TFuncDef<T>;
-    allowedRoles: SocketRole[];
-}
-/**
- * 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 declare type TFuncDef<T extends plugins.typedrequestInterfaces.ITypedRequest> = (dataArg: T['request'], connectionArg: SocketConnection) => PromiseLike<T['response']>;
-/**
- * class that respresents a function that can be transparently called using a SocketConnection
- */
-export declare class SocketFunction<T extends plugins.typedrequestInterfaces.ITypedRequest> {
-    static getSocketFunctionByName<Q extends plugins.typedrequestInterfaces.ITypedRequest>(smartsocketRefArg: Smartsocket | SmartsocketClient, functionNameArg: string): SocketFunction<Q>;
-    name: string;
-    funcDef: TFuncDef<T>;
-    roles: SocketRole[];
-    /**
-     * the constructor for SocketFunction
-     */
-    constructor(optionsArg: ISocketFunctionConstructorOptions<T>);
-    /**
-     * invokes the function of this SocketFunction
-     */
-    invoke(dataArg: ISocketFunctionCallDataRequest<T>, socketConnectionArg: SocketConnection): Promise<ISocketFunctionCallDataResponse<T>>;
-    /**
-     * notifies a role about access to this SocketFunction
-     */
-    private _notifyRole;
-}
--- a/dist_ts/smartsocket.classes.socketfunction.js
+++ b/dist_ts/smartsocket.classes.socketfunction.js
@ -1,49 +0,0 @@
-"use strict";
-Object.defineProperty(exports, "__esModule", { value: true });
-exports.SocketFunction = void 0;
-// export classes
-/**
- * class that respresents a function that can be transparently called using a SocketConnection
- */
-class SocketFunction {
-    /**
-     * the constructor for SocketFunction
-     */
-    constructor(optionsArg) {
-        this.name = optionsArg.funcName;
-        this.funcDef = optionsArg.funcDef;
-        this.roles = optionsArg.allowedRoles;
-        for (const socketRoleArg of this.roles) {
-            this._notifyRole(socketRoleArg);
-        }
-    }
-    // STATIC
-    static getSocketFunctionByName(smartsocketRefArg, functionNameArg) {
-        return smartsocketRefArg.socketFunctions.find(socketFunctionArg => {
-            return socketFunctionArg.name === functionNameArg;
-        });
-    }
-    /**
-     * invokes the function of this SocketFunction
-     */
-    async invoke(dataArg, socketConnectionArg) {
-        if (dataArg.funcName === this.name) {
-            const funcResponseData = {
-                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!");
-        }
-    }
-    /**
-     * notifies a role about access to this SocketFunction
-     */
-    _notifyRole(socketRoleArg) {
-        socketRoleArg.addSocketFunction(this);
-    }
-}
-exports.SocketFunction = SocketFunction;
-//# sourceMappingURL=data:application/json;base64,eyJ2ZXJzaW9uIjozLCJmaWxlIjoic21hcnRzb2NrZXQuY2xhc3Nlcy5zb2NrZXRmdW5jdGlvbi5qcyIsInNvdXJjZVJvb3QiOiIiLCJzb3VyY2VzIjpbIi4uL3RzL3NtYXJ0c29ja2V0LmNsYXNzZXMuc29ja2V0ZnVuY3Rpb24udHMiXSwibmFtZXMiOltdLCJtYXBwaW5ncyI6Ijs7O0FBd0NBLGlCQUFpQjtBQUVqQjs7R0FFRztBQUNILE1BQWEsY0FBYztJQWdCekI7O09BRUc7SUFDSCxZQUFZLFVBQWdEO1FBQzFELElBQUksQ0FBQyxJQUFJLEdBQUcsVUFBVSxDQUFDLFFBQVEsQ0FBQztRQUNoQyxJQUFJLENBQUMsT0FBTyxHQUFHLFVBQVUsQ0FBQyxPQUFPLENBQUM7UUFDbEMsSUFBSSxDQUFDLEtBQUssR0FBRyxVQUFVLENBQUMsWUFBWSxDQUFDO1FBQ3JDLEtBQUssTUFBTSxhQUFhLElBQUksSUFBSSxDQUFDLEtBQUssRUFBRTtZQUN0QyxJQUFJLENBQUMsV0FBVyxDQUFDLGFBQWEsQ0FBQyxDQUFDO1NBQ2pDO0lBQ0gsQ0FBQztJQXpCRCxTQUFTO0lBQ0YsTUFBTSxDQUFDLHVCQUF1QixDQUNuQyxpQkFBa0QsRUFDbEQsZUFBdUI7UUFFdkIsT0FBTyxpQkFBaUIsQ0FBQyxlQUFlLENBQUMsSUFBSSxDQUFDLGlCQUFpQixDQUFDLEVBQUU7WUFDaEUsT0FBTyxpQkFBaUIsQ0FBQyxJQUFJLEtBQUssZUFBZSxDQUFDO1FBQ3BELENBQUMsQ0FBQyxDQUFDO0lBQ0wsQ0FBQztJQW1CRDs7T0FFRztJQUNJLEtBQUssQ0FBQyxNQUFNLENBQUMsT0FBMEMsRUFBRSxtQkFBcUM7UUFDbkcsSUFBSSxPQUFPLENBQUMsUUFBUSxLQUFLLElBQUksQ0FBQyxJQUFJLEVBQUU7WUFDbEMsTUFBTSxnQkFBZ0IsR0FBdUM7Z0JBQzNELFFBQVEsRUFBRSxJQUFJLENBQUMsSUFBSTtnQkFDbkIsV0FBVyxFQUFFLE1BQU0sSUFBSSxDQUFDLE9BQU8sQ0FBQyxPQUFPLENBQUMsV0FBVyxFQUFFLG1CQUFtQixDQUFDO2FBQzFFLENBQUM7WUFDRixPQUFPLGdCQUFnQixDQUFDO1NBQ3pCO2FBQU07WUFDTCxNQUFNLElBQUksS0FBSyxDQUFDLCtEQUErRCxDQUFDLENBQUM7U0FDbEY7SUFDSCxDQUFDO0lBRUQ7O09BRUc7SUFDSyxXQUFXLENBQUMsYUFBeUI7UUFDM0MsYUFBYSxDQUFDLGlCQUFpQixDQUFDLElBQUksQ0FBQyxDQUFDO0lBQ3hDLENBQUM7Q0FDRjtBQWpERCx3Q0FpREMifQ==
--- a/dist_ts/smartsocket.classes.socketrequest.d.ts
+++ b/dist_ts/smartsocket.classes.socketrequest.d.ts
@ -1,47 +0,0 @@
-import * as plugins from './smartsocket.plugins';
-import { ISocketFunctionCallDataRequest, ISocketFunctionCallDataResponse } from './smartsocket.classes.socketfunction';
-import { SocketConnection } from './smartsocket.classes.socketconnection';
-import { Smartsocket } from './smartsocket.classes.smartsocket';
-import { SmartsocketClient } from './smartsocket.classes.smartsocketclient';
-export declare type TSocketRequestStatus = 'new' | 'pending' | 'finished';
-export declare type TSocketRequestSide = 'requesting' | 'responding';
-/**
- * interface of constructor of class SocketRequest
- */
-export interface ISocketRequestConstructorOptions<T extends plugins.typedrequestInterfaces.ITypedRequest> {
-    side: TSocketRequestSide;
-    originSocketConnection: SocketConnection;
-    shortId: string;
-    funcCallData?: ISocketFunctionCallDataRequest<T>;
-}
-/**
- * request object that is sent initially and may or may not receive a response
- */
-export interface ISocketRequestDataObject<T extends plugins.typedrequestInterfaces.ITypedRequest> {
-    funcCallData: ISocketFunctionCallDataRequest<T> | ISocketFunctionCallDataResponse<T>;
-    shortId: string;
-    responseTimeout?: number;
-}
-export declare class SocketRequest<T extends plugins.typedrequestInterfaces.ITypedRequest> {
-    static getSocketRequestById(smartsocketRef: Smartsocket | SmartsocketClient, shortIdArg: string): SocketRequest<any>;
-    status: TSocketRequestStatus;
-    side: TSocketRequestSide;
-    shortid: string;
-    originSocketConnection: SocketConnection;
-    funcCallData: ISocketFunctionCallDataRequest<T>;
-    done: plugins.smartpromise.Deferred<ISocketFunctionCallDataResponse<T>>;
-    smartsocketRef: Smartsocket | SmartsocketClient;
-    constructor(smartsocketRefArg: Smartsocket | SmartsocketClient, optionsArg: ISocketRequestConstructorOptions<T>);
-    /**
-     * dispatches a socketrequest from the requesting to the receiving side
-     */
-    dispatch(): Promise<ISocketFunctionCallDataResponse<T>>;
-    /**
-     * handles the response that is received by the requesting side
-     */
-    handleResponse(responseDataArg: ISocketRequestDataObject<T>): Promise<void>;
-    /**
-     * creates the response on the responding side
-     */
-    createResponse(): Promise<void>;
-}
--- a/dist_ts/smartsocket.classes.socketrequest.js
+++ b/dist_ts/smartsocket.classes.socketrequest.js
@ -1,90 +0,0 @@
-"use strict";
-var __createBinding = (this && this.__createBinding) || (Object.create ? (function(o, m, k, k2) {
-    if (k2 === undefined) k2 = k;
-    Object.defineProperty(o, k2, { enumerable: true, get: function() { return m[k]; } });
-}) : (function(o, m, k, k2) {
-    if (k2 === undefined) k2 = k;
-    o[k2] = m[k];
-}));
-var __setModuleDefault = (this && this.__setModuleDefault) || (Object.create ? (function(o, v) {
-    Object.defineProperty(o, "default", { enumerable: true, value: v });
-}) : function(o, v) {
-    o["default"] = v;
-});
-var __importStar = (this && this.__importStar) || function (mod) {
-    if (mod && mod.__esModule) return mod;
-    var result = {};
-    if (mod != null) for (var k in mod) if (k !== "default" && Object.hasOwnProperty.call(mod, k)) __createBinding(result, mod, k);
-    __setModuleDefault(result, mod);
-    return result;
-};
-Object.defineProperty(exports, "__esModule", { value: true });
-exports.SocketRequest = void 0;
-const plugins = __importStar(require("./smartsocket.plugins"));
-// import interfaces
-const smartsocket_classes_socketfunction_1 = require("./smartsocket.classes.socketfunction");
-const smartsocket_logging_1 = require("./smartsocket.logging");
-// export classes
-class SocketRequest {
-    constructor(smartsocketRefArg, optionsArg) {
-        // INSTANCE
-        this.status = 'new';
-        this.done = plugins.smartpromise.defer();
-        this.smartsocketRef = smartsocketRefArg;
-        this.side = optionsArg.side;
-        this.shortid = optionsArg.shortId;
-        this.funcCallData = optionsArg.funcCallData;
-        this.originSocketConnection = optionsArg.originSocketConnection;
-        this.smartsocketRef.socketRequests.add(this);
-    }
-    // STATIC
-    static getSocketRequestById(smartsocketRef, shortIdArg) {
-        return smartsocketRef.socketRequests.find(socketRequestArg => {
-            return socketRequestArg.shortid === shortIdArg;
-        });
-    }
-    // requesting --------------------------
-    /**
-     * dispatches a socketrequest from the requesting to the receiving side
-     */
-    dispatch() {
-        const requestData = {
-            funcCallData: this.funcCallData,
-            shortId: this.shortid
-        };
-        this.originSocketConnection.socket.emit('function', requestData);
-        return this.done.promise;
-    }
-    /**
-     * handles the response that is received by the requesting side
-     */
-    async handleResponse(responseDataArg) {
-        smartsocket_logging_1.logger.log('info', 'handling response!');
-        this.done.resolve(responseDataArg.funcCallData);
-        this.smartsocketRef.socketRequests.remove(this);
-    }
-    // responding --------------------------
-    /**
-     * creates the response on the responding side
-     */
-    async createResponse() {
-        const targetSocketFunction = smartsocket_classes_socketfunction_1.SocketFunction.getSocketFunctionByName(this.smartsocketRef, this.funcCallData.funcName);
-        if (!targetSocketFunction) {
-            smartsocket_logging_1.logger.log('warn', `There is no SocketFunction defined for ${this.funcCallData.funcName}`);
-            smartsocket_logging_1.logger.log('warn', `So now response is being sent.`);
-            return;
-        }
-        smartsocket_logging_1.logger.log('info', `invoking ${targetSocketFunction.name}`);
-        targetSocketFunction.invoke(this.funcCallData, this.originSocketConnection).then(resultData => {
-            smartsocket_logging_1.logger.log('info', 'got resultData. Sending it to requesting party.');
-            const responseData = {
-                funcCallData: resultData,
-                shortId: this.shortid
-            };
-            this.originSocketConnection.socket.emit('functionResponse', responseData);
-            this.smartsocketRef.socketRequests.remove(this);
-        });
-    }
-}
-exports.SocketRequest = SocketRequest;
-//# sourceMappingURL=data:application/json;base64,eyJ2ZXJzaW9uIjozLCJmaWxlIjoic21hcnRzb2NrZXQuY2xhc3Nlcy5zb2NrZXRyZXF1ZXN0LmpzIiwic291cmNlUm9vdCI6IiIsInNvdXJjZXMiOlsiLi4vdHMvc21hcnRzb2NrZXQuY2xhc3Nlcy5zb2NrZXRyZXF1ZXN0LnRzIl0sIm5hbWVzIjpbXSwibWFwcGluZ3MiOiI7Ozs7Ozs7Ozs7Ozs7Ozs7Ozs7Ozs7QUFBQSwrREFBaUQ7QUFFakQsb0JBQW9CO0FBQ3BCLDZGQUF1STtBQUl2SSwrREFBK0M7QUEyQi9DLGlCQUFpQjtBQUNqQixNQUFhLGFBQWE7SUFxQnhCLFlBQ0UsaUJBQWtELEVBQ2xELFVBQStDO1FBWmpELFdBQVc7UUFDSixXQUFNLEdBQXlCLEtBQUssQ0FBQztRQUtyQyxTQUFJLEdBQUcsT0FBTyxDQUFDLFlBQVksQ0FBQyxLQUFLLEVBQXNDLENBQUM7UUFRN0UsSUFBSSxDQUFDLGNBQWMsR0FBRyxpQkFBaUIsQ0FBQztRQUN4QyxJQUFJLENBQUMsSUFBSSxHQUFHLFVBQVUsQ0FBQyxJQUFJLENBQUM7UUFDNUIsSUFBSSxDQUFDLE9BQU8sR0FBRyxVQUFVLENBQUMsT0FBTyxDQUFDO1FBQ2xDLElBQUksQ0FBQyxZQUFZLEdBQUcsVUFBVSxDQUFDLFlBQVksQ0FBQztRQUM1QyxJQUFJLENBQUMsc0JBQXNCLEdBQUcsVUFBVSxDQUFDLHNCQUFzQixDQUFDO1FBQ2hFLElBQUksQ0FBQyxjQUFjLENBQUMsY0FBYyxDQUFDLEdBQUcsQ0FBQyxJQUFJLENBQUMsQ0FBQztJQUMvQyxDQUFDO0lBOUJELFNBQVM7SUFDRixNQUFNLENBQUMsb0JBQW9CLENBQ2hDLGNBQStDLEVBQy9DLFVBQWtCO1FBRWxCLE9BQU8sY0FBYyxDQUFDLGNBQWMsQ0FBQyxJQUFJLENBQUMsZ0JBQWdCLENBQUMsRUFBRTtZQUMzRCxPQUFPLGdCQUFnQixDQUFDLE9BQU8sS0FBSyxVQUFVLENBQUM7UUFDakQsQ0FBQyxDQUFDLENBQUM7SUFDTCxDQUFDO0lBd0JELHdDQUF3QztJQUV4Qzs7T0FFRztJQUNJLFFBQVE7UUFDYixNQUFNLFdBQVcsR0FBZ0M7WUFDL0MsWUFBWSxFQUFFLElBQUksQ0FBQyxZQUFZO1lBQy9CLE9BQU8sRUFBRSxJQUFJLENBQUMsT0FBTztTQUN0QixDQUFDO1FBQ0YsSUFBSSxDQUFDLHNCQUFzQixDQUFDLE1BQU0sQ0FBQyxJQUFJLENBQUMsVUFBVSxFQUFFLFdBQVcsQ0FBQyxDQUFDO1FBQ2pFLE9BQU8sSUFBSSxDQUFDLElBQUksQ0FBQyxPQUFPLENBQUM7SUFDM0IsQ0FBQztJQUVEOztPQUVHO0lBQ0ksS0FBSyxDQUFDLGNBQWMsQ0FBQyxlQUE0QztRQUN0RSw0QkFBTSxDQUFDLEdBQUcsQ0FBQyxNQUFNLEVBQUUsb0JBQW9CLENBQUMsQ0FBQztRQUN6QyxJQUFJLENBQUMsSUFBSSxDQUFDLE9BQU8sQ0FBQyxlQUFlLENBQUMsWUFBWSxDQUFDLENBQUM7UUFDaEQsSUFBSSxDQUFDLGNBQWMsQ0FBQyxjQUFjLENBQUMsTUFBTSxDQUFDLElBQUksQ0FBQyxDQUFDO0lBQ2xELENBQUM7SUFFRCx3Q0FBd0M7SUFFeEM7O09BRUc7SUFDSSxLQUFLLENBQUMsY0FBYztRQUN6QixNQUFNLG9CQUFvQixHQUFzQixtREFBYyxDQUFDLHVCQUF1QixDQUNwRixJQUFJLENBQUMsY0FBYyxFQUNuQixJQUFJLENBQUMsWUFBWSxDQUFDLFFBQVEsQ0FDM0IsQ0FBQztRQUVGLElBQUksQ0FBQyxvQkFBb0IsRUFBRTtZQUN6Qiw0QkFBTSxDQUFDLEdBQUcsQ0FDUixNQUFNLEVBQ04sMENBQTBDLElBQUksQ0FBQyxZQUFZLENBQUMsUUFBUSxFQUFFLENBQ3ZFLENBQUM7WUFDRiw0QkFBTSxDQUFDLEdBQUcsQ0FBQyxNQUFNLEVBQUUsZ0NBQWdDLENBQUMsQ0FBQztZQUNyRCxPQUFPO1NBQ1I7UUFDRCw0QkFBTSxDQUFDLEdBQUcsQ0FBQyxNQUFNLEVBQUUsWUFBWSxvQkFBb0IsQ0FBQyxJQUFJLEVBQUUsQ0FBQyxDQUFDO1FBQzVELG9CQUFvQixDQUFDLE1BQU0sQ0FBQyxJQUFJLENBQUMsWUFBWSxFQUFFLElBQUksQ0FBQyxzQkFBc0IsQ0FBQyxDQUFDLElBQUksQ0FBQyxVQUFVLENBQUMsRUFBRTtZQUM1Riw0QkFBTSxDQUFDLEdBQUcsQ0FBQyxNQUFNLEVBQUUsaURBQWlELENBQUMsQ0FBQztZQUN0RSxNQUFNLFlBQVksR0FBZ0M7Z0JBQ2hELFlBQVksRUFBRSxVQUFVO2dCQUN4QixPQUFPLEVBQUUsSUFBSSxDQUFDLE9BQU87YUFDdEIsQ0FBQztZQUNGLElBQUksQ0FBQyxzQkFBc0IsQ0FBQyxNQUFNLENBQUMsSUFBSSxDQUFDLGtCQUFrQixFQUFFLFlBQVksQ0FBQyxDQUFDO1lBQzFFLElBQUksQ0FBQyxjQUFjLENBQUMsY0FBYyxDQUFDLE1BQU0sQ0FBQyxJQUFJLENBQUMsQ0FBQztRQUNsRCxDQUFDLENBQUMsQ0FBQztJQUNMLENBQUM7Q0FDRjtBQXRGRCxzQ0FzRkMifQ==
--- a/dist_ts/smartsocket.classes.socketrole.d.ts
+++ b/dist_ts/smartsocket.classes.socketrole.d.ts
@ -1,28 +0,0 @@
-import * as plugins from './smartsocket.plugins';
-import { SocketFunction } from './smartsocket.classes.socketfunction';
-import { Smartsocket } from './smartsocket.classes.smartsocket';
-import { SmartsocketClient } from './smartsocket.classes.smartsocketclient';
-import { ISocketConnectionAuthenticationObject } from './smartsocket.classes.socketconnection';
-/**
- * interface for class SocketRole
- */
-export interface ISocketRoleOptions {
-    name: string;
-    passwordHash: string;
-}
-/**
- * A socketrole defines access to certain routines.
- */
-export declare class SocketRole {
-    static getSocketRoleByName(referenceSmartsocket: Smartsocket | SmartsocketClient, socketRoleNameArg: string): SocketRole;
-    static checkPasswordForRole(dataArg: ISocketConnectionAuthenticationObject, referenceSmartsocket: Smartsocket | SmartsocketClient): boolean;
-    name: string;
-    passwordHash: string;
-    allowedFunctions: plugins.lik.ObjectMap<SocketFunction<any>>;
-    constructor(optionsArg: ISocketRoleOptions);
-    /**
-     * adds the socketfunction to the socketrole
-     * @param socketFunctionArg
-     */
-    addSocketFunction(socketFunctionArg: SocketFunction<any>): void;
-}
--- a/dist_ts/smartsocket.classes.socketrole.js
+++ b/dist_ts/smartsocket.classes.socketrole.js
@ -1,54 +0,0 @@
-"use strict";
-var __createBinding = (this && this.__createBinding) || (Object.create ? (function(o, m, k, k2) {
-    if (k2 === undefined) k2 = k;
-    Object.defineProperty(o, k2, { enumerable: true, get: function() { return m[k]; } });
-}) : (function(o, m, k, k2) {
-    if (k2 === undefined) k2 = k;
-    o[k2] = m[k];
-}));
-var __setModuleDefault = (this && this.__setModuleDefault) || (Object.create ? (function(o, v) {
-    Object.defineProperty(o, "default", { enumerable: true, value: v });
-}) : function(o, v) {
-    o["default"] = v;
-});
-var __importStar = (this && this.__importStar) || function (mod) {
-    if (mod && mod.__esModule) return mod;
-    var result = {};
-    if (mod != null) for (var k in mod) if (k !== "default" && Object.hasOwnProperty.call(mod, k)) __createBinding(result, mod, k);
-    __setModuleDefault(result, mod);
-    return result;
-};
-Object.defineProperty(exports, "__esModule", { value: true });
-exports.SocketRole = void 0;
-const plugins = __importStar(require("./smartsocket.plugins"));
-/**
- * A socketrole defines access to certain routines.
- */
-class SocketRole {
-    constructor(optionsArg) {
-        this.allowedFunctions = new plugins.lik.ObjectMap();
-        this.name = optionsArg.name;
-        this.passwordHash = optionsArg.passwordHash;
-    }
-    // STATIC
-    static getSocketRoleByName(referenceSmartsocket, socketRoleNameArg) {
-        return referenceSmartsocket.socketRoles.find(socketRoleArg => {
-            return socketRoleArg.name === socketRoleNameArg;
-        });
-    }
-    static checkPasswordForRole(dataArg, referenceSmartsocket) {
-        const targetPasswordHash = SocketRole.getSocketRoleByName(referenceSmartsocket, dataArg.role)
-            .passwordHash;
-        const computedCompareHash = plugins.smarthash.sha256FromStringSync(dataArg.password);
-        return targetPasswordHash === computedCompareHash;
-    }
-    /**
-     * adds the socketfunction to the socketrole
-     * @param socketFunctionArg
-     */
-    addSocketFunction(socketFunctionArg) {
-        this.allowedFunctions.add(socketFunctionArg);
-    }
-}
-exports.SocketRole = SocketRole;
-//# sourceMappingURL=data:application/json;base64,eyJ2ZXJzaW9uIjozLCJmaWxlIjoic21hcnRzb2NrZXQuY2xhc3Nlcy5zb2NrZXRyb2xlLmpzIiwic291cmNlUm9vdCI6IiIsInNvdXJjZXMiOlsiLi4vdHMvc21hcnRzb2NrZXQuY2xhc3Nlcy5zb2NrZXRyb2xlLnRzIl0sIm5hbWVzIjpbXSwibWFwcGluZ3MiOiI7Ozs7Ozs7Ozs7Ozs7Ozs7Ozs7Ozs7QUFBQSwrREFBaUQ7QUFnQmpEOztHQUVHO0FBQ0gsTUFBYSxVQUFVO0lBeUJyQixZQUFZLFVBQThCO1FBRG5DLHFCQUFnQixHQUFHLElBQUksT0FBTyxDQUFDLEdBQUcsQ0FBQyxTQUFTLEVBQXVCLENBQUM7UUFFekUsSUFBSSxDQUFDLElBQUksR0FBRyxVQUFVLENBQUMsSUFBSSxDQUFDO1FBQzVCLElBQUksQ0FBQyxZQUFZLEdBQUcsVUFBVSxDQUFDLFlBQVksQ0FBQztJQUM5QyxDQUFDO0lBM0JELFNBQVM7SUFDRixNQUFNLENBQUMsbUJBQW1CLENBQy9CLG9CQUFxRCxFQUNyRCxpQkFBeUI7UUFFekIsT0FBTyxvQkFBb0IsQ0FBQyxXQUFXLENBQUMsSUFBSSxDQUFDLGFBQWEsQ0FBQyxFQUFFO1lBQzNELE9BQU8sYUFBYSxDQUFDLElBQUksS0FBSyxpQkFBaUIsQ0FBQztRQUNsRCxDQUFDLENBQUMsQ0FBQztJQUNMLENBQUM7SUFFTSxNQUFNLENBQUMsb0JBQW9CLENBQ2hDLE9BQThDLEVBQzlDLG9CQUFxRDtRQUVyRCxNQUFNLGtCQUFrQixHQUFHLFVBQVUsQ0FBQyxtQkFBbUIsQ0FBQyxvQkFBb0IsRUFBRSxPQUFPLENBQUMsSUFBSSxDQUFDO2FBQzFGLFlBQVksQ0FBQztRQUNoQixNQUFNLG1CQUFtQixHQUFHLE9BQU8sQ0FBQyxTQUFTLENBQUMsb0JBQW9CLENBQUMsT0FBTyxDQUFDLFFBQVEsQ0FBQyxDQUFDO1FBQ3JGLE9BQU8sa0JBQWtCLEtBQUssbUJBQW1CLENBQUM7SUFDcEQsQ0FBQztJQVdEOzs7T0FHRztJQUNJLGlCQUFpQixDQUFDLGlCQUFzQztRQUM3RCxJQUFJLENBQUMsZ0JBQWdCLENBQUMsR0FBRyxDQUFDLGlCQUFpQixDQUFDLENBQUM7SUFDL0MsQ0FBQztDQUNGO0FBckNELGdDQXFDQyJ9
--- a/dist_ts/smartsocket.classes.socketserver.d.ts
+++ b/dist_ts/smartsocket.classes.socketserver.d.ts
@ -1,33 +0,0 @@
-/// <reference types="node" />
-import * as plugins from './smartsocket.plugins';
-import * as http from 'http';
-import * as https from 'https';
-import { Smartsocket } from './smartsocket.classes.smartsocket';
-/**
- * class socketServer
- * handles the attachment of socketIo to whatever server is in play
- */
-export declare class SocketServer {
-    private smartsocket;
-    private httpServer;
-    private standaloneServer;
-    private expressServer;
-    constructor(smartSocketInstance: Smartsocket);
-    /**
-     * starts the server with another server
-     * also works with an express style server
-     */
-    setExternalServer(serverType: 'smartexpress', serverArg: plugins.smartexpress.Server): Promise<void>;
-    /**
-     * gets the server for socket.io
-     */
-    getServerForSocketIo(): http.Server | https.Server;
-    /**
-     * starts listening to incoming sockets:
-     */
-    start(): Promise<void>;
-    /**
-     * closes the server
-     */
-    stop(): Promise<void>;
-}
--- a/dist_ts/smartsocket.classes.socketserver.js
+++ b/dist_ts/smartsocket.classes.socketserver.js
@ -1,88 +0,0 @@
-"use strict";
-var __createBinding = (this && this.__createBinding) || (Object.create ? (function(o, m, k, k2) {
-    if (k2 === undefined) k2 = k;
-    Object.defineProperty(o, k2, { enumerable: true, get: function() { return m[k]; } });
-}) : (function(o, m, k, k2) {
-    if (k2 === undefined) k2 = k;
-    o[k2] = m[k];
-}));
-var __setModuleDefault = (this && this.__setModuleDefault) || (Object.create ? (function(o, v) {
-    Object.defineProperty(o, "default", { enumerable: true, value: v });
-}) : function(o, v) {
-    o["default"] = v;
-});
-var __importStar = (this && this.__importStar) || function (mod) {
-    if (mod && mod.__esModule) return mod;
-    var result = {};
-    if (mod != null) for (var k in mod) if (k !== "default" && Object.hasOwnProperty.call(mod, k)) __createBinding(result, mod, k);
-    __setModuleDefault(result, mod);
-    return result;
-};
-Object.defineProperty(exports, "__esModule", { value: true });
-exports.SocketServer = void 0;
-const plugins = __importStar(require("./smartsocket.plugins"));
-// used in case no other server is supplied
-const http = __importStar(require("http"));
-const smartsocket_logging_1 = require("./smartsocket.logging");
-/**
- * class socketServer
- * handles the attachment of socketIo to whatever server is in play
- */
-class SocketServer {
-    constructor(smartSocketInstance) {
-        // wether httpServer is standalone
-        this.standaloneServer = false;
-        this.smartsocket = smartSocketInstance;
-    }
-    /**
-     * starts the server with another server
-     * also works with an express style server
-     */
-    async setExternalServer(serverType, serverArg) {
-        await serverArg.startedPromise;
-        this.httpServer = serverArg.httpServer;
-    }
-    /**
-     * gets the server for socket.io
-     */
-    getServerForSocketIo() {
-        if (this.httpServer) {
-            return this.httpServer;
-        }
-        else {
-            this.httpServer = new http.Server();
-            this.standaloneServer = true;
-            return this.httpServer;
-        }
-    }
-    /**
-     * starts listening to incoming sockets:
-     */
-    async start() {
-        const done = plugins.smartpromise.defer();
-        // handle http servers
-        // in case an external server has been set "this.standaloneServer" should be false
-        if (this.httpServer && this.standaloneServer) {
-            if (!this.smartsocket.options.port) {
-                smartsocket_logging_1.logger.log('error', 'there should be a port specifed for smartsocket!');
-                throw new Error('there should be a port specified for smartsocket');
-            }
-            this.httpServer.listen(this.smartsocket.options.port, () => {
-                smartsocket_logging_1.logger.log('success', `Server started in standalone mode on ${this.smartsocket.options.port}`);
-                done.resolve();
-            });
-        }
-        else {
-            done.resolve();
-        }
-        // nothing else to do if express server is set
-        await done.promise;
-        return;
-    }
-    /**
-     * closes the server
-     */
-    async stop() { }
-}
-exports.SocketServer = SocketServer;
-//# sourceMappingURL=data:application/json;base64,eyJ2ZXJzaW9uIjozLCJmaWxlIjoic21hcnRzb2NrZXQuY2xhc3Nlcy5zb2NrZXRzZXJ2ZXIuanMiLCJzb3VyY2VSb290IjoiIiwic291cmNlcyI6WyIuLi90cy9zbWFydHNvY2tldC5jbGFzc2VzLnNvY2tldHNlcnZlci50cyJdLCJuYW1lcyI6W10sIm1hcHBpbmdzIjoiOzs7Ozs7Ozs7Ozs7Ozs7Ozs7Ozs7O0FBQUEsK0RBQWlEO0FBRWpELDJDQUEyQztBQUMzQywyQ0FBNkI7QUFHN0IsK0RBQStDO0FBRS9DOzs7R0FHRztBQUNILE1BQWEsWUFBWTtJQU92QixZQUFZLG1CQUFnQztRQUo1QyxrQ0FBa0M7UUFDMUIscUJBQWdCLEdBQUcsS0FBSyxDQUFDO1FBSS9CLElBQUksQ0FBQyxXQUFXLEdBQUcsbUJBQW1CLENBQUM7SUFDekMsQ0FBQztJQUVEOzs7T0FHRztJQUNJLEtBQUssQ0FBQyxpQkFBaUIsQ0FDNUIsVUFBMEIsRUFDMUIsU0FBc0M7UUFFdEMsTUFBTSxTQUFTLENBQUMsY0FBYyxDQUFDO1FBQy9CLElBQUksQ0FBQyxVQUFVLEdBQUcsU0FBUyxDQUFDLFVBQVUsQ0FBQztJQUN6QyxDQUFDO0lBRUQ7O09BRUc7SUFDSSxvQkFBb0I7UUFDekIsSUFBSSxJQUFJLENBQUMsVUFBVSxFQUFFO1lBQ25CLE9BQU8sSUFBSSxDQUFDLFVBQVUsQ0FBQztTQUN4QjthQUFNO1lBQ0wsSUFBSSxDQUFDLFVBQVUsR0FBRyxJQUFJLElBQUksQ0FBQyxNQUFNLEVBQUUsQ0FBQztZQUNwQyxJQUFJLENBQUMsZ0JBQWdCLEdBQUcsSUFBSSxDQUFDO1lBQzdCLE9BQU8sSUFBSSxDQUFDLFVBQVUsQ0FBQztTQUN4QjtJQUNILENBQUM7SUFFRDs7T0FFRztJQUNJLEtBQUssQ0FBQyxLQUFLO1FBQ2hCLE1BQU0sSUFBSSxHQUFHLE9BQU8sQ0FBQyxZQUFZLENBQUMsS0FBSyxFQUFFLENBQUM7UUFFMUMsc0JBQXNCO1FBQ3RCLGtGQUFrRjtRQUNsRixJQUFJLElBQUksQ0FBQyxVQUFVLElBQUksSUFBSSxDQUFDLGdCQUFnQixFQUFFO1lBQzVDLElBQUksQ0FBQyxJQUFJLENBQUMsV0FBVyxDQUFDLE9BQU8sQ0FBQyxJQUFJLEVBQUU7Z0JBQ2xDLDRCQUFNLENBQUMsR0FBRyxDQUFDLE9BQU8sRUFBRSxrREFBa0QsQ0FBQyxDQUFDO2dCQUN4RSxNQUFNLElBQUksS0FBSyxDQUFDLGtEQUFrRCxDQUFDLENBQUM7YUFDckU7WUFDRCxJQUFJLENBQUMsVUFBVSxDQUFDLE1BQU0sQ0FBQyxJQUFJLENBQUMsV0FBVyxDQUFDLE9BQU8sQ0FBQyxJQUFJLEVBQUUsR0FBRyxFQUFFO2dCQUN6RCw0QkFBTSxDQUFDLEdBQUcsQ0FBQyxTQUFTLEVBQUUsd0NBQXdDLElBQUksQ0FBQyxXQUFXLENBQUMsT0FBTyxDQUFDLElBQUksRUFBRSxDQUFDLENBQUM7Z0JBQy9GLElBQUksQ0FBQyxPQUFPLEVBQUUsQ0FBQztZQUNqQixDQUFDLENBQUMsQ0FBQztTQUNKO2FBQU07WUFDTCxJQUFJLENBQUMsT0FBTyxFQUFFLENBQUM7U0FDaEI7UUFFRCw4Q0FBOEM7UUFDOUMsTUFBTSxJQUFJLENBQUMsT0FBTyxDQUFDO1FBQ25CLE9BQU87SUFDVCxDQUFDO0lBRUQ7O09BRUc7SUFDSSxLQUFLLENBQUMsSUFBSSxLQUFJLENBQUM7Q0FDdkI7QUFsRUQsb0NBa0VDIn0=
--- a/dist_ts/smartsocket.logging.d.ts
+++ b/dist_ts/smartsocket.logging.d.ts
@ -1,2 +0,0 @@
-import * as plugins from './smartsocket.plugins';
-export declare const logger: plugins.smartlog.ConsoleLog;
--- a/dist_ts/smartsocket.logging.js
+++ b/dist_ts/smartsocket.logging.js
@ -1,25 +0,0 @@
-"use strict";
-var __createBinding = (this && this.__createBinding) || (Object.create ? (function(o, m, k, k2) {
-    if (k2 === undefined) k2 = k;
-    Object.defineProperty(o, k2, { enumerable: true, get: function() { return m[k]; } });
-}) : (function(o, m, k, k2) {
-    if (k2 === undefined) k2 = k;
-    o[k2] = m[k];
-}));
-var __setModuleDefault = (this && this.__setModuleDefault) || (Object.create ? (function(o, v) {
-    Object.defineProperty(o, "default", { enumerable: true, value: v });
-}) : function(o, v) {
-    o["default"] = v;
-});
-var __importStar = (this && this.__importStar) || function (mod) {
-    if (mod && mod.__esModule) return mod;
-    var result = {};
-    if (mod != null) for (var k in mod) if (k !== "default" && Object.hasOwnProperty.call(mod, k)) __createBinding(result, mod, k);
-    __setModuleDefault(result, mod);
-    return result;
-};
-Object.defineProperty(exports, "__esModule", { value: true });
-exports.logger = void 0;
-const plugins = __importStar(require("./smartsocket.plugins"));
-exports.logger = new plugins.smartlog.ConsoleLog();
-//# sourceMappingURL=data:application/json;base64,eyJ2ZXJzaW9uIjozLCJmaWxlIjoic21hcnRzb2NrZXQubG9nZ2luZy5qcyIsInNvdXJjZVJvb3QiOiIiLCJzb3VyY2VzIjpbIi4uL3RzL3NtYXJ0c29ja2V0LmxvZ2dpbmcudHMiXSwibmFtZXMiOltdLCJtYXBwaW5ncyI6Ijs7Ozs7Ozs7Ozs7Ozs7Ozs7Ozs7OztBQUFBLCtEQUFpRDtBQUVwQyxRQUFBLE1BQU0sR0FBRyxJQUFJLE9BQU8sQ0FBQyxRQUFRLENBQUMsVUFBVSxFQUFFLENBQUMifQ==
--- a/dist_ts/smartsocket.plugins.d.ts
+++ b/dist_ts/smartsocket.plugins.d.ts
@ -1,15 +0,0 @@
-import * as typedrequestInterfaces from '@apiglobal/typedrequest-interfaces';
-export { typedrequestInterfaces };
-import * as lik from '@pushrocks/lik';
-import * as smartlog from '@pushrocks/smartlog';
-import * as smarthash from '@pushrocks/smarthash';
-import * as smartdelay from '@pushrocks/smartdelay';
-import * as smartexpress from '@pushrocks/smartexpress';
-import * as smartpromise from '@pushrocks/smartpromise';
-import * as smarttime from '@pushrocks/smarttime';
-import * as smartunique from '@pushrocks/smartunique';
-import * as smartrx from '@pushrocks/smartrx';
-export { lik, smartlog, smarthash, smartdelay, smartexpress, smartpromise, smarttime, smartunique, smartrx };
-import socketIo from 'socket.io';
-import socketIoClient from 'socket.io-client';
-export { socketIo, socketIoClient };
--- a/dist_ts/smartsocket.plugins.js
+++ b/dist_ts/smartsocket.plugins.js
@ -1,53 +0,0 @@
-"use strict";
-var __createBinding = (this && this.__createBinding) || (Object.create ? (function(o, m, k, k2) {
-    if (k2 === undefined) k2 = k;
-    Object.defineProperty(o, k2, { enumerable: true, get: function() { return m[k]; } });
-}) : (function(o, m, k, k2) {
-    if (k2 === undefined) k2 = k;
-    o[k2] = m[k];
-}));
-var __setModuleDefault = (this && this.__setModuleDefault) || (Object.create ? (function(o, v) {
-    Object.defineProperty(o, "default", { enumerable: true, value: v });
-}) : function(o, v) {
-    o["default"] = v;
-});
-var __importStar = (this && this.__importStar) || function (mod) {
-    if (mod && mod.__esModule) return mod;
-    var result = {};
-    if (mod != null) for (var k in mod) if (k !== "default" && Object.hasOwnProperty.call(mod, k)) __createBinding(result, mod, k);
-    __setModuleDefault(result, mod);
-    return result;
-};
-var __importDefault = (this && this.__importDefault) || function (mod) {
-    return (mod && mod.__esModule) ? mod : { "default": mod };
-};
-Object.defineProperty(exports, "__esModule", { value: true });
-exports.socketIoClient = exports.socketIo = exports.smartrx = exports.smartunique = exports.smarttime = exports.smartpromise = exports.smartexpress = exports.smartdelay = exports.smarthash = exports.smartlog = exports.lik = exports.typedrequestInterfaces = void 0;
-// apiglobal scope
-const typedrequestInterfaces = __importStar(require("@apiglobal/typedrequest-interfaces"));
-exports.typedrequestInterfaces = typedrequestInterfaces;
-// pushrocks scope
-const lik = __importStar(require("@pushrocks/lik"));
-exports.lik = lik;
-const smartlog = __importStar(require("@pushrocks/smartlog"));
-exports.smartlog = smartlog;
-const smarthash = __importStar(require("@pushrocks/smarthash"));
-exports.smarthash = smarthash;
-const smartdelay = __importStar(require("@pushrocks/smartdelay"));
-exports.smartdelay = smartdelay;
-const smartexpress = __importStar(require("@pushrocks/smartexpress"));
-exports.smartexpress = smartexpress;
-const smartpromise = __importStar(require("@pushrocks/smartpromise"));
-exports.smartpromise = smartpromise;
-const smarttime = __importStar(require("@pushrocks/smarttime"));
-exports.smarttime = smarttime;
-const smartunique = __importStar(require("@pushrocks/smartunique"));
-exports.smartunique = smartunique;
-const smartrx = __importStar(require("@pushrocks/smartrx"));
-exports.smartrx = smartrx;
-// third party scope
-const socket_io_1 = __importDefault(require("socket.io"));
-exports.socketIo = socket_io_1.default;
-const socket_io_client_1 = __importDefault(require("socket.io-client"));
-exports.socketIoClient = socket_io_client_1.default;
-//# sourceMappingURL=data:application/json;base64,eyJ2ZXJzaW9uIjozLCJmaWxlIjoic21hcnRzb2NrZXQucGx1Z2lucy5qcyIsInNvdXJjZVJvb3QiOiIiLCJzb3VyY2VzIjpbIi4uL3RzL3NtYXJ0c29ja2V0LnBsdWdpbnMudHMiXSwibmFtZXMiOltdLCJtYXBwaW5ncyI6Ijs7Ozs7Ozs7Ozs7Ozs7Ozs7Ozs7Ozs7OztBQUFBLGtCQUFrQjtBQUNsQiwyRkFBNkU7QUFFckUsd0RBQXNCO0FBRTlCLGtCQUFrQjtBQUNsQixvREFBc0M7QUFZcEMsa0JBQUc7QUFYTCw4REFBZ0Q7QUFZOUMsNEJBQVE7QUFYVixnRUFBa0Q7QUFZaEQsOEJBQVM7QUFYWCxrRUFBb0Q7QUFZbEQsZ0NBQVU7QUFYWixzRUFBd0Q7QUFZdEQsb0NBQVk7QUFYZCxzRUFBd0Q7QUFZdEQsb0NBQVk7QUFYZCxnRUFBa0Q7QUFZaEQsOEJBQVM7QUFYWCxvRUFBc0Q7QUFZcEQsa0NBQVc7QUFYYiw0REFBOEM7QUFZNUMsMEJBQU87QUFHVCxvQkFBb0I7QUFDcEIsMERBQWlDO0FBSS9CLG1CQUpLLG1CQUFRLENBSUw7QUFIVix3RUFBOEM7QUFJNUMseUJBSkssMEJBQWMsQ0FJTCJ9
--- a/npmextra.json
+++ b/npmextra.json
@ -5,7 +5,7 @@
      "githost": "gitlab.com",
      "gitscope": "pushrocks",
      "gitrepo": "smartsocket",
-      "shortDescription": "easy and secure websocket communication",
+      "description": "easy and secure websocket communication",
      "npmPackagename": "@pushrocks/smartsocket",
      "license": "MIT",
      "projectDomain": "push.rocks"
--- a/package-lock.json
+++ b/package-lock.json
--- a/package.json
+++ b/package.json
@ -1,12 +1,13 @@
 {
  "name": "@pushrocks/smartsocket",
-  "version": "1.1.60",
+  "version": "2.0.2",
  "description": "easy and secure websocket communication",
  "main": "dist_ts/index.js",
  "typings": "dist_ts/index.d.ts",
+  "type": "module",
  "scripts": {
    "test": "(tstest test/)",
-    "build": "(tsbuild --web)"
+    "build": "(tsbuild --web --allowimplicitany --skiplibcheck && tsbundle --from ./ts/index.ts --to dist_bundle/bundle.js)"
  },
  "repository": {
    "type": "git",
@ -20,25 +21,26 @@
  "homepage": "https://gitlab.com/pushrocks/smartsocket#README",
  "dependencies": {
    "@apiglobal/typedrequest-interfaces": "^1.0.15",
-    "@pushrocks/lik": "^4.0.17",
-    "@pushrocks/smartdelay": "^2.0.10",
-    "@pushrocks/smartexpress": "^3.0.76",
-    "@pushrocks/smarthash": "^2.1.6",
-    "@pushrocks/smartlog": "^2.0.39",
-    "@pushrocks/smartpromise": "^3.0.6",
-    "@pushrocks/smartrx": "^2.0.19",
-    "@pushrocks/smartunique": "^3.0.3",
-    "@types/socket.io": "^2.1.11",
-    "@types/socket.io-client": "^1.4.33",
-    "socket.io": "^2.3.0",
-    "socket.io-client": "^2.3.0"
+    "@pushrocks/isohash": "^2.0.0",
+    "@pushrocks/isounique": "^1.0.5",
+    "@pushrocks/lik": "^5.0.4",
+    "@pushrocks/smartdelay": "^2.0.13",
+    "@pushrocks/smartenv": "^5.0.0",
+    "@pushrocks/smartexpress": "^4.0.0",
+    "@pushrocks/smartjson": "^4.0.6",
+    "@pushrocks/smartlog": "^2.0.44",
+    "@pushrocks/smartpromise": "^3.1.7",
+    "@pushrocks/smartrx": "^2.0.25",
+    "@pushrocks/smarttime": "^3.0.45",
+    "socket.io": "^4.4.1",
+    "socket.io-client": "^4.4.1"
  },
  "devDependencies": {
-    "@gitzone/tsbuild": "^2.1.25",
-    "@gitzone/tsrun": "^1.2.12",
-    "@gitzone/tstest": "^1.0.44",
-    "@pushrocks/tapbundle": "^3.2.9",
-    "@types/node": "^14.11.2",
+    "@gitzone/tsbuild": "^2.1.61",
+    "@gitzone/tsrun": "^1.2.32",
+    "@gitzone/tstest": "^1.0.69",
+    "@pushrocks/tapbundle": "^5.0.3",
+    "@types/node": "^17.0.23",
    "tslint": "^6.1.3",
    "tslint-config-prettier": "^1.18.0"
  },
--- a/readme.md
+++ b/readme.md
@ -8,13 +8,20 @@ easy and secure websocket communication
 * [docs (typedoc)](https://pushrocks.gitlab.io/smartsocket/)

 ## Status for master
-[![build status](https://gitlab.com/pushrocks/smartsocket/badges/master/build.svg)](https://gitlab.com/pushrocks/smartsocket/commits/master)
-[![coverage report](https://gitlab.com/pushrocks/smartsocket/badges/master/coverage.svg)](https://gitlab.com/pushrocks/smartsocket/commits/master)
-[![npm downloads per month](https://img.shields.io/npm/dm/@pushrocks/smartsocket.svg)](https://www.npmjs.com/package/@pushrocks/smartsocket)
-[![Known Vulnerabilities](https://snyk.io/test/npm/@pushrocks/smartsocket/badge.svg)](https://snyk.io/test/npm/@pushrocks/smartsocket)
-[![TypeScript](https://img.shields.io/badge/TypeScript->=%203.x-blue.svg)](https://nodejs.org/dist/latest-v10.x/docs/api/)
-[![node](https://img.shields.io/badge/node->=%2010.x.x-blue.svg)](https://nodejs.org/dist/latest-v10.x/docs/api/)
-[![JavaScript Style Guide](https://img.shields.io/badge/code%20style-prettier-ff69b4.svg)](https://prettier.io/)
+
+Status Category | Status Badge
+-- | --
+GitLab Pipelines | [![pipeline status](https://gitlab.com/pushrocks/smartsocket/badges/master/pipeline.svg)](https://lossless.cloud)
+GitLab Pipline Test Coverage | [![coverage report](https://gitlab.com/pushrocks/smartsocket/badges/master/coverage.svg)](https://lossless.cloud)
+npm | [![npm downloads per month](https://badgen.net/npm/dy/@pushrocks/smartsocket)](https://lossless.cloud)
+Snyk | [![Known Vulnerabilities](https://badgen.net/snyk/pushrocks/smartsocket)](https://lossless.cloud)
+TypeScript Support | [![TypeScript](https://badgen.net/badge/TypeScript/>=%203.x/blue?icon=typescript)](https://lossless.cloud)
+node Support | [![node](https://img.shields.io/badge/node->=%2010.x.x-blue.svg)](https://nodejs.org/dist/latest-v10.x/docs/api/)
+Code Style | [![Code Style](https://badgen.net/badge/style/prettier/purple)](https://lossless.cloud)
+PackagePhobia (total standalone install weight) | [![PackagePhobia](https://badgen.net/packagephobia/install/@pushrocks/smartsocket)](https://lossless.cloud)
+PackagePhobia (package size on registry) | [![PackagePhobia](https://badgen.net/packagephobia/publish/@pushrocks/smartsocket)](https://lossless.cloud)
+BundlePhobia (total size when bundled) | [![BundlePhobia](https://badgen.net/bundlephobia/minzip/@pushrocks/smartsocket)](https://lossless.cloud)
+Platform support | [![Supports Windows 10](https://badgen.net/badge/supports%20Windows%2010/yes/green?icon=windows)](https://lossless.cloud) [![Supports Mac OS X](https://badgen.net/badge/supports%20Mac%20OS%20X/yes/green?icon=apple)](https://lossless.cloud)

 ## Usage

@ -30,7 +37,7 @@ import * as q from q; // q is a promise library

 // The "Smartsocket" listens on a port and can receive new "SocketConnection" requests.
 let mySmartsocket = new smartsocket.Smartsocket({
-  port: 3000 // the port smartsocket will listen on
+  port: 3000, // the port smartsocket will listen on
 });

 // optional:
@ -43,7 +50,7 @@ mySmartsocket.setServer(someExpressServer);
 // "SocketFunction"s know which "SocketRole"s are allowed to execute them
 let mySocketRole = new smartsocket.SocketRole({
  name: 'someRoleName',
-  passwordHash: 'someHashedString'
+  passwordHash: 'someHashedString',
 });

 // A "SocketFunction" executes a referenced function and passes in any data of the corresponding "SocketRequest".
@ -51,10 +58,10 @@ let mySocketRole = new smartsocket.SocketRole({
 // Any "SocketRequest" carries a unique identifier. If the referenced function's promise resolved any passed on argument will be returned to the requesting party
 let testSocketFunction1 = new smartsocket.SocketFunction({
  funcName: 'testSocketFunction1',
-  funcDef: data => {
+  funcDef: (data) => {
    console.log('testSocketFunction1 executed successfully!');
  },
-  allowedRoles: [mySocketRole] // all roles that have access to a specific function
+  allowedRoles: [mySocketRole], // all roles that have access to a specific function
 });

 // A "Smartsocket" exposes a .clientCall() that gets
@ -62,7 +69,7 @@ let testSocketFunction1 = new smartsocket.SocketFunction({
 // 2. the data to pass in
 // 3. And a target "SocketConnection" (there can be multiple connections at once)
 // any unique id association is done internally
-mySmartsocket.clientCall('restart', data, someTargetConnection).then(responseData => {});
+mySmartsocket.clientCall('restart', data, someTargetConnection).then((responseData) => {});
 ```

 #### Client side
@ -77,7 +84,7 @@ let testSmartsocketClient = new smartsocket.SmartsocketClient({
  url: 'http://localhost',
  password: 'testPassword',
  alias: 'testClient1',
-  role: 'testRole1'
+  role: 'testRole1',
 });

 // You can .connect() and .disconnect() from a "Smartsocket"
@ -88,12 +95,12 @@ testSmartsocketClient.connect().then(() => {
 // The client can also specify "SocketFunction"s. It can also specify "SocketRole"s in case a client connects to multiple servers at once
 let testSocketFunction2 = new smartsocket.SocketFunction({
  funcName: 'testSocketFunction2',
-  funcDef: data => {}, // the function to execute, has to return promise
-  allowedRoles: []
+  funcDef: (data) => {}, // the function to execute, has to return promise
+  allowedRoles: [],
 });

 // A "SmartsocketClient" can call functions on the serverside using .serverCall() analog to the "Smartsocket"'s .clientCall method.
-mySmartsocketClient.serverCall('function', functionCallData).then(functionResponseData => {
+mySmartsocketClient.serverCall('function', functionCallData).then((functionResponseData) => {
  // the functionResponseData comes from the server... awesome, right?
 });
 ```
@ -103,6 +110,10 @@ mySmartsocketClient.serverCall('function', functionCallData).then(functionRespon
 > `data` is always a js object that you can design for your specific needs.  
 > It supports buffers for large binary data network exchange.

+## Contribution
+
+We are always happy for code contributions. If you are not the code contributing type that is ok. Still, maintaining Open Source repositories takes considerable time and thought. If you like the quality of what we do and our modules are useful to you we would appreciate a little monthly contribution: You can [contribute one time](https://lossless.link/contribute-onetime) or [contribute monthly](https://lossless.link/contribute). :)
+
 For further information read the linked docs at the top of this readme.

 > MIT licensed | **&copy;** [Lossless GmbH](https://lossless.gmbh)
--- a/test/common/test.ts
+++ b/test/common/test.ts
@ -1 +0,0 @@
-console.log('TODO');
--- a/test/test.expressserver.ts
+++ b/test/test.expressserver.ts
@ -1,16 +1,13 @@
 // tslint:disable-next-line:no-implicit-dependencies
-import { expect, tap } from '@pushrocks/tapbundle';
+import { expect, expectAsync, tap } from '@pushrocks/tapbundle';

-import * as smarthash from '@pushrocks/smarthash';
-import * as smartpromise from '@pushrocks/smartpromise';
+import * as isohash from '@pushrocks/isohash';
 import * as smartexpress from '@pushrocks/smartexpress';

-import socketIoClient = require('socket.io-client');
-import smartsocket = require('../ts/index');
+import * as smartsocket from '../ts/index.js';

 let testSmartsocket: smartsocket.Smartsocket;
 let testSmartsocketClient: smartsocket.SmartsocketClient;
-let testSocketRole1: smartsocket.SocketRole;
 let testSocketFunction1: smartsocket.SocketFunction<any>;
 let myseServer: smartexpress.Server;

@ -20,8 +17,8 @@ const testConfig = {

 // class smartsocket
 tap.test('should create a new smartsocket', async () => {
-  testSmartsocket = new smartsocket.Smartsocket({ port: testConfig.port });
-  expect(testSmartsocket).be.instanceOf(smartsocket.Smartsocket);
+  testSmartsocket = new smartsocket.Smartsocket({ alias: 'testserver', port: testConfig.port });
+  expect(testSmartsocket).toBeInstanceOf(smartsocket.Smartsocket);
 });

 tap.test('Should accept an smartExpressServer as server', async () => {
@ -36,19 +33,10 @@ tap.test('Should accept an smartExpressServer as server', async () => {
  await myseServer.start();
 });

-// class socketrole
-tap.test('should add a socketrole', async () => {
-  testSocketRole1 = new smartsocket.SocketRole({
-    name: 'testRole1',
-    passwordHash: smarthash.sha256FromStringSync('testPassword'),
-  });
-  testSmartsocket.addSocketRoles([testSocketRole1]);
-});

 // class SocketFunction
 tap.test('should register a new Function', async () => {
  testSocketFunction1 = new smartsocket.SocketFunction({
-    allowedRoles: [testSocketRole1],
    funcDef: async (dataArg, socketConnectionArg) => {
      return dataArg;
    },
@ -67,12 +55,9 @@ tap.test('should react to a new websocket connection from client', async () => {
  testSmartsocketClient = new smartsocket.SmartsocketClient({
    port: testConfig.port,
    url: 'http://localhost',
-    password: 'testPassword',
    alias: 'testClient1',
-    role: 'testRole1',
  });
  testSmartsocketClient.addSocketFunction(testSocketFunction1);
-  console.log(testSmartsocketClient.socketFunctions);
  await testSmartsocketClient.connect();
 });

@ -87,10 +72,25 @@ tap.test('2 clients should connect in parallel', async () => {
 });

 tap.test('should be able to make a functionCall from client to server', async () => {
-  const response = await testSmartsocketClient.serverCall('testFunction1', {
-    value1: 'hello',
-  });
-  console.log(response);
+  const totalCycles = 20000;
+  let counter = 0;
+  let startTime = Date.now();
+  while (counter < totalCycles) {
+    const randomString = `hello ${Math.random()}`;
+    const response: any = await testSmartsocketClient.serverCall('testFunction1', {
+      value1: randomString,
+    });
+    expect(response.value1).toEqual(randomString);
+    if (counter % 100 === 0) {
+      console.log(
+        `processed 100 more messages in ${Date.now() - startTime}ms. ${
+          totalCycles - counter
+        } messages to go.`
+      );
+      startTime = Date.now();
+    }
+    counter++;
+  }
 });

 tap.test('should be able to make a functionCall from server to client', async () => {});
--- a/test/test.reconnect.ts
+++ b/test/test.reconnect.ts
@ -0,0 +1,152 @@
+// tslint:disable-next-line:no-implicit-dependencies
+import { expect, tap } from '@pushrocks/tapbundle';
+
+import * as smartsocket from '../ts/index.js';
+
+let testSmartsocket: smartsocket.Smartsocket;
+let testSmartsocketClient: smartsocket.SmartsocketClient;
+let testSocketFunctionForServer: smartsocket.SocketFunction<any>;
+let testSocketFunctionClient: smartsocket.SocketFunction<any>;
+
+export interface IReqResClient {
+  method: 'testFunction1';
+  request: {
+    value1: string;
+  };
+  response: {
+    value1: string;
+  };
+}
+
+export interface IReqResServer {
+  method: 'testFunction2';
+  request: {
+    hi: string;
+  };
+  response: {
+    hi: string;
+  };
+}
+
+const testConfig = {
+  port: 3000,
+};
+
+// class smartsocket
+tap.test('should create a new smartsocket', async () => {
+  testSmartsocket = new smartsocket.Smartsocket({ alias: 'testserver1', port: testConfig.port });
+  await testSmartsocket.start();
+});
+
+// class SocketFunction
+tap.test('should register a new Function', async () => {
+  testSocketFunctionForServer = new smartsocket.SocketFunction({
+    funcDef: async (dataArg, socketConnectionArg) => {
+      return dataArg;
+    },
+    funcName: 'testFunction1',
+  });
+  testSmartsocket.addSocketFunction(testSocketFunctionForServer);
+
+  testSocketFunctionClient = new smartsocket.SocketFunction({
+    funcDef: async (dataArg, socketConnectionArg) => {
+      return dataArg;
+    },
+    funcName: 'testFunction2',
+  });
+  testSmartsocket.addSocketFunction(testSocketFunctionForServer);
+});
+
+// class SmartsocketClient
+tap.test('should react to a new websocket connection from client', async () => {
+  testSmartsocketClient = new smartsocket.SmartsocketClient({
+    port: testConfig.port,
+    url: 'http://localhost',
+    alias: 'testClient1',
+    autoReconnect: true,
+  });
+  testSmartsocketClient.addSocketFunction(testSocketFunctionClient);
+  await testSmartsocketClient.connect();
+});
+
+tap.test('should be able to tag a connection from client', async (tools) => {
+  await testSmartsocketClient.addTag({
+    id: 'awesome',
+    payload: 'yes',
+  });
+  const tagOnServerSide = await testSmartsocket.socketConnections
+    .findSync((socketConnection) => {
+      return true;
+    })
+    .getTagById('awesome');
+  expect(tagOnServerSide.payload).toEqual('yes');
+});
+
+tap.test('should be able to tag a connection from server', async (tools) => {
+  await testSmartsocket.socketConnections
+    .findSync((socketConnection) => {
+      return true;
+    })
+    .addTag({
+      id: 'awesome2',
+      payload: 'absolutely',
+    });
+  const tagOnClientSide = await testSmartsocketClient.socketConnection.getTagById('awesome2');
+  expect(tagOnClientSide.payload).toEqual('absolutely');
+});
+
+tap.test('should be able to make a functionCall from client to server', async () => {
+  const response = await testSmartsocketClient.serverCall<IReqResClient>('testFunction1', {
+    value1: 'hello',
+  });
+  console.log(response);
+  expect(response.value1).toEqual('hello');
+});
+
+tap.test('should be able to make a functionCall from server to client', async () => {
+  const response = await testSmartsocket.clientCall<IReqResServer>(
+    'testFunction2',
+    {
+      hi: 'hi there from server',
+    },
+    testSmartsocket.socketConnections.findSync((socketConnection) => {
+      return true;
+    })
+  );
+  console.log(response);
+  expect(response.hi).toEqual('hi there from server');
+});
+
+tap.test('client should disconnect and reconnect', async (toolsArg) => {
+  await testSmartsocketClient.disconnect();
+  await testSmartsocketClient.connect();
+  await toolsArg.delayFor(2000);
+  expect(testSmartsocket.socketConnections.getArray().length).toEqual(1);
+});
+
+// class smartsocket
+tap.test('should be able to switch to a new server', async (toolsArg) => {
+  await testSmartsocket.stop();
+  testSmartsocket = new smartsocket.Smartsocket({ alias: 'testserver2', port: testConfig.port });
+  await testSmartsocket.start();
+  await toolsArg.delayFor(30000);
+});
+
+tap.test('should be able to locate a connection tag after reconnect', async (tools) => {
+  expect(testSmartsocket.socketConnections.getArray().length).toEqual(1);
+  const tagOnServerSide = await testSmartsocket.socketConnections
+    .findSync((socketConnection) => {
+      return true;
+    })
+    .getTagById('awesome');
+  expect(tagOnServerSide.payload).toEqual('yes');
+});
+
+// terminate
+tap.test('should close the server', async (tools) => {
+  await testSmartsocketClient.stop();
+  await testSmartsocket.stop();
+  tools.delayFor(1000).then(() => process.exit(0));
+});
+
+tap.start();
--- a/test/test.tagging.ts
+++ b/test/test.tagging.ts
@ -1,16 +1,10 @@
 // tslint:disable-next-line:no-implicit-dependencies
 import { expect, tap } from '@pushrocks/tapbundle';

-import * as smarthash from '@pushrocks/smarthash';
-import * as smartpromise from '@pushrocks/smartpromise';
-
-import socketIoClient = require('socket.io-client');
-import smartsocket = require('../ts/index');
+import * as smartsocket from '../ts/index.js';

 let testSmartsocket: smartsocket.Smartsocket;
 let testSmartsocketClient: smartsocket.SmartsocketClient;
-let testSocketConnection: smartsocket.SocketConnection;
-let testSocketRole1: smartsocket.SocketRole;
 let testSocketFunctionForServer: smartsocket.SocketFunction<any>;
 let testSocketFunctionClient: smartsocket.SocketFunction<any>;

@ -40,23 +34,13 @@ const testConfig = {

 // class smartsocket
 tap.test('should create a new smartsocket', async () => {
-  testSmartsocket = new smartsocket.Smartsocket({ port: testConfig.port });
-  expect(testSmartsocket).be.instanceOf(smartsocket.Smartsocket);
-});
-
-// class socketrole
-tap.test('should add a socketrole', async () => {
-  testSocketRole1 = new smartsocket.SocketRole({
-    name: 'testRole1',
-    passwordHash: smarthash.sha256FromStringSync('testPassword'),
-  });
-  testSmartsocket.addSocketRoles([testSocketRole1]);
+  testSmartsocket = new smartsocket.Smartsocket({ alias: 'testserver2', port: testConfig.port });
+  expect(testSmartsocket).toBeInstanceOf(smartsocket.Smartsocket);
 });

 // class SocketFunction
 tap.test('should register a new Function', async () => {
  testSocketFunctionForServer = new smartsocket.SocketFunction({
-    allowedRoles: [testSocketRole1],
    funcDef: async (dataArg, socketConnectionArg) => {
      return dataArg;
    },
@ -65,14 +49,12 @@ tap.test('should register a new Function', async () => {
  testSmartsocket.addSocketFunction(testSocketFunctionForServer);

  testSocketFunctionClient = new smartsocket.SocketFunction({
-    allowedRoles: [],
    funcDef: async (dataArg, socketConnectionArg) => {
      return dataArg;
    },
    funcName: 'testFunction2',
  });
  testSmartsocket.addSocketFunction(testSocketFunctionForServer);
-  console.log(testSmartsocket.socketFunctions);
 });

 tap.test('should start listening when .started is called', async () => {
@ -84,15 +66,38 @@ tap.test('should react to a new websocket connection from client', async () => {
  testSmartsocketClient = new smartsocket.SmartsocketClient({
    port: testConfig.port,
    url: 'http://localhost',
-    password: 'testPassword',
    alias: 'testClient1',
-    role: 'testRole1',
  });
  testSmartsocketClient.addSocketFunction(testSocketFunctionClient);
-  console.log(testSmartsocketClient.socketFunctions);
  await testSmartsocketClient.connect();
 });

+tap.test('should be able to tag a connection from client', async (tools) => {
+  await testSmartsocketClient.addTag({
+    id: 'awesome',
+    payload: 'yes',
+  });
+  const tagOnServerSide = await testSmartsocket.socketConnections
+    .findSync((socketConnection) => {
+      return true;
+    })
+    .getTagById('awesome');
+  expect(tagOnServerSide.payload).toEqual('yes');
+});
+
+tap.test('should be able to tag a connection from server', async (tools) => {
+  await testSmartsocket.socketConnections
+    .findSync((socketConnection) => {
+      return true;
+    })
+    .addTag({
+      id: 'awesome2',
+      payload: 'absolutely',
+    });
+  const tagOnClientSide = await testSmartsocketClient.socketConnection.getTagById('awesome2');
+  expect(tagOnClientSide.payload).toEqual('absolutely');
+});
+
 tap.test('2 clients should connect in parallel', async () => {
  // TODO: implement parallel test
 });
@ -102,7 +107,7 @@ tap.test('should be able to make a functionCall from client to server', async ()
    value1: 'hello',
  });
  console.log(response);
-  expect(response.value1).to.equal('hello');
+  expect(response.value1).toEqual('hello');
 });

 tap.test('should be able to make a functionCall from server to client', async () => {
@ -111,20 +116,29 @@ tap.test('should be able to make a functionCall from server to client', async ()
    {
      hi: 'hi there from server',
    },
-    testSmartsocket.socketConnections.find((socketConnection) => {
+    testSmartsocket.socketConnections.findSync((socketConnection) => {
      return true;
    })
  );
  console.log(response);
-  expect(response.hi).to.equal('hi there from server');
+  expect(response.hi).toEqual('hi there from server');
 });

 tap.test('client should disconnect and reconnect', async (tools) => {
  await testSmartsocketClient.disconnect();
-  await tools.delayFor(100);
  await testSmartsocketClient.connect();
 });

+tap.test('should be able to locate a connection tag after reconnect', async (tools) => {
+  console.log(testSmartsocket.socketConnections.getArray().length);
+  const tagOnServerSide = await testSmartsocket.socketConnections
+    .findSync((socketConnection) => {
+      return true;
+    })
+    .getTagById('awesome');
+  expect(tagOnServerSide.payload).toEqual('yes');
+});
+
 // terminate
 tap.test('should close the server', async () => {
  await testSmartsocket.stop();
--- a/ts/index.ts
+++ b/ts/index.ts
@ -1,8 +1,7 @@
 // export main classes
-export * from './smartsocket.classes.smartsocket';
-export * from './smartsocket.classes.smartsocketclient';
+export * from './smartsocket.classes.smartsocket.js';
+export * from './smartsocket.classes.smartsocketclient.js';

 // export further classes and objects
-export * from './smartsocket.classes.socketfunction';
-export * from './smartsocket.classes.socketrole';
-export * from './smartsocket.classes.socketconnection';
+export * from './smartsocket.classes.socketfunction.js';
+export * from './smartsocket.classes.socketconnection.js';
--- a/ts/interfaces/connection.ts
+++ b/ts/interfaces/connection.ts
@ -1,5 +1,5 @@
 export interface IRequestAuthPayload {
-  serverShortId: string;
+  serverAlias: string;
 }

 export type TConnectionStatus =
@ -7,4 +7,5 @@ export type TConnectionStatus =
  | 'connecting'
  | 'connected'
  | 'disconnecting'
-  | 'disconnected';
+  | 'disconnected'
+  | 'timedOut';
--- a/ts/interfaces/index.ts
+++ b/ts/interfaces/index.ts
@ -1 +1,2 @@
-export * from './connection';
+export * from './connection.js';
+export * from './tag.js';
--- a/ts/interfaces/tag.ts
+++ b/ts/interfaces/tag.ts
@ -0,0 +1,6 @@
+export interface ITag<T = any> {
+  id: string;
+  payload: T;
+}
+
+export type TTagStore = { [key: string]: ITag };
--- a/ts/smartsocket.classes.smartsocket.ts
+++ b/ts/smartsocket.classes.smartsocket.ts
@ -1,21 +1,20 @@
-import * as plugins from './smartsocket.plugins';
+import * as plugins from './smartsocket.plugins.js';
+import * as pluginsTyped from './smartsocket.pluginstyped.js';

 // classes
-import { SocketConnection } from './smartsocket.classes.socketconnection';
+import { SocketConnection } from './smartsocket.classes.socketconnection.js';
 import {
  ISocketFunctionCallDataRequest,
  SocketFunction,
  ISocketFunctionCallDataResponse,
-} from './smartsocket.classes.socketfunction';
-import { SocketRequest } from './smartsocket.classes.socketrequest';
-import { SocketRole } from './smartsocket.classes.socketrole';
-import { SocketServer } from './smartsocket.classes.socketserver';
+} from './smartsocket.classes.socketfunction.js';
+import { SocketRequest } from './smartsocket.classes.socketrequest.js';
+import { SocketServer } from './smartsocket.classes.socketserver.js';

-// socket.io
-import * as SocketIO from 'socket.io';
-import { logger } from './smartsocket.logging';
+import { logger } from './smartsocket.logging.js';

 export interface ISmartsocketConstructorOptions {
+  alias: string;
  port?: number;
 }

@ -23,11 +22,11 @@ export class Smartsocket {
  /**
   * a unique id to detect server restarts
   */
-  public shortId = plugins.smartunique.shortId();
+  public alias: string;
+  public smartenv = new plugins.smartenv.Smartenv();
  public options: ISmartsocketConstructorOptions;
-  public io: SocketIO.Server;
+  public io: pluginsTyped.socketIo.Server;
  public socketConnections = new plugins.lik.ObjectMap<SocketConnection>();
-  public socketRoles = new plugins.lik.ObjectMap<SocketRole>();
  public socketFunctions = new plugins.lik.ObjectMap<SocketFunction<any>>();
  public socketRequests = new plugins.lik.ObjectMap<SocketRequest<any>>();

@ -35,6 +34,7 @@ export class Smartsocket {

  constructor(optionsArg: ISmartsocketConstructorOptions) {
    this.options = optionsArg;
+    this.alias = plugins.isounique.uni(this.options.alias);
  }

  // tslint:disable-next-line:member-ordering
@ -46,7 +46,8 @@ export class Smartsocket {
   * starts smartsocket
   */
  public async start() {
-    this.io = plugins.socketIo(this.socketServer.getServerForSocketIo());
+    const socketIoModule = await this.smartenv.getSafeNodeModule('socket.io');
+    this.io = new socketIoModule.Server(await this.socketServer.getServerForSocketIo());
    await this.socketServer.start();
    this.io.on('connection', (socketArg) => {
      this._handleSocketConnection(socketArg);
@ -59,8 +60,10 @@ export class Smartsocket {
  public async stop() {
    await plugins.smartdelay.delayFor(1000);
    this.socketConnections.forEach((socketObjectArg: SocketConnection) => {
-      logger.log('info', `disconnect socket with >>alias ${socketObjectArg.alias}`);
-      socketObjectArg.socket.disconnect();
+      if (socketObjectArg) {
+        logger.log('info', `disconnecting socket with >>alias ${socketObjectArg.alias} due to server stop...`);
+        socketObjectArg.disconnect();
+      }
    });
    this.socketConnections.wipe();
    this.io.close();
@ -85,7 +88,7 @@ export class Smartsocket {
        funcName: functionNameArg,
      },
      originSocketConnection: targetSocketConnectionArg,
-      shortId: plugins.smartunique.shortId(),
+      shortId: plugins.isounique.uni(),
      side: 'requesting',
    });
    const response: ISocketFunctionCallDataResponse<T> = await socketRequest.dispatch();
@ -93,16 +96,6 @@ export class Smartsocket {
    return result;
  }

-  /**
-   * adds socketRoles
-   */
-  public addSocketRoles(socketRolesArray: SocketRole[]): void {
-    for (const socketRole of socketRolesArray) {
-      this.socketRoles.add(socketRole);
-    }
-    return;
-  }
-
  public addSocketFunction(socketFunction: SocketFunction<any>) {
    this.socketFunctions.add(socketFunction);
  }
@ -110,18 +103,24 @@ export class Smartsocket {
  /**
   * the standard handler for new socket connections
   */
-  private async _handleSocketConnection(socketArg: plugins.socketIo.Socket) {
+  private async _handleSocketConnection(socketArg: pluginsTyped.socketIo.Socket) {
    const socketConnection: SocketConnection = new SocketConnection({
      alias: undefined,
      authenticated: false,
-      role: undefined,
      side: 'server',
      smartsocketHost: this,
      socket: socketArg,
    });
    logger.log('info', 'Socket connected. Trying to authenticate...');
    this.socketConnections.add(socketConnection);
+    const disconnectSubscription = socketConnection.eventSubject.subscribe((eventArg) => {
+      if (eventArg === 'disconnected') {
+        this.socketConnections.remove(socketConnection);
+        disconnectSubscription.unsubscribe();
+      }
+    });
    await socketConnection.authenticate();
    await socketConnection.listenToFunctionRequests();
+    await socketConnection.socket.emit('serverFullyReactive');
  }
 }
--- a/ts/smartsocket.classes.smartsocketclient.ts
+++ b/ts/smartsocket.classes.smartsocketclient.ts
@ -1,14 +1,14 @@
-import * as plugins from './smartsocket.plugins';
-import * as interfaces from './interfaces';
+import * as plugins from './smartsocket.plugins.js';
+import * as pluginsTyped from './smartsocket.pluginstyped.js';
+import * as interfaces from './interfaces/index.js';

-import { SocketConnection } from './smartsocket.classes.socketconnection';
+import { SocketConnection } from './smartsocket.classes.socketconnection.js';
 import {
  ISocketFunctionCallDataRequest,
  SocketFunction,
-} from './smartsocket.classes.socketfunction';
-import { ISocketRequestDataObject, SocketRequest } from './smartsocket.classes.socketrequest';
-import { SocketRole } from './smartsocket.classes.socketrole';
-import { logger } from './smartsocket.logging';
+} from './smartsocket.classes.socketfunction.js';
+import { ISocketRequestDataObject, SocketRequest } from './smartsocket.classes.socketrequest.js';
+import { logger } from './smartsocket.logging.js';

 /**
 * interface for class SmartsocketClient
@ -17,20 +17,17 @@ export interface ISmartsocketClientOptions {
  port: number;
  url: string;
  alias: string; // an alias makes it easier to identify this client in a multo client environment
-  role: string;
-  password: string; // by setting a password access to functions can be limited
  autoReconnect?: boolean;
 }

 export class SmartsocketClient {
  // a unique id
-  public shortId = plugins.smartunique.shortId();
+  public shortId = plugins.isounique.uni();

  // the shortId of the remote we connect to
  public remoteShortId: string = null;

  public alias: string;
-  public socketRole: SocketRole;
  public socketConnection: SocketConnection;
  public serverUrl: string;
  public serverPort: number;
@ -42,124 +39,194 @@ export class SmartsocketClient {

  public socketFunctions = new plugins.lik.ObjectMap<SocketFunction<any>>();
  public socketRequests = new plugins.lik.ObjectMap<SocketRequest<any>>();
-  public socketRoles = new plugins.lik.ObjectMap<SocketRole>();
+
+  // tagStore
+  private tagStore: { [key: string]: interfaces.ITag } = {};
+  private tagStoreSubscription: plugins.smartrx.rxjs.Subscription;
+
+  /**
+   * adds a tag to a connection
+   */
+  public async addTag(tagArg: interfaces.ITag) {
+    if (this.socketConnection) {
+      await this.socketConnection.addTag(tagArg);
+    } else {
+      this.tagStore[tagArg.id] = tagArg;
+    }
+  }
+
+  /**
+   * gets a tag by id
+   * @param tagIdArg
+   */
+  public async getTagById(tagIdArg: interfaces.ITag['id']) {
+    return this.tagStore[tagIdArg];
+  }
+
+  /**
+   * removes a tag from a connection
+   */
+  public async removeTagById(tagIdArg: interfaces.ITag['id']) {
+    if (this.socketConnection) {
+      this.socketConnection.removeTagById(tagIdArg);
+    } else {
+      delete this.tagStore[tagIdArg];
+    }
+  }

  constructor(optionsArg: ISmartsocketClientOptions) {
    this.alias = optionsArg.alias;
    this.serverUrl = optionsArg.url;
    this.serverPort = optionsArg.port;
-    this.socketRole = new SocketRole({
-      name: optionsArg.role,
-      passwordHash: optionsArg.password,
-    });
    this.autoReconnect = optionsArg.autoReconnect;
  }

  public addSocketFunction(socketFunction: SocketFunction<any>) {
    this.socketFunctions.add(socketFunction);
-    this.socketRole.allowedFunctions.add(socketFunction);
  }

  /**
   * connect the client to the server
   */
-  public connect() {
+  public async connect() {
    const done = plugins.smartpromise.defer();
+    const smartenvInstance = new plugins.smartenv.Smartenv();
+    const socketIoClient: any = await smartenvInstance.getEnvAwareModule({
+      nodeModuleName: 'socket.io-client',
+      webUrlArg: 'https://cdn.jsdelivr.net/npm/socket.io-client@4/dist/socket.io.js',
+      getFunction: () => {
+        return (globalThis as any).io;
+      },
+    });
    logger.log('info', 'trying to connect...');
    const socketUrl = `${this.serverUrl}:${this.serverPort}`;
    this.socketConnection = new SocketConnection({
      alias: this.alias,
      authenticated: false,
-      role: this.socketRole,
      side: 'client',
      smartsocketHost: this,
-      socket: plugins.socketIoClient(socketUrl, {
-        multiplex: false,
-        reconnectionAttempts: 5,
-      }),
+      socket: await socketIoClient
+        .connect(socketUrl, {
+          multiplex: false,
+          autoConnect: false,
+          reconnectionAttempts: 0,
+          rejectUnauthorized: socketUrl.startsWith('https://localhost') ? false : true,
+        })
+        .open(),
    });

    const timer = new plugins.smarttime.Timer(5000);
    timer.start();
    timer.completed.then(() => {
+      this.updateStatus('timedOut');
      logger.log('warn', 'connection to server timed out.');
-      this.disconnect();
+      this.disconnect(true);
    });

    // authentication flow
-    this.socketConnection.socket.on(
-      'requestAuth',
-      (requestAuthPayload: interfaces.IRequestAuthPayload) => {
-        timer.reset();
-        logger.log('info', 'server requested authentication');
+    this.socketConnection.socket.on('requestAuth', (dataArg: interfaces.IRequestAuthPayload) => {
+      timer.reset();
+      logger.log('info', `server ${dataArg.serverAlias} requested authentication`);

-        // lets register the authenticated event
-        this.socketConnection.socket.on('authenticated', () => {
-          this.remoteShortId = requestAuthPayload.serverShortId;
-          logger.log('info', 'client is authenticated');
-          this.socketConnection.authenticated = true;
-          this.socketConnection.listenToFunctionRequests();
-          done.resolve();
-        });
+      // lets register the authenticated event
+      this.socketConnection.socket.on('authenticated', async () => {
+        this.remoteShortId = dataArg.serverAlias;
+        logger.log('info', 'client is authenticated');
+        this.socketConnection.authenticated = true;
+        await this.socketConnection.listenToFunctionRequests();
+      });

-        // lets register the forbidden event
-        this.socketConnection.socket.on('forbidden', async () => {
-          logger.log('warn', `disconnecting due to being forbidden to use the ressource`);
-          await this.disconnect();
-        });
+      this.socketConnection.socket.on('serverFullyReactive', async () => {
+        // lets take care of retagging
+        const oldTagStore = this.tagStore;
+        this.tagStoreSubscription?.unsubscribe();
+        for (const keyArg of Object.keys(this.tagStore)) {
+          this.socketConnection.addTag(this.tagStore[keyArg]);
+        }
+        this.tagStoreSubscription = this.socketConnection.tagStoreObservable.subscribe(
+          (tagStoreArg) => {
+            this.tagStore = tagStoreArg;
+          }
+        );

-        // lets provide the actual auth data
-        this.socketConnection.socket.emit('dataAuth', {
-          role: this.socketRole.name,
-          password: this.socketRole.passwordHash,
-          alias: this.alias,
-        });
-      }
-    );
+        for (const tag of Object.keys(oldTagStore)) {
+          await this.addTag(oldTagStore[tag]);
+        }
+        this.updateStatus('connected');
+        done.resolve();
+      });
+
+      // lets register the forbidden event
+      this.socketConnection.socket.on('forbidden', async () => {
+        logger.log('warn', `disconnecting due to being forbidden to use the ressource`);
+        await this.disconnect();
+      });
+
+      // lets provide the actual auth data
+      this.socketConnection.socket.emit('dataAuth', {
+        alias: this.alias,
+      });
+    });

    // handle connection
-    this.socketConnection.socket.on('connect', async () => {
-      this.updateStatus('connected');
-    });
+    this.socketConnection.socket.on('connect', async () => {});

    // handle disconnection and errors
    this.socketConnection.socket.on('disconnect', async () => {
-      await this.disconnect();
+      await this.disconnect(true);
    });

    this.socketConnection.socket.on('reconnect_failed', async () => {
-      await this.disconnect();
+      await this.disconnect(true);
    });
    this.socketConnection.socket.on('connect_error', async () => {
-      await this.disconnect();
+      await this.disconnect(true);
    });
    return done.promise;
  }

+  private disconnectRunning = false;
+
  /**
   * disconnect from the server
   */
-  public async disconnect() {
+  public async disconnect(useAutoReconnectSetting = false) {
+    if (this.disconnectRunning) {
+      return;
+    }
+    this.disconnectRunning = true;
+    this.updateStatus('disconnecting');
+    this.tagStoreSubscription?.unsubscribe();
    if (this.socketConnection) {
      await this.socketConnection.disconnect();
      this.socketConnection = undefined;
-      logger.log('ok', 'disconnected!');
+      logger.log('ok', 'disconnected socket!');
+    } else {
+      this.disconnectRunning = false;
+      logger.log('warn', 'tried to disconnect, without a SocketConnection');
+      return;
    }
+
    logger.log('warn', `disconnected from server ${this.remoteShortId}`);
    this.remoteShortId = null;
-    this.updateStatus('disconnected');

-    if (this.autoReconnect) {
-      this.tryDebouncedReconnect();
+    if (this.autoReconnect && useAutoReconnectSetting && this.eventStatus !== 'connecting') {
+      this.updateStatus('connecting');
+      console.log('debounced reconnect!');
+      await plugins.smartdelay.delayForRandom(10000, 20000);
+      this.disconnectRunning = false;
+      await this.connect();
+    } else {
+      this.disconnectRunning = false;
    }
  }

  /**
-   * try a reconnection
+   * stops the client completely
   */
-  public async tryDebouncedReconnect() {
-    await plugins.smartdelay.delayForRandom(10000, 60000);
-    await this.connect();
+  public async stop() {
+    this.autoReconnect = false;
+    await this.disconnect();
  }

  /**
@ -175,7 +242,7 @@ export class SmartsocketClient {
    const socketRequest = new SocketRequest<T>(this, {
      side: 'requesting',
      originSocketConnection: this.socketConnection,
-      shortId: plugins.smartunique.shortId(),
+      shortId: plugins.isounique.uni(),
      funcCallData: {
        funcName: functionNameArg,
        funcDataArg: dataArg,
--- a/ts/smartsocket.classes.socketconnection.ts
+++ b/ts/smartsocket.classes.socketconnection.ts
@ -1,16 +1,15 @@
-import * as plugins from './smartsocket.plugins';
-import * as interfaces from './interfaces';
+import * as plugins from './smartsocket.plugins.js';
+import * as pluginsTyped from './smartsocket.pluginstyped.js';
+import * as interfaces from './interfaces/index.js';

 // import classes
-import { Smartsocket } from './smartsocket.classes.smartsocket';
-import { SocketFunction } from './smartsocket.classes.socketfunction';
-import { SocketRequest, ISocketRequestDataObject } from './smartsocket.classes.socketrequest';
-import { SocketRole } from './smartsocket.classes.socketrole';
+import { Smartsocket } from './smartsocket.classes.smartsocket.js';
+import { SocketFunction } from './smartsocket.classes.socketfunction.js';
+import { SocketRequest, ISocketRequestDataObject } from './smartsocket.classes.socketrequest.js';

 // socket.io
-import * as SocketIO from 'socket.io';
-import { SmartsocketClient } from './smartsocket.classes.smartsocketclient';
-import { logger } from './smartsocket.logging';
+import { SmartsocketClient } from './smartsocket.classes.smartsocketclient.js';
+import { logger } from './smartsocket.logging.js';

 // export interfaces

@ -25,19 +24,16 @@ export type TSocketConnectionSide = 'server' | 'client';
 export interface ISocketConnectionConstructorOptions {
  alias: string;
  authenticated: boolean;
-  role: SocketRole;
  side: TSocketConnectionSide;
  smartsocketHost: Smartsocket | SmartsocketClient;
-  socket: SocketIO.Socket | SocketIOClient.Socket;
+  socket: pluginsTyped.socketIo.Socket | pluginsTyped.socketIoClient.Socket;
 }

 /**
 * interface for authentication data
 */
 export interface ISocketConnectionAuthenticationObject {
-  role: 'coreflowContainer';
-  password: 'somePassword';
-  alias: 'coreflow1';
+  alias: string;
 }

 // export classes
@ -50,17 +46,19 @@ export class SocketConnection {
  public alias: string;
  public side: TSocketConnectionSide;
  public authenticated: boolean = false;
-  public role: SocketRole;
  public smartsocketRef: Smartsocket | SmartsocketClient;
-  public socket: SocketIO.Socket | SocketIOClient.Socket;
+  public socket: pluginsTyped.socketIo.Socket | pluginsTyped.socketIoClient.Socket;

  public eventSubject = new plugins.smartrx.rxjs.Subject<interfaces.TConnectionStatus>();
  public eventStatus: interfaces.TConnectionStatus = 'new';

+  private tagStore: interfaces.TTagStore = {};
+  public tagStoreObservable = new plugins.smartrx.rxjs.Subject<interfaces.TTagStore>();
+  public remoteTagStoreObservable = new plugins.smartrx.rxjs.Subject<interfaces.TTagStore>();
+
  constructor(optionsArg: ISocketConnectionConstructorOptions) {
    this.alias = optionsArg.alias;
    this.authenticated = optionsArg.authenticated;
-    this.role = optionsArg.role;
    this.side = optionsArg.side;
    this.smartsocketRef = optionsArg.smartsocketHost;
    this.socket = optionsArg.socket;
@ -79,9 +77,49 @@ export class SocketConnection {
      );
      await this.disconnect();
      allSocketConnections.remove(this);
+      this.eventSubject.next('disconnected');
    });
  }

+  /**
+   * adds a tag to a connection
+   */
+  public async addTag(tagArg: interfaces.ITag) {
+    const done = plugins.smartpromise.defer();
+    this.tagStore[tagArg.id] = tagArg;
+    this.tagStoreObservable.next(this.tagStore);
+    const remoteSubscription = this.remoteTagStoreObservable.subscribe((remoteTagStore) => {
+      if (!remoteTagStore[tagArg.id]) {
+        return;
+      }
+      const localTagString = plugins.smartjson.stringify(tagArg);
+      const remoteTagString = plugins.smartjson.stringify(remoteTagStore[tagArg.id]);
+      if (localTagString === remoteTagString) {
+        remoteSubscription.unsubscribe();
+        done.resolve();
+      }
+    });
+    this.socket.emit('updateTagStore', this.tagStore);
+    await done.promise;
+  }
+
+  /**
+   * gets a tag by id
+   * @param tagIdArg
+   */
+  public async getTagById(tagIdArg: interfaces.ITag['id']) {
+    return this.tagStore[tagIdArg];
+  }
+
+  /**
+   * removes a tag from a connection
+   */
+  public async removeTagById(tagIdArg: interfaces.ITag['id']) {
+    delete this.tagStore[tagIdArg];
+    this.tagStoreObservable.next(this.tagStore);
+    this.socket.emit('updateTagStore', this.tagStore);
+  }
+
  // authenticating --------------------------

  /**
@ -90,24 +128,23 @@ export class SocketConnection {
  public authenticate() {
    const done = plugins.smartpromise.defer();
    this.socket.on('dataAuth', async (dataArg: ISocketConnectionAuthenticationObject) => {
-      logger.log('info', 'received authentication data. now hashing and comparing...');
-      this.socket.removeListener('dataAuth', () => {});
-      if (SocketRole.checkPasswordForRole(dataArg, this.smartsocketRef)) {
+      logger.log('info', 'received authentication data...');
+      this.socket.removeAllListeners('dataAuth');
+      if (dataArg.alias) {
        // TODO: authenticate password
        this.alias = dataArg.alias;
        this.authenticated = true;
-        this.role = SocketRole.getSocketRoleByName(this.smartsocketRef, dataArg.role);
        this.socket.emit('authenticated');
-        logger.log('ok', `socket with >>alias ${this.alias} >>role ${this.role} is authenticated!`);
+        logger.log('ok', `socket with >>alias ${this.alias} is authenticated!`);
        done.resolve(this);
      } else {
        this.authenticated = false;
        await this.disconnect();
-        done.reject('not authenticated');
+        done.reject('a socket tried to connect, but could not authenticated.');
      }
    });
    const requestAuthPayload: interfaces.IRequestAuthPayload = {
-      serverShortId: this.smartsocketRef.shortId,
+      serverAlias: this.smartsocketRef.alias,
    };
    this.socket.emit('requestAuth', requestAuthPayload);
    return done.promise;
@ -123,14 +160,14 @@ export class SocketConnection {
    if (this.authenticated) {
      this.socket.on('function', (dataArg: ISocketRequestDataObject<any>) => {
        // check if requested function is available to the socket's scope
-        logger.log('info', 'function request received');
-        const referencedFunction: SocketFunction<any> = this.role.allowedFunctions.find(
+        // logger.log('info', 'function request received');
+        const referencedFunction: SocketFunction<any> = this.smartsocketRef.socketFunctions.findSync(
          (socketFunctionArg) => {
            return socketFunctionArg.name === dataArg.funcCallData.funcName;
          }
        );
        if (referencedFunction) {
-          logger.log('ok', 'function in access scope');
+          // logger.log('ok', 'function in access scope');
          const localSocketRequest = new SocketRequest(this.smartsocketRef, {
            side: 'responding',
            originSocketConnection: this,
@ -143,14 +180,24 @@ export class SocketConnection {
        }
      });
      this.socket.on('functionResponse', (dataArg: ISocketRequestDataObject<any>) => {
-        logger.log('info', `received response for request with id ${dataArg.shortId}`);
+        // logger.log('info', `received response for request with id ${dataArg.shortId}`);
        const targetSocketRequest = SocketRequest.getSocketRequestById(
          this.smartsocketRef,
          dataArg.shortId
        );
        targetSocketRequest.handleResponse(dataArg);
      });
-      logger.log('info', `now listening to function requests for ${this.alias}`);
+
+      this.socket.on('updateTagStore', async (tagStoreArg: interfaces.TTagStore) => {
+        if (!plugins.smartjson.deepEqualObjects(this.tagStore, tagStoreArg)) {
+          this.tagStore = tagStoreArg;
+          this.socket.emit('updateTagStore', this.tagStore);
+          this.tagStoreObservable.next(this.tagStore);
+        }
+        this.remoteTagStoreObservable.next(tagStoreArg);
+      });
+
+      logger.log('info', `now listening to function requests for ${this.alias} on side ${this.side}`);
      done.resolve(this);
    } else {
      const errMessage = 'socket needs to be authenticated first';
--- a/ts/smartsocket.classes.socketfunction.ts
+++ b/ts/smartsocket.classes.socketfunction.ts
@ -1,10 +1,9 @@
-import * as plugins from './smartsocket.plugins';
+import * as plugins from './smartsocket.plugins.js';

 // import classes
-import { SocketRole } from './smartsocket.classes.socketrole';
-import { SocketConnection } from './smartsocket.classes.socketconnection';
-import { Smartsocket } from './smartsocket.classes.smartsocket';
-import { SmartsocketClient } from './smartsocket.classes.smartsocketclient';
+import { SocketConnection } from './smartsocket.classes.socketconnection.js';
+import { Smartsocket } from './smartsocket.classes.smartsocket.js';
+import { SmartsocketClient } from './smartsocket.classes.smartsocketclient.js';

 // export interfaces

@ -16,7 +15,6 @@ export interface ISocketFunctionConstructorOptions<
 > {
  funcName: T['method'];
  funcDef: TFuncDef<T>;
-  allowedRoles: SocketRole[]; // all roles that are allowed to execute a SocketFunction
 }

 /**
@ -58,7 +56,7 @@ export class SocketFunction<T extends plugins.typedrequestInterfaces.ITypedReque
    smartsocketRefArg: Smartsocket | SmartsocketClient,
    functionNameArg: string
  ): SocketFunction<Q> {
-    return smartsocketRefArg.socketFunctions.find((socketFunctionArg) => {
+    return smartsocketRefArg.socketFunctions.findSync((socketFunctionArg) => {
      return socketFunctionArg.name === functionNameArg;
    });
  }
@ -66,7 +64,6 @@ export class SocketFunction<T extends plugins.typedrequestInterfaces.ITypedReque
  // INSTANCE
  public name: string;
  public funcDef: TFuncDef<T>;
-  public roles: SocketRole[];

  /**
   * the constructor for SocketFunction
@ -74,10 +71,6 @@ export class SocketFunction<T extends plugins.typedrequestInterfaces.ITypedReque
  constructor(optionsArg: ISocketFunctionConstructorOptions<T>) {
    this.name = optionsArg.funcName;
    this.funcDef = optionsArg.funcDef;
-    this.roles = optionsArg.allowedRoles;
-    for (const socketRoleArg of this.roles) {
-      this._notifyRole(socketRoleArg);
-    }
  }

  /**
@ -97,11 +90,4 @@ export class SocketFunction<T extends plugins.typedrequestInterfaces.ITypedReque
      throw new Error("SocketFunction.name does not match the data argument's .name!");
    }
  }
-
-  /**
-   * notifies a role about access to this SocketFunction
-   */
-  private _notifyRole(socketRoleArg: SocketRole) {
-    socketRoleArg.addSocketFunction(this);
-  }
 }
--- a/ts/smartsocket.classes.socketrequest.ts
+++ b/ts/smartsocket.classes.socketrequest.ts
@ -1,17 +1,17 @@
-import * as plugins from './smartsocket.plugins';
+import * as plugins from './smartsocket.plugins.js';

 // import interfaces
 import {
  SocketFunction,
  ISocketFunctionCallDataRequest,
  ISocketFunctionCallDataResponse,
-} from './smartsocket.classes.socketfunction';
+} from './smartsocket.classes.socketfunction.js';

 // import classes
-import { SocketConnection } from './smartsocket.classes.socketconnection';
-import { logger } from './smartsocket.logging';
-import { Smartsocket } from './smartsocket.classes.smartsocket';
-import { SmartsocketClient } from './smartsocket.classes.smartsocketclient';
+import { SocketConnection } from './smartsocket.classes.socketconnection.js';
+import { logger } from './smartsocket.logging.js';
+import { Smartsocket } from './smartsocket.classes.smartsocket.js';
+import { SmartsocketClient } from './smartsocket.classes.smartsocketclient.js';

 // export interfaces
 export type TSocketRequestStatus = 'new' | 'pending' | 'finished';
@ -45,7 +45,7 @@ export class SocketRequest<T extends plugins.typedrequestInterfaces.ITypedReques
    smartsocketRef: Smartsocket | SmartsocketClient,
    shortIdArg: string
  ): SocketRequest<any> {
-    return smartsocketRef.socketRequests.find((socketRequestArg) => {
+    return smartsocketRef.socketRequests.findSync((socketRequestArg) => {
      return socketRequestArg.shortid === shortIdArg;
    });
  }
@ -90,7 +90,7 @@ export class SocketRequest<T extends plugins.typedrequestInterfaces.ITypedReques
   * handles the response that is received by the requesting side
   */
  public async handleResponse(responseDataArg: ISocketRequestDataObject<T>) {
-    logger.log('info', 'handling response!');
+    // logger.log('info', 'handling response!');
    this.done.resolve(responseDataArg.funcCallData);
    this.smartsocketRef.socketRequests.remove(this);
  }
@ -107,15 +107,14 @@ export class SocketRequest<T extends plugins.typedrequestInterfaces.ITypedReques
    );

    if (!targetSocketFunction) {
-      logger.log('warn', `There is no SocketFunction defined for ${this.funcCallData.funcName}`);
-      logger.log('warn', `So now response is being sent.`);
+      logger.log('error', `There is no SocketFunction defined for ${this.funcCallData.funcName}`);
      return;
    }
-    logger.log('info', `invoking ${targetSocketFunction.name}`);
+    // logger.log('info', `invoking ${targetSocketFunction.name}`);
    targetSocketFunction
      .invoke(this.funcCallData, this.originSocketConnection)
      .then((resultData) => {
-        logger.log('info', 'got resultData. Sending it to requesting party.');
+        // logger.log('info', 'got resultData. Sending it to requesting party.');
        const responseData: ISocketRequestDataObject<T> = {
          funcCallData: resultData,
          shortId: this.shortid,
--- a/ts/smartsocket.classes.socketrole.ts
+++ b/ts/smartsocket.classes.socketrole.ts
@ -1,57 +0,0 @@
-import * as plugins from './smartsocket.plugins';
-
-// import classes
-import { SocketFunction } from './smartsocket.classes.socketfunction';
-import { Smartsocket } from './smartsocket.classes.smartsocket';
-import { SmartsocketClient } from './smartsocket.classes.smartsocketclient';
-import { ISocketConnectionAuthenticationObject } from './smartsocket.classes.socketconnection';
-
-/**
- * interface for class SocketRole
- */
-export interface ISocketRoleOptions {
-  name: string;
-  passwordHash: string;
-}
-
-/**
- * A socketrole defines access to certain routines.
- */
-export class SocketRole {
-  // STATIC
-  public static getSocketRoleByName(
-    referenceSmartsocket: Smartsocket | SmartsocketClient,
-    socketRoleNameArg: string
-  ): SocketRole {
-    return referenceSmartsocket.socketRoles.find((socketRoleArg) => {
-      return socketRoleArg.name === socketRoleNameArg;
-    });
-  }
-
-  public static checkPasswordForRole(
-    dataArg: ISocketConnectionAuthenticationObject,
-    referenceSmartsocket: Smartsocket | SmartsocketClient
-  ): boolean {
-    const targetPasswordHash = SocketRole.getSocketRoleByName(referenceSmartsocket, dataArg.role)
-      .passwordHash;
-    const computedCompareHash = plugins.smarthash.sha256FromStringSync(dataArg.password);
-    return targetPasswordHash === computedCompareHash;
-  }
-
-  // INSTANCE
-  public name: string;
-  public passwordHash: string;
-  public allowedFunctions = new plugins.lik.ObjectMap<SocketFunction<any>>();
-  constructor(optionsArg: ISocketRoleOptions) {
-    this.name = optionsArg.name;
-    this.passwordHash = optionsArg.passwordHash;
-  }
-
-  /**
-   * adds the socketfunction to the socketrole
-   * @param socketFunctionArg
-   */
-  public addSocketFunction(socketFunctionArg: SocketFunction<any>) {
-    this.allowedFunctions.add(socketFunctionArg);
-  }
-}
--- a/ts/smartsocket.classes.socketserver.ts
+++ b/ts/smartsocket.classes.socketserver.ts
@ -1,10 +1,9 @@
-import * as plugins from './smartsocket.plugins';
+import * as plugins from './smartsocket.plugins.js';
+import * as pluginsTyped from './smartsocket.pluginstyped.js';

 // used in case no other server is supplied
-import * as http from 'http';
-import * as https from 'https';
-import { Smartsocket } from './smartsocket.classes.smartsocket';
-import { logger } from './smartsocket.logging';
+import { Smartsocket } from './smartsocket.classes.smartsocket.js';
+import { logger } from './smartsocket.logging.js';

 /**
 * class socketServer
@ -12,10 +11,13 @@ import { logger } from './smartsocket.logging';
 */
 export class SocketServer {
  private smartsocket: Smartsocket;
-  private httpServer: http.Server | https.Server;
-  // wether httpServer is standalone
+  private httpServerDeferred: plugins.smartpromise.Deferred<any>;
+  private httpServer: pluginsTyped.http.Server | pluginsTyped.https.Server;
+  
+  /**
+   * wether httpServer is standalone
+   */
  private standaloneServer = false;
-  private expressServer: any;

  constructor(smartSocketInstance: Smartsocket) {
    this.smartsocket = smartSocketInstance;
@ -27,20 +29,26 @@ export class SocketServer {
   */
  public async setExternalServer(
    serverType: 'smartexpress',
-    serverArg: plugins.smartexpress.Server
+    serverArg: pluginsTyped.smartexpress.Server
  ) {
+    this.httpServerDeferred = plugins.smartpromise.defer();
    await serverArg.startedPromise;
    this.httpServer = serverArg.httpServer;
+    this.httpServerDeferred.resolve();
  }

  /**
   * gets the server for socket.io
   */
-  public getServerForSocketIo() {
+  public async getServerForSocketIo() {
+    if (this.httpServerDeferred) {
+      await this.httpServerDeferred.promise;
+    }
    if (this.httpServer) {
      return this.httpServer;
    } else {
-      this.httpServer = new http.Server();
+      const httpModule = await this.smartsocket.smartenv.getSafeNodeModule('http');
+      this.httpServer = new httpModule.Server();
      this.standaloneServer = true;
      return this.httpServer;
    }
@ -78,5 +86,9 @@ export class SocketServer {
  /**
   * closes the server
   */
-  public async stop() {}
+  public async stop() {
+    if (this.httpServer) {
+      this.httpServer.close();
+    }
+  }
 }
--- a/ts/smartsocket.logging.ts
+++ b/ts/smartsocket.logging.ts
@ -1,3 +1,3 @@
-import * as plugins from './smartsocket.plugins';
+import * as plugins from './smartsocket.plugins.js';

 export const logger = new plugins.smartlog.ConsoleLog();
--- a/ts/smartsocket.plugins.ts
+++ b/ts/smartsocket.plugins.ts
@ -4,30 +4,26 @@ import * as typedrequestInterfaces from '@apiglobal/typedrequest-interfaces';
 export { typedrequestInterfaces };

 // pushrocks scope
+import * as isohash from '@pushrocks/isohash';
+import * as isounique from '@pushrocks/isounique';
 import * as lik from '@pushrocks/lik';
+import * as smartenv from '@pushrocks/smartenv';
+import * as smartjson from '@pushrocks/smartjson';
 import * as smartlog from '@pushrocks/smartlog';
-import * as smarthash from '@pushrocks/smarthash';
 import * as smartdelay from '@pushrocks/smartdelay';
-import * as smartexpress from '@pushrocks/smartexpress';
 import * as smartpromise from '@pushrocks/smartpromise';
 import * as smarttime from '@pushrocks/smarttime';
-import * as smartunique from '@pushrocks/smartunique';
 import * as smartrx from '@pushrocks/smartrx';

 export {
+  isohash,
+  isounique,
  lik,
+  smartenv,
+  smartjson,
  smartlog,
-  smarthash,
  smartdelay,
-  smartexpress,
  smartpromise,
  smarttime,
-  smartunique,
  smartrx,
 };
-
-// third party scope
-import socketIo from 'socket.io';
-import socketIoClient from 'socket.io-client';
-
-export { socketIo, socketIoClient };
--- a/ts/smartsocket.pluginstyped.ts
+++ b/ts/smartsocket.pluginstyped.ts
@ -0,0 +1,23 @@
+// node native
+import type * as http from 'http';
+import type * as https from 'https';
+
+export { http, https };
+
+// pushrocks scope
+import type * as smartexpress from '@pushrocks/smartexpress';
+
+export { smartexpress };
+
+// third party scope
+import type { Socket as ServerSocket, Server as ServerServer} from 'socket.io';
+import type { Socket as ClientSocket, connect as ClientIo } from 'socket.io-client';
+
+export namespace socketIo {
+  export type Socket = ServerSocket;
+  export type Server = ServerServer;
+}
+export namespace socketIoClient {
+  export type Socket = ClientSocket;
+  export type connect = typeof ClientIo;
+}
--- a/tsconfig.json
+++ b/tsconfig.json
@ -0,0 +1,7 @@
+{
+  "compilerOptions": {
+    "module": "ES2020",
+    "moduleResolution": "node12",
+    "esModuleInterop": true
+  }
+}
Author	SHA1	Message	Date
Philipp Kunz	6f3700adc0	2.0.2	2022-03-24 20:17:04 +01:00
Philipp Kunz	3648f12358	fix(core): update	2022-03-24 20:17:04 +01:00
Philipp Kunz	c239eaa9d5	2.0.1	2022-03-24 12:52:29 +01:00
Philipp Kunz	75bd7a9175	fix(core): update	2022-03-24 12:52:28 +01:00
Philipp Kunz	be9b47e73b	2.0.0	2022-03-14 22:40:56 +01:00
Philipp Kunz	966d953aff	BREAKING CHANGE(switch to esm): update	2022-03-14 22:40:55 +01:00
Philipp Kunz	7f73664970	1.2.22	2022-01-20 18:38:18 +01:00
Philipp Kunz	71452a293f	fix(core): update	2022-01-20 18:38:17 +01:00
Philipp Kunz	c5e60d804a	1.2.21	2022-01-20 18:33:47 +01:00
Philipp Kunz	c5d52013e6	fix(core): update	2022-01-20 18:33:46 +01:00
Philipp Kunz	64195e4c78	1.2.20	2022-01-20 17:14:12 +01:00
Philipp Kunz	01b5b3dc1a	fix(core): update	2022-01-20 17:14:11 +01:00
Philipp Kunz	b34d7faec2	1.2.19	2022-01-20 16:50:26 +01:00
Philipp Kunz	7c98e19988	fix(core): update	2022-01-20 16:50:25 +01:00
Philipp Kunz	608669ec44	1.2.18	2022-01-19 19:52:16 +01:00
Philipp Kunz	a7b14cd383	fix(core): update	2022-01-19 19:52:14 +01:00
Philipp Kunz	21dc933302	1.2.17	2022-01-19 19:05:45 +01:00
Philipp Kunz	4e7455fa26	fix(core): update	2022-01-19 19:05:44 +01:00
Philipp Kunz	c424d589ea	1.2.16	2022-01-19 18:36:14 +01:00
Philipp Kunz	9435796333	fix(core): update	2022-01-19 18:36:13 +01:00
Philipp Kunz	12d7310b90	1.2.15	2022-01-19 18:06:41 +01:00
Philipp Kunz	9fc4db1e35	fix(core): update	2022-01-19 18:06:39 +01:00
Philipp Kunz	895464115e	1.2.14	2022-01-19 16:37:46 +01:00
Philipp Kunz	00f22f9651	fix(core): update	2022-01-19 16:37:45 +01:00
Philipp Kunz	278b35c9c5	1.2.13	2022-01-19 15:34:53 +01:00
Philipp Kunz	da78da27e5	fix(core): update	2022-01-19 15:34:52 +01:00
Philipp Kunz	a8aeeaaa6c	1.2.12	2022-01-19 08:05:08 +01:00
Philipp Kunz	f9f6975b87	fix(core): update	2022-01-19 08:05:06 +01:00
Philipp Kunz	b9a6f1d5b0	1.2.11	2022-01-19 07:01:59 +01:00
Philipp Kunz	489ad9284b	fix(core): update	2022-01-19 07:01:58 +01:00
Philipp Kunz	6fdf0d9955	1.2.10	2022-01-18 18:54:30 +01:00
Philipp Kunz	499a1893f9	fix(core): update	2022-01-18 18:54:29 +01:00
Philipp Kunz	2754447aae	1.2.9	2022-01-18 17:10:47 +01:00
Philipp Kunz	544277cb8a	fix(core): update	2022-01-18 17:10:46 +01:00
Phil Kunz	9a23960d21	1.2.8	2021-02-01 22:36:38 +00:00
Phil Kunz	23cca6cce3	fix(core): update	2021-02-01 22:36:37 +00:00
Phil Kunz	2a9e58cc35	1.2.7	2021-01-28 12:39:32 +00:00
Phil Kunz	7d6a9921b5	fix(core): update	2021-01-28 12:39:31 +00:00
Phil Kunz	3ee46a31f7	1.2.6	2021-01-28 01:39:24 +00:00
Phil Kunz	d72310ce10	fix(core): update	2021-01-28 01:39:23 +00:00
Phil Kunz	1e14166ddb	1.2.5	2021-01-28 01:31:43 +00:00
Phil Kunz	be38e91548	fix(core): update	2021-01-28 01:31:42 +00:00
Phil Kunz	6c2057b119	1.2.4	2021-01-28 01:30:28 +00:00
Phil Kunz	08d7224016	fix(core): update	2021-01-28 01:30:27 +00:00
Phil Kunz	bfa3330eb6	1.2.3	2021-01-23 06:03:55 +00:00
Phil Kunz	644fa2a49d	fix(core): update	2021-01-23 06:03:54 +00:00
Phil Kunz	c0dad3a977	1.2.2	2021-01-23 05:50:02 +00:00
Phil Kunz	a921033cc4	fix(core): update	2021-01-23 05:50:02 +00:00
Phil Kunz	21e4712b04	1.2.1	2021-01-23 04:12:56 +00:00
Phil Kunz	df43bc2974	fix(core): update	2021-01-23 04:12:55 +00:00
Phil Kunz	564988185d	1.2.0	2020-12-26 18:06:23 +00:00
Phil Kunz	8442f3570f	feat(SmartsocketClient): socket client can now be stopped with .stop() addiditionally to .reconnect(), which will still try to re	2020-12-26 18:06:22 +00:00
Phil Kunz	196357c878	1.1.71	2020-12-26 17:43:20 +00:00
Phil Kunz	bc187b7e41	fix(core): update	2020-12-26 17:43:19 +00:00
Phil Kunz	0e54bf889f	1.1.70	2020-12-22 00:19:00 +00:00
Phil Kunz	4c211bc82e	fix(test): use @pushrocks/isohash instead of @pushrocks/smarthash in tests	2020-12-22 00:18:59 +00:00
Phil Kunz	a1be281670	1.1.69	2020-12-16 02:20:28 +00:00
Phil Kunz	1a44d2027c	fix(core): update	2020-12-16 02:20:28 +00:00
Phil Kunz	4bf5456a1d	1.1.68	2020-12-16 01:38:58 +00:00
Phil Kunz	57c748657a	fix(core): update	2020-12-16 01:38:57 +00:00
Phil Kunz	15df24bf68	1.1.67	2020-09-30 00:20:54 +00:00
Phil Kunz	ca7470eedf	fix(core): update	2020-09-30 00:20:53 +00:00
Phil Kunz	38f017934c	1.1.66	2020-09-29 19:43:10 +00:00
Phil Kunz	1980824540	fix(core): update	2020-09-29 19:43:10 +00:00
Phil Kunz	09dec2071e	1.1.65	2020-09-29 19:42:38 +00:00
Phil Kunz	a1443deafe	fix(core): update	2020-09-29 19:42:38 +00:00
Phil Kunz	9eac5ad336	1.1.64	2020-09-29 19:37:49 +00:00
Phil Kunz	cf607a79d5	fix(core): update	2020-09-29 19:37:49 +00:00
Phil Kunz	8426c976bf	1.1.63	2020-09-29 18:58:10 +00:00
Phil Kunz	1086065000	fix(core): update	2020-09-29 18:58:09 +00:00
Phil Kunz	72196ec383	1.1.62	2020-09-29 17:21:08 +00:00
Phil Kunz	c6ad490a6f	fix(core): update	2020-09-29 17:21:08 +00:00
Phil Kunz	a40a83f0bf	1.1.61	2020-09-29 08:35:27 +00:00
Phil Kunz	82fa029d05	fix(core): update	2020-09-29 08:35:26 +00:00