fix subflow copy/paste

Author: icecrasher321

apps/sim/socket/database/operations.ts

@@ -493,16 +493,28 @@ async function handleBlocksOperationTx(
 
         await tx.insert(workflowBlocks).values(blockValues)
 
-        // Create subflow entries for loop/parallel blocks
+        // Create subflow entries for loop/parallel blocks (skip if already in payload)
+        const loopIds = new Set(loops ? Object.keys(loops) : [])
+        const parallelIds = new Set(parallels ? Object.keys(parallels) : [])
         for (const block of blocks) {
-          if (block.type === 'loop' || block.type === 'parallel') {
+          const blockId = block.id as string
+          if (block.type === 'loop' && !loopIds.has(blockId)) {
             await tx.insert(workflowSubflows).values({
-              id: block.id as string,
+              id: blockId,
               workflowId,
-              type: block.type as string,
+              type: 'loop',
               config: {
                 loopType: 'for',
                 iterations: DEFAULT_LOOP_ITERATIONS,
+                nodes: [],
+              },
+            })
+          } else if (block.type === 'parallel' && !parallelIds.has(blockId)) {
+            await tx.insert(workflowSubflows).values({
+              id: blockId,
+              workflowId,
+              type: 'parallel',
+              config: {
                 parallelType: 'fixed',
                 count: DEFAULT_PARALLEL_COUNT,
                 nodes: [],

apps/sim/stores/workflows/registry/store.ts

@@ -792,7 +792,15 @@ export const useWorkflowRegistry = create<WorkflowRegistry>()(
         const copiedSubBlockValues: Record<string, Record<string, unknown>> = {}
         const blockIdSet = new Set(blockIds)
 
+        // Auto-include nested nodes from selected subflows
         blockIds.forEach((blockId) => {
+          const loop = workflowStore.loops[blockId]
+          if (loop?.nodes) loop.nodes.forEach((n) => blockIdSet.add(n))
+          const parallel = workflowStore.parallels[blockId]
+          if (parallel?.nodes) parallel.nodes.forEach((n) => blockIdSet.add(n))
+        })
+
+        blockIdSet.forEach((blockId) => {
           const block = workflowStore.blocks[blockId]
           if (block) {
             copiedBlocks[blockId] = JSON.parse(JSON.stringify(block))