Remove old references to last row read stored outside events

Author: Lan2u

src/init-dependencies/google/cache-sheet-data.ts

@@ -22,7 +22,6 @@ export const cacheSheetData =
           VALUES (?, ?, ?)
           ON CONFLICT (sheet_id) DO UPDATE SET
             cached_at = excluded.cached_at,
-            last_row_read = excluded.last_row_read,
             cached_data = excluded.cached_data;
         `,
         [cacheTimestamp, sheetId, cachedData]

src/init-dependencies/google/cached-data-table.ts

@@ -6,7 +6,6 @@ export const CachedDataTable = t.strict({
     t.strict({
       cached_at: tt.DateFromNumber,
       sheet_id: t.string,
-      last_row_read: tt.withFallback(t.string, '{}'),
       cached_data: t.string,
     })
   ),

src/init-dependencies/google/get-cached-sheet-data.ts

@@ -18,7 +18,6 @@ import {
 } from '../../types/failure-with-status';
 import {StatusCodes} from 'http-status-codes';
 import {dbExecute} from '../../util';
-import {LastGoogleSheetRowRead} from '../../read-models/shared-state/return-types';
 
 // Note that this isn't automatically type safe. It does rely on the cached
 // data actually being the type of DomainEvent we say it is.
@@ -33,16 +32,6 @@ const extractCachedEvents = <R>(
     E.map(elements => elements as ReadonlyArray<R>)
   );
 
-const extractLastRowRead = (
-  rawLastRowReadData: string
-): t.Validation<LastGoogleSheetRowRead> =>
-  pipe(
-    rawLastRowReadData,
-    tt.JsonFromString.decode,
-    E.chain(tt.JsonRecord.decode),
-    E.chain(t.record(t.string, t.record(t.string, t.number)).decode)
-  );
-
 export const getCachedSheetData =
   <R>(dbClient: Client) =>
   (
@@ -51,7 +40,6 @@ export const getCachedSheetData =
     FailureWithStatus,
     O.Option<{
       cached_at: Date;
-      last_row_read: t.Validation<LastGoogleSheetRowRead>;
       cached_data: t.Validation<ReadonlyArray<R>>;
     }>
   > =>
@@ -82,7 +70,6 @@ export const getCachedSheetData =
           table.rows,
           RA.map(row => ({
             ...row,
-            last_row_read: extractLastRowRead(row.last_row_read),
             cached_data: extractCachedEvents<R>(row.cached_data),
           })),
           RA.head