test(client-kinesis): resolve e2e endpoint from client config

Author: trivikr

clients/client-kinesis/test/Kinesis.e2e.spec.ts

@@ -22,6 +22,13 @@ describe("@aws-sdk/client-kinesis", () => {
     return (client.config.requestHandler as any).connectionManager?.debug?.();
   };
 
+  /**
+   * The endpoint the client resolves to, used as the connection pool key.
+   * Resolved from the client config instead of being hardcoded, so the test
+   * follows the client's configured region/endpoint.
+   */
+  let endpoint: string;
+
   async function setup() {
     await client.createStream({ StreamName: STREAM_NAME, ShardCount: SHARD_COUNT });
     let status = "";
@@ -113,10 +120,17 @@ describe("@aws-sdk/client-kinesis", () => {
    * ```
    */
   function getSessions(state: any) {
-    return state?.["https://kinesis.us-west-2.amazonaws.com/"]?.sessions ?? [];
+    return state?.[endpoint]?.sessions ?? [];
   }
 
   beforeAll(async () => {
+    const { url } = client.config.endpointProvider({
+      Region: await client.config.region(),
+      UseFIPS: await client.config.useFipsEndpoint(),
+      UseDualStack: await client.config.useDualstackEndpoint(),
+    });
+    endpoint = url.toString();
+
     connectionManagerStates.initial = debug();
     await setup();
 
@@ -161,7 +175,6 @@ describe("@aws-sdk/client-kinesis", () => {
   });
 
   describe("Node.js HTTP2 session concurrency", () => {
-    const usWest2Endpoint = "https://kinesis.us-west-2.amazonaws.com/";
     const sessionType = {
       id: expect.any(Number),
       active: expect.any(Number),
@@ -179,20 +192,20 @@ describe("@aws-sdk/client-kinesis", () => {
 
       expect(getSessions(connectionManagerStates.requestsFinished)).not.toEqual([]);
       expect(connectionManagerStates.requestsFinished).toMatchObject({
-        [usWest2Endpoint]: {
+        [endpoint]: {
           sessions: getSessions(connectionManagerStates.requestsFinished).map(() => sessionType),
         },
       });
 
       expect(getSessions(connectionManagerStates.secondBatchRequestsFinished)).not.toEqual([]);
       expect(connectionManagerStates.secondBatchRequestsFinished).toMatchObject({
-        [usWest2Endpoint]: {
+        [endpoint]: {
           sessions: getSessions(connectionManagerStates.secondBatchRequestsFinished).map(() => sessionType),
         },
       });
 
       expect(connectionManagerStates.idle).toEqual({
-        "https://kinesis.us-west-2.amazonaws.com/": {
+        [endpoint]: {
           sessions: [],
         },
       });