good-map

Transform stream for Hapi Good process monitoring. Modify the incoming object stream with your own mapping functions.

Tested with

• Node 12/14/15, Hapi 19/20, Good 9
• Node 10, Hapi 18, Good 8

Install

npm install good-map

Usage

Your Good logging configuration may look like this:

const Hapi = require('@hapi/hapi');
const Good = require('@hapi/good'),

const server = new Hapi.Server();

const options = {
  reporters: {
    myConsoleReporter: [{
      module: '@hapi/good-squeeze',
      name: 'Squeeze',
      args: [{ log: '*', response: '*' }],
    }, {
      module: 'good-map',
      args: [{
        events: ['log'],
        tags: ['error'],
        map: {
          timestamp: (ms) => moment(ms).utc().format(),
          'database.password': () => '***',
          'error.stack': (stack) => truncate(stack),
        },
        observe: (item) => {
          item.service = 'foo';
        },
      }],
    }, {
      module: '@hapi/good-console',
    }, 'stdout'],
  },
};

await server.register({
  plugin: Good,
  options,
});

await server.start();

Configuration

The good-map transform stream can be placed anywhere in the pipeline where log values are still objects, e.g., after Squeeze.

args in the Good configuration for good-map is an array with two arguments which are passed to GoodMap(rules, [options]):

• rules: An object with the following parameters (all optional):
  • events: A list of Hapi server event types, e.g., ['request'], for filtering purposes.
  • tags: A list of event tags, e.g., ['error'], for filtering purposes.
  • map: An object that maps the log item's properties (including deep properties separated by dots), e.g., timestamp or 'error.message' to a mapping function (synchronous). It has the form (value) => 'newValue', e.g., () => '***' or str => str.toUpperCase(). If a property does not exist (before), it is not set. If the mapping function returns undefined, the property is deleted. If the mapping function throws an error, the error is ignored. For full flexibility, the second parameter provides access to the complete log item: (value, item) => ....
  • observe: Listen to the complete log item as it appears in the stream. The observer function (synchronous) has the form (item) => { ... }. Use this hook to read and write to the log item. If the observer function throws an error, the error is ignored.
• options: An optional configuration object that gets passed to the Node Stream.Transform constructor. objectMode is always true.