mw_utils.js

/**
 * Middleware Utils module.
 *
 * Exposes various configuration and helper methods to be used by the middleware.
 * @module mw_utils
 */

var Segment = require('../segments/segment');
var IncomingRequestData = require('./incoming_request_data');
var logger = require('../logger');
var coreUtils = require('../utils');

var wildcardMatch = require('../utils').wildcardMatch;
var processTraceData = require('../utils').processTraceData;

//headers are case-insensitive
var XRAY_HEADER = 'x-amzn-trace-id';
var overrideFlag = !!process.env.AWS_XRAY_TRACING_NAME;

var utils = {
  defaultName: process.env.AWS_XRAY_TRACING_NAME,
  dynamicNaming: false,
  hostPattern: null,
  sampler: require('./sampling/default_sampler'),

  /**
   * Enables dynamic naming for segments via the middleware. Use 'AWSXRay.middleware.enableDynamicNaming()'.
   * @param {string} [hostPattern] - The pattern to match the host header. See the README on dynamic and fixed naming modes.
   * @alias module:mw_utils.enableDynamicNaming
   */

  enableDynamicNaming: function(hostPattern) {
    this.dynamicNaming = true;

    if (hostPattern && typeof hostPattern !== 'string') {
      throw new Error('Host pattern must be a string.');
    }

    this.hostPattern = hostPattern || null;
  },

  /**
   * Splits out the 'x-amzn-trace-id' header params from the incoming request.  Used by the middleware.
   * @param {http.IncomingMessage|https.IncomingMessage} req - The request object from the incoming call.
   * @returns {object}
   * @alias module:mw_utils.processHeaders
   */

  processHeaders: function processHeaders(req) {
    var amznTraceHeader = {};

    if (req && req.headers && req.headers[XRAY_HEADER]) {
      amznTraceHeader = processTraceData(req.headers[XRAY_HEADER]);
    }

    return amznTraceHeader;
  },

  /**
   * Resolves the name of the segment as determined by fixed or dynamic mode options. Used by the middleware.
   * @param {string} hostHeader - The string from the request.headers.host property.
   * @returns {string}
   * @alias module:mw_utils.resolveName
   */

  resolveName: function resolveName(hostHeader) {
    var name;

    if (this.dynamicNaming && hostHeader) {
      name = this.hostPattern ? (wildcardMatch(this.hostPattern, hostHeader) ? hostHeader : this.defaultName) : hostHeader;
    } else {
      name = this.defaultName;
    }

    return name;
  },

  /**
   * Resolves the sampling decision as determined by the values given and options set. Used by the middleware.
   * @param {object} amznTraceHeader - The object as returned by the processHeaders function.
   * @param {Segment} segment - The string from the request.headers.host property.
   * @param {http.ServerResponse|https.ServerResponse} res - The response object from the incoming call.
   * @returns {boolean}
   * @alias module:mw_utils.resolveSampling
   */

  resolveSampling: function resolveSampling(amznTraceHeader, segment, res) {
    var isSampled;

    if (amznTraceHeader.sampled === '1') {
      isSampled = true;
    } else if (amznTraceHeader.sampled === '0') {
      isSampled = false;
    } else {
      var sampleRequest = {
        host: res.req.headers.host,
        httpMethod: res.req.method,
        urlPath: res.req.url,
        serviceName: segment.name
      };

      isSampled = this.sampler.shouldSample(sampleRequest);
      if (isSampled instanceof String || typeof isSampled === 'string') {
        segment.setMatchedSamplingRule(isSampled);
        isSampled = true;
      }
    }

    if (amznTraceHeader.sampled === '?' && res.header) {
      res.header(XRAY_HEADER, 'Root=' + amznTraceHeader.root + ';Sampled=' + (isSampled ? '1' : '0'));
    }

    if (!isSampled) {
      segment.notTraced = true;
    }
  },

  /**
   * Sets the default name of created segments. Used with the middleware.
   * Can be overridden by the AWS_XRAY_TRACING_NAME environment variable.
   * @param {string} name - The default name for segments created in the middleware.
   * @alias module:mw_utils.setDefaultName
   */

  setDefaultName: function setDefaultName(name) {
    if (!overrideFlag) {
      this.defaultName = name;
    }
  },

  disableCentralizedSampling: function disableCentralizedSampling() {
    this.sampler = require('./sampling/local_sampler');
  },

  /**
   * Overrides the default sampling rules file to specify at what rate to sample at for specific routes.
   * The base sampling rules file can be found at /lib/resources/default_sampling_rules.json
   * @param {string|Object} source - The path to the custom sampling rules file, or the source JSON object.
   * @memberof AWSXRay
   */

  setSamplingRules: function setSamplingRules(source) {
    if (!source || source instanceof String || !(typeof source === 'string' || (source instanceof Object))) {
      throw new Error('Please specify a path to the local sampling rules file, or supply an object containing the rules.');
    }

    this.sampler.setLocalRules(source);
  },

  /**
   * Logs a debug message including core request and segment information
   * @param {string} message - The message to be logged
   * @param {string} url - The request url being traced
   * @param {Segment} - The current segment
   */
  middlewareLog: function middlewareLog(message, url, segment) {
    logger.getLogger().debug(message + ': { url: ' + url + ', name: ' + segment.name + ', trace_id: ' +
      segment.trace_id + ', id: ' + segment.id + ', sampled: ' + !segment.notTraced + ' }');
  },

  /**
   * Traces the request/response cycle of an http.IncomingMessage / http.ServerResponse pair.
   * Resolves sampling rules, creates a segment, adds the core request / response data adding
   * throttling / error / fault flags based on the response status code.
   * @param {http.IncomingMessage} req - The incoming request.
   * @param {http.ServerResponse} res - The server response.
   * @returns {Segment}
   * @memberof AWSXRay
   */
  traceRequestResponseCycle: function traceRequestResponseCycle(req, res) {
    var amznTraceHeader = this.processHeaders(req);
    var name = this.resolveName(req.headers.host);
    var segment = new Segment(name, amznTraceHeader.root, amznTraceHeader.parent);

    if (!res.req) {
      res.req = req;
    }
    this.resolveSampling(amznTraceHeader, segment, res);

    segment.addIncomingRequestData(new IncomingRequestData(req));

    this.middlewareLog('Starting middleware segment', req.url, segment);

    var middlewareLog = this.middlewareLog;
    var didEnd = false;
    var endSegment = function () {
      // ensure `endSegment` is only called once
      // in some versions of node.js 10.x and in all versions of node.js 11.x and higher,
      // the 'finish' and 'close' event are BOTH triggered.
      // Previously, only one or the other was triggered:
      // https://github.com/nodejs/node/pull/20611
      if (didEnd) {
        return;
      }
      didEnd = true;

      if (res.statusCode === 429) {
        segment.addThrottleFlag();
      }

      const cause = coreUtils.getCauseTypeFromHttpStatus(
        res.statusCode
      );

      if (cause) {
        segment[cause] = true;
      }

      segment.http.close(res);
      segment.close();

      middlewareLog('Closed middleware segment successfully', req.url, segment);
    };

    res.on('finish', endSegment);
    res.on('close', endSegment);
    return segment;
  }
};

module.exports = utils;