From 5e6f2c6fbf594df712c70cbb36422c30a2fe1996 Mon Sep 17 00:00:00 2001 From: Philipp Kunz Date: Mon, 1 Aug 2022 17:15:52 +0200 Subject: [PATCH] fix(core): update --- ts/00_commitinfo_data.ts | 2 +- ts/smartrequest.request.ts | 12 ++++++++---- 2 files changed, 9 insertions(+), 5 deletions(-) diff --git a/ts/00_commitinfo_data.ts b/ts/00_commitinfo_data.ts index 2cbbfc0..1e3f5b7 100644 --- a/ts/00_commitinfo_data.ts +++ b/ts/00_commitinfo_data.ts @@ -3,6 +3,6 @@ */ export const commitinfo = { name: '@pushrocks/smartrequest', - version: '2.0.8', + version: '2.0.9', description: 'dropin replacement for request' } diff --git a/ts/smartrequest.request.ts b/ts/smartrequest.request.ts index 669bf84..7b50cce 100644 --- a/ts/smartrequest.request.ts +++ b/ts/smartrequest.request.ts @@ -98,7 +98,7 @@ export let request = async ( responseStreamArg: boolean = false, requestDataFunc: (req: plugins.http.ClientRequest) => void = null ): Promise => { - const done = plugins.smartpromise.defer(); + const done = plugins.smartpromise.defer(); // merge options const defaultOptions: interfaces.ISmartRequestOptions = { @@ -158,7 +158,7 @@ export let request = async ( // lets perform the actual request const requestToFire = requestModule.request(optionsArg, async (response) => { if (responseStreamArg) { - done.resolve(response); + done.resolve(response as IExtendedIncomingMessage); } else { const builtResponse = await buildUtf8Response(response, optionsArg.autoJsonParse); done.resolve(builtResponse); @@ -190,6 +190,10 @@ export let request = async ( requestToFire.destroy(); }); - const result = await done.promise; - return result; + const response = await done.promise; + response.on('error', (err) => { + console.log(err); + response.destroy(); + }) + return response; };