Implement getting quiz results on a per-member basis

Author: Lan2u

src/dependencies.ts

@@ -46,6 +46,9 @@ export type Dependencies = {
     sheetId: string,
     from: O.Option<Date>
   ) => TE.TaskEither<string, SheetDataTable['rows']>;
+  getSheetDataByMemberNumber: (
+    memberNumber: number,
+  ) => TE.TaskEither<string, SheetDataTable['rows']>,
   getTroubleTicketData: (
     from: O.Option<Date>
   ) => TE.TaskEither<string, O.Option<TroubleTicketDataTable['rows']>>;

src/init-dependencies/init-dependencies.ts

@@ -12,7 +12,7 @@ import {Client} from '@libsql/client';
 
 import {initSharedReadModel} from '../read-models/shared-state';
 import {lastSync} from '../sync-worker/db/last_sync';
-import {getSheetData} from '../sync-worker/db/get_sheet_data';
+import {getSheetData, getSheetDataByMemberNumber} from '../sync-worker/db/get_sheet_data';
 import {getTroubleTicketData} from '../sync-worker/db/get_trouble_ticket_data';
 
 export const initLogger = (conf: Config) => {
@@ -79,6 +79,7 @@ export const initDependencies = (
     logger,
     lastQuizSync: lastSync(googleDB),
     getSheetData: getSheetData(googleDB),
+    getSheetDataByMemberNumber: getSheetDataByMemberNumber(googleDB),
     getTroubleTicketData: getTroubleTicketData(
       googleDB,
       O.fromNullable(conf.TROUBLE_TICKET_SHEET)

src/read-models/external-state/equipment-quiz.ts

@@ -1,14 +1,15 @@
 import * as O from 'fp-ts/Option';
 import * as TE from 'fp-ts/TaskEither';
 import * as RA from 'fp-ts/ReadonlyArray';
+import * as RR from 'fp-ts/ReadonlyRecord';
 
 import {Dependencies} from '../../dependencies';
 import {SheetDataTable} from '../../sync-worker/google/sheet-data-table';
 import {pipe} from 'fp-ts/lib/function';
 import {Equipment, MemberCoreInfo} from '../shared-state/return-types';
 import {DateTime, Duration} from 'luxon';
 import { ReadonlyRecord } from 'fp-ts/lib/ReadonlyRecord';
-import { UUID } from 'io-ts-types';
+import { EquipmentId } from '../../types/equipment-id';
 
 export type EquipmentQuizResults = {
   passedQuizes: SheetDataTable['rows'];
@@ -29,20 +30,23 @@ export type MemberAwaitingTraining = Pick<
   waitingSince: Date;
 };
 
+const isPassed = (row: SheetDataTable['rows'][0]) => row.percentage >= 100;
+const isFailed = (row: SheetDataTable['rows'][0]) => !isPassed(row);
+
 const extractPassedQuizes = (
   sheetData: SheetDataTable['rows']
 ): SheetDataTable['rows'] =>
   pipe(
     sheetData,
-    RA.filter(row => row.percentage === 100)
+    RA.filter(isPassed)
   );
 
 const extractFailedQuizes = (
   sheetData: SheetDataTable['rows']
 ): SheetDataTable['rows'] =>
   pipe(
     sheetData,
-    RA.filter(row => row.percentage < 100)
+    RA.filter(isFailed)
   );
 
 const getQuizResults = (
@@ -128,20 +132,69 @@ export const getFullQuizResultsForEquipment = (
   );
 
 export type FullQuizResultsForMember = {
-  equipmentQuizPassedAt: ReadonlyRecord<UUID, Date>,
-  equipmentQuizAttempted: ReadonlyRecord<UUID, {
+  equipmentQuizPassedAt: ReadonlyRecord<EquipmentId, ReadonlyArray<Date>>,
+  equipmentQuizAttempted: ReadonlyRecord<EquipmentId, ReadonlyArray<{
+    response_submitted: Date,
+    sheet_id: string;
+    score: number;
+    max_score: number;
+    percentage: number;
+  }>>,
+  orphanedQuizAttempts: ReadonlyArray<{
     response_submitted: Date,
     sheet_id: string;
     score: number;
     max_score: number;
     percentage: number;
-  }>
+  }>,
 };
 
 export const getFullQuizResultsForMember = (
-  deps: Pick<Dependencies, 'sharedReadModel' | 'getSheetData'>,
+  deps: Pick<Dependencies, 'sharedReadModel' | 'getSheetDataByMemberNumber'>,
   memberNumber: number
-): TE.TaskEither<string, FullQuizResultsForMember> => {
-  
-
-};
+): TE.TaskEither<string, FullQuizResultsForMember> => pipe(
+  deps.getSheetDataByMemberNumber(memberNumber),
+  TE.map(
+    qr => {
+      const equipmentQuizPassedAt: Record<EquipmentId, Date[]> = {};
+      const equipmentQuizAttempted: Record<EquipmentId, {
+        response_submitted: Date,
+        sheet_id: string;
+        score: number;
+        max_score: number;
+        percentage: number;
+      }[]> = {};
+      const orphanedQuizAttempts: {
+        response_submitted: Date,
+        sheet_id: string;
+        score: number;
+        max_score: number;
+        percentage: number;
+      }[] = [];
+      const trainingSheetMapping = deps.sharedReadModel.equipment.getTrainingSheetIdMapping();
+      for (const row of qr) {
+        const equipmentId = RR.lookup(row.sheet_id)(trainingSheetMapping);
+        if (O.isNone(equipmentId)) {
+          orphanedQuizAttempts.push(row);
+        } else {
+          if (isPassed(row)) {
+            if (!equipmentQuizPassedAt[equipmentId.value]) {
+              equipmentQuizPassedAt[equipmentId.value] = [];
+            }
+            equipmentQuizPassedAt[equipmentId.value].push(row.response_submitted);
+          } else {
+            if (!equipmentQuizAttempted[equipmentId.value]) {
+              equipmentQuizAttempted[equipmentId.value] = [];
+            }
+            equipmentQuizAttempted[equipmentId.value].push(row);
+          }
+        }
+      }
+      return {
+        equipmentQuizPassedAt,
+        equipmentQuizAttempted,
+        orphanedQuizAttempts,
+      }
+    }
+  )
+);

src/read-models/shared-state/equipment/get.ts

@@ -1,11 +1,15 @@
 import {pipe} from 'fp-ts/lib/function';
 import {BetterSQLite3Database} from 'drizzle-orm/better-sqlite3';
-import {eq} from 'drizzle-orm';
+import {eq, isNotNull} from 'drizzle-orm';
 import * as O from 'fp-ts/Option';
 import * as RA from 'fp-ts/ReadonlyArray';
+import * as RR from 'fp-ts/ReadonlyRecord';
 import {equipmentTable} from '../state';
 import {MinimalEquipment} from '../return-types';
 import {UUID} from 'io-ts-types';
+import { ReadonlyRecord } from 'fp-ts/lib/ReadonlyRecord';
+import { TrainingSheetId } from '../../../types/training-sheet';
+import { EquipmentId } from '../../../types/equipment-id';
 
 const transformRow = <
   R extends {
@@ -47,3 +51,18 @@ export const getAllEquipmentMinimal = (
   db: BetterSQLite3Database
 ): ReadonlyArray<MinimalEquipment> =>
   pipe(db.select().from(equipmentTable).all(), RA.map(transformRow));
+
+export const getTrainingSheetIdMapping = (
+  db: BetterSQLite3Database
+) => (): ReadonlyRecord<TrainingSheetId, EquipmentId> => 
+  pipe(
+    db.select({
+      trainingSheetId: equipmentTable.trainingSheetId,
+      id: equipmentTable.id,
+    }).from(equipmentTable).where(isNotNull(equipmentTable.trainingSheetId)).all(),
+    RA.map(
+      row => ([row.trainingSheetId!, row.id as UUID])
+    ),
+    (x: ReadonlyArray<[string, UUID]>) => x,
+    RR.fromEntries
+  )

src/read-models/shared-state/index.ts

@@ -27,6 +27,10 @@ import {dumpCurrentState, SharedDatabaseDump} from './debug/dump';
 import {MemberLinking} from './member-linking';
 import {DateTime} from 'luxon';
 import {getLastSent} from './training-stat-notifications/get-last-sent';
+import { ReadonlyRecord } from 'fp-ts/lib/ReadonlyRecord';
+import { TrainingSheetId } from '../../types/training-sheet';
+import { EquipmentId } from '../../types/equipment-id';
+import { getTrainingSheetIdMapping } from './equipment/get';
 
 export type SharedReadModel = {
   db: BetterSQLite3Database;
@@ -44,6 +48,7 @@ export type SharedReadModel = {
   equipment: {
     get: (id: UUID) => O.Option<Equipment>;
     getAll: () => ReadonlyArray<Equipment>;
+    getTrainingSheetIdMapping: () => ReadonlyRecord<TrainingSheetId, EquipmentId>;
   };
   area: {
     get: (id: UUID) => O.Option<Area>;
@@ -94,6 +99,7 @@ export const initSharedReadModel = (
     equipment: {
       get: getEquipmentFull(readModelDb, linking),
       getAll: getAllEquipmentFull(readModelDb, linking),
+      getTrainingSheetIdMapping: getTrainingSheetIdMapping(readModelDb),
     },
     area: {
       get: getAreaFull(readModelDb, linking),

src/read-models/shared-state/member-linking.ts

@@ -1,4 +1,4 @@
-type MemberNumber = number;
+import { MemberNumber } from "../../types/member-number";
 
 export class MemberLinking {
   // Stores the linking between member numbers.

src/sync-worker/db/get_sheet_data.ts

@@ -49,3 +49,33 @@ export const getSheetData =
       ),
       TE.map(data => data.rows)
     );
+
+export const getSheetDataByMemberNumber =
+  (googleDB: Client) =>
+  (
+    memberNumber: number,
+  ): TE.TaskEither<string, SheetDataTable['rows']> =>
+    pipe(
+      TE.tryCatch<string, ResultSet>(
+        () => googleDB.execute(
+          ` SELECT *
+            FROM sheet_data
+            WHERE member_number_provided = ?
+          `, [memberNumber]
+        ),
+        reason =>
+          `Failed to get sheet data for memberNumber '${memberNumber}': ${(reason as Error).message}`
+      ),
+      TE.flatMapEither<ResultSet, string, SheetDataTable>(data =>
+        pipe(
+          data,
+          SheetDataTable.decode,
+          E.mapLeft(
+            e =>
+              'Failed to pull sheet data due to malformed data: ' +
+              formatValidationErrors(e).join(',')
+          )
+        )
+      ),
+      TE.map(data => data.rows)
+    );

src/types/equipment-id.ts

@@ -0,0 +1,4 @@
+import { UUID } from "io-ts-types";
+
+// Simple type alias to make typing easier to follow.
+export type EquipmentId = UUID;

src/types/member-number.ts

@@ -0,0 +1,2 @@
+// Simple type alias to make typing easier to follow.
+export type MemberNumber = number;

src/types/training-sheet.ts

@@ -0,0 +1,2 @@
+// Simple type alias to make typing easier to follow.
+export type TrainingSheetId = string;