Superalgos/Client/client.js

/* Load Environment Variables */
let ENVIRONMENT = require('../Environment.js');
let ENVIRONMENT_MODULE = ENVIRONMENT.newEnvironment()
global.env = ENVIRONMENT_MODULE

process.on('uncaughtException', function (err) {
    if (err.message && err.message.indexOf("EADDRINUSE") > 0) {
        console.log("A Superalgos Client cannot be started. Reason: the port configured migth be being used by another application, or Superalgos might be already running.")
        return
    }
    console.log('[ERROR] Client -> client-> uncaughtException -> err.message = ' + err.message)
    console.log('[ERROR] Client -> client-> uncaughtException -> err.stack = ' + err.stack)
    console.log('[ERROR] Client -> client-> uncaughtException -> err = ' + err)
    process.exit(1)
})

process.on('unhandledRejection', (reason, p) => {
    // Signal user that a necissary node module is missing
    if (reason.code == 'MODULE_NOT_FOUND') {
        console.log("[ERROR] Dependency library not found. Please try running the 'node setup' command and then restart the Client.")
        console.log('[ERROR] Client -> client-> reason = ' + JSON.stringify(reason))
        process.exit(1)
    }
    console.log('[ERROR] Client -> client-> unhandledRejection -> reason = ' + JSON.stringify(reason))
    console.log('[ERROR] Client -> client-> unhandledRejection -> p = ' + JSON.stringify(p))
    process.exit(1)
})

/* Callbacks default responses. */

global.DEFAULT_OK_RESPONSE = {
    result: "Ok",
    message: "Operation Succeeded"
};

global.DEFAULT_FAIL_RESPONSE = {
    result: "Fail",
    message: "Operation Failed"
};

global.DEFAULT_RETRY_RESPONSE = {
    result: 'Retry',
    message: 'Retry Later'
}

global.CUSTOM_OK_RESPONSE = {
    result: 'Ok, but check Message',
    message: 'Custom Message'
}

global.CUSTOM_FAIL_RESPONSE = {
    result: 'Fail Because',
    message: 'Custom Message'
}

/* Servers */
let WEB_SERVER = require('./webServer.js')
let DATA_FILE_SERVER = require('./dataFileServer.js')
let PROJECT_FILE_SERVER = require('./projectFileServer.js')
let UI_FILE_SERVER = require('./uiFileServer.js')
let PLUGIN_SERVER = require('./pluginServer.js')
let EVENT_SERVER = require('./eventServer.js')
let TASK_MANAGER_SERVER = require('./taskManagerServer.js')
let CCXT_SERVER = require('./ccxtServer.js')
let WEB3_SERVER = require('./web3Server.js')
let GITHUB_SERVER = require('./githubServer.js')

/* Network Interfaces */
let WEB_SOCKETS_INTERFACE = require('./webSocketsInterface.js')
let HTTP_INTERFACE = require('./httpInterface.js')

try {
    /* 
    The CL object is accesible everywhere at the Superalgos Client. 
    It provides access to all modules built for this Client.
    */
    global.CL = {}
    /* 
    The SA object is accesible everywhere at the Superalgos Client. 
    It provides access to all modules built for Superalgos in general.
    */
    global.SA = {}
    /*
    First thing is to load the project schema file.
    */
    global.PROJECTS_SCHEMA = require(global.env.PATH_TO_PROJECT_SCHEMA)
    /* 
    Setting up the modules that will be available for the Servers Running inside this Client 
    */
    let MULTI_PROJECT = require('../MultiProject.js');
    let MULTI_PROJECT_MODULE = MULTI_PROJECT.newMultiProject()
    MULTI_PROJECT_MODULE.initialize(CL, 'CL')
    MULTI_PROJECT_MODULE.initialize(SA, 'SA')
    /*
    Setting up external dependencies.
    */
    SA.nodeModules = {
        fs: require('fs'),
        nodeFetch: require('node-fetch')
    }
    /*
    Setting up servers running inside this Client.
    */
    CL.servers = {}
    console.log('CLIENT SERVERS:')
    console.log('')

    CL.servers.WEB_SERVER = WEB_SERVER.newWebServer()
    CL.servers.WEB_SERVER.initialize()
    CL.servers.WEB_SERVER.run()
    console.log('Web Server .................................................. Started')

    CL.servers.UI_FILE_SERVER = UI_FILE_SERVER.newUIFileServer()
    CL.servers.UI_FILE_SERVER.initialize()
    CL.servers.UI_FILE_SERVER.run()
    console.log('UI File Server .............................................. Started')

    CL.servers.PROJECT_FILE_SERVER = PROJECT_FILE_SERVER.newProjectFileServer()
    CL.servers.PROJECT_FILE_SERVER.initialize()
    CL.servers.PROJECT_FILE_SERVER.run()
    console.log('Project File Server ......................................... Started')

    CL.servers.PLUGIN_SERVER = PLUGIN_SERVER.newPluginServer()
    CL.servers.PLUGIN_SERVER.initialize()
    CL.servers.PLUGIN_SERVER.run()
    console.log('Plugin Server ............................................... Started')

    CL.servers.DATA_FILE_SERVER = DATA_FILE_SERVER.newDataFileServer()
    CL.servers.DATA_FILE_SERVER.initialize()
    CL.servers.DATA_FILE_SERVER.run()
    console.log('Data File Server ............................................ Started')

    CL.servers.EVENT_SERVER = EVENT_SERVER.newEventServer()
    CL.servers.EVENT_SERVER.initialize()
    CL.servers.EVENT_SERVER.run()
    console.log('Events Server ............................................... Started')

    TASK_MANAGER_SERVER = TASK_MANAGER_SERVER.newTaskManagerServer()
    TASK_MANAGER_SERVER.initialize()
    TASK_MANAGER_SERVER.run()
    console.log('Task Manager Server ......................................... Started')

    CL.servers.CCXT_SERVER = CCXT_SERVER.newCCXTServer()
    CL.servers.CCXT_SERVER.initialize()
    CL.servers.CCXT_SERVER.run()
    console.log('CCXT Server ................................................. Started')

    CL.servers.WEB3_SERVER = WEB3_SERVER.newWeb3Server()
    CL.servers.WEB3_SERVER.initialize()
    CL.servers.WEB3_SERVER.run()
    console.log('WEB3 Server ................................................. Started')

    CL.servers.GITHUB_SERVER = GITHUB_SERVER.newGithubServer()
    CL.servers.GITHUB_SERVER.initialize()
    CL.servers.GITHUB_SERVER.run()
    console.log('Github Server ............................................... Started')

    console.log('')
    console.log('CLIENT INTERFACES:')
    console.log('')

    WEB_SOCKETS_INTERFACE = WEB_SOCKETS_INTERFACE.newWebSocketsInterface()
    WEB_SOCKETS_INTERFACE.initialize()
    WEB_SOCKETS_INTERFACE.run()
    console.log('Web Sockets Interface ....................................... Listening at port ' + global.env.CLIENT_WEB_SOCKETS_INTERFACE_PORT)

    HTTP_INTERFACE = HTTP_INTERFACE.newHttpInterface()
    HTTP_INTERFACE.initialize()
    HTTP_INTERFACE.run()
    console.log('Http Interface .............................................. Listening at port ' + global.env.CLIENT_HTTP_INTERFACE_PORT)

    console.log('')
    console.log("You are running Superalgos Beta 11")
    console.log('')
    console.log("What's new? These are the main new features in this version:")
    console.log('')
    console.log('Governance System ........................................... Automates the distribution of SA Tokens and allow users to vote on the direction of the project.')
    console.log('TensorFlow Integration ...................................... Allows creating and training ML models and use them in trading strategies.')
    console.log('')
    console.log("What's next? This is the current development pipeline:")
    console.log('')
    console.log('Superalgos P2P Network ...................................... Will allow algo-traders to share trading signals with Superalgos users consuming these signals via a mobile app.')
    console.log('Real-time Trading Signals ................................... Will allow users to emit trading signals and be rewarded with SA Tokens.')
    console.log('Superalgos Mobile ........................................... Will allow users to consume trading signals for free and autonomously execute trades from their mobile phones.')
    console.log('Ethereum Integration ........................................ Will allow mining data from an Ethereum network node, and bring it into the Superalgos workflow.')

    console.log('')

} catch (err) {
    console.log('[ERROR] Client -> Error = ' + err.stack)
}