Table to store the responses internally

Author: Lan2u

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

@@ -165,6 +165,34 @@ const createTrainingQuizTable = sql`
   )
 `;
 
+export const troubleTicketResponsesTable = sqliteTable(
+  'troubleTicketResponses',
+  {
+    responseSubmitted: integer('responseSubmitted', {
+      mode: 'timestamp',
+    }).notNull(),
+    emailAddress: text('emailAddress'),
+    whichEquipment: text('whichEquipment'), // FIXME - This should be the equipment_id if found
+    submitterName: text('submitterName'),
+    submitterMembershipNumber: integer('submitterMembershipNumber'),
+    submittedResponse: text('submittedResponse', {mode: 'json'}),
+  }
+);
+
+// Using response_submitted, email_address, which_equipment as the unique key is temporary
+// for POC. In future we should probably use the row index or something from the trouble tickets sheet.
+const createTroubleTicketResponsesTable = sql`
+  CREATE TABLE IF NOT EXISTS troubleTicketResponses (
+    responseSubmitted INTEGER,
+    emailAddress TEXT,
+    whichEquipment TEXT,
+    submitterName TEXT,
+    submitterMembershipNumber INTEGER,
+    submittedResponse TEXT,
+    UNIQUE(responseSubmitted, emailAddress, whichEquipment)
+  )
+`;
+
 export const createTables = [
   createMembersTable,
   createEquipmentTable,
@@ -173,6 +201,7 @@ export const createTables = [
   createAreasTable,
   createOwnersTable,
   createTrainingQuizTable,
+  createTroubleTicketResponsesTable,
 ];
 
 type Member = {

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

@@ -10,6 +10,7 @@ import {
   trainedMemberstable,
   trainersTable,
   trainingQuizTable,
+  troubleTicketResponsesTable,
 } from './state';
 import {BetterSQLite3Database} from 'drizzle-orm/better-sqlite3';
 import {and, eq, inArray} from 'drizzle-orm';
@@ -266,6 +267,25 @@ export const updateState =
           )
           .run();
         break;
+      case 'TroubleTicketResponseSubmitted':
+        db.insert(troubleTicketResponsesTable)
+          .values({
+            responseSubmitted: event.response_submitted,
+            emailAddress: event.email_address,
+            whichEquipment: event.which_equipment,
+            submitterName: event.submitter_name,
+            submitterMembershipNumber: event.submitter_membership_number,
+            submittedResponse: event.submitted_response,
+          })
+          .onConflictDoNothing({
+            target: [
+              troubleTicketResponsesTable.responseSubmitted,
+              troubleTicketResponsesTable.emailAddress,
+              troubleTicketResponsesTable.whichEquipment,
+            ],
+          })
+          .run();
+        break;
       default:
         break;
     }