git-moeen
diff --git a/‎lambda/proxy-i.js‎
Lines changed: 14 additions & 10 deletions b/‎lambda/proxy-i.js‎
Lines changed: 14 additions & 10 deletions
diff --git a/‎lambda/proxy.js‎
Lines changed: 5 additions & 0 deletions b/‎lambda/proxy.js‎
Lines changed: 5 additions & 0 deletions
@@ -10,17 +10,20 @@ exports.lambdaHandler = awslambda.streamifyResponse(async (event, responseStream
         let headers = Object.fromEntries(Object.entries(event.headers).filter(
             ([key]) => !key.startsWith('x-') && key.toLowerCase() !== 'host'
         ));
+
+        const httpRequest = {
+            method: event.requestContext.http.method,
+            path: event.rawPath,
+            url: 'https:/' + event.rawPath + (event.rawQueryString ? '?' + event.rawQueryString : ''),
+            data: event.body || '',
+            headers: headers,
+            responseType: 'stream',
+            timeout: 600 * 1000, // 10 minutes
+        }
+
         let httpResponse;
         try {
-            httpResponse = await axios({
-                method: event.requestContext.http.method,
-                path: event.rawPath,
-                url: 'https:/' + event.rawPath + (event.rawQueryString ? '?' + event.rawQueryString : ''),
-                data: event.body || '',
-                headers: headers,
-                responseType: 'stream',
-                timeout: 600 * 1000, // 10 minutes
-            });
+            httpResponse = await axios(httpRequest);
         } catch (error) {
             if (error.response) {
                 await pipeline(
@@ -37,14 +40,15 @@ exports.lambdaHandler = awslambda.streamifyResponse(async (event, responseStream
         headers = Object.fromEntries(Object.entries(httpResponse.headers).filter(
             ([key]) => !key.startsWith('x-')
         ));
-        delete headers['content-length'];
+
         await pipeline(
             httpResponse.data,
             awslambda.HttpResponseStream.from(responseStream, {
                 statusCode: httpResponse.status,
                 headers: headers,
             }),
         );
+
     } catch (error) {
         console.error(error);
         responseStream = awslambda.HttpResponseStream.from(responseStream, {
 
@@ -18,6 +18,7 @@ exports.lambdaHandler = awslambda.streamifyResponse(async (event, responseStream
             ([key]) => !key.startsWith('x-')
         ));
         headers['host'] = proxy_url.hostname;
+
         const httpRequest = {
             method: event.requestContext.http.method,
             path: event.rawPath,
@@ -27,6 +28,7 @@ exports.lambdaHandler = awslambda.streamifyResponse(async (event, responseStream
             responseType: 'stream',
             timeout: 600 * 1000, // 10 minutes
         };
+
         const credentials = await defaultProvider()();
         const signer = new SignatureV4({
             credentials: credentials,
@@ -35,6 +37,7 @@ exports.lambdaHandler = awslambda.streamifyResponse(async (event, responseStream
             sha256: Sha256,
         });
         const signedRequest = await signer.sign(httpRequest);
+
         let httpResponse;
         try {
             httpResponse = await axios(signedRequest);
@@ -54,13 +57,15 @@ exports.lambdaHandler = awslambda.streamifyResponse(async (event, responseStream
         headers = Object.fromEntries(Object.entries(httpResponse.headers).filter(
             ([key]) => !key.startsWith('x-')
         ));
+
         await pipeline(
             httpResponse.data,
             awslambda.HttpResponseStream.from(responseStream, {
                 statusCode: httpResponse.status,
                 headers: headers,
             }),
         );
+
     } catch (error) {
         console.error(error);
         responseStream = awslambda.HttpResponseStream.from(responseStream, {