test: create log group if none exists

Author: kuhe

clients/client-cloudwatch-logs/test/CloudWatchLogs.e2e.spec.ts

@@ -1,6 +1,6 @@
 import { CloudWatchLogs } from "@aws-sdk/client-cloudwatch-logs";
+import { GetCallerIdentityCommandOutput, STS } from "@aws-sdk/client-sts";
 import { AwsJson1_1Protocol, AwsSmithyRpcV2CborProtocol } from "@aws-sdk/core/protocols";
-import type { IncomingMessage } from "node:http";
 import { describe, expect, test as it } from "vitest";
 
 describe(
@@ -34,12 +34,29 @@ describe(
     });
 
     it("should be able to use an event stream to tail logs", async () => {
+      const sts = new STS({ region: "us-west-2" });
+      const id: GetCallerIdentityCommandOutput = await sts.getCallerIdentity();
+      const accountId = id.Account;
+
       for (const cwl of [cwlDefault, cwlCustom]) {
-        const logGroups = await cwl.listLogGroups({
+        const testLogGroupName = `/jsv3-e2e-${accountId}`;
+
+        let logGroups = await cwl.listLogGroups({
+          logGroupNamePattern: `^${testLogGroupName}`,
           limit: 1,
         });
 
-        const groupArn = logGroups.logGroups?.[0].logGroupArn;
+        if (!logGroups.logGroups?.length) {
+          await cwl.createLogGroup({
+            logGroupName: testLogGroupName,
+          });
+          logGroups = await cwl.listLogGroups({
+            logGroupNamePattern: `^${testLogGroupName}`,
+            limit: 1,
+          });
+        }
+
+        const groupArn = logGroups.logGroups?.[0]?.logGroupArn;
 
         if (groupArn) {
           const liveTail = await cwl.startLiveTail({
@@ -69,5 +86,8 @@ describe(
       }
     });
   },
-  120_000
+  {
+    timeout: 120_000,
+    retry: 4,
+  }
 );