index.js

"use strict";

var co = require('co');
var Server = require('./server');
var bma  = require('./app/lib/streams/bma');
var webmin  = require('./app/lib/streams/webmin');
var logger = require('./app/lib/logger')('ucoin');

module.exports = function (dbConf, overConf) {
  return new Server(dbConf, overConf);
};

module.exports.statics = {

  enableHttpAdmin: (dbConf, overConf, httpLogs, wmHost, wmPort) => webmin(dbConf, overConf, [{
    ip:  wmHost || 'localhost',
    port: wmPort || 9220
  }], httpLogs !== false),

  startNode: (server, conf) => co(function *() {

    logger.info(">> NODE STARTING");

    // Public http interface
    let bmapi = yield bma(server, null, conf.httplogs);

    // Routing documents
    server.routing();

    // Services
    yield module.exports.statics.startServices(server);
    yield bmapi.openConnections();

    logger.info('>> Server ready!');
  }),

  startServices: (server) => co(function *() {

    /***************
     * HTTP ROUTING
     **************/
    server.router(server.conf.routing);

    /***************
     *    UPnP
     **************/
    if (server.conf.upnp) {
      try {
        if (server.upnpAPI) {
          server.upnpAPI.stopRegular();
        }
        yield server.upnp();
        server.upnpAPI.startRegular();
      } catch (e) {
        logger.warn(e);
      }
    }

    /*******************
     * BLOCK COMPUTING
     ******************/
    if (server.conf.participate) {
      server.startBlockComputation();
    }

    /***********************
     * CRYPTO NETWORK LAYER
     **********************/
    yield server.start();

    return {};
  }),

  stopServices: (server) => co(function *() {

    server.router(false);
    if (server.conf.participate) {
      server.stopBlockComputation();
    }
    yield server.stop();

    return {};
  })
};