feat: add duplicate flow functionality

packages/backend/src/graphql/mutation-resolvers.ts

@@ -9,6 +9,7 @@ import updateFlow from './mutations/update-flow';
 import updateFlowStatus from './mutations/update-flow-status';
 import executeFlow from './mutations/execute-flow';
 import deleteFlow from './mutations/delete-flow';
+import duplicateFlow from './mutations/duplicate-flow';
 import createStep from './mutations/create-step';
 import updateStep from './mutations/update-step';
 import deleteStep from './mutations/delete-step';
@@ -31,6 +32,7 @@ const mutationResolvers = {
   updateFlowStatus,
   executeFlow,
   deleteFlow,
+  duplicateFlow,
   createStep,
   updateStep,
   deleteStep,

packages/backend/src/graphql/mutations/duplicate-flow.ts

@@ -0,0 +1,88 @@
+import Context from '../../types/express/context';
+import Step from '../../models/step';
+
+type Params = {
+  input: {
+    id: string;
+  };
+};
+
+type NewStepIds = Record<string, string>;
+
+function updateStepId(value: string, newStepIds: NewStepIds) {
+  let newValue = value;
+
+  const stepIdEntries = Object.entries(newStepIds);
+  for (const stepIdEntry of stepIdEntries) {
+    const [oldStepId, newStepId] = stepIdEntry;
+    const partialOldVariable = `{{step.${oldStepId}.`;
+    const partialNewVariable = `{{step.${newStepId}.`;
+
+    newValue = newValue.replace(partialOldVariable, partialNewVariable);
+  }
+
+  return newValue;
+}
+
+function updateStepVariables(parameters: Step['parameters'], newStepIds: NewStepIds): Step['parameters'] {
+  const entries = Object.entries(parameters);
+  return entries.reduce((result, [key, value]: [string, unknown]) => {
+    if (typeof value === 'string') {
+      return {
+        ...result,
+        [key]: updateStepId(value, newStepIds),
+      };
+    }
+
+    if (Array.isArray(value)) {
+      return {
+        ...result,
+        [key]: value.map(item => updateStepVariables(item, newStepIds)),
+      };
+    }
+
+    return {
+      ...result,
+      [key]: value,
+    };
+  }, {});
+}
+
+const duplicateFlow = async (
+  _parent: unknown,
+  params: Params,
+  context: Context
+) => {
+  const flow = await context.currentUser
+    .$relatedQuery('flows')
+    .withGraphJoined('[steps]')
+    .orderBy('steps.position', 'asc')
+    .findOne({ 'flows.id': params.input.id })
+    .throwIfNotFound();
+
+  const duplicatedFlow = await context.currentUser
+    .$relatedQuery('flows')
+    .insert({
+      name: `Copy of ${flow.name}`,
+      active: false,
+    });
+
+  const newStepIds: NewStepIds = {};
+  for (const step of flow.steps) {
+    const duplicatedStep = await duplicatedFlow.$relatedQuery('steps')
+      .insert({
+        key: step.key,
+        appKey: step.appKey,
+        type: step.type,
+        connectionId: step.connectionId,
+        position: step.position,
+        parameters: updateStepVariables(step.parameters, newStepIds),
+      });
+
+    newStepIds[step.id] = duplicatedStep.id;
+  }
+
+  return duplicatedFlow;
+};
+
+export default duplicateFlow;

packages/backend/src/graphql/schema.graphql

@@ -56,6 +56,7 @@ type Mutation {
   updateFlowStatus(input: UpdateFlowStatusInput): Flow
   executeFlow(input: ExecuteFlowInput): executeFlowType
   deleteFlow(input: DeleteFlowInput): Boolean
+  duplicateFlow(input: DuplicateFlowInput): Flow
   createStep(input: CreateStepInput): Step
   updateStep(input: UpdateStepInput): Step
   deleteStep(input: DeleteStepInput): Step
@@ -324,6 +325,10 @@ input DeleteFlowInput {
   id: String!
 }
 
+input DuplicateFlowInput {
+  id: String!
+}
+
 input CreateStepInput {
   id: String
   previousStepId: String