use event structure for submissionSessions

lib/apiEvents.ts

@@ -0,0 +1,58 @@
+import { ApiEvent, pageSubmissionData } from "./types";
+
+type validationError = {
+  status: number;
+  message: string;
+};
+
+export const validateEvents = (
+  events: ApiEvent[]
+): validationError | undefined => {
+  if (!Array.isArray(events)) {
+    return { status: 400, message: `"events" needs to be a list` };
+  }
+  for (const event of events) {
+    if (
+      ![
+        "createSubmissionSession",
+        "pageSubmission",
+        "submissionCompleted",
+        "updateSchema",
+      ].includes(event.type)
+    ) {
+      return {
+        status: 400,
+        message: `event type ${event.type} is not suppported`,
+      };
+    }
+    return;
+  }
+};
+
+export const processApiEvent = async (event: ApiEvent, formId) => {
+  if (event.type === "pageSubmission") {
+    const data = event.data;
+    await prisma.sessionEvent.create({
+      data: {
+        type: "pageSubmission",
+        data: {
+          pageName: data.pageName,
+          submission: data.submission,
+        },
+        submissionSession: { connect: { id: data.submissionSessionId } },
+      },
+    });
+  } else if (event.type === "submissionCompleted") {
+    // TODO
+  } else if (event.type === "updateSchema") {
+    const data = { schema: event.data, updatedAt: new Date() };
+    await prisma.form.update({
+      where: { id: formId },
+      data,
+    });
+  } else {
+    throw Error(
+      `apiEvents: unsupported event type in event ${JSON.stringify(event)}`
+    );
+  }
+};