archive-gh-me/gitbeaker
1
0
Fork 0
mirror of https://github.com/jdalrymple/gitbeaker.git synced 2026-01-25 16:04:01 +00:00
Code Issues Projects Releases Wiki Activity

refactor: Conditionally add the https new Agent

Browse Source
This commit is contained in:
Justin 2019-06-28 10:33:07 -04:00
parent 71dde54d02
commit 17bed59e52
1 changed files with 20 additions and 15 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

35
src/infrastructure/KyRequester.ts
View File

@ -23,34 +23,39 @@ function responseHeadersAsObject(response) {
function defaultRequest(service: any, { body, query, sudo, method }) {
const headers = new Headers(service.headers);
let bod = body;
let agent;
if (sudo) headers.append('sudo', `${sudo}`);
if (typeof body === 'object' && !(body instanceof FormData)){
if (typeof body === 'object' && !(body instanceof FormData)) {
bod = JSON.stringify(decamelizeKeys(body, skipAllCaps));
}
if (service.rejectUnauthorized) {
agent = new Agent({
rejectUnauthorized: service.rejectUnauthorized,
});
}
return {
timeout: service.requestTimeout,
headers,
method: (method === 'stream') ? 'get' : method,
onProgress: (method === 'stream') ? () => {} : undefined,
searchParams: stringify(decamelizeKeys(query || {}) as any, { arrayFormat: 'bracket' }),
prefixUrl: service.url,
body: bod,
agent: new Agent({
rejectUnauthorized: service.rejectUnauthorized
})
}
timeout: service.requestTimeout,
headers,
method: method === 'stream' ? 'get' : method,
onProgress: method === 'stream' ? () => {} : undefined,
searchParams: stringify(decamelizeKeys(query || {}) as any, { arrayFormat: 'bracket' }),
prefixUrl: service.url,
body: bod,
agent,
};
}
async function processBody(response) {
const contentType = response.headers.get('content-type') || '';
const content = await response.text();
if(contentType.includes('json')) {
if (contentType.includes('json')) {
try {
return JSON.parse(content || "{}");
return JSON.parse(content || '{}');
} catch {
return {};
}