80 lines
2.1 KiB
JavaScript
80 lines
2.1 KiB
JavaScript
|
'use strict';
|
||
|
|
const errors = require('./errors');
|
||
|
|
const asStream = require('./as-stream');
|
||
|
|
const asPromise = require('./as-promise');
|
||
|
|
const normalizeArguments = require('./normalize-arguments');
|
||
|
|
const merge = require('./merge');
|
||
|
|
const deepFreeze = require('./utils/deep-freeze');
|
||
|
|
|
||
|
|
const getPromiseOrStream = options => options.stream ? asStream(options) : asPromise(options);
|
||
|
|
|
||
|
|
const aliases = [
|
||
|
|
'get',
|
||
|
|
'post',
|
||
|
|
'put',
|
||
|
|
'patch',
|
||
|
|
'head',
|
||
|
|
'delete'
|
||
|
|
];
|
||
|
|
|
||
|
|
const create = defaults => {
|
||
|
|
defaults = merge({}, defaults);
|
||
|
|
normalizeArguments.preNormalize(defaults.options);
|
||
|
|
|
||
|
|
if (!defaults.handler) {
|
||
|
|
// This can't be getPromiseOrStream, because when merging
|
||
|
|
// the chain would stop at this point and no further handlers would be called.
|
||
|
|
defaults.handler = (options, next) => next(options);
|
||
|
|
}
|
||
|
|
|
||
|
|
function got(url, options) {
|
||
|
|
try {
|
||
|
|
return defaults.handler(normalizeArguments(url, options, defaults), getPromiseOrStream);
|
||
|
|
} catch (error) {
|
||
|
|
if (options && options.stream) {
|
||
|
|
throw error;
|
||
|
|
} else {
|
||
|
|
return Promise.reject(error);
|
||
|
|
}
|
||
|
|
}
|
||
|
|
}
|
||
|
|
|
||
|
|
got.create = create;
|
||
|
|
got.extend = options => {
|
||
|
|
let mutableDefaults;
|
||
|
|
if (options && Reflect.has(options, 'mutableDefaults')) {
|
||
|
|
mutableDefaults = options.mutableDefaults;
|
||
|
|
delete options.mutableDefaults;
|
||
|
|
} else {
|
||
|
|
mutableDefaults = defaults.mutableDefaults;
|
||
|
|
}
|
||
|
|
|
||
|
|
return create({
|
||
|
|
options: merge.options(defaults.options, options),
|
||
|
|
handler: defaults.handler,
|
||
|
|
mutableDefaults
|
||
|
|
});
|
||
|
|
};
|
||
|
|
|
||
|
|
got.mergeInstances = (...args) => create(merge.instances(args));
|
||
|
|
|
||
|
|
got.stream = (url, options) => got(url, {...options, stream: true});
|
||
|
|
|
||
|
|
for (const method of aliases) {
|
||
|
|
got[method] = (url, options) => got(url, {...options, method});
|
||
|
|
got.stream[method] = (url, options) => got.stream(url, {...options, method});
|
||
|
|
}
|
||
|
|
|
||
|
|
Object.assign(got, {...errors, mergeOptions: merge.options});
|
||
|
|
Object.defineProperty(got, 'defaults', {
|
||
|
|
value: defaults.mutableDefaults ? defaults : deepFreeze(defaults),
|
||
|
|
writable: defaults.mutableDefaults,
|
||
|
|
configurable: defaults.mutableDefaults,
|
||
|
|
enumerable: true
|
||
|
|
});
|
||
|
|
|
||
|
|
return got;
|
||
|
|
};
|
||
|
|
|
||
|
|
module.exports = create;
|