fix(sockets): redrawing edges should not lead to socket ops

Author: icecrasher321

apps/sim/hooks/use-collaborative-workflow.ts

@@ -242,7 +242,20 @@ export function useCollaborativeWorkflow() {
             case EDGES_OPERATIONS.BATCH_ADD_EDGES: {
               const { edges } = payload
               if (Array.isArray(edges) && edges.length > 0) {
-                workflowStore.batchAddEdges(edges)
+                const currentEdges = workflowStore.edges
+                const newEdges = edges.filter((edge: Edge) => {
+                  if (edge.source === edge.target) return false
+                  return !currentEdges.some(
+                    (e) =>
+                      e.source === edge.source &&
+                      e.sourceHandle === edge.sourceHandle &&
+                      e.target === edge.target &&
+                      e.targetHandle === edge.targetHandle
+                  )
+                })
+                if (newEdges.length > 0) {
+                  workflowStore.batchAddEdges(newEdges)
+                }
               }
               break
             }
@@ -976,23 +989,40 @@ export function useCollaborativeWorkflow() {
 
       if (edges.length === 0) return false
 
+      const currentEdges = workflowStore.edges
+      const newEdges = edges.filter((edge) => {
+        if (edge.source === edge.target) return false
+        return !currentEdges.some(
+          (e) =>
+            e.source === edge.source &&
+            e.sourceHandle === edge.sourceHandle &&
+            e.target === edge.target &&
+            e.targetHandle === edge.targetHandle
+        )
+      })
+
+      if (newEdges.length === 0) {
+        logger.debug('Skipping batch add edges - all edges already exist')
+        return false
+      }
+
       const operationId = crypto.randomUUID()
 
       addToQueue({
         id: operationId,
         operation: {
           operation: EDGES_OPERATIONS.BATCH_ADD_EDGES,
           target: OPERATION_TARGETS.EDGES,
-          payload: { edges },
+          payload: { edges: newEdges },
         },
         workflowId: activeWorkflowId || '',
         userId: session?.user?.id || 'unknown',
       })
 
-      workflowStore.batchAddEdges(edges)
+      workflowStore.batchAddEdges(newEdges)
 
       if (!options?.skipUndoRedo) {
-        edges.forEach((edge) => undoRedo.recordAddEdge(edge.id))
+        newEdges.forEach((edge) => undoRedo.recordAddEdge(edge.id))
       }
 
       return true

apps/sim/stores/workflows/workflow/store.test.ts

@@ -297,7 +297,7 @@ describe('workflow store', () => {
       expectEdgeConnects(edges, 'block-1', 'block-2')
     })
 
-    it('should not add duplicate edges', () => {
+    it('should not add duplicate connections', () => {
       const { addBlock, batchAddEdges } = useWorkflowStore.getState()
 
       addBlock('block-1', 'starter', 'Start', { x: 0, y: 0 })
@@ -309,17 +309,6 @@ describe('workflow store', () => {
       const state = useWorkflowStore.getState()
       expectEdgeCount(state, 1)
     })
-
-    it('should prevent self-referencing edges', () => {
-      const { addBlock, batchAddEdges } = useWorkflowStore.getState()
-
-      addBlock('block-1', 'function', 'Self', { x: 0, y: 0 })
-
-      batchAddEdges([{ id: 'e1', source: 'block-1', target: 'block-1' }])
-
-      const state = useWorkflowStore.getState()
-      expectEdgeCount(state, 0)
-    })
   })
 
   describe('batchRemoveEdges', () => {

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

@@ -497,16 +497,8 @@ export const useWorkflowStore = create<WorkflowStore>()(
       batchAddEdges: (edges: Edge[]) => {
         const currentEdges = get().edges
         const newEdges = [...currentEdges]
-        const existingEdgeIds = new Set(currentEdges.map((e) => e.id))
 
         for (const edge of edges) {
-          // Skip if edge ID already exists
-          if (existingEdgeIds.has(edge.id)) continue
-
-          // Skip self-referencing edges
-          if (edge.source === edge.target) continue
-
-          // Skip if identical connection already exists (same ports)
           const connectionExists = newEdges.some(
             (e) =>
               e.source === edge.source &&
@@ -515,8 +507,6 @@ export const useWorkflowStore = create<WorkflowStore>()(
               e.targetHandle === edge.targetHandle
           )
           if (connectionExists) continue
-
-          // Skip if would create a cycle
           if (wouldCreateCycle([...newEdges], edge.source, edge.target)) continue
 
           newEdges.push({
@@ -528,7 +518,6 @@ export const useWorkflowStore = create<WorkflowStore>()(
             type: edge.type || 'default',
             data: edge.data || {},
           })
-          existingEdgeIds.add(edge.id)
         }
 
         const blocks = get().blocks