feat: remove mrf steps

Author: pregnantboy

packages/backend/src/apps/formsg/triggers/new-submission/index.ts

@@ -13,6 +13,7 @@ import { createMrfSteps } from './create-mrf-steps'
 import { fetchFormSchema } from './fetch-form-schema'
 import getMockData from './get-mock-data'
 import { parseWorkflowData } from './get-workflow-data'
+import { removeMrfSteps } from './remove-mrf-steps'
 
 const formsgTestRunMetadataSchema = z
   .object({
@@ -114,6 +115,9 @@ const trigger: IRawTrigger = {
       // Create MRF steps for multirespondent forms
       const mrfWorkflowData = await parseWorkflowData($, formSchema)
       await createMrfSteps($, mrfWorkflowData)
+    } else {
+      // remove mrf object from parameters and remove mrf steps (if any)
+      await removeMrfSteps($)
     }
 
     // if test with mock data is selected OR no past submission exists

packages/backend/src/apps/formsg/triggers/new-submission/remove-mrf-steps.ts

@@ -0,0 +1,33 @@
+import { IGlobalVariable } from '@plumber/types'
+
+import StepError from '@/errors/step'
+import Step from '@/models/step'
+
+export async function removeMrfSteps($: IGlobalVariable) {
+  if (!$.flow?.id || !$.step?.id) {
+    throw new StepError(
+      'Missing flow or step',
+      'This should not happen, please contact support.',
+      $.step.position,
+      $.app.name,
+    )
+  }
+
+  await Step.transaction(async (trx) => {
+    // delete all mrf action steps
+    await Step.query(trx)
+      .where('flow_id', $.flow.id)
+      .where('type', 'action')
+      .where('key', 'mrfSubmission')
+      .delete()
+
+    // reset trigger step parameters
+    await Step.query(trx)
+      .where('flow_id', $.flow.id)
+      .where('type', 'trigger')
+      .where('key', 'newSubmission')
+      .patch({
+        parameters: {},
+      })
+  })
+}