mirror of https://github.com/Seich/Beau.git
114 lines
2.5 KiB
JavaScript
114 lines
2.5 KiB
JavaScript
const request = require('request-promise-native');
|
|
const {httpVerbs, requestRegex, replacementRegex} = require('./shared');
|
|
const RequestList = require('./requestList');
|
|
const RequestCache = require('./requestCache');
|
|
|
|
class Request {
|
|
constructor(req, list) {
|
|
let config = {};
|
|
this.originalRequest = req;
|
|
|
|
Object.keys(req).forEach(k => config[k.toUpperCase()] = req[k]);
|
|
|
|
let { REQUEST, ALIAS, PAYLOAD, HOST, PARAMS, HEADERS } = config;
|
|
let { verb, endpoint } = this.parseRequest(REQUEST);
|
|
|
|
this.VERB = verb;
|
|
this.ENDPOINT = HOST + endpoint;
|
|
|
|
this.HEADERS = HEADERS;
|
|
this.PAYLOAD = PAYLOAD;
|
|
this.PARAMS = PARAMS;
|
|
|
|
this.ALIAS = ALIAS;
|
|
this.DEPENDENCIES = this.findDependencies(req);
|
|
|
|
this.list = list;
|
|
}
|
|
|
|
parseRequest(request) {
|
|
let parts = request.match(requestRegex);
|
|
|
|
return {
|
|
verb: parts[1],
|
|
endpoint: parts[2]
|
|
};
|
|
}
|
|
|
|
findDependencies(request, set = new Set()) {
|
|
if (typeof request === 'object') {
|
|
Object.keys(request).forEach(key => {
|
|
if (key === 'ALIAS')
|
|
return;
|
|
|
|
set = this.findDependencies(request[key], set);
|
|
});
|
|
} else if (typeof request === 'string') {
|
|
let matches = request.match(replacementRegex) || [];
|
|
let deps = matches.map(m => m.split('.')[0].substring(1));
|
|
|
|
return new Set([...set, ...deps]);
|
|
}
|
|
|
|
return set;
|
|
}
|
|
|
|
exec(modifiers = []) {
|
|
let dependencies = Array.from(this.DEPENDENCIES);
|
|
|
|
return this.list.fetchDependencies(dependencies).then(cache => {
|
|
let settings = {
|
|
endpoint: cache.parse(this.ENDPOINT),
|
|
method: this.VERB,
|
|
headers: cache.parse(this.HEADERS),
|
|
query: cache.parse(this.PARAMS),
|
|
payload: cache.parse(this.PAYLOAD)
|
|
};
|
|
|
|
modifiers.forEach(mod => {
|
|
if (typeof mod.preRequest !== 'undefined') {
|
|
mod.preRequest(settings, this.originalRequest);
|
|
}
|
|
});
|
|
|
|
return request({
|
|
url: settings.endpoint,
|
|
method: settings.method,
|
|
headers: settings.headers,
|
|
qs: settings.query,
|
|
body: settings.payload,
|
|
json: true,
|
|
simple: false,
|
|
resolveWithFullResponse: true
|
|
})
|
|
|
|
.then(response => {
|
|
let results = {
|
|
request: {
|
|
headers: response.request.headers,
|
|
body: response.request.body,
|
|
endpoint: response.request.uri.href
|
|
},
|
|
response: {
|
|
status: response.statusCode,
|
|
headers: response.headers,
|
|
body: response.body
|
|
},
|
|
body: response.body
|
|
};
|
|
|
|
cache.add(`$${this.ALIAS}`, results);
|
|
|
|
return results;
|
|
})
|
|
|
|
.catch(function({error}) {
|
|
throw new Error(error.message);
|
|
});
|
|
|
|
});
|
|
}
|
|
}
|
|
|
|
module.exports = Request;
|