ezy-managers.js

import Const from './ezy-constants';
import Util from './ezy-util';
import DataHandler from './ezy-data-handlers';
import EventHandler from './ezy-event-handlers';

export class EzyAppManager {
    constructor(zoneName) {
        this.zoneName = zoneName;
        this.appList = [];
        this.appsById = {};
        this.appsByName = {};
    }

    getApp() {
        var app = null;
        if (this.appList.length > 0) app = this.appList[0];
        else Util.EzyLogger.console('has no app in zone: ' + this.zoneName);
        return app;
    }

    addApp(app) {
        this.appList.push(app);
        this.appsById[app.id] = app;
        this.appsByName[app.name] = app;
    }

    removeApp(appId) {
        var app = this.appsById[appId];
        if (app) {
            delete this.appsById[appId];
            delete this.appsByName[app.name];
            this.appList = this.appList.filter((item) => item.id !== appId);
        }
        return app;
    }

    getAppById(id) {
        var app = this.appsById[id];
        return app;
    }

    getAppByName(name) {
        var app = this.appsByName[name];
        return app;
    }
}

//======================================

export class EzyPluginManager {
    constructor(zoneName) {
        this.zoneName = zoneName;
        this.pluginList = [];
        this.pluginsById = {};
        this.pluginsByName = {};
    }

    getPlugin() {
        var plugin = null;
        if (this.pluginList.length > 0) plugin = this.pluginList[0];
        else Util.EzyLogger.console('has no plugin in zone: ' + this.zoneName);
        return plugin;
    }

    addPlugin(plugin) {
        this.pluginList.push(plugin);
        this.pluginsById[plugin.id] = plugin;
        this.pluginsByName[plugin.name] = plugin;
    }

    getPluginById(id) {
        var plugin = this.pluginsById[id];
        return plugin;
    }

    getPluginByName(name) {
        var plugin = this.pluginsByName[name];
        return plugin;
    }
}

//======================================

export class EzyPingManager {
    constructor() {
        this.pingPeriod = 5000;
        this.lostPingCount = 0;
        this.maxLostPingCount = 5;
    }

    increaseLostPingCount() {
        return ++this.lostPingCount;
    }
}

//======================================

export class EzyHandlerManager {
    constructor(client) {
        this.client = client;
        this.dataHandlers = this.newDataHandlers();
        this.eventHandlers = this.newEventHandlers();
        this.appDataHandlersByName = {};
        this.pluginDataHandlersByName = {};
    }

    newEventHandlers() {
        var handlers = new EventHandler.EzyEventHandlers(this.client);
        handlers.addHandler(
            Const.EzyEventType.CONNECTION_SUCCESS,
            new EventHandler.EzyConnectionSuccessHandler()
        );
        handlers.addHandler(
            Const.EzyEventType.CONNECTION_FAILURE,
            new EventHandler.EzyConnectionFailureHandler()
        );
        handlers.addHandler(
            Const.EzyEventType.DISCONNECTION,
            new EventHandler.EzyDisconnectionHandler()
        );
        return handlers;
    }

    newDataHandlers() {
        var handlers = new DataHandler.EzyDataHandlers(this.client);
        handlers.addHandler(
            Const.EzyCommand.PONG,
            new DataHandler.EzyPongHandler()
        );
        handlers.addHandler(
            Const.EzyCommand.HANDSHAKE,
            new DataHandler.EzyHandshakeHandler()
        );
        handlers.addHandler(
            Const.EzyCommand.LOGIN,
            new DataHandler.EzyLoginSuccessHandler()
        );
        handlers.addHandler(
            Const.EzyCommand.LOGIN_ERROR,
            new DataHandler.EzyLoginErrorHandler()
        );
        handlers.addHandler(
            Const.EzyCommand.APP_ACCESS,
            new DataHandler.EzyAppAccessHandler()
        );
        handlers.addHandler(
            Const.EzyCommand.APP_REQUEST,
            new DataHandler.EzyAppResponseHandler()
        );
        handlers.addHandler(
            Const.EzyCommand.APP_EXIT,
            new DataHandler.EzyAppExitHandler()
        );
        handlers.addHandler(
            Const.EzyCommand.PLUGIN_INFO,
            new DataHandler.EzyPluginInfoHandler()
        );
        handlers.addHandler(
            Const.EzyCommand.PLUGIN_REQUEST,
            new DataHandler.EzyPluginResponseHandler()
        );
        return handlers;
    }

    getDataHandler(cmd) {
        var handler = this.dataHandlers.getHandler(cmd);
        return handler;
    }

    getEventHandler(eventType) {
        var handler = this.eventHandlers.getHandler(eventType);
        return handler;
    }

    getAppDataHandlers(appName) {
        var answer = this.appDataHandlersByName[appName];
        if (!answer) {
            answer = new DataHandler.EzyAppDataHandlers();
            this.appDataHandlersByName[appName] = answer;
        }
        return answer;
    }

    getPluginDataHandlers(pluginName) {
        var answer = this.pluginDataHandlersByName[pluginName];
        if (!answer) {
            answer = new DataHandler.EzyPluginDataHandlers();
            this.pluginDataHandlersByName[pluginName] = answer;
        }
        return answer;
    }

    addDataHandler(cmd, dataHandler) {
        this.dataHandlers.addHandler(cmd, dataHandler);
    }

    addEventHandler(eventType, eventHandler) {
        this.eventHandlers.addHandler(eventType, eventHandler);
    }
}

export default {
    EzyAppManager,
    EzyPluginManager,
    EzyPingManager,
    EzyHandlerManager,
};