Fix: Add retry logic for all flaky tests and remove firefox/webkit

Author: ipanaque94

.github/workflows/test-and-deploy.yml

@@ -35,6 +35,7 @@ jobs:
         run: |
           npx playwright test --project=chromium \
             --retries=2 \
+            --timeout=90000 \
             --reporter=html,list
         continue-on-error: true
 

package.json

@@ -4,10 +4,13 @@
   "main": "index.js",
   "scripts": {
     "test": "playwright test",
-    "test:report": "playwright test --reporter=html",
-    "upload:report": "ts-node scripts/uploadReportToS3.ts",
-    "test:s3": "npm run test:report && npm run upload:report",
-    "test:all": "npm test && npm run upload:report"
+    "test:all": "npm run test:core && npm run test:integration && npm run test:s3",
+    "test:core": "playwright test --grep-invert \"S3 Reports\" --grep-invert \"Tests de integración\" --grep-invert \"CloudWatch muestra métricas de invocaciones\"",
+    "test:integration": "playwright test --grep \"Tests de integración con SQS y DynamoDB\" --timeout=60000 --retries=1",
+    "test:s3": "playwright test tests/S3Reports.spec.ts",
+    "test:cloudwatch": "playwright test --grep \"CloudWatch muestra métricas de invocaciones\"",
+    "test:report": "playwright test --reporter=html && playwright show-report"
+  
   },
   "keywords": [],
   "author": "",

playwright.config.ts

@@ -39,7 +39,7 @@ export default defineConfig({
       use: { ...devices["Desktop Chrome"] },
     },
 
-    {
+    /*{
       name: "firefox",
       use: { ...devices["Desktop Firefox"] },
     },
@@ -48,7 +48,7 @@ export default defineConfig({
       name: "webkit",
       use: { ...devices["Desktop Safari"] },
     },
-
+   */
     /* Test against mobile viewports. */
     // {
     //   name: 'Mobile Chrome',

tests/DynamoCity.spec.ts

@@ -40,6 +40,8 @@ test("Test con ciudad vacía en DynamoDB", async () => {
 });
 
 test("Simulación de concurrencia - 10 ciudades INVOCAR LAMBDA", async () => {
+  test.setTimeout(120000);
+
   const ciudades = [
     "Jaén",
     "Bagua Grande",
@@ -52,25 +54,46 @@ test("Simulación de concurrencia - 10 ciudades INVOCAR LAMBDA", async () => {
     "Cuzco",
     "Tacna",
   ];
+  let resultados: any[];
+
+  await test.step("1. Limpiar DynamoDB", async () => {
+    await Promise.all(ciudades.map((c) => DynamoDBHelper.deleteItem(c)));
+    await new Promise((resolve) => setTimeout(resolve, 2000));
+    console.log("✅ DynamoDB limpio para todas las ciudades");
+  });
 
-  await test.step("1. Invocar Lambda para 10 ciudades", async () => {
+  await test.step("2. Invocar Lambda para 10 ciudades", async () => {
     const lambdaInvoker = new LambdaInvoker();
     const promesas = ciudades.map((ciudad) =>
       lambdaInvoker.invokeLambda("Clima", { ciudad }),
     );
-    await Promise.all(promesas);
-    console.log("✅ Lambdas invocadas");
+    resultados = await Promise.all(promesas);
+    console.log("✅ Todas las invocaciones completadas");
   });
 
-  await test.step("2. Esperar procesamiento", async () => {
-    await new Promise((resolve) => setTimeout(resolve, 5000));
+  await test.step("3. Esperar propagación (15 segundos)", async () => {
+    await new Promise((resolve) => setTimeout(resolve, 15000)); // ✅ 15 segundos
+    console.log("✅ Esperando propagación...");
   });
 
-  await test.step("3. Verificar en DynamoDB", async () => {
+  await test.step("4. Verificar en DynamoDB con reintentos", async () => {
     for (const ciudad of ciudades) {
-      const result = await DynamoDBHelper.getItem(ciudad);
+      let result = null;
+
+      // ✅ 10 reintentos de 2 segundos cada uno
+      for (let i = 0; i < 10; i++) {
+        result = await DynamoDBHelper.getItem(ciudad);
+        if (result) break;
+
+        if (i < 9) {
+          console.log(`⏳ ${ciudad}: Intento ${i + 1}/10`);
+          await new Promise((resolve) => setTimeout(resolve, 2000));
+        }
+      }
+
       expect(result).toBeDefined();
-      console.log(`✅ ${ciudad}: Verificado`);
+      expect(result.ciudad).toBe(ciudad);
+      console.log(`✅ ${ciudad}: OK`);
     }
   });
 });

tests/LambdaClima.spec.ts

@@ -49,7 +49,7 @@ test.describe.serial("Tests de integración con SQS y DynamoDB", () => {
 
   for (const ciudad of ciudadesReales) {
     test(`Procesar ciudad válida: ${ciudad}`, async () => {
-      test.setTimeout(45000);
+      test.setTimeout(60000);
 
       let messageId: string;
       let mensajeResultado: any;

utils/LambdaClimaHelper.ts

@@ -38,7 +38,7 @@ export class LambdaClimaHelper {
     const mensajeResultado = await SQSHelper.waitForMessage(
       CONFIG.SQS_RESULTS_URL,
       (msg) => msg.ciudad?.toLowerCase() === ciudad.toLowerCase(),
-      10,
+      15,
     );
 
     // 4. Obtener de DynamoDB con reintentos
@@ -51,7 +51,7 @@ export class LambdaClimaHelper {
 
     return {
       messageId,
-      mensajeResultado, // ✅ YA NO HAY JSON.parse()
+      mensajeResultado,
       dbItem,
     };
   }

utils/TestConfig.ts

@@ -16,7 +16,7 @@ export const CONFIG = {
   API_GATEWAY_URL: process.env.API_GATEWAY_URL!,
 
   // Polling
-  MAX_POLL_ATTEMPTS: 10,
+  MAX_POLL_ATTEMPTS: 15,
   POLL_INTERVAL_MS: 2000,
   SQS_WAIT_TIME_SECONDS: 5,
   SQS_MAX_MESSAGES: 10,