Ride-The-Lightning-RTL/controllers/lnd/switch.js

var request = require('request-promise');
var common = require('../../common');
var logger = require('../logger');
var options = {};

exports.getAllForwardingEvents = (start, end, offset, max_events) => {
  return new Promise(function(resolve, reject) {
    options = common.getOptions();
    options.url = common.getSelLNServerUrl() + '/switch';
    options.form = {};
    if (start) { options.form.start_time = start; }
    if (end) { options.form.end_time = end; }
    options.form.num_max_events = max_events ? max_events : 1000;
    options.form.index_offset = offset ? offset : 0;
    options.form = JSON.stringify(options.form);
    logger.info({fileName: 'Switch', msg: 'Forwarding History Params: ' + options.form});
    request.post(options).then((body) => {
      if(undefined === body || body.error) {
        logger.error({fileName: 'Switch', lineNum: 31, msg: 'Forwarding History Error: ' + JSON.stringify((undefined === body) ? 'Error From Server!' : body.error)});
        res.status(500).json({
          message: "Switch post failed!",
          error: (undefined === body) ? 'Error From Server!' : body.error
        });
      } else {
        logger.info({fileName: 'Switch', msg: 'Forwarding History Received: ' + JSON.stringify(body)});
        if (body.forwarding_events && body.forwarding_events.length > 0) {
          body.forwarding_events.forEach(event => {
            event.timestamp_str =  (undefined === event.timestamp) ? '' : common.convertTimestampToDate(event.timestamp);
          });
          body.forwarding_events = common.sortDescByKey(body.forwarding_events, 'timestamp');
        }
        logger.info({fileName: 'Switch', msg: 'Forwarding History before Resolve: ' + JSON.stringify(body)});
        resolve(body);
      }
    })
    .catch(function (err) {
      logger.error({fileName: 'Switch', lineNum: 48, msg: 'Forwarding History Error: ' + JSON.stringify(err)});
      resolve({
        message: "Switch post failed!",
        error: err.error
      });
    });
  });
}

exports.forwardingHistory = (req, res, next) => {
  this.getAllForwardingEvents(req.body.start_time, req.body.end_time, 0, 1000).then(function(values) {
    logger.info({fileName: 'Switch', msg: 'All Forwarding Events: ' + JSON.stringify(values)});
    res.status(201).json(values);
  }).catch(err => {
    logger.error({fileName: 'Switch', lineNum: 60, msg: 'Get All Forwarding Events: ' + JSON.stringify(err)});
    res.status(500).json({
      message: "Switch post failed!",
      error: err.error
    });
  });  
};