radio/magnus/core/magnus.js

"use strict";
var Subscribable = require("../lib/utils/subscribable");
var Socket = require("../lib/wSocket/socket");
var Server = require("../lib/wSocket/server");
var Address = require("../lib/wType/address");
var String = require("../lib/wType/string");
var Vocabulary = require("../lib/wType/vocabulary");
var Dispatcher = require("../lib/wDispatcher/dispatcher");
var ParentReporter = require("../lib/wDispatcher/parentreporter");
var Logger = require("../lib/wDispatcher/logger");
var log = require("../lib/log")(module);

var Commands = require("./commands");
var Connector = require("./connector");

var GlobalControls = require("../lib/wModel/globalControls");
var PageStorage = require("../lib/wModel/pageStorage");
var ModelString = require("../lib/wModel/string");
var Attributes = require("../lib/wModel/attributes");

var HomePage = require("../pages/home");
var MusicPage = require("../pages/music");
var TestPage = require("../pages/test");

var Magnus = Subscribable.inherit({
    "className": "Magnus",
    "constructor": function(config) {
        Subscribable.fn.constructor.call(this);
        
        this._cfg = config;
        
        this._initDispatcher();
        this._initServer();
        this._initModels();
        this._initConnector();
        this._initPages();
        
        var port = this._cfg.get("webSocketServerPort");
        this.server.listen(port);
        
        global.magnus = this;
    },
    "_initConnector": function() {
        this._connector = new Connector(this.dispatcher, this.server, this._commands);
        
        this._connector.on("serviceMessage", this._onModelServiceMessage, this);
        this._connector.on("nodeConnected", this._onNodeConnected, this);
        this._connector.on("nodeDisconnected", this._onNodeDisconnected, this);
        
        this._connector.addIgnoredNode("Lorgar");
        this._connector.addIgnoredNode("Roboute");
    },
    "_initDispatcher": function() {
        this.dispatcher = new Dispatcher();
        this._logger = new Logger();
        this._pr = new ParentReporter();
        this.dispatcher.registerDefaultHandler(this._pr);
        this.dispatcher.registerDefaultHandler(this._logger);
    },
    "_initModels": function() {
        this._commands = new Commands(new Address(["management"]));
        
        var version = new ModelString(new Address(["version"]), this._cfg.get("version"));
        version.addProperty("backgroundColor","secondaryColor");
        version.addProperty("color", "secondaryFontColor");
        version.addProperty("fontFamily", "smallFont");
        version.addProperty("fontSize", "smallFontSize");
        
        this._attributes = new Attributes(new Address(["attributes"]));
        this._gc = new GlobalControls(new Address(["magnus", "gc"]));
        var root = this._rootPage = new HomePage(new Address(["pages", "root"]), "root");
        this._ps = new PageStorage(new Address(["magnus", "ps"]), root, this._pr);
        
        this._commands.on("serviceMessage", this._onModelServiceMessage, this);
        this._gc.on("serviceMessage", this._onModelServiceMessage, this);
        this._ps.on("serviceMessage", this._onModelServiceMessage, this);
        this._attributes.on("serviceMessage", this._onModelServiceMessage, this);
        
        this._attributes.addAttribute("name", new ModelString(new Address(["attributes", "name"]), "Magnus"));
        this._attributes.addAttribute("connectionsAmount", new ModelString(new Address(["connectionsAmount"]), "0"));
        this._attributes.addAttribute("version", version);
        this._gc.addModelAsLink("version", version);
        
        this._commands.register(this.dispatcher, this.server);
        this._gc.register(this.dispatcher, this.server);
        this._ps.register(this.dispatcher, this.server);
        this._attributes.register(this.dispatcher, this.server);
    },
    "_initPages": function() {
        this._gc.addNav("Home", this._rootPage.getAddress());
        
        var music = this._musicPage = new MusicPage(new Address(["pages", "/music"]), "music");
        this._rootPage.addPage(music);
        this._gc.addNav("Music", music.getAddress());
        
        var test = new TestPage(new Address(["pages", "/test"]), "test");
        this._rootPage.addPage(test);
        this._gc.addNav("Testing...", test.getAddress());
    },
    "_initServer": function() {
        this.server = new Server("Magnus");
        this.server.on("ready", this._onServerReady, this);
        this.server.on("connectionsCountChange", this._onConnectionsCountChange, this);
    },
    "hasPage": function(name) {
        return this._ps.hasPage(name);
    },
    "_onConnectionsCountChange": function(count) {
        this._attributes.setAttribute("connectionsAmount", count);
    },
    "_onModelServiceMessage": function(msg, severity) {
        var fn;
        
        switch (severity) {
            case 2:
                fn = log.error;
                break;
            case 1:
                fn = log.warn;
                break;
            case 0:
            default:
                fn = log.info;
                break;
        }
        
        fn(msg);
    },
    "_onNodeConnected": function(nodeName) {
        switch (nodeName) {
            case "Perturabo":
                this._musicPage.showBandList(this._connector.getNodeSocket(nodeName));
                break;
            case "Corax":
                break;
        }
    },
    "_onNodeDisconnected": function(nodeName) {
        switch (nodeName) {
            case "Perturabo":
                this._musicPage.showError();
                break;
            case "Corax":
                break;
        }
    },
    "_onServerReady": function() {
        log.info("Magnus is listening on port " + this._cfg.get("webSocketServerPort"));
        log.info("Magnus is ready");
    }
});

module.exports = Magnus;