fix(ec2-metadata-service): set timeout for requests (#6072)

* fix(ec2-metadata-service): set timeout for requests

* test(ec2-metadata-service): fix test for TimeOut error

* fix(ec2-metadata-service): add connectionTimeout

Author: siddsriv

packages/ec2-metadata-service/src/MetadataService.e2e.spec.ts

@@ -94,4 +94,17 @@ describe("MetadataService E2E Tests", () => {
       expect(lines).toContain("services/");
     }
   });
+
+  it("should timeout as expected when a request exceeds the specified duration", async () => {
+    if (!metadataServiceAvailable) {
+      return;
+    }
+    metadataService = new MetadataService({ httpOptions: { timeout: 0.1 } }); // 0.1ms timeout for testing
+    try {
+      await metadataService.request("/latest/meta-data/", {});
+    } catch (error) {
+      expect(error).toBeDefined();
+      expect(error.message).toMatch(/TimeoutError/);
+    }
+  });
 });

packages/ec2-metadata-service/src/MetadataService.ts

@@ -32,8 +32,11 @@ export class MetadataService {
   }
 
   async request(path: string, options: { method?: string; headers?: Record<string, string> }): Promise<string> {
-    const { endpoint, ec2MetadataV1Disabled } = await this.config;
-    const handler = new NodeHttpHandler();
+    const { endpoint, ec2MetadataV1Disabled, httpOptions } = await this.config;
+    const handler = new NodeHttpHandler({
+      requestTimeout: httpOptions?.timeout,
+      connectionTimeout: httpOptions?.timeout,
+    });
     const endpointUrl = new URL(endpoint!);
     const headers = options.headers || {};
     /**
@@ -82,8 +85,11 @@ export class MetadataService {
     /**
      * Refer: https://docs.aws.amazon.com/AWSEC2/latest/UserGuide/instance-metadata-v2-how-it-works.html
      */
-    const { endpoint } = await this.config;
-    const handler = new NodeHttpHandler();
+    const { endpoint, httpOptions } = await this.config;
+    const handler = new NodeHttpHandler({
+      requestTimeout: httpOptions?.timeout,
+      connectionTimeout: httpOptions?.timeout,
+    });
     const endpointUrl = new URL(endpoint!);
     const tokenRequest = new HttpRequest({
       method: "PUT",