Handle lastRowsRead not being set on equipment yet

Lan2u · Lan2u · commit ccf28af1eae5 · 2025-06-12T23:57:16.000+01:00
diff --git a/src/read-models/shared-state/equipment/get.ts b/src/read-models/shared-state/equipment/get.ts
@@ -29,7 +29,7 @@ const transformRow = <
   lastQuizSync: O.fromNullable(
     row.lastQuizSync
   ) as O.Option<EpochTimestampMilliseconds>,
-  lastRowsRead: row.lastRowsRead as LastGoogleSheetRowRead,
+  lastRowsRead: (row.lastRowsRead ?? {}) as LastGoogleSheetRowRead,
 });
 
 export const getEquipmentForAreaMinimal =
diff --git a/tests/google-sheets/async-apply-external.test.ts b/tests/google-sheets/async-apply-external.test.ts
@@ -202,7 +202,7 @@ describe('Integration asyncApplyExternalEventSources', () => {
           )
         ).cached_data
       );
-      await new Promise(res => setTimeout(res, rateLimitMs * 2)); // The rate limit varies between [rateLimitMs, 2 * rateLimitMs] to spread cpu load.
+      await new Promise(res => setTimeout(res, rateLimitMs));
       results2 = await runAsyncApplyExternalEventSources(framework);
       cachedData2 = getRightOrFail(
         getSomeOrFail(

Original file line number	Diff line number	Diff line change
`@@ -202,7 +202,7 @@ describe('Integration asyncApplyExternalEventSources', () => {`
`202`	`202`	`)`
`203`	`203`	`).cached_data`
`204`	`204`	`);`
`205`		`- await new Promise(res => setTimeout(res, rateLimitMs * 2)); // The rate limit varies between [rateLimitMs, 2 * rateLimitMs] to spread cpu load.`
	`205`	`+ await new Promise(res => setTimeout(res, rateLimitMs));`
`206`	`206`	`results2 = await runAsyncApplyExternalEventSources(framework);`
`207`	`207`	`cachedData2 = getRightOrFail(`
`208`	`208`	`getSomeOrFail(`