chore: add batch execution to CloudDataSource

packages/app/cypress/e2e/specs_list_flaky.cy.ts

@@ -35,8 +35,18 @@ describe('App: Spec List - Flaky Indicator', () => {
               dashboardUrl: '#',
             },
           }
-        } else {
-          obj.result.data.cloudSpecByPath = {
+        }
+      }
+
+      return obj.result
+    })
+
+    cy.remoteGraphQLInterceptBatched(async (obj) => {
+      await new Promise((r) => setTimeout(r, 20))
+
+      if (obj.field === 'cloudSpecByPath') {
+        if (obj.variables.specPath.includes('123.spec.js')) {
+          return {
             __typename: 'CloudProjectSpec',
             id: `id${obj.variables.specPath}`,
             retrievedAt: new Date().toISOString(),
@@ -45,12 +55,34 @@ describe('App: Spec List - Flaky Indicator', () => {
               __typename: 'CloudSpecRunConnection',
               nodes: [],
             },
-            isConsideredFlaky: false,
-            flakyStatus: null,
+            isConsideredFlaky: true,
+            flakyStatus: {
+              __typename: 'CloudProjectSpecFlakyStatus',
+              severity: 'LOW',
+              flakyRuns: 2,
+              flakyRunsWindow: 50,
+              lastFlaky: 2,
+              dashboardUrl: '#',
+            },
           }
         }
-      } else if (obj.result.data && 'cloudLatestRunUpdateSpecData' in obj.result.data) {
-        obj.result.data.cloudLatestRunUpdateSpecData = {
+
+        return {
+          __typename: 'CloudProjectSpec',
+          id: `id${obj.variables.specPath}`,
+          retrievedAt: new Date().toISOString(),
+          averageDuration: null,
+          specRuns: {
+            __typename: 'CloudSpecRunConnection',
+            nodes: [],
+          },
+          isConsideredFlaky: false,
+          flakyStatus: null,
+        }
+      }
+
+      if (obj.field === 'cloudLatestRunUpdateSpecData') {
+        return {
           __typename: 'CloudLatestRunUpdateSpecData',
           mostRecentUpdate: new Date('2022-06-10').toISOString(),
           pollingInterval: 60,

packages/app/cypress/e2e/specs_list_latest_runs.cy.ts

@@ -66,7 +66,11 @@ function specShouldShow (specFileName: string, runDotsClasses: string[], latestR
 }
 
 function simulateRunData () {
-  cy.remoteGraphQLIntercept(async (obj) => {
+  cy.remoteGraphQLInterceptBatched(async (obj) => {
+    if (obj.field !== 'cloudSpecByPath') {
+      return obj.result
+    }
+
     const fakeRuns = (statuses: string[], idPrefix: string) => {
       return statuses.map((s, idx) => {
         return {
@@ -107,34 +111,30 @@ function simulateRunData () {
       })
     }
 
-    if (obj.result.data && 'cloudSpecByPath' in obj.result.data) {
-      // simulate network latency to allow for caching to register
-      await new Promise((r) => setTimeout(r, 20))
-
-      const statuses = obj.variables.specPath?.includes('accounts_list.spec.js') ?
-        ['PASSED', 'FAILED', 'CANCELLED', 'ERRORED'] :
-        obj.variables.specPath?.includes('app.spec.js') ?
-          [] :
-          ['RUNNING', 'PASSED']
-
-      const runs = fakeRuns(statuses, obj.variables.specPath)
-      const averageDuration = obj.variables.specPath?.includes('accounts_list.spec.js') ?
-        12000 : // 0:12
-        123000 // 2:03
-
-      obj.result.data.cloudSpecByPath = {
-        __typename: 'CloudProjectSpec',
-        retrievedAt: new Date().toISOString(),
-        id: `id${obj.variables.specPath}`,
-        specRuns: {
-          __typename: 'CloudSpecRunConnection',
-          nodes: runs,
-        },
-        averageDuration,
-      }
+    // simulate network latency to allow for caching to register
+    await new Promise((r) => setTimeout(r, 20))
+
+    const statuses = obj.variables.specPath?.includes('accounts_list.spec.js') ?
+      ['PASSED', 'FAILED', 'CANCELLED', 'ERRORED'] :
+      obj.variables.specPath?.includes('app.spec.js') ?
+        [] :
+        ['RUNNING', 'PASSED']
+
+    const runs = fakeRuns(statuses, obj.variables.specPath)
+    const averageDuration = obj.variables.specPath?.includes('accounts_list.spec.js') ?
+      12000 : // 0:12
+      123000 // 2:03
+
+    return {
+      __typename: 'CloudProjectSpec',
+      retrievedAt: new Date().toISOString(),
+      id: `id${obj.variables.specPath}`,
+      specRuns: {
+        __typename: 'CloudSpecRunConnection',
+        nodes: runs,
+      },
+      averageDuration,
     }
-
-    return obj.result
   })
 }
 
@@ -163,21 +163,12 @@ describe('App/Cloud Integration - Latest runs and Average duration', { viewportW
     it('shows placeholders for all visible specs', { defaultCommandTimeout: 6000 }, () => {
       cy.loginUser()
 
-      cy.remoteGraphQLIntercept(async (obj) => {
-        if (obj.result.data && 'cloudSpecByPath' in obj.result.data) {
-          obj.result.data.cloudSpecByPath = {
-            __typename: 'CloudProjectSpecNotFound',
-            retrievedAt: new Date().toISOString(),
-            id: `id${obj.variables.specPath}`,
-            specRuns: {
-              __typename: 'CloudSpecRunConnection',
-              nodes: [],
-            },
-            averageDuration: null,
-          }
+      cy.remoteGraphQLInterceptBatched(async (obj) => {
+        return {
+          __typename: 'CloudProjectSpecNotFound',
+          retrievedAt: new Date().toISOString(),
+          message: 'Spec Not Found',
         }
-
-        return obj.result
       })
 
       cy.visitApp()
@@ -350,6 +341,7 @@ describe('App/Cloud Integration - Latest runs and Average duration', { viewportW
       cy.get('.v-popper__popper--shown').should('not.exist')
       cy.get(dotSelector('app.spec.js', 'latest')).trigger('mouseleave')
 
+      cy.get('.spec-list-container').scrollTo('top')
       // oldest 2 status dots will use placeholder
       specShouldShow('accounts_new.spec.js', ['gray-300', 'gray-300', 'jade-400'], 'RUNNING')
       cy.get(dotSelector('accounts_new.spec.js', 'latest')).trigger('mouseenter')
@@ -436,6 +428,30 @@ describe('App/Cloud Integration - Latest runs and Average duration', { viewportW
       cy.loginUser()
 
       cy.remoteGraphQLIntercept(async (obj, testState) => {
+        const pollingCounter = testState.pollingCounter ?? 0
+
+        if (obj.result.data && 'cloudLatestRunUpdateSpecData' in obj.result.data) {
+          const mostRecentUpdate = pollingCounter > 1 ? new Date().toISOString() : new Date('2022-06-10').toISOString()
+          // initial polling interval is set to every second to avoid long wait times
+          const pollingInterval = pollingCounter > 1 ? 30 : 1
+
+          obj.result.data.cloudLatestRunUpdateSpecData = {
+            __typename: 'CloudLatestRunUpdateSpecData',
+            mostRecentUpdate,
+            pollingInterval,
+          }
+
+          testState.pollingCounter = pollingCounter + 1
+        }
+
+        return obj.result
+      })
+
+      cy.remoteGraphQLInterceptBatched(async (obj, testState) => {
+        if (obj.field !== 'cloudSpecByPath') {
+          return obj.result
+        }
+
         const fakeRuns = (statuses: string[], idPrefix: string) => {
           return statuses.map((s, idx) => {
             return {
@@ -478,39 +494,23 @@ describe('App/Cloud Integration - Latest runs and Average duration', { viewportW
 
         const pollingCounter = testState.pollingCounter ?? 0
 
-        if (obj.result.data && 'cloudSpecByPath' in obj.result.data) {
-          // simulate network latency to allow for caching to register
-          await new Promise((r) => setTimeout(r, 20))
-
-          const statuses = pollingCounter < 2 ? ['PASSED', 'FAILED', 'CANCELLED', 'ERRORED'] : ['FAILED', 'PASSED', 'FAILED', 'CANCELLED', 'ERRORED']
-          const runs = fakeRuns(statuses, obj.variables.specPath)
-          const averageDuration = pollingCounter < 2 ? 12000 : 13000
-
-          obj.result.data.cloudSpecByPath = {
-            __typename: 'CloudProjectSpec',
-            retrievedAt: new Date().toISOString(),
-            id: `id${obj.variables.specPath}`,
-            specRuns: {
-              __typename: 'CloudSpecRunConnection',
-              nodes: runs,
-            },
-            averageDuration,
-          }
-        } else if (obj.result.data && 'cloudLatestRunUpdateSpecData' in obj.result.data) {
-          const mostRecentUpdate = pollingCounter > 1 ? new Date().toISOString() : new Date('2022-06-10').toISOString()
-          // initial polling interval is set to every second to avoid long wait times
-          const pollingInterval = pollingCounter > 1 ? 30 : 1
+        // simulate network latency to allow for caching to register
+        await new Promise((r) => setTimeout(r, 20))
 
-          obj.result.data.cloudLatestRunUpdateSpecData = {
-            __typename: 'CloudLatestRunUpdateSpecData',
-            mostRecentUpdate,
-            pollingInterval,
-          }
+        const statuses = pollingCounter < 2 ? ['PASSED', 'FAILED', 'CANCELLED', 'ERRORED'] : ['FAILED', 'PASSED', 'FAILED', 'CANCELLED', 'ERRORED']
+        const runs = fakeRuns(statuses, obj.variables.specPath)
+        const averageDuration = pollingCounter < 2 ? 12000 : 13000
 
-          testState.pollingCounter = pollingCounter + 1
+        return {
+          __typename: 'CloudProjectSpec',
+          retrievedAt: new Date().toISOString(),
+          id: `id${obj.variables.specPath}`,
+          specRuns: {
+            __typename: 'CloudSpecRunConnection',
+            nodes: runs,
+          },
+          averageDuration,
         }
-
-        return obj.result
       })
 
       cy.visitApp()
@@ -542,6 +542,30 @@ describe('App/Cloud Integration - Latest runs and Average duration', { viewportW
       cy.loginUser()
 
       cy.remoteGraphQLIntercept(async (obj, testState) => {
+        const pollingCounter = testState.pollingCounter ?? 0
+
+        if (obj.result.data && 'cloudLatestRunUpdateSpecData' in obj.result.data) {
+          const mostRecentUpdate = new Date('2022-06-10').toISOString()
+          // initial polling interval is set to every second to avoid long wait times
+          const pollingInterval = pollingCounter > 1 ? 30 : 1
+
+          obj.result.data.cloudLatestRunUpdateSpecData = {
+            __typename: 'CloudLatestRunUpdateSpecData',
+            mostRecentUpdate,
+            pollingInterval,
+          }
+
+          testState.pollingCounter = pollingCounter + 1
+        }
+
+        return obj.result
+      })
+
+      cy.remoteGraphQLInterceptBatched(async (obj, testState) => {
+        if (obj.field !== 'cloudSpecByPath') {
+          return obj.result
+        }
+
         const fakeRuns = (statuses: string[], idPrefix: string) => {
           return statuses.map((s, idx) => {
             return {
@@ -584,39 +608,23 @@ describe('App/Cloud Integration - Latest runs and Average duration', { viewportW
 
         const pollingCounter = testState.pollingCounter ?? 0
 
-        if (obj.result.data && 'cloudSpecByPath' in obj.result.data) {
-          // simulate network latency to allow for caching to register
-          await new Promise((r) => setTimeout(r, 20))
-
-          const statuses = pollingCounter < 2 ? ['PASSED', 'FAILED', 'CANCELLED', 'ERRORED'] : ['FAILED', 'PASSED', 'FAILED', 'CANCELLED', 'ERRORED']
-          const runs = fakeRuns(statuses, obj.variables.specPath)
-          const averageDuration = pollingCounter < 2 ? 12000 : 13000
-
-          obj.result.data.cloudSpecByPath = {
-            __typename: 'CloudProjectSpec',
-            retrievedAt: new Date().toISOString(),
-            id: `id${obj.variables.specPath}`,
-            specRuns: {
-              __typename: 'CloudSpecRunConnection',
-              nodes: runs,
-            },
-            averageDuration,
-          }
-        } else if (obj.result.data && 'cloudLatestRunUpdateSpecData' in obj.result.data) {
-          const mostRecentUpdate = new Date('2022-06-10').toISOString()
-          // initial polling interval is set to every second to avoid long wait times
-          const pollingInterval = pollingCounter > 1 ? 30 : 1
+        // simulate network latency to allow for caching to register
+        await new Promise((r) => setTimeout(r, 20))
 
-          obj.result.data.cloudLatestRunUpdateSpecData = {
-            __typename: 'CloudLatestRunUpdateSpecData',
-            mostRecentUpdate,
-            pollingInterval,
-          }
+        const statuses = pollingCounter < 2 ? ['PASSED', 'FAILED', 'CANCELLED', 'ERRORED'] : ['FAILED', 'PASSED', 'FAILED', 'CANCELLED', 'ERRORED']
+        const runs = fakeRuns(statuses, obj.variables.specPath)
+        const averageDuration = pollingCounter < 2 ? 12000 : 13000
 
-          testState.pollingCounter = pollingCounter + 1
+        return {
+          __typename: 'CloudProjectSpec',
+          retrievedAt: new Date().toISOString(),
+          id: `id${obj.variables.specPath}`,
+          specRuns: {
+            __typename: 'CloudSpecRunConnection',
+            nodes: runs,
+          },
+          averageDuration,
         }
-
-        return obj.result
       })
 
       cy.visitApp()