'use strict';
var __assign = (this && this.__assign) || Object.assign || function(t) {
    for (var s, i = 1, n = arguments.length; i < n; i++) {
        s = arguments[i];
        for (var p in s) if (Object.prototype.hasOwnProperty.call(s, p))
            t[p] = s[p];
    }
    return t;
};
exports.__esModule = true;
var GenericResponse = require("http-response-object");
var Promise = require("promise");
var concat = require("concat-stream");
var ResponsePromise_1 = require("./ResponsePromise");
exports.ResponsePromise = ResponsePromise_1.ResponsePromise;
var handle_qs_1 = require("./handle-qs");
var http_basic_1 = require("http-basic");
var FormData = require("form-data");
exports.FormData = FormData;
var caseless = require('caseless');
var basicRequest = http_basic_1["default"];
var BufferBody = /** @class */ (function () {
    function BufferBody(body, extraHeaders) {
        this._body = body;
        this._headers = extraHeaders;
    }
    BufferBody.prototype.getHeaders = function () {
        return Promise.resolve(__assign({ 'content-length': '' + this._body.length }, this._headers));
    };
    BufferBody.prototype.pipe = function (stream) {
        stream.end(this._body);
    };
    return BufferBody;
}());
var FormBody = /** @class */ (function () {
    function FormBody(body) {
        this._body = body;
    }
    FormBody.prototype.getHeaders = function () {
        var _this = this;
        var headers = this._body.getHeaders();
        return new Promise(function (resolve, reject) {
            var gotLength = false;
            _this._body.getLength(function (err, length) {
                if (gotLength)
                    return;
                gotLength = true;
                if (err) {
                    return reject(typeof err == 'string'
                        ? new Error(err)
                        : err);
                }
                headers['content-length'] = '' + length;
                resolve(headers);
            });
        });
    };
    FormBody.prototype.pipe = function (stream) {
        this._body.pipe(stream);
    };
    return FormBody;
}());
var StreamBody = /** @class */ (function () {
    function StreamBody(body) {
        this._body = body;
    }
    StreamBody.prototype.getHeaders = function () {
        return Promise.resolve({});
    };
    StreamBody.prototype.pipe = function (stream) {
        this._body.pipe(stream);
    };
    return StreamBody;
}());
function handleBody(options) {
    if (options.form) {
        return new FormBody(options.form);
    }
    var extraHeaders = {};
    var body = options.body;
    if (options.json) {
        extraHeaders['content-type'] = 'application/json';
        body = JSON.stringify(options.json);
    }
    if (typeof body === 'string') {
        body = Buffer.from(body);
    }
    if (!body) {
        body = Buffer.alloc(0);
    }
    if (!Buffer.isBuffer(body)) {
        if (typeof body.pipe === 'function') {
            return new StreamBody(body);
        }
        throw new TypeError('body should be a Buffer or a String');
    }
    return new BufferBody(body, extraHeaders);
}
function request(method, url, options) {
    if (options === void 0) { options = {}; }
    return ResponsePromise_1["default"](new Promise(function (resolve, reject) {
        // check types of arguments
        if (typeof method !== 'string') {
            throw new TypeError('The method must be a string.');
        }
        if (typeof url !== 'string') {
            throw new TypeError('The URL/path must be a string.');
        }
        if (options == null) {
            options = {};
        }
        if (typeof options !== 'object') {
            throw new TypeError('Options must be an object (or null).');
        }
        method = method.toUpperCase();
        options.headers = options.headers || {};
        var headers = caseless(options.headers);
        // handle query string
        if (options.qs) {
            url = handle_qs_1["default"](url, options.qs);
        }
        var duplex = !(method === 'GET' || method === 'DELETE' || method === 'HEAD');
        if (duplex) {
            var body_1 = handleBody(options);
            body_1.getHeaders().then(function (bodyHeaders) {
                Object.keys(bodyHeaders).forEach(function (key) {
                    if (!headers.has(key)) {
                        headers.set(key, bodyHeaders[key]);
                    }
                });
                ready(body_1);
            })["catch"](reject);
        }
        else if (options.body) {
            throw new Error('You cannot pass a body to a ' + method + ' request.');
        }
        else {
            ready();
        }
        function ready(body) {
            var req = basicRequest(method, url, {
                allowRedirectHeaders: options.allowRedirectHeaders,
                headers: options.headers,
                followRedirects: options.followRedirects !== false,
                maxRedirects: options.maxRedirects,
                gzip: options.gzip !== false,
                cache: options.cache,
                agent: options.agent,
                timeout: options.timeout,
                socketTimeout: options.socketTimeout,
                retry: options.retry,
                retryDelay: options.retryDelay,
                maxRetries: options.maxRetries,
                isMatch: options.isMatch,
                isExpired: options.isExpired,
                canCache: options.canCache
            }, function (err, res) {
                if (err)
                    return reject(err);
                if (!res)
                    return reject(new Error('No request was received'));
                res.body.on('error', reject);
                res.body.pipe(concat(function (body) {
                    resolve(new GenericResponse(res.statusCode, res.headers, Array.isArray(body) ? Buffer.alloc(0) : body, res.url));
                }));
            });
            if (req && body) {
                body.pipe(req);
            }
        }
    }));
}
exports["default"] = request;
module.exports = request;
module.exports["default"] = request;
module.exports.FormData = FormData;