diff --git a/src/utils/proxy/http.js b/src/utils/proxy/http.js index 72f65be3..61f41585 100644 --- a/src/utils/proxy/http.js +++ b/src/utils/proxy/http.js @@ -1,6 +1,6 @@ /* eslint-disable prefer-promise-reject-errors */ /* eslint-disable no-param-reassign */ -import { createUnzip } from "node:zlib"; +import { createUnzip, constants as zlibConstants } from "node:zlib"; import { http, https } from "follow-redirects"; @@ -34,7 +34,11 @@ function handleRequest(requestor, url, params) { let responseContent = response; if (contentEncoding === 'gzip' || contentEncoding === 'deflate') { - responseContent = createUnzip(); + responseContent = createUnzip({ + flush: zlibConstants.Z_SYNC_FLUSH, + finishFlush: zlibConstants.Z_SYNC_FLUSH + }); + // zlib errors responseContent.on("error", (e) => { logger.error(e); @@ -103,6 +107,6 @@ export async function httpProxy(url, params = {}) { constructedUrl.pathname ); logger.error(err); - return [500, "application/json", { error: {message: err?.message ?? "Unknown error", url, rawError: err} }, null]; + return [500, "application/json", { error: { message: err?.message ?? "Unknown error", url, rawError: err } }, null]; } }