fix: close socket sync review gaps

Author: PlaneInABottle

apps/sim/socket/database/operations.ts

@@ -92,34 +92,6 @@ function findDbDescendants(containerId: string, allBlocks: DbBlockRef[]): string
   return descendants
 }
 
-/**
- * Shared function to handle auto-connect edge insertion
- * @param tx - Database transaction
- * @param workflowId - The workflow ID
- * @param autoConnectEdge - The auto-connect edge data
- * @param logger - Logger instance
- */
-async function insertAutoConnectEdge(
-  tx: any,
-  workflowId: string,
-  autoConnectEdge: any,
-  logger: any
-) {
-  if (!autoConnectEdge) return
-
-  await tx.insert(workflowEdges).values({
-    id: autoConnectEdge.id,
-    workflowId,
-    sourceBlockId: autoConnectEdge.source,
-    targetBlockId: autoConnectEdge.target,
-    sourceHandle: autoConnectEdge.sourceHandle || null,
-    targetHandle: autoConnectEdge.targetHandle || null,
-  })
-  logger.debug(
-    `Added auto-connect edge ${autoConnectEdge.id}: ${autoConnectEdge.source} -> ${autoConnectEdge.target}`
-  )
-}
-
 enum SubflowType {
   LOOP = 'loop',
   PARALLEL = 'parallel',

apps/sim/socket/handlers/operations.test.ts

@@ -123,7 +123,9 @@ describe('setupOperationsHandlers', () => {
       timestamp: expect.any(Number),
       userId: 'user-1',
     })
-    expect(socketRoomEmit).toHaveBeenCalledWith(
+    expect(emitToWorkflow).toHaveBeenNthCalledWith(
+      1,
+      'workflow-1',
       'workflow-operation',
       expect.objectContaining({
         operation: EDGES_OPERATIONS.BATCH_REMOVE_EDGES,

apps/sim/socket/handlers/operations.ts

@@ -503,7 +503,7 @@ export function setupOperationsHandlers(socket: AuthenticatedSocket, roomManager
 
         // Broadcast edge removals if the parent update cleaned up boundary edges
         if (result?.removedEdgeIds && result.removedEdgeIds.length > 0) {
-          socket.to(workflowId).emit('workflow-operation', {
+          roomManager.emitToWorkflow(workflowId, 'workflow-operation', {
             operation: EDGES_OPERATIONS.BATCH_REMOVE_EDGES,
             target: OPERATION_TARGETS.EDGES,
             payload: { ids: result.removedEdgeIds },