fix: report results for cypress crashes

packages/cypress-cloud/lib/run.ts

@@ -19,6 +19,7 @@ import { getPlatform } from "./platform";
 import { pubsub } from "./pubsub";
 import { summarizeTestResults, summaryTable } from "./results";
 import {
+  createReportTaskSpec,
   getExecutionStateResults,
   reportTasks,
   runTillDoneOrCancelled,
@@ -140,7 +141,9 @@ function listenToSpecEvents() {
 
   pubsub.on(
     "after:spec",
-    async ({ spec, results }: { spec: Cypress.Spec; results: any }) =>
-      setSpecAfter(spec.relative, results)
+    async ({ spec, results }: { spec: Cypress.Spec; results: any }) => {
+      setSpecAfter(spec.relative, results);
+      createReportTaskSpec(spec.relative);
+    }
   );
 }

packages/cypress-cloud/lib/runner/index.ts

@@ -1,2 +1,3 @@
 export * from "./cancellable";
+export * from "./reportTask";
 export * from "./state";

packages/cypress-cloud/lib/runner/reportTask.ts

@@ -0,0 +1,42 @@
+import { InstanceId } from "cypress-cloud/types";
+import Debug from "debug";
+import { error } from "../log";
+import { getReportResultsTask } from "../results";
+import {
+  getExecutionStateInstance,
+  getExecutionStateSpec,
+  getInstanceResults,
+} from "./state";
+
+const debug = Debug("currents:reportTask");
+
+export const reportTasks: Promise<any>[] = [];
+
+export const createReportTask = (instanceId: InstanceId) => {
+  const executionState = getExecutionStateInstance(instanceId);
+  if (!executionState) {
+    error("Cannot find execution state for instance %s", instanceId);
+    return;
+  }
+  if (executionState.reportStartedAt) {
+    debug("Report task already created for instance %s", instanceId);
+    return;
+  }
+
+  reportTasks.push(
+    getReportResultsTask(
+      instanceId,
+      getInstanceResults(instanceId),
+      executionState.output ?? "no output captured"
+    ).catch(error)
+  );
+};
+
+export const createReportTaskSpec = (spec: string) => {
+  const i = getExecutionStateSpec(spec);
+  if (!i) {
+    error("Cannot find execution state for spec %s", spec);
+    return;
+  }
+  return createReportTask(i.instanceId);
+};

packages/cypress-cloud/lib/runner/runner.ts

@@ -4,7 +4,7 @@ import {
 } from "cypress-cloud/types";
 import { getCapturedOutput, resetCapture } from "../capture";
 
-import { getCypressRunResultForSpec, getReportResultsTask } from "../results";
+import { getCypressRunResultForSpec } from "../results";
 
 import Debug from "debug";
 import {
@@ -16,12 +16,10 @@ import {
 
 import { runSpecFileSafe } from "../cypress";
 import { isCurrents } from "../env";
-import { divider, error, info, title, warn } from "../log";
+import { divider, info, title, warn } from "../log";
+import { createReportTask, reportTasks } from "./reportTask";
 import {
-  getExecutionStateInstance,
-  getInstanceResults,
   initExecutionState,
-  reportTasks,
   setInstanceOutput,
   setInstanceResult,
 } from "./state";
@@ -58,20 +56,7 @@ export async function runTillDone(
       hasMore = false;
       break;
     }
-    newTasks.forEach((t) => {
-      const executionState = getExecutionStateInstance(t.instanceId);
-      if (!executionState) {
-        error("Cannot find execution state for instance %s", t.instanceId);
-        return;
-      }
-      reportTasks.push(
-        getReportResultsTask(
-          t.instanceId,
-          getInstanceResults(t.instanceId),
-          executionState.output ?? "no output captured"
-        ).catch(error)
-      );
-    });
+    newTasks.forEach((t) => createReportTask(t.instanceId));
   }
 }
 

packages/cypress-cloud/lib/runner/state.ts

@@ -1,13 +1,11 @@
+import { InstanceId } from "cypress-cloud/types";
 import { error, warn } from "../log";
 import { getFailedDummyResult } from "../results";
 import { specResultsToCypressResults } from "./mapResult";
 import { SpecResult } from "./spec.type";
 
-export const reportTasks: Promise<any>[] = [];
-
-type InstanceId = string;
 type InstanceExecutionState = {
-  instanceId: string;
+  instanceId: InstanceId;
   spec: string;
   output?: string;
   specBefore?: Date;
@@ -16,6 +14,7 @@ type InstanceExecutionState = {
   runResultsReportedAt?: Date;
   specAfter?: Date;
   specAfterResults?: SpecResult;
+  reportStartedAt?: Date;
 };
 
 const executionState: Record<InstanceId, InstanceExecutionState> = {};

packages/cypress-cloud/types.ts

@@ -1,3 +1,4 @@
+export type InstanceId = string;
 export type TestingType = Cypress.TestingType;
 export type SpecType = "component" | "integration";
 export type ArrayItemType<T> = T extends (infer U)[] ? U : T;