import { request } from 'https';
import { globalAgent } from 'http';
import { parse, resolve } from 'url';

function toError(rej, res, err) {
	err = err || new Error(res.statusMessage);
	err.statusMessage = res.statusMessage;
	err.statusCode = res.statusCode;
	err.headers = res.headers;
	err.data = res.data;
	rej(err);
}

export function send(method, uri, opts={}) {
	return new Promise((res, rej) => {
		let out = '';
		opts.method = method;
		let { redirect=true } = opts;
		if (uri && !!uri.toJSON) uri = uri.toJSON();
		Object.assign(opts, typeof uri === 'string' ? parse(uri) : uri);
		opts.agent = opts.protocol === 'http:' ? globalAgent : void 0;

		let req = request(opts, r => {
			r.setEncoding('utf8');

			r.on('data', d => {
				out += d;
			});

			r.on('end', () => {
				let type = r.headers['content-type'];
				if (type && out && type.includes('application/json')) {
					try {
						out = JSON.parse(out, opts.reviver);
					} catch (err) {
						return toError(rej, r, err);
					}
				}
				r.data = out;
				if (r.statusCode >= 400) {
					toError(rej, r);
				} else if (r.statusCode > 300 && redirect && r.headers.location) {
					opts.path = resolve(opts.path, r.headers.location);
					return send(method, opts.path.startsWith('/') ? opts : opts.path, opts).then(res, rej);
				} else {
					res(r);
				}
			});
		});

		req.on('error', rej);

		if (opts.body) {
			let isObj = typeof opts.body === 'object' && !Buffer.isBuffer(opts.body);
			let str = isObj ? JSON.stringify(opts.body) : opts.body;
			isObj && req.setHeader('content-type', 'application/json');
			req.setHeader('content-length', Buffer.byteLength(str));
			req.write(str);
		}

		req.end();
	});
}

export const get = send.bind(null, 'GET');
export const post = send.bind(null, 'POST');
export const patch = send.bind(null, 'PATCH');
export const del = send.bind(null, 'DELETE');
export const put = send.bind(null, 'PUT');