fix build

Author: rkodev

packages/http/fetch/src/middlewares/compressionHandler.ts

@@ -88,20 +88,18 @@ export class CompressionHandler implements Middleware {
 		span?.setAttribute("http.request.body.size", compressedBody.size);
 
 		// execute the next middleware and check if the response code is 415
-		try {
-			const response = await this.next?.execute(url, requestInit, requestOptions);
-			if (response?.status === 415) {
-				// remove the Content-Encoding header
-				requestInit.headers.delete(CompressionHandler.CONTENT_ENCODING_HEADER);
-				requestInit.body = unCompressedBody.buffer;
-				span?.setAttribute("http.request.body.compressed", false);
-				span?.setAttribute("http.request.body.size", unCompressedBodySize);
-
-				return this.next?.execute(url, requestInit, requestOptions) ?? Promise.reject(new Error("Response is undefined"));
-			}
-		} catch (error) {
+
+		const response = await this.next?.execute(url, requestInit, requestOptions);
+		if (response?.status === 415) {
+			// remove the Content-Encoding header
+			requestInit.headers.delete(CompressionHandler.CONTENT_ENCODING_HEADER);
+			requestInit.body = unCompressedBody.buffer;
+			span?.setAttribute("http.request.body.compressed", false);
+			span?.setAttribute("http.request.body.size", unCompressedBodySize);
+
 			return this.next?.execute(url, requestInit, requestOptions) ?? Promise.reject(new Error("Response is undefined"));
 		}
+		return response != null ? Promise.resolve(response) : Promise.reject(new Error("Response is undefined"));
 	}
 
 	private contentRangeBytesIsPresent(header: HeadersInit | undefined): boolean {

packages/http/fetch/test/common/middleware/compressionHandler.ts

@@ -52,6 +52,9 @@ describe("CompressionHandler", () => {
 		const options = new CompressionHandlerOptions({ enableCompression: true });
 		compressionHandler = new CompressionHandler(options);
 
+		compressionHandler.next = nextMiddleware;
+		nextMiddleware.setResponses([new Response("ok", { status: 200 })]);
+
 		const requestInit = { headers: new Headers(), body: "test" };
 		await compressionHandler.execute("http://example.com", requestInit);
 
@@ -65,8 +68,6 @@ describe("CompressionHandler", () => {
 		compressionHandler.next = nextMiddleware;
 		nextMiddleware.setResponses([new Response("nope", { status: 415 }), new Response("ok", { status: 200 })]);
 
-		//(nextMiddleware.execute as any).mockResolvedValueOnce(new Response(null, { status: 415 }));
-
 		const requestInit = { headers: new Headers(), body: "test" };
 		const response = await compressionHandler.execute("http://example.com", requestInit);