'use strict';

Object.defineProperty(exports, "__esModule", {
  value: true
});

var _typeof = typeof Symbol === "function" && typeof Symbol.iterator === "symbol" ? function (obj) { return typeof obj; } : function (obj) { return obj && typeof Symbol === "function" && obj.constructor === Symbol && obj !== Symbol.prototype ? "symbol" : typeof obj; };

exports.getRequestOptions = getRequestOptions;
exports.dataIsAndCanBePrimitive = dataIsAndCanBePrimitive;
exports.getApidocTypeForPrimitive = getApidocTypeForPrimitive;
exports.getTypesForUnion = getTypesForUnion;
exports.isObject = isObject;
exports.getQueryString = getQueryString;
exports.doRequest = doRequest;

var _request = require('request');

var _request2 = _interopRequireDefault(_request);

function _interopRequireDefault(obj) { return obj && obj.__esModule ? obj : { default: obj }; }

function _defineProperty(obj, key, value) { if (key in obj) { Object.defineProperty(obj, key, { value: value, enumerable: true, configurable: true, writable: true }); } else { obj[key] = value; } return obj; }

var showLogMessages = process.env.NODE_DEBUG ? process.env.NODE_DEBUG.indexOf('apidoc') !== -1 : false;
var enums = [{ "name": "default_emr_job_flow_role", "plural": "default_emr_job_flow_roles", "values": [{ "name": "default_emr_job_flow_role", "attributes": [], "value": "EMR_EC2_DefaultRole" }], "attributes": [], "description": "The default EMR EC2 Instance role" }, { "name": "default_emr_service_role", "plural": "default_emr_service_roles", "values": [{ "name": "default_emr_service_role", "attributes": [], "value": "EMR_DefaultRole" }], "attributes": [], "description": "The default EMR Service role" }, { "name": "emr_application", "plural": "emr_applications", "values": [{ "name": "Hadoop", "attributes": [] }, { "name": "Hive", "attributes": [] }, { "name": "Mahout", "attributes": [] }, { "name": "Pig", "attributes": [] }, { "name": "Spark", "attributes": [] }], "attributes": [], "description": "List of applications to install in the EMR cluster" }, { "name": "emr_release_label", "plural": "emr_release_labels", "values": [{ "name": "emr-5.14.0", "attributes": [] }, { "name": "emr-5.13.0", "attributes": [] }, { "name": "emr-5.12.1", "attributes": [] }, { "name": "emr-5.12.0", "attributes": [] }, { "name": "emr-5.11.1", "attributes": [] }, { "name": "emr-5.11.0", "attributes": [] }, { "name": "emr-5.10.0", "attributes": [] }, { "name": "emr-5.9.0", "attributes": [] }, { "name": "emr-4.9.2", "attributes": [] }, { "name": "emr-4.9.1", "attributes": [] }], "attributes": [], "description": "Version (aka label in AWS-EMR) of the EMR stack to create." }, { "name": "notification_options", "plural": "notification_optionses", "values": [{ "name": "always", "attributes": [], "description": "Always notify when a process completes" }, { "name": "on_failure", "attributes": [], "description": "Notify when a process fails" }, { "name": "on_state_change", "attributes": [], "description": "Notify when a process goes from succeeding to failing and vica versa" }, { "name": "on_state_change_and_failures", "attributes": [], "description": "Notify when going from failing to succeeded and on each failure" }, { "name": "never", "attributes": [], "description": "Never notify" }], "attributes": [] }, { "name": "on_demand", "plural": "on_demands", "values": [{ "name": "on_demand", "attributes": [] }], "attributes": [], "description": "The onDemand type of Market Type" }, { "name": "process_overlap_action", "plural": "process_overlap_actions", "values": [{ "name": "wait", "attributes": [], "description": "The process should wait until the currently running instance finishes" }, { "name": "terminate", "attributes": [], "description": "The currently running process should be killed" }], "attributes": [] }, { "name": "process_status", "plural": "process_statuses", "values": [{ "name": "running", "attributes": [], "description": "The process has tasks currently executing" }, { "name": "succeeded", "attributes": [], "description": "All of the process's tasks succeeded on its last run" }, { "name": "failed", "attributes": [], "description": "At least one of the process's tasks failed on its last run" }], "attributes": [] }, { "name": "task_status", "plural": "task_statuses", "values": [{ "name": "submitted", "attributes": [], "description": "The task has been submitted" }, { "name": "runnable", "attributes": [] }, { "name": "starting", "attributes": [] }, { "name": "pending", "attributes": [], "description": "The task is waiting on compute resources" }, { "name": "running", "attributes": [], "description": "The task is currently executing or awaiting backoff" }, { "name": "failed", "attributes": [], "description": "The task has irrevocably failed" }, { "name": "succeeded", "attributes": [], "description": "The task has succeeded without serious errors" }], "attributes": [] }];
var unions = [{ "name": "aws_market", "plural": "aws_markets", "types": [{ "type": "on_demand", "attributes": [], "discriminator_value": "on_demand" }, { "type": "spot", "attributes": [], "discriminator_value": "spot" }], "attributes": [], "interfaces": [], "description": "The EC2 market of the EC2 instances" }, { "name": "emr_cluster", "plural": "emr_clusters", "types": [{ "type": "new_emr_cluster", "attributes": [], "discriminator_value": "new_emr_cluster" }, { "type": "existing_emr_cluster", "attributes": [], "discriminator_value": "existing_emr_cluster" }], "attributes": [], "interfaces": [], "description": "Whether or not to create a new EMR cluster or re-use a pre-existing one" }, { "name": "emr_job_flow_role", "plural": "emr_job_flow_roles", "types": [{ "type": "default_emr_job_flow_role", "attributes": [], "discriminator_value": "default_emr_job_flow_role" }, { "type": "custom_emr_job_flow_role", "attributes": [], "discriminator_value": "custom_emr_job_flow_role" }], "attributes": [], "interfaces": [], "description": "The EMR role to use on the EC2 instances" }, { "name": "emr_service_role", "plural": "emr_service_roles", "types": [{ "type": "default_emr_service_role", "attributes": [], "discriminator_value": "default_emr_service_role" }, { "type": "custom_emr_service_role", "attributes": [], "discriminator_value": "custom_emr_service_role" }], "attributes": [], "interfaces": [], "description": "The EMR service role to use" }, { "name": "notification", "plural": "notifications", "types": [{ "type": "email", "attributes": [], "discriminator_value": "email" }, { "type": "pagerduty", "attributes": [], "discriminator_value": "pagerduty" }], "attributes": [], "interfaces": [] }, { "name": "process_schedule", "plural": "process_schedules", "types": [{ "type": "cron_schedule", "attributes": [], "discriminator_value": "cron_schedule" }, { "type": "continuous_schedule", "attributes": [], "discriminator_value": "continuous_schedule" }], "attributes": [], "interfaces": [], "description": "A specification for when a process should be run" }, { "name": "task_executable", "plural": "task_executables", "types": [{ "type": "docker_image_command", "attributes": [], "description": "Docker image to run on ECS with Sundial companion container", "deprecation": { "description": "Running jobs on AWS ECS is now deprecated. Use AWS Batch via batch_image_command instead." }, "discriminator_value": "docker_image_command" }, { "type": "shell_script_command", "attributes": [], "description": "Shell command to run on Sundial service instance (Experimental)", "discriminator_value": "shell_script_command" }, { "type": "batch_image_command", "attributes": [], "description": "Docker image to run on AWS Batch", "discriminator_value": "batch_image_command" }, { "type": "emr_command", "attributes": [], "description": "Command to submit Spark Jobs on AWS EMR", "discriminator_value": "emr_command" }], "attributes": [], "interfaces": [] }];

function getRequestOptions(settings, userOptions) {
  return new Promise(function (resolve, reject) {
    if (!isObject(userOptions || {})) {
      reject(new Error('options parameter is required and must be a plain object'));
      return;
    }

    // Don't mutate the options the user provided
    var options = Object.assign({}, userOptions);

    // Handle the body of the request (options.data as provided by the user)
    if (settings.requiresBody) {
      if (!options.data) {
        reject(new Error('options.data property is required.'));
        return;
      }

      if (settings.discriminator) {
        if (dataIsAndCanBePrimitive(settings.bodyType, options.data)) {
          var _dataUpdate;

          var dataUpdate = (_dataUpdate = {}, _defineProperty(_dataUpdate, settings.discriminator, getApidocTypeForPrimitive(settings.bodyType, options.data)), _defineProperty(_dataUpdate, 'value', options.data), _dataUpdate);
          options.data = Object.assign({}, dataUpdate);
        }

        if (!options.data[settings.discriminator]) {
          reject(new Error('options.data.' + settings.discriminator + ' must be defined. Available options for [' + settings.bodyType + '] are: ' + getTypesForUnion(settings.bodyType).join(', ')));
          return;
        }
      }
    }

    var qs = {};
    settings.queryParams.forEach(function (param) {
      if (options[param.nameCamelCase]) {
        qs[param.name] = options[param.nameCamelCase];
      }
    });

    var json = settings.isApplicationJson ? options.data : undefined;
    var form = settings.isFormUrlEncoded ? options.data : undefined;
    var method = settings.method;

    resolve(Object.assign(options, {
      json: json,
      form: form,
      method: method,
      qs: qs
    }));
  });
}

function dataIsAndCanBePrimitive(bodyType, data) {
  var typesForUnion = getTypesForUnion(bodyType);
  var dataType = typeof data === 'undefined' ? 'undefined' : _typeof(data);

  if (dataType === 'string') {
    return typesForUnion.indexOf('string') != -1;
  } else if (dataType === 'number') {
    return typesForUnion.indexOf('decimal') != -1 || typesForUnion.indexOf('double') != -1 || typesForUnion.indexOf('integer') != -1 || typesForUnion.indexOf('long') != -1;
  } else {
    return false;
  }
}

// Within the context of a union type
function getApidocTypeForPrimitive(bodyType, data) {
  var typesForUnion = getTypesForUnion(bodyType);
  var dataType = typeof data === 'undefined' ? 'undefined' : _typeof(data);

  if (dataType === 'string') {
    // Check if data matches an enum. Use the enum name if it does.
    var enumForData = enums.find(function (e) {
      return !!e.values.find(function (v) {
        return v.name === data;
      });
    });

    if (enumForData) {
      return enumForData.name;
    }

    // default to 'string'
    return dataType;
  } else if (dataType === 'number') {
    var containsDecimalPoint = data.toString().indexOf('.') !== -1;
    var possibleApidocTypes = containsDecimalPoint ? ['decimal', 'double'] : ['integer', 'long'];

    // Return the first one found. Buggy in that this code should know the
    // difference between each of the apidoc types. They are all 'number' in
    // JavaScript though.
    return typesForUnion.find(function (t) {
      return possibleApidocTypes.indexOf(t) !== -1;
    });
  }
}

function getTypesForUnion(unionType) {
  var ut = unions.find(function (u) {
    return u.name === unionType;
  });
  if (ut) {
    return ut.types.map(function (t) {
      return t.type;
    });
  }

  return [];
}

/**
 * Simple plain object check. This is actually really involved to be 100%
 * accurate
 */
function isObject(obj) {
  return (typeof obj === 'undefined' ? 'undefined' : _typeof(obj)) === 'object' && !Array.isArray(obj);
}

function log(message) {
  if (showLogMessages) {
    console.log('[apidoc] ' + message);
  }
}

function getQueryString(options) {
  var qs = options.qs || {};
  var params = Object.keys(qs).reduce(function (kvPairs, key) {
    return kvPairs.concat(key + '=' + qs[key]);
  }, []);
  return params.join('&');
}

function doRequest(options) {
  var startMs = Date.now();
  options = options || {};

  options.qsStringifyOptions = {
    arrayFormat: 'repeat'
  };

  var queryString = getQueryString(options);
  var url = options.uri + (queryString ? '?' + queryString : '');

  log(options.method + ' ' + url);
  if (options.method === 'POST' || options.method === 'PUT' || options.method === 'PATCH') {
    log('|--> With body:\n\t\t' + JSON.stringify(options.json));
  }

  return new Promise(function (resolve, reject) {
    (0, _request2.default)(options, function (err, response) {
      if (err) {
        reject(err);
        return;
      }

      var duration = Date.now() - startMs;
      var requestHref = response.request ? response.request.href : '<unknown url>';

      log('Completed ' + options.method + ' ' + requestHref + ' ' + response.statusCode + ' ' + duration + 'ms');

      resolve(response);
    });
  });
}