index.node.js

/**
 * Copyright 2016-2018, Optimizely
 *
 * Licensed 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.
 */
var http = require('http');
var https = require('https');
var url = require('url');

module.exports = {
  /**
   * Dispatch an HTTP request to the given url and the specified options
   * @param {Object}  eventObj          Event object containing
   * @param {string}  eventObj.url      the url to make the request to
   * @param {Object}  eventObj.params   parameters to pass to the request (i.e. in the POST body)
   * @param {string}  eventObj.httpVerb the HTTP request method type. only POST is supported.
   * @param {function} callback         callback to execute
   * @return {ClientRequest|undefined}          ClientRequest object which made the request, or undefined if no request was made (error)
   */
  dispatchEvent: function(eventObj, callback) {
    // Non-POST requests not supported
    if (eventObj.httpVerb !== 'POST') {
      callback(new Error('httpVerb not supported: ' + eventObj.httpVerb));
      return;
    }

    var parsedUrl = url.parse(eventObj.url);
    var path = parsedUrl.path;
    if (parsedUrl.query) {
      path += '?' + parsedUrl.query;
    }

    var dataString = JSON.stringify(eventObj.params);

    var requestOptions = {
      host: parsedUrl.host,
      path: parsedUrl.path,
      method: 'POST',
      headers: {
        'content-type': 'application/json',
        'content-length': dataString.length.toString(),
      }
    };

    var requestCallback = function(error, response, body) {
      if (response && response.statusCode && response.statusCode >= 200 && response.statusCode < 400 && callback && typeof callback === 'function') {
        callback();
      }
    };

    var req = (parsedUrl.protocol === 'http:' ? http : https).request(requestOptions, requestCallback);
    req.on('error', function(err) {
      callback(err);
    });
    req.write(dataString);
    req.end();
    return req;
  }
};