serverless/lib/plugins/run/utils/logEventGateway.js

'use strict';

const chalk = require('chalk');
const log = require('./log');

const colorText = chalk.hex('#D86121');
const caret = colorText('|');
const prefix = colorText(' Event Gateway  |  ');

const prettifyValue = value => {
  const prettified = JSON.stringify(value, null, 2).replace(
    new RegExp('\\n', 'g'),
    `\n                ${caret}      `
  );
  return `                ${caret}      ${prettified}`;
};

const transformMessages = parsedMsg => {
  if (parsedMsg.msg === 'Function registered.') {
    return `Registered function ${parsedMsg.functionId}\n`;
  } else if (parsedMsg.msg === 'Subscription created.') {
    return `Subscribed function ${parsedMsg.functionId} to event ${parsedMsg.event}\n`;
  } else if (parsedMsg.msg === 'Subscription deleted.') {
    return `Unsubscribed function ${parsedMsg.functionId} to event ${parsedMsg.event}\n`;
  } else if (parsedMsg.msg === 'Event received.') {
    const event = JSON.parse(parsedMsg.event);
    if (event.headers) {
      const text = `Received http event on path ${parsedMsg.path} ${parsedMsg.method}\n`;
      // TODO const ppBody = prettifyValue(event.body);
      const ppBody = prettifyValue(event.body);
      const bodyText = `                ${caret}    body:\n${ppBody}`;
      return `${text}${bodyText}\n`;
    }
    const text = `Received event ${event.event}\n`;
    const dataTypeText = `                ${caret}    dataType: ${event.dataType}\n`;
    const ppData = prettifyValue(event.data);
    const dataText = `                ${caret}    data:\n${ppData}`;
    return `${text}${dataTypeText}${dataText}\n`;
  } else if (parsedMsg.msg === 'Function invoked.') {
    const response = prettifyValue(JSON.parse(parsedMsg.response));
    const responseText = `                ${caret}    response:\n${response}`;
    const text = `Invoked function ${parsedMsg.functionId}\n${responseText}`;
    return `${text}`;
  } else if (parsedMsg.msg === 'Function invocation failed.') {
    const text = `Failed to invoke function ${parsedMsg.functionId}\n`;
    const errorText = `                ${caret}    error: ${parsedMsg.error}\n`;
    return `${text}${errorText}`;
  } else if (parsedMsg.msg === 'Handling "http" event failed.') {
    const text = `Failed to handle http event on path ${parsedMsg.path}\n`;
    const errorText = `                ${caret}    error: ${parsedMsg.error}\n`;
    return `${text}${errorText}`;
  } else if (parsedMsg.msg.startsWith('Running in development mode with embedded etcd')) {
    const partOne = 'Running in development mode with embedded etcd. Event API listening on ';
    const re = new RegExp(`${partOne}(.*). Config API listening on (.*).`);
    const found = parsedMsg.msg.match(re);
    if (found) {
      return `Event API listening on ${found[1]}\n${prefix}Config API listening on ${found[2]}\n`;
    }
    throw new Error('Could not parse boot message');
  }
  return `${parsedMsg.msg.trim()}\n`;
};

module.exports = msg => {
  try {
    const parsedMsg = JSON.parse(msg);
    log(`${prefix}${transformMessages(parsedMsg)}`);
  } catch (err) {
    log(`${prefix}raw Event Gateway output: ${msg}\n`);
  }
};