server.js

var Q = require('q');
var express = require('express');
var jsonBody = require('body/json');
var sendJson = require('send-data/json');
var cors = require('cors');
var logger = require('morgan');
var backend = require('./backend')
var tsmbackend = require('./tsmbackend')
var _ = require('lodash')

var app = express();

var cors_options = {origin: true, credentials: true};
app.use(logger());
app.use(cors(cors_options));
app.options('*', cors(cors_options));

var api = express.Router();

function definePostCall(name, computeFn, formatFn) {
  api.post(name, function (req, res) {
    jsonBody(req, function (error, body) {
      if (error) res.status(400).json({error: 'JSON required'})
      else {
        computeFn(body).done(
          function (result) { res.json(formatFn(result))},
          function (err) {
            console.error("Error in api-call:" + name,  err.stack || err)
            res.status(500).json({error: err.toString()}) 
          }
        );
      }
    })
  })
}
function defineGetCall(name, computeFn, formatFn) {
  api.get(name, function (req, res) {
    var params = req.query;
    computeFn(params).done(
      function (result) { res.json(formatFn(result))},
      function (err) {
        console.error("Error in api-call:" + name, err.stack || err)
        res.status(500).json({error: err.toString()}) 
      }
    );
  });
}


definePostCall('/createIssueTx', backend.createIssueTx, _.identity);
definePostCall('/getUnspentCoins', backend.getUnspentCoinsData, function (coins) { return {coins: coins} });
definePostCall('/createTransferTx', backend.createTransferTx, _.identity);
defineGetCall('/getAllColoredCoins', backend.getAllColoredCoins, _.identity);
defineGetCall('/getTx', backend.getTx, function (tx) { return {tx: tx} });
definePostCall('/getTxColorValues', backend.getTxColorValues, _.identity);
definePostCall('/broadcastTx', backend.broadcastTx, function () { return {success: true} });

definePostCall('/tsm/newMonitoringGroup', tsmbackend.newMonitoringGroup,
  function(groupId) { return {groupId: groupId} });
definePostCall('/tsm/addTx', tsmbackend.addTx, function () { return {success: true}});
definePostCall('/tsm/addAddress', tsmbackend.addAddress, function () { return {success: true}});
definePostCall('/tsm/getLog', tsmbackend.getLog, _.identity);


app.use('/api', api);
var server;

var startService = function (args) {
  var deferred = Q.defer()

  var defaults = {
    testnet: false,
    port: 4444
  }

  args = _.extend(defaults, args);
  if (!args.scanner)
    args.scanner = args.testnet ? 
                     'http://v1.testnet.bitcoin.chromanode.net/v2/cc/' :
                     'http://v1.livenet.bitcoin.chromanode.net/v2/cc/';

  var walletOpts = {
    testnet: args.testnet,
    blockchain: {name: 'Naive'},
    storageSaveTimeout: 0
  };

  if (args.chromanode) {
    walletOpts.connector = {opts: {url: args.chromanode}}
  }

  var opts = {
      walletOpts: walletOpts,
      scannerUrl: args.scanner,
      otherArgs: args
  }

  backend.initialize(opts, function () {
    server = app.listen(args.port, function () {
                   console.log('Listening on port %d', server.address().port);
                   deferred.resolve();
                 })
  })
  return deferred.promise
}
var stopService =  function () {
  if (server) server.close()
  server = null
}

module.exports = {
  startService: startService,
  stopService: stopService
}