[Updater > Request] Clean up source more
This commit is contained in:
parent
6fa918c6c7
commit
5fb4664a9b
1 changed files with 5 additions and 3 deletions
|
@ -1,7 +1,9 @@
|
||||||
const request = require('request');
|
const request = require('request');
|
||||||
|
|
||||||
const nodeRequest = ({ method, url, headers, qs, timeout, body, stream }) => new Promise((resolve, reject) => {
|
const nodeRequest = (opts) => new Promise((resolve, reject) => {
|
||||||
const req = request({ method, url, headers, qs, timeout: timeout ?? 30000, body });
|
const { stream, timeout } = opts;
|
||||||
|
|
||||||
|
const req = request({ ...opts, timeout: timeout ?? 30000 });
|
||||||
|
|
||||||
req.on('response', (response) => {
|
req.on('response', (response) => {
|
||||||
const total = parseInt(response.headers['content-length'] || 1, 10);
|
const total = parseInt(response.headers['content-length'] || 1, 10);
|
||||||
|
@ -26,7 +28,7 @@ const nodeRequest = ({ method, url, headers, qs, timeout, body, stream }) => new
|
||||||
return stream.end();
|
return stream.end();
|
||||||
}
|
}
|
||||||
|
|
||||||
if (badStatus) return reject(new Error('Req error:' + response.statusCode));
|
if (badStatus) return reject(new Error('Req fail'));
|
||||||
|
|
||||||
resolve({ ...response, body: Buffer.concat(chunks) });
|
resolve({ ...response, body: Buffer.concat(chunks) });
|
||||||
});
|
});
|
||||||
|
|
Loading…
Reference in a new issue