From 2a3fdc90488e8bdbde481d49c240b045a85b1379 Mon Sep 17 00:00:00 2001
From: Bram <bram2w@users.noreply.github.com>
Date: Fri, 7 Nov 2025 06:48:54 +0100
Subject: [PATCH] Add node duplication

---
 .../contrib/automation/nodes/actions.py       |  4 +-
 .../contrib/automation/nodes/service.py       |  8 +--
 .../components/workflow/WorkflowEdge.vue      | 10 ++-
 .../components/workflow/WorkflowEditor.vue    |  9 ++-
 .../components/workflow/WorkflowNode.vue      |  3 +
 .../workflow/WorkflowNodeContent.vue          | 26 +++++++-
 .../modules/automation/locales/en.json        |  4 +-
 .../modules/automation/nodeTypeMixins.js      |  4 ++
 web-frontend/modules/automation/nodeTypes.js  | 15 +++++
 .../automation/pages/automationWorkflow.vue   |  7 ++
 .../services/automationWorkflowNode.js        |  3 +
 .../store/automationWorkflowNode.js           | 66 +++++++++++++++++++
 12 files changed, 148 insertions(+), 11 deletions(-)

diff --git a/backend/src/baserow/contrib/automation/nodes/actions.py b/backend/src/baserow/contrib/automation/nodes/actions.py
index 52092652df..d949f6ccce 100644
--- a/backend/src/baserow/contrib/automation/nodes/actions.py
+++ b/backend/src/baserow/contrib/automation/nodes/actions.py
@@ -264,7 +264,9 @@ def undo(
         action_to_undo: Action,
     ):
         # Trash the duplicated node.
-        AutomationNodeService().delete_node(user, params.duplicated_node_id)
+        AutomationNodeService().delete_node(
+            user, params.duplicated_node_id, ignore_user_for_signal=True
+        )
 
     @classmethod
     def redo(
diff --git a/backend/src/baserow/contrib/automation/nodes/service.py b/backend/src/baserow/contrib/automation/nodes/service.py
index 074c24a297..f870e608f3 100644
--- a/backend/src/baserow/contrib/automation/nodes/service.py
+++ b/backend/src/baserow/contrib/automation/nodes/service.py
@@ -241,9 +241,7 @@ def update_node(
         )
 
     def delete_node(
-        self,
-        user: AbstractUser,
-        node_id: int,
+        self, user: AbstractUser | None, node_id: int, ignore_user_for_signal=False
     ) -> AutomationNode:
         """
         Deletes the specified automation node.
@@ -268,7 +266,7 @@ def delete_node(
         node.get_type().before_delete(node.specific)
 
         TrashHandler.trash(
-            user,
+            user if not ignore_user_for_signal else None,
             automation.workspace,
             automation,
             node,
@@ -278,7 +276,7 @@ def delete_node(
             self,
             workflow=workflow,
             node_id=node.id,
-            user=user,
+            user=user if not ignore_user_for_signal else None,
         )
 
         return node
diff --git a/web-frontend/modules/automation/components/workflow/WorkflowEdge.vue b/web-frontend/modules/automation/components/workflow/WorkflowEdge.vue
index 0b80a1ed4a..d9f87a95d7 100644
--- a/web-frontend/modules/automation/components/workflow/WorkflowEdge.vue
+++ b/web-frontend/modules/automation/components/workflow/WorkflowEdge.vue
@@ -50,6 +50,7 @@
       @remove-node="emit('remove-node', $event)"
       @replace-node="emit('replace-node', $event)"
       @move-node="emit('move-node', $event)"
+      @duplicate-node="emit('duplicate-node', $event)"
     />
   </div>
 </template>
@@ -90,7 +91,14 @@ const props = defineProps({
   },
 })
 
-const emit = defineEmits(['add-node', 'select-node', 'move-node'])
+const emit = defineEmits([
+  'add-node',
+  'select-node',
+  'move-node',
+  'remove-node',
+  'replace-node',
+  'duplicate-node',
+])
 
 const store = useStore()
 const workflow = inject('workflow')
diff --git a/web-frontend/modules/automation/components/workflow/WorkflowEditor.vue b/web-frontend/modules/automation/components/workflow/WorkflowEditor.vue
index 38d2e643f0..9849e6d189 100644
--- a/web-frontend/modules/automation/components/workflow/WorkflowEditor.vue
+++ b/web-frontend/modules/automation/components/workflow/WorkflowEditor.vue
@@ -29,6 +29,7 @@
         @replace-node="emit('replace-node', $event)"
         @select-node="emit('input', $event.id)"
         @move-node="emit('move-node', $event)"
+        @duplicate-node="emit('duplicate-node', $event)"
       />
       <template v-else>
         <div class="workflow-editor__trigger-selector" @scroll.stop>
@@ -72,7 +73,13 @@ const props = defineProps({
 })
 
 const vueFlowEdges = []
-const emit = defineEmits(['add-node', 'remove-node', 'input', 'move-node'])
+const emit = defineEmits([
+  'add-node',
+  'remove-node',
+  'input',
+  'move-node',
+  'duplicate-node',
+])
 
 const { onPaneClick } = useVueFlow()
 
diff --git a/web-frontend/modules/automation/components/workflow/WorkflowNode.vue b/web-frontend/modules/automation/components/workflow/WorkflowNode.vue
index 2e886c0614..b1771825d1 100644
--- a/web-frontend/modules/automation/components/workflow/WorkflowNode.vue
+++ b/web-frontend/modules/automation/components/workflow/WorkflowNode.vue
@@ -14,6 +14,7 @@
       @select-node="emit('select-node', $event)"
       @remove-node="emit('remove-node', $event)"
       @replace-node="emit('replace-node', $event)"
+      @duplicate-node="emit('duplicate-node', $event)"
     />
     <div v-if="nodeType.isContainer" class="workflow-node__children">
       <div ref="children" class="workflow-node__children-wrapper">
@@ -67,6 +68,7 @@
         @remove-node="emit('remove-node', $event)"
         @replace-node="emit('replace-node', $event)"
         @move-node="emit('move-node', $event)"
+        @duplicate-node="emit('duplicate-node', $event)"
       />
     </div>
   </div>
@@ -111,6 +113,7 @@ const emit = defineEmits([
   'remove-node',
   'replace-node',
   'move-node',
+  'duplicate-node',
 ])
 
 const { app } = useContext()
diff --git a/web-frontend/modules/automation/components/workflow/WorkflowNodeContent.vue b/web-frontend/modules/automation/components/workflow/WorkflowNodeContent.vue
index 602083e648..dbd9863462 100644
--- a/web-frontend/modules/automation/components/workflow/WorkflowNodeContent.vue
+++ b/web-frontend/modules/automation/components/workflow/WorkflowNodeContent.vue
@@ -75,7 +75,17 @@
             {{ $t('workflowNode.moreReplace') }}
           </a>
         </li>
-        <li class="context__menu-item">
+        <li v-if="canBeDuplicated" class="context__menu-item">
+          <a
+            role="button"
+            class="context__menu-item-link"
+            @click="emit('duplicate-node', node.id)"
+          >
+            <i class="context__menu-item-icon iconoir-copy"></i>
+            {{ $t('workflowNode.moreDuplicate') }}
+          </a>
+        </li>
+        <li class="context__menu-item context__menu-item--with-separator">
           <a
             :key="getDeleteErrorMessage"
             v-tooltip="getDeleteErrorMessage || null"
@@ -131,7 +141,12 @@ const props = defineProps({
   },
 })
 
-const emit = defineEmits(['remove-node', 'replace-node', 'select-node'])
+const emit = defineEmits([
+  'remove-node',
+  'replace-node',
+  'select-node',
+  'duplicate-node',
+])
 
 const isDragging = ref(false)
 
@@ -277,4 +292,11 @@ const getDataBeforeLabel = computed(() => {
     output,
   })
 })
+
+const canBeDuplicated = computed(() => {
+  return nodeType.value.isDuplicable({
+    workflow: workflow.value,
+    node: props.node,
+  })
+})
 </script>
diff --git a/web-frontend/modules/automation/locales/en.json b/web-frontend/modules/automation/locales/en.json
index d4cd625e36..f2a1a32215 100644
--- a/web-frontend/modules/automation/locales/en.json
+++ b/web-frontend/modules/automation/locales/en.json
@@ -132,7 +132,9 @@
     "beforeLabelRepeat": "For each item",
     "moreEdit": "Edit",
     "moreReplace": "Replace",
-    "nodeOptions": "Node options"
+    "nodeOptions": "Node options",
+    "displayLabelDebug": "ID: {id} | Prev: {previousNodeId} | {outputUid}",
+    "moreDuplicate": "Duplicate"
   },
   "workflowAddNode": {
     "displayTitle": "Create automation node"
diff --git a/web-frontend/modules/automation/nodeTypeMixins.js b/web-frontend/modules/automation/nodeTypeMixins.js
index 0fa94ef11f..9edc5d2ef7 100644
--- a/web-frontend/modules/automation/nodeTypeMixins.js
+++ b/web-frontend/modules/automation/nodeTypeMixins.js
@@ -20,6 +20,10 @@ export const TriggerNodeTypeMixin = (Base) =>
     getDeleteErrorMessage({ workflow, node }) {
       return this.app.i18n.t('nodeType.triggerDeletionError')
     }
+
+    isDuplicable({ workflow, node }) {
+      return false
+    }
   }
 
 export const ActionNodeTypeMixin = (Base) =>
diff --git a/web-frontend/modules/automation/nodeTypes.js b/web-frontend/modules/automation/nodeTypes.js
index a023d6b2b8..2ee877e43a 100644
--- a/web-frontend/modules/automation/nodeTypes.js
+++ b/web-frontend/modules/automation/nodeTypes.js
@@ -158,6 +158,13 @@ export class NodeType extends Registerable {
     return Boolean(this.getDeleteErrorMessage({ workflow, node }))
   }
 
+  /**
+   * Returns whether the given node can be duplicated.
+   */
+  isDuplicable({ workflow, node }) {
+    return true
+  }
+
   /**
    * Returns the error message we should show when a node cannot be deleted.
    * By default, this method is empty, but can be overridden by the node type
@@ -655,6 +662,10 @@ export class CoreIteratorNodeType extends containerNodeTypeMixin(
     }
     return ''
   }
+
+  isDuplicable({ workflow, node }) {
+    return false
+  }
 }
 
 export class CoreSMTPEmailNodeType extends ActionNodeTypeMixin(NodeType) {
@@ -805,6 +816,10 @@ export class CoreRouterNodeType extends ActionNodeTypeMixin(
       },
     ]
   }
+
+  isDuplicable({ workflow, node }) {
+    return false
+  }
 }
 
 export class AIAgentActionNodeType extends ActionNodeTypeMixin(NodeType) {
diff --git a/web-frontend/modules/automation/pages/automationWorkflow.vue b/web-frontend/modules/automation/pages/automationWorkflow.vue
index fa3e4b28d9..5bfe8eec1a 100644
--- a/web-frontend/modules/automation/pages/automationWorkflow.vue
+++ b/web-frontend/modules/automation/pages/automationWorkflow.vue
@@ -27,6 +27,7 @@
             @remove-node="handleRemoveNode"
             @replace-node="handleReplaceNode"
             @move-node="handleMoveNode"
+            @duplicate-node="handleDuplicateNode"
           />
         </client-only>
       </div>
@@ -265,6 +266,12 @@ export default {
         notifyIf(err, 'automation')
       }
     },
+    async handleDuplicateNode(nodeId) {
+      await this.$store.dispatch('automationWorkflowNode/duplicate', {
+        workflow: this.workflow,
+        nodeId,
+      })
+    },
   },
 }
 </script>
diff --git a/web-frontend/modules/automation/services/automationWorkflowNode.js b/web-frontend/modules/automation/services/automationWorkflowNode.js
index f71df490e5..8e0a77003a 100644
--- a/web-frontend/modules/automation/services/automationWorkflowNode.js
+++ b/web-frontend/modules/automation/services/automationWorkflowNode.js
@@ -27,5 +27,8 @@ export default (client) => {
     simulateDispatch(nodeId) {
       return client.post(`automation/node/${nodeId}/simulate-dispatch/`)
     },
+    duplicate(nodeId) {
+      return client.post(`automation/node/${nodeId}/duplicate/`)
+    },
   }
 }
diff --git a/web-frontend/modules/automation/store/automationWorkflowNode.js b/web-frontend/modules/automation/store/automationWorkflowNode.js
index 25f20444a3..077f75afec 100644
--- a/web-frontend/modules/automation/store/automationWorkflowNode.js
+++ b/web-frontend/modules/automation/store/automationWorkflowNode.js
@@ -172,6 +172,7 @@ const actions = {
       type,
       workflow: workflow.id,
     })
+
     commit('ADD_ITEM', { workflow, node: tempNode })
 
     const initialGraph = clone(workflow.graph)
@@ -407,6 +408,71 @@ const actions = {
       throw error
     }
   },
+  async duplicate({ commit, dispatch, getters }, { workflow, nodeId }) {
+    const nodeToDuplicate = getters.findById(workflow, nodeId)
+    if (!nodeToDuplicate) {
+      return
+    }
+
+    // Get the node type to properly initialize the node
+    const nodeType = this.$registry.get('node', nodeToDuplicate.type)
+
+    // Use getDefaultValues like in create, but override with duplicated node's data
+    const tempNode = nodeType.getDefaultValues({
+      ...nodeToDuplicate, // Copy all properties from the original
+      id: uuid(), // But give it a new ID
+      workflow: workflow.id,
+    })
+
+    commit('ADD_ITEM', { workflow, node: tempNode })
+
+    const initialGraph = clone(workflow.graph)
+
+    // Insert the duplicated node after the original node using 'south' position
+    await dispatch('graphInsert', {
+      workflow,
+      node: tempNode,
+      referenceNode: nodeToDuplicate,
+      position: 'south',
+      output: '', // Default output for creating after a node
+    })
+
+    try {
+      const { data: node } = await AutomationWorkflowNodeService(
+        this.$client
+      ).duplicate(nodeId)
+
+      commit('ADD_ITEM', { workflow, node })
+
+      await dispatch('graphReplace', {
+        workflow,
+        nodeToReplace: tempNode,
+        newNode: node,
+      })
+
+      // Remove temp node and add real one
+      commit('DELETE_ITEM', { workflow, nodeId: tempNode.id })
+
+      setTimeout(() => {
+        const populatedNode = getters.findById(workflow, node.id)
+        dispatch('select', { workflow, node: populatedNode })
+      })
+
+      return node
+    } catch (error) {
+      // If API fails, restore the initial graph
+      await dispatch(
+        'automationWorkflow/forceUpdate',
+        {
+          workflow,
+          values: { graph: initialGraph },
+        },
+        { root: true }
+      )
+      commit('DELETE_ITEM', { workflow, nodeId: tempNode.id })
+      throw error
+    }
+  },
   select({ commit, dispatch }, { workflow, node }) {
     commit('SELECT_ITEM', { workflow, node })
     dispatch(