This commit is contained in:
Matthias Nannt
2022-11-02 11:36:15 +01:00
parent bd4019539f
commit e19c7d9c3f
3 changed files with 17 additions and 19 deletions
+17 -15
View File
@@ -48,10 +48,6 @@ export const processApiEvent = async (event: ApiEvent, formId) => {
if (event.type === "pageSubmission") {
const schema = form.schema as Schema;
const { pageName } = event.data;
const pages = schema.pages.filter((page) => page.type === "form");
const indexOfPage = pages.findIndex((page) => page.name === pageName);
// const owner = form.owner;
await prisma.sessionEvent.create({
data: {
@@ -71,17 +67,23 @@ export const processApiEvent = async (event: ApiEvent, formId) => {
sendTelemetry("pageSubmission received");
if (indexOfPage === pages.length - 1) {
processApiEvent(
{
...event,
type: "formCompleted",
data: {
submissionSessionId: event.data.submissionSessionId,
if ("pages" in schema) {
const pages = schema.pages.filter((page) => page.type === "form");
const indexOfPage = pages.findIndex((page) => page.name === pageName);
if (indexOfPage === pages.length - 1) {
processApiEvent(
{
...event,
type: "formCompleted",
data: {
submissionSessionId: event.data.submissionSessionId,
},
},
},
formId
);
formId
);
}
}
} else if (event.type === "formCompleted") {
await prisma.sessionEvent.create({
@@ -100,7 +102,7 @@ export const processApiEvent = async (event: ApiEvent, formId) => {
sendTelemetry("formCompleted received");
} else if (event.type === "updateSchema") {
const data = { schema: event.data, updatedAt: new Date() };
prisma.form.update({
await prisma.form.update({
where: { id: formId },
data,
});
@@ -1,2 +0,0 @@
-- AlterEnum
ALTER TYPE "PipelineType" ADD VALUE 'EMAIL_NOTIFICATION';
@@ -1,2 +0,0 @@
-- AlterEnum
ALTER TYPE "PipelineEvent" ADD VALUE 'FORM_COMPLETED';