chore: use original fetch for sending spans

Author: tschoffelen

packages/lambda-layer/lib/utils/httpSpansAgent.js

@@ -1,4 +1,5 @@
 const { SQSClient, SendMessageCommand } = require("@aws-sdk/client-sqs");
+const { FetchHttpHandler } = require("@smithy/fetch-http-handler");
 
 /*
  * This module handles sending spans to an SQS queue.
@@ -12,9 +13,14 @@ exports.HttpSpansAgent = (() => {
   let sqsClient;
 
   const initAgent = () => {
-    sqsClient = new SQSClient({
-      region: process.env.AUTO_TRACE_QUEUE_REGION || "eu-west-1",
-    });
+    try {
+      sqsClient = new SQSClient({
+        region: process.env.AUTO_TRACE_QUEUE_REGION || "eu-west-1",
+        requestHandler: new FetchHttpHandler({}),
+      });
+    } catch (error) {
+      console.warn("Error initializing SQS client:", error);
+    }
   };
 
   const cleanSessionInstance = () => {
@@ -37,6 +43,19 @@ exports.HttpSpansAgent = (() => {
         },
         MessageBody: JSON.stringify(requestBody),
       });
+
+      // This is a workaround to avoid the fetch function being overridden
+      // @ts-ignore
+      if (fetch && fetch.__originalFetch) {
+        const wrappedFetch = fetch;
+        // @ts-ignore
+        fetch = wrappedFetch.__originalFetch;
+        setTimeout(() => {
+          // @ts-ignore
+          fetch = wrappedFetch;
+        }, 1);
+      }
+
       await sqsClient.send(command);
     } catch (error) {
       console.warn("Error sending trace spans:", error);

packages/lambda-layer/package.json

@@ -20,6 +20,7 @@
   "dependencies": {
     "@aws-sdk/client-sqs": "^3.777.0",
     "@lumigo/tracer": "^1.107.1",
+    "@smithy/fetch-http-handler": "^5.0.2",
     "axios": "^1.8.4",
     "node-fetch": "^3.3.2"
   },

yarn.lock

@@ -9520,6 +9520,7 @@ __metadata:
   dependencies:
     "@aws-sdk/client-sqs": "npm:^3.777.0"
     "@lumigo/tracer": "npm:^1.107.1"
+    "@smithy/fetch-http-handler": "npm:^5.0.2"
     "@types/jest": "npm:^29.5.14"
     axios: "npm:^1.8.4"
     esbuild: "npm:^0.25.1"