fix(e2e): clean up sqs before tests run

Author: kuhe

features/sqs/step_definitions/sqs.js

@@ -1,10 +1,43 @@
 const { Before } = require("cucumber");
 
-Before({ tags: "@sqs" }, function (scenario, callback) {
+Before({ tags: "@sqs" }, async function (scenario) {
   const { SQS } = require("../../../clients/client-sqs");
   this.service = new SQS({
     region: "us-east-1",
   });
   this.createdQueues = [];
-  callback();
+
+  // delete any stale queues found before the test starts.
+  const list = await this.service.listQueues({});
+  for (const url of list.QueueUrls || []) {
+    if (url.includes("/aws-js-sdk-")) {
+      try {
+        if (url.includes("aws-js-sdk-")) {
+          const created = Number(url.split("aws-js-sdk-")[1]);
+          const now = Date.now();
+          const dateLimit = new Date("2022-01-01").getTime();
+          const ONE_HOUR = 60 * 60 * 1000;
+
+          // Avoid deleting any queues created very recently,
+          // since another test could be running against them.
+
+          if (now - created > ONE_HOUR && created > dateLimit) {
+            await this.service.deleteQueue({
+              QueueUrl: url,
+            });
+            console.log("Deleting stale SQS queue", url, "created at", new Date(created));
+          } else {
+            console.log("Skipping cleanup of", url, "created at", new Date(created));
+          }
+        }
+      } catch (e) {
+        // queue cleanup errors are considered non-fatal to E2E.
+        console.warn("Error during SQS queue cleanup: ", e);
+
+        // potential throttling issue, wait and continue.
+        console.log("Waiting 1s.");
+        await new Promise((r) => setTimeout(r, 1000));
+      }
+    }
+  }
 });