diff --git a/src/services/http-client-service.v2.ts b/src/services/http-client-service.v2.ts index 12c3865..70f0621 100644 --- a/src/services/http-client-service.v2.ts +++ b/src/services/http-client-service.v2.ts @@ -26,18 +26,20 @@ class HttpClientServiceV2 { return new Promise((resolve, reject) => { axios.get(this.resolveUrl(url), { headers: this.buildHeaders(contextService.getContext().profile), - responseType: "stream" + responseType: "stream", + validateStatus: status => status >= 200 }).then(response => { const data: Buffer[] = []; response.data.on("data", (chunk: Buffer) => { data.push(chunk); }); response.data.on("end", () => { - if (this.checkBadRequest(response.status)) { - this.handleBadRequest(response.status, response.data, reject); - } else { - this.handleResponseStreamData(Buffer.concat(data), resolve, reject); + if (response.status !== 200) { + reject(Buffer.concat(data).toString()); + return; } + + this.handleResponseStreamData(Buffer.concat(data), resolve, reject); }); }).catch(err => { this.handleError(err, resolve, reject); diff --git a/tests/utls/http-requests-mock.ts b/tests/utls/http-requests-mock.ts index 8da4a7f..eee2543 100644 --- a/tests/utls/http-requests-mock.ts +++ b/tests/utls/http-requests-mock.ts @@ -17,6 +17,7 @@ const mockAxiosGet = (url: string, responseData: any) => { readableStream.push(response.data) readableStream.push(null); return Promise.resolve({ + status: 200, data: readableStream, }); } else {