Pulling and logging data from google works - now try extracting the google sheet data but don't update state

Author: Lan2u

src/index.ts

@@ -77,7 +77,7 @@ const periodicExternalReadModelRefresh = setInterval(() => {
         'Unexpected error when refreshing read model with external sources'
       )
     );
-}, 180_000);
+}, 300_000);
 server.on('close', () => {
   clearInterval(periodicReadModelRefresh);
   clearInterval(periodicExternalReadModelRefresh);

src/read-models/shared-state/async-apply-external-event-sources.ts

@@ -18,6 +18,7 @@ import {
 } from '../../training-sheets/extract-metadata';
 import {
   columnBoundsRequired,
+  extractGoogleSheetData,
   shouldPullFromSheet,
 } from '../../training-sheets/google';
 import {inspect} from 'node:util';
@@ -35,7 +36,7 @@ const pullNewEquipmentQuizResultsForSheet = async (
   equipment: EquipmentWithLastQuizResult,
   trainingSheetId: string,
   sheet: GoogleSheetMetadata,
-  _timezone: string,
+  timezone: string,
   _updateState: (event: EventOfType<'EquipmentTrainingQuizResult'>) => void
 ): Promise<void> => {
   logger = logger.child({sheet_name: sheet.name});
@@ -70,17 +71,18 @@ const pullNewEquipmentQuizResultsForSheet = async (
     logger.info('Pulled data from google');
     logger.info(inspect(data));
     await new Promise(res => setTimeout(res, 5000));
-    // logger.info('About to extract google sheet data');
-    // const result = extractGoogleSheetData(
-    //   logger,
-    //   trainingSheetId,
-    //   equipment.id,
-    //   sheet,
-    //   timezone,
-    //   equipment.lastQuizResult
-    // )(data.right);
-    // logger.info('Google sheet data extracted, result:');
-    // logger.info(inspect(result));
+    logger.info('About to extract google sheet data');
+    const result = extractGoogleSheetData(
+      logger,
+      trainingSheetId,
+      equipment.id,
+      sheet,
+      timezone,
+      equipment.lastQuizResult
+    )(data.right);
+    logger.info('Google sheet data extracted, result:');
+    await new Promise(res => setTimeout(res, 5000));
+    logger.info(inspect(result));
     // logger.info('Updating data with the extracted data');
     // if (O.isSome(result)) {
     //   result.value.forEach(updateState);