configuration.js

/*
 * Licensed to Elasticsearch B.V. under one or more contributor
 * license agreements. See the NOTICE file distributed with
 * this work for additional information regarding copyright
 * ownership. Elasticsearch B.V. licenses this file to you under
 * the Apache License, Version 2.0 (the "License"); you may
 * not use this file except in compliance with the License.
 * You may obtain a copy of the License at
 *
 *    http://www.apache.org/licenses/LICENSE-2.0
 *
 * Unless required by applicable law or agreed to in writing,
 * software distributed under the License is distributed on an
 * "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY
 * KIND, either express or implied.  See the License for the
 * specific language governing permissions and limitations
 * under the License.
 */

import _ from 'lodash';
import { getLoggerStream } from './log_reporter';

export default function loggingConfiguration(config) {
  const events = config.get('logging.events');

  if (config.get('logging.silent')) {
    _.defaults(events, {});
  }
  else if (config.get('logging.quiet')) {
    _.defaults(events, {
      log: ['listening', 'error', 'fatal'],
      request: ['error'],
      error: '*'
    });
  }
  else if (config.get('logging.verbose')) {
    _.defaults(events, {
      log: '*',
      ops: '*',
      request: '*',
      response: '*',
      error: '*'
    });
  }
  else {
    _.defaults(events, {
      log: ['info', 'warning', 'error', 'fatal'],
      request: ['info', 'warning', 'error', 'fatal'],
      error: '*'
    });
  }

  const loggerStream = getLoggerStream({
    config: {
      json: config.get('logging.json'),
      dest: config.get('logging.dest'),
      timezone: config.get('logging.timezone'),

      // I'm adding the default here because if you add another filter
      // using the commandline it will remove authorization. I want users
      // to have to explicitly set --logging.filter.authorization=none or
      // --logging.filter.cookie=none to have it show up in the logs.
      filter: _.defaults(config.get('logging.filter'), {
        authorization: 'remove',
        cookie: 'remove'
      })
    },
    events: _.transform(events, function (filtered, val, key) {
      // provide a string compatible way to remove events
      if (val !== '!') filtered[key] = val;
    }, {})
  });

  const options = {
    ops: {
      interval: config.get('ops.interval')
    },
    includes: {
      request: ['headers', 'payload']
    },
    reporters: {
      logReporter: [loggerStream]
    }
  };
  return options;
}