2016-04-05 10:43:12 -07:00
|
|
|
|
2015-06-03 21:05:01 -07:00
|
|
|
/**
|
|
|
|
* request.js
|
|
|
|
*
|
|
|
|
* Request class contains server only options
|
2018-03-04 19:38:57 -08:00
|
|
|
*
|
|
|
|
* All spec algorithm step numbers are based on https://fetch.spec.whatwg.org/commit-snapshots/ae716822cb3a61843226cd090eefc6589446c1d2/.
|
2015-06-03 21:05:01 -07:00
|
|
|
*/
|
|
|
|
|
2018-07-22 09:58:03 -07:00
|
|
|
import { format as format_url, parse as parse_url } from 'url';
|
2018-03-22 22:01:45 -07:00
|
|
|
import Headers, { exportNodeCompatibleHeaders } from './headers.js';
|
2016-11-23 13:39:35 -08:00
|
|
|
import Body, { clone, extractContentType, getTotalBytes } from './body';
|
|
|
|
|
2018-01-27 12:28:56 -08:00
|
|
|
const INTERNALS = Symbol('Request internals');
|
|
|
|
|
|
|
|
/**
|
|
|
|
* Check if a value is an instance of Request.
|
|
|
|
*
|
|
|
|
* @param Mixed input
|
|
|
|
* @return Boolean
|
|
|
|
*/
|
|
|
|
function isRequest(input) {
|
|
|
|
return (
|
|
|
|
typeof input === 'object' &&
|
|
|
|
typeof input[INTERNALS] === 'object'
|
|
|
|
);
|
|
|
|
}
|
2015-06-03 21:05:01 -07:00
|
|
|
|
|
|
|
/**
|
|
|
|
* Request class
|
|
|
|
*
|
|
|
|
* @param Mixed input Url or Request instance
|
|
|
|
* @param Object init Custom options
|
|
|
|
* @return Void
|
|
|
|
*/
|
2017-02-26 14:29:40 -08:00
|
|
|
export default class Request {
|
2016-10-10 11:50:04 -07:00
|
|
|
constructor(input, init = {}) {
|
2016-10-08 18:31:42 -07:00
|
|
|
let parsedURL;
|
2015-06-03 21:05:01 -07:00
|
|
|
|
2016-10-10 11:50:04 -07:00
|
|
|
// normalize input
|
2018-01-27 12:28:56 -08:00
|
|
|
if (!isRequest(input)) {
|
2016-10-12 19:56:47 -07:00
|
|
|
if (input && input.href) {
|
|
|
|
// in order to support Node.js' Url objects; though WHATWG's URL objects
|
|
|
|
// will fall into this branch also (since their `toString()` will return
|
|
|
|
// `href` property anyway)
|
|
|
|
parsedURL = parse_url(input.href);
|
|
|
|
} else {
|
|
|
|
// coerce input to a string before attempting to parse
|
2016-12-14 15:44:30 -08:00
|
|
|
parsedURL = parse_url(`${input}`);
|
2016-10-12 19:56:47 -07:00
|
|
|
}
|
2016-10-10 11:50:04 -07:00
|
|
|
input = {};
|
|
|
|
} else {
|
2016-10-08 18:31:42 -07:00
|
|
|
parsedURL = parse_url(input.url);
|
2016-10-10 11:50:04 -07:00
|
|
|
}
|
2015-06-03 21:05:01 -07:00
|
|
|
|
2016-12-04 13:13:51 -08:00
|
|
|
let method = init.method || input.method || 'GET';
|
2017-11-18 20:44:02 -08:00
|
|
|
method = method.toUpperCase();
|
2016-12-04 13:13:51 -08:00
|
|
|
|
2018-01-27 12:28:56 -08:00
|
|
|
if ((init.body != null || isRequest(input) && input.body !== null) &&
|
2016-12-04 13:13:51 -08:00
|
|
|
(method === 'GET' || method === 'HEAD')) {
|
|
|
|
throw new TypeError('Request with GET/HEAD method cannot have body');
|
|
|
|
}
|
|
|
|
|
2016-12-04 13:16:03 -08:00
|
|
|
let inputBody = init.body != null ?
|
|
|
|
init.body :
|
2018-01-27 12:28:56 -08:00
|
|
|
isRequest(input) && input.body !== null ?
|
2016-12-04 13:16:03 -08:00
|
|
|
clone(input) :
|
|
|
|
null;
|
|
|
|
|
2017-02-26 14:29:40 -08:00
|
|
|
Body.call(this, inputBody, {
|
2016-10-10 11:50:04 -07:00
|
|
|
timeout: init.timeout || input.timeout || 0,
|
|
|
|
size: init.size || input.size || 0
|
|
|
|
});
|
2015-06-03 21:05:01 -07:00
|
|
|
|
2018-01-27 12:28:56 -08:00
|
|
|
const headers = new Headers(init.headers || input.headers || {});
|
2015-06-03 21:40:01 -07:00
|
|
|
|
2016-12-04 13:13:51 -08:00
|
|
|
if (init.body != null) {
|
2016-11-23 12:42:24 -08:00
|
|
|
const contentType = extractContentType(this);
|
2018-01-27 12:28:56 -08:00
|
|
|
if (contentType !== null && !headers.has('Content-Type')) {
|
|
|
|
headers.append('Content-Type', contentType);
|
2016-11-23 12:42:24 -08:00
|
|
|
}
|
|
|
|
}
|
|
|
|
|
2018-01-27 12:28:56 -08:00
|
|
|
this[INTERNALS] = {
|
|
|
|
method,
|
|
|
|
redirect: init.redirect || input.redirect || 'follow',
|
|
|
|
headers,
|
|
|
|
parsedURL
|
|
|
|
};
|
|
|
|
|
|
|
|
// node-fetch-only options
|
2016-10-10 11:50:04 -07:00
|
|
|
this.follow = init.follow !== undefined ?
|
|
|
|
init.follow : input.follow !== undefined ?
|
|
|
|
input.follow : 20;
|
|
|
|
this.compress = init.compress !== undefined ?
|
|
|
|
init.compress : input.compress !== undefined ?
|
|
|
|
input.compress : true;
|
|
|
|
this.counter = init.counter || input.counter || 0;
|
|
|
|
this.agent = init.agent || input.agent;
|
2018-01-27 12:28:56 -08:00
|
|
|
}
|
2015-08-10 12:35:01 -07:00
|
|
|
|
2018-01-27 12:28:56 -08:00
|
|
|
get method() {
|
|
|
|
return this[INTERNALS].method;
|
2016-10-08 18:31:42 -07:00
|
|
|
}
|
|
|
|
|
|
|
|
get url() {
|
2018-01-27 12:28:56 -08:00
|
|
|
return format_url(this[INTERNALS].parsedURL);
|
|
|
|
}
|
|
|
|
|
|
|
|
get headers() {
|
|
|
|
return this[INTERNALS].headers;
|
|
|
|
}
|
|
|
|
|
|
|
|
get redirect() {
|
|
|
|
return this[INTERNALS].redirect;
|
2016-10-10 11:50:04 -07:00
|
|
|
}
|
2015-08-10 12:35:01 -07:00
|
|
|
|
2016-10-10 11:50:04 -07:00
|
|
|
/**
|
|
|
|
* Clone this request
|
|
|
|
*
|
|
|
|
* @return Request
|
|
|
|
*/
|
|
|
|
clone() {
|
|
|
|
return new Request(this);
|
|
|
|
}
|
|
|
|
}
|
2016-11-23 14:36:08 -08:00
|
|
|
|
2017-02-26 14:42:09 -08:00
|
|
|
Body.mixIn(Request.prototype);
|
2017-02-26 14:29:40 -08:00
|
|
|
|
2016-11-23 14:36:08 -08:00
|
|
|
Object.defineProperty(Request.prototype, Symbol.toStringTag, {
|
2018-01-27 12:28:56 -08:00
|
|
|
value: 'Request',
|
2016-11-23 14:36:08 -08:00
|
|
|
writable: false,
|
|
|
|
enumerable: false,
|
|
|
|
configurable: true
|
|
|
|
});
|
2016-11-23 13:39:35 -08:00
|
|
|
|
2018-01-27 12:28:56 -08:00
|
|
|
Object.defineProperties(Request.prototype, {
|
|
|
|
method: { enumerable: true },
|
|
|
|
url: { enumerable: true },
|
|
|
|
headers: { enumerable: true },
|
|
|
|
redirect: { enumerable: true },
|
|
|
|
clone: { enumerable: true }
|
|
|
|
});
|
|
|
|
|
2018-01-27 11:49:12 -08:00
|
|
|
/**
|
|
|
|
* Convert a Request to Node.js http request options.
|
|
|
|
*
|
|
|
|
* @param Request A Request instance
|
|
|
|
* @return Object The options object to be passed to http.request
|
|
|
|
*/
|
2017-01-29 09:56:19 -08:00
|
|
|
export function getNodeRequestOptions(request) {
|
2018-01-27 12:28:56 -08:00
|
|
|
const parsedURL = request[INTERNALS].parsedURL;
|
|
|
|
const headers = new Headers(request[INTERNALS].headers);
|
2016-11-23 13:39:35 -08:00
|
|
|
|
2018-03-04 19:38:57 -08:00
|
|
|
// fetch step 1.3
|
2017-01-29 09:56:19 -08:00
|
|
|
if (!headers.has('Accept')) {
|
|
|
|
headers.set('Accept', '*/*');
|
2016-11-23 13:39:35 -08:00
|
|
|
}
|
|
|
|
|
2017-01-29 09:56:19 -08:00
|
|
|
// Basic fetch
|
2017-02-26 15:30:43 -08:00
|
|
|
if (!parsedURL.protocol || !parsedURL.hostname) {
|
|
|
|
throw new TypeError('Only absolute URLs are supported');
|
|
|
|
}
|
|
|
|
|
|
|
|
if (!/^https?:$/.test(parsedURL.protocol)) {
|
|
|
|
throw new TypeError('Only HTTP(S) protocols are supported');
|
2016-11-23 13:39:35 -08:00
|
|
|
}
|
|
|
|
|
2018-03-04 19:38:57 -08:00
|
|
|
// HTTP-network-or-cache fetch steps 2.4-2.7
|
2017-01-29 09:56:19 -08:00
|
|
|
let contentLengthValue = null;
|
|
|
|
if (request.body == null && /^(POST|PUT)$/i.test(request.method)) {
|
|
|
|
contentLengthValue = '0';
|
2016-11-23 13:39:35 -08:00
|
|
|
}
|
2017-01-29 09:56:19 -08:00
|
|
|
if (request.body != null) {
|
2016-11-23 13:39:35 -08:00
|
|
|
const totalBytes = getTotalBytes(request);
|
|
|
|
if (typeof totalBytes === 'number') {
|
2017-01-29 09:56:19 -08:00
|
|
|
contentLengthValue = String(totalBytes);
|
2016-11-23 13:39:35 -08:00
|
|
|
}
|
|
|
|
}
|
2017-01-29 09:56:19 -08:00
|
|
|
if (contentLengthValue) {
|
|
|
|
headers.set('Content-Length', contentLengthValue);
|
|
|
|
}
|
2016-11-23 13:39:35 -08:00
|
|
|
|
2018-03-04 19:38:57 -08:00
|
|
|
// HTTP-network-or-cache fetch step 2.11
|
2017-01-29 09:56:19 -08:00
|
|
|
if (!headers.has('User-Agent')) {
|
|
|
|
headers.set('User-Agent', 'node-fetch/1.0 (+https://github.com/bitinn/node-fetch)');
|
|
|
|
}
|
|
|
|
|
2018-03-04 19:38:57 -08:00
|
|
|
// HTTP-network-or-cache fetch step 2.15
|
2017-01-29 09:56:19 -08:00
|
|
|
if (request.compress) {
|
|
|
|
headers.set('Accept-Encoding', 'gzip,deflate');
|
|
|
|
}
|
|
|
|
if (!headers.has('Connection') && !request.agent) {
|
|
|
|
headers.set('Connection', 'close');
|
|
|
|
}
|
|
|
|
|
2018-03-04 19:38:57 -08:00
|
|
|
// HTTP-network fetch step 4.2
|
2017-01-29 09:56:19 -08:00
|
|
|
// chunked encoding is handled by Node.js
|
2016-11-23 13:39:35 -08:00
|
|
|
|
2017-02-26 15:30:43 -08:00
|
|
|
return Object.assign({}, parsedURL, {
|
2016-11-23 13:39:35 -08:00
|
|
|
method: request.method,
|
2018-03-22 22:01:45 -07:00
|
|
|
headers: exportNodeCompatibleHeaders(headers),
|
2016-11-23 13:39:35 -08:00
|
|
|
agent: request.agent
|
|
|
|
});
|
|
|
|
}
|