fallback if requestData cannot be parsed

Author: Ankcorn

src/index.ts

@@ -266,19 +266,27 @@ function parseJSON(str: string) {
   }
 }
 function parseHttpEvent(event: APIGatewayProxyEventV2 | APIGatewayProxyEvent): HttpEvent {
-  if (event.headers['content-type']?.toLowerCase() === 'application/json') {
+  try {
+    if (event.headers['content-type']?.toLowerCase() === 'application/json') {
+      return {
+        body: parseJSON(event.body || '{}'),
+        headers: event.headers
+      };
+    }
+  
+    /**
+     * TODO: add support for other content types
+     */
+  
+    return {
+      body: event.body,
+      headers: event.headers
+    };
+  } catch (_) {
     return {
-      body: parseJSON(event.body || '{}'),
+      body: event.body,
       headers: event.headers
     };
   }
-
-  /**
-   * TODO: add support for other content types
-   */
-
-  return {
-    body: event.body,
-    headers: event.headers
-  };
+  
 }

src/lambda-wrapper.ts

@@ -88,30 +88,26 @@ const instrumentations: Instrumentation[] = [
 						try {
 							requestBodyChunks.push(decodeURIComponent(data.toString()));
 						} catch (e) {
-	
+
 						}
 					}
 					const headers = request.getHeaders();
 
 					const body: string = requestBodyChunks.join();
 					let requestData: unknown
-					if (headers['content-type'] && typeof headers['content-type'] === 'string') {
-						if (headers['content-type'].includes('application/json') || headers['content-type'].includes('application/x-amz-json')) {
-							try {
+					try {
+						if (headers['content-type'] && typeof headers['content-type'] === 'string') {
+							if (headers['content-type'].includes('application/json') || headers['content-type'].includes('application/x-amz-json')) {
 								requestData = JSON.parse(body);
-							} catch (e) {
-								requestData = body;
-							}
-						} else if (headers['content-type'].includes('application/x-www-form-urlencoded')) {
-							try {
+							} else if (headers['content-type'].includes('application/x-www-form-urlencoded')) {
 								requestData = parse(body);
-							} catch (e) {
-								requestData = body;
 							}
-							requestData = body;
 						}
+					} catch (_) {
+						requestData = body;
 					}
 
+
 					const httpReqData = {
 						request: {
 							headers,