analytics/index.js

'use strict';

var debug = require('debug')('plugin:analytics');
var volos = require('volos-analytics-apigee');
module.exports.init = function(config, logger, stats) {

  config.finalizeRecord = function finalizeRecord(req, res, record, cb) {
    if (res.proxy) {
      record.apiproxy = res.proxy.name;
      record.apiproxy_revision = res.proxy.revision;
    }

    if(config.mask) {
      var maskString = config.mask.mask_string;
      var fieldsToMask = config.mask.fields_to_mask;
      fieldsToMask.forEach((f)=> {
        //Only attempt to mask if the property exists.
        if(record[f]) {
          record[f] = maskString;
        }
      });
    }
    
    cb(null, record);
  };

  var analytics = volos.create(config);
  var middleware = analytics.expressMiddleWare().apply();

  return {

    testprobe: function() { return analytics },

    onrequest: function(req, res, next) {
      middleware(req, res, next);
    }

  };

}