Class LocalGateway

cli/local_gateway.js:8–90

const Gateway = require('functionscript').Daemon.Gateway;

class LocalGateway extends Gateway {

  constructor (cfg) {
    cfg = cfg || {};
    cfg.name = 'LocalGateway';
    cfg.defaultTimeout = 120000;
    super(cfg);
    this._maxResultLogLength = 128;
  }

  formatName (name) {
    return chalk.grey(`[${chalk.green(this.name)}]`);
  }

  formatRequest (req) {
    return chalk.grey(`(${chalk.yellow(req ? (req._background ? chalk.bold('bg:') : '') + req._uuid.split('-')[0] : 'GLOBAL')}) ${this.routename(req)}`);
  }

  formatMessage (message, logType) {
    let color = {result: 'cyan', error: 'red'}[logType] || 'grey';
    return chalk[color](super.formatMessage(message, logType));
  }

  service (serviceName) {
    this.serviceName = serviceName.replace(/^\//gi, '');
  }

  environment (env) {
    Object.keys(env).forEach(key => process.env[key] = env[key]);
    return true;
  }

  listen (port, callback, opts) {
    port = port || this.port;
    process.env.STDLIB_LOCAL_PORT = port;
    super.listen(port, callback, opts);
  }

  createContext (req, definitions, params, data, buffer) {
    let context = super.createContext(req, definitions, params, data, buffer);
    context.service = {};
    context.service.name = this.serviceName;
    context.service.path = this.serviceName.split('/');
    context.service.version = null;
    context.service.environment = 'local';
    context.service.identifier = `${context.service.path.join('.')}[@${context.service.version || context.service.environment}]`;
    context.service.uuid = '000000';
    context.service.hash = '000000';
    context.providers = context.providers || {};
    return context;
  }

  resolve (req, res, buffer, callback) {
    let urlinfo = url.parse(req.url, true);
    let pathname = urlinfo.pathname;
    if (this.serviceName && pathname.indexOf(this.serviceName) !== 1) {
      let e = new Error(`Local Service Not Loaded: ${pathname}`);
      e.statusCode = 404;