Time the loading of cached events

Author: Lan2u

src/index.ts

@@ -20,6 +20,7 @@ import cookieSession from 'cookie-session';
 import {initRoutes} from './routes';
 import {ensureCachedSheetDataTableExists} from './init-dependencies/google/ensure-cached-sheet-data-table-exists';
 import {loadCachedSheetData} from './load-cached-sheet-data';
+import {timeAsync} from './util';
 
 // Dependencies and Config
 const conf = loadConfig();
@@ -95,12 +96,18 @@ void (async () => {
   )();
 
   deps.logger.info('Loading cached external events...');
-  await loadCachedSheetData(
-    deps.getCachedSheetData,
-    deps.logger,
-    deps.sharedReadModel.updateState
+  await timeAsync(elapsedNs =>
+    deps.logger.info(
+      'Loaded cached external events in %sms',
+      elapsedNs / (1000 * 1000)
+    )
+  )(
+    loadCachedSheetData(
+      deps.getCachedSheetData,
+      deps.logger,
+      deps.sharedReadModel.updateState
+    )
   );
-  deps.logger.info('Cached external events loaded');
   await deps.sharedReadModel.asyncRefresh()();
   await deps.sharedReadModel.asyncApplyExternalEventSources()();
 

src/util.ts

@@ -64,3 +64,12 @@ export const fieldIsUUID =
     obj: T
   ): obj is T & {[P in K]: tt.UUID} =>
     E.isRight(tt.UUID.decode(obj[key]));
+
+export const timeAsync =
+  (callback: (nanoseconds: number) => void) => async (fn: Promise<void>) => {
+    const start = process.hrtime.bigint();
+    const result = await fn;
+    // Realistically we aren't going to be have elapsed periods big enough that this conversion back to number is problematic.
+    callback(Number(process.hrtime.bigint() - start));
+    return result;
+  };