feat: enhance node and port cloning with deep copy for improved performance, add option to disable events when adding edges to the flow

yakud · yakud · commit 7fc22372b15b · 2025-09-23T15:57:54.000+03:00
diff --git a/.changeset/pre.json b/.changeset/pre.json
@@ -31,6 +31,7 @@
     "hungry-words-hang",
     "loud-gifts-tell",
     "lovely-areas-count",
+    "lovely-planes-wear",
     "modern-pants-train",
     "olive-ears-camp",
     "petite-paws-cut",
diff --git a/apps/chaingraph-backend/CHANGELOG.md b/apps/chaingraph-backend/CHANGELOG.md
@@ -1,5 +1,11 @@
 # @badaitech/chaingraph-backend
 
+## 0.5.5-dev.28
+
+### Patch Changes
+
+- feat: enhance node and port cloning with deep copy for improved performance, add option to disable events when adding edges to the flow
+
 ## 0.5.5-dev.27
 
 ### Patch Changes
diff --git a/apps/chaingraph-backend/package.json b/apps/chaingraph-backend/package.json
@@ -1,7 +1,7 @@
 {
   "name": "@badaitech/chaingraph-backend",
   "type": "module",
-  "version": "0.5.5-dev.27",
+  "version": "0.5.5-dev.28",
   "private": false,
   "description": "Backend server for the Chaingraph project",
   "license": "BUSL-1.1",
diff --git a/apps/chaingraph-execution-api/CHANGELOG.md b/apps/chaingraph-execution-api/CHANGELOG.md
@@ -1,5 +1,15 @@
 # @badaitech/chaingraph-execution-api
 
+## 0.5.5-dev.28
+
+### Patch Changes
+
+- feat: enhance node and port cloning with deep copy for improved performance, add option to disable events when adding edges to the flow
+- Updated dependencies
+  - @badaitech/chaingraph-executor@0.5.5-dev.28
+  - @badaitech/chaingraph-types@0.5.5-dev.28
+  - @badaitech/chaingraph-trpc@0.5.5-dev.28
+
 ## 0.5.5-dev.27
 
 ### Patch Changes
diff --git a/apps/chaingraph-execution-api/package.json b/apps/chaingraph-execution-api/package.json
@@ -1,7 +1,7 @@
 {
   "name": "@badaitech/chaingraph-execution-api",
   "type": "module",
-  "version": "0.5.5-dev.27",
+  "version": "0.5.5-dev.28",
   "private": false,
   "description": "Chaingraph tRPC Server - Scalable API server for Chaingraph execution management",
   "license": "BUSL-1.1",
diff --git a/apps/chaingraph-execution-worker/CHANGELOG.md b/apps/chaingraph-execution-worker/CHANGELOG.md
@@ -1,5 +1,16 @@
 # @badaitech/chaingraph-execution-worker
 
+## 0.5.5-dev.28
+
+### Patch Changes
+
+- feat: enhance node and port cloning with deep copy for improved performance, add option to disable events when adding edges to the flow
+- Updated dependencies
+  - @badaitech/chaingraph-executor@0.5.5-dev.28
+  - @badaitech/chaingraph-nodes@0.5.5-dev.28
+  - @badaitech/chaingraph-types@0.5.5-dev.28
+  - @badaitech/chaingraph-trpc@0.5.5-dev.28
+
 ## 0.5.5-dev.27
 
 ### Patch Changes
diff --git a/apps/chaingraph-execution-worker/package.json b/apps/chaingraph-execution-worker/package.json
@@ -1,7 +1,7 @@
 {
   "name": "@badaitech/chaingraph-execution-worker",
   "type": "module",
-  "version": "0.5.5-dev.27",
+  "version": "0.5.5-dev.28",
   "private": false,
   "description": "Chaingraph Execution Worker Service which connected to Kafka and process the flow executions",
   "license": "BUSL-1.1",
diff --git a/apps/chaingraph-frontend/CHANGELOG.md b/apps/chaingraph-frontend/CHANGELOG.md
@@ -1,5 +1,17 @@
 # @badaitech/chaingraph-frontend
 
+## 0.5.5-dev.28
+
+### Patch Changes
+
+- feat: enhance node and port cloning with deep copy for improved performance, add option to disable events when adding edges to the flow
+- Updated dependencies
+  - @badaitech/chaingraph-executor@0.5.5-dev.28
+  - @badaitech/chaingraph-nodes@0.5.5-dev.28
+  - @badaitech/chaingraph-types@0.5.5-dev.28
+  - @badaitech/chaingraph-trpc@0.5.5-dev.28
+  - @badaitech/badai-api@0.5.5-dev.28
+
 ## 0.5.5-dev.27
 
 ### Patch Changes
diff --git a/apps/chaingraph-frontend/package.json b/apps/chaingraph-frontend/package.json
@@ -1,7 +1,7 @@
 {
   "name": "@badaitech/chaingraph-frontend",
   "type": "module",
-  "version": "0.5.5-dev.27",
+  "version": "0.5.5-dev.28",
   "private": false,
   "description": "Frontend application for the Chaingraph project",
   "license": "BUSL-1.1",
diff --git a/packages/badai-api-example/package.json b/packages/badai-api-example/package.json
@@ -1,7 +1,7 @@
 {
   "name": "@badaitech/badai-api-example",
   "type": "module",
-  "version": "0.5.5-dev.27",
+  "version": "0.5.5-dev.28",
   "private": true,
   "description": "Bad AI GraphQL API client example",
   "license": "BUSL-1.1",
diff --git a/packages/badai-api/CHANGELOG.md b/packages/badai-api/CHANGELOG.md
@@ -1,5 +1,11 @@
 # @badaitech/badai-api
 
+## 0.5.5-dev.28
+
+### Patch Changes
+
+- feat: enhance node and port cloning with deep copy for improved performance, add option to disable events when adding edges to the flow
+
 ## 0.5.5-dev.27
 
 ### Patch Changes
diff --git a/packages/badai-api/package.json b/packages/badai-api/package.json
@@ -1,7 +1,7 @@
 {
   "name": "@badaitech/badai-api",
   "type": "module",
-  "version": "0.5.5-dev.27",
+  "version": "0.5.5-dev.28",
   "private": false,
   "description": "Bad AI GraphQL API client",
   "license": "BUSL-1.1",
diff --git a/packages/chaingraph-executor/package.json b/packages/chaingraph-executor/package.json
@@ -1,7 +1,7 @@
 {
   "name": "@badaitech/chaingraph-executor",
   "type": "module",
-  "version": "0.5.5-dev.27",
+  "version": "0.5.5-dev.28",
   "private": false,
   "description": "Chaingraph Message Bus for inter-service communication",
   "license": "BUSL-1.1",
diff --git a/packages/chaingraph-nodes/CHANGELOG.md b/packages/chaingraph-nodes/CHANGELOG.md
@@ -1,5 +1,13 @@
 # @badaitech/chaingraph-nodes
 
+## 0.5.5-dev.28
+
+### Patch Changes
+
+- feat: enhance node and port cloning with deep copy for improved performance, add option to disable events when adding edges to the flow
+- Updated dependencies
+  - @badaitech/chaingraph-types@0.5.5-dev.28
+
 ## 0.5.5-dev.27
 
 ### Patch Changes
diff --git a/packages/chaingraph-nodes/package.json b/packages/chaingraph-nodes/package.json
@@ -1,7 +1,7 @@
 {
   "name": "@badaitech/chaingraph-nodes",
   "type": "module",
-  "version": "0.5.5-dev.27",
+  "version": "0.5.5-dev.28",
   "private": false,
   "description": "Node components for the Chaingraph project",
   "license": "BUSL-1.1",
diff --git a/packages/chaingraph-trpc/CHANGELOG.md b/packages/chaingraph-trpc/CHANGELOG.md
@@ -1,5 +1,11 @@
 # @badaitech/chaingraph-trpc
 
+## 0.5.5-dev.28
+
+### Patch Changes
+
+- feat: enhance node and port cloning with deep copy for improved performance, add option to disable events when adding edges to the flow
+
 ## 0.5.5-dev.27
 
 ### Patch Changes
diff --git a/packages/chaingraph-trpc/package.json b/packages/chaingraph-trpc/package.json
@@ -1,7 +1,7 @@
 {
   "name": "@badaitech/chaingraph-trpc",
   "type": "module",
-  "version": "0.5.5-dev.27",
+  "version": "0.5.5-dev.28",
   "private": false,
   "description": "tRPC client and server for the Chaingraph V2",
   "license": "BUSL-1.1",
diff --git a/packages/chaingraph-types/CHANGELOG.md b/packages/chaingraph-types/CHANGELOG.md
@@ -1,5 +1,11 @@
 # @badaitech/chaingraph-types
 
+## 0.5.5-dev.28
+
+### Patch Changes
+
+- feat: enhance node and port cloning with deep copy for improved performance, add option to disable events when adding edges to the flow
+
 ## 0.5.5-dev.27
 
 ### Patch Changes
diff --git a/packages/chaingraph-types/package.json b/packages/chaingraph-types/package.json
@@ -1,7 +1,7 @@
 {
   "name": "@badaitech/chaingraph-types",
   "type": "module",
-  "version": "0.5.5-dev.27",
+  "version": "0.5.5-dev.28",
   "private": false,
   "description": "Core type definitions for the Chaingraph project",
   "license": "BUSL-1.1",
diff --git a/packages/chaingraph-types/src/flow/flow.ts b/packages/chaingraph-types/src/flow/flow.ts
@@ -336,7 +336,7 @@ export class Flow implements IFlow {
     this.edges.set(edge.id, edge)
   }
 
-  async addEdge(edge: IEdge): Promise<void> {
+  async addEdge(edge: IEdge, disableEvents?: boolean): Promise<void> {
     if (this.edges.has(edge.id)) {
       throw new Error(`Edge with ID ${edge.id} already exists in the flow.`)
     }
@@ -346,29 +346,31 @@ export class Flow implements IFlow {
       edge.targetPort.addConnection(edge.sourceNode.id, edge.sourcePort.id)
     }
 
-    await Promise.all([
-      edge.targetNode.emit({
-        type: NodeEventType.PortConnected,
-        sourceNode: edge.targetNode.clone(),
-        sourcePort: edge.targetPort.clone(),
-        targetNode: edge.sourceNode.clone(),
-        targetPort: edge.sourcePort.clone(),
-        nodeId: edge.targetNode.id,
-        timestamp: new Date(),
-        version: edge.targetNode.getVersion(),
-      }),
+    if (!disableEvents) {
+      await Promise.all([
+        edge.targetNode.emit({
+          type: NodeEventType.PortConnected,
+          sourceNode: edge.targetNode.clone(),
+          sourcePort: edge.targetPort.clone(),
+          targetNode: edge.sourceNode.clone(),
+          targetPort: edge.sourcePort.clone(),
+          nodeId: edge.targetNode.id,
+          timestamp: new Date(),
+          version: edge.targetNode.getVersion(),
+        }),
 
-      edge.sourceNode.emit({
-        type: NodeEventType.PortConnected,
-        sourceNode: edge.sourceNode.clone(),
-        sourcePort: edge.sourcePort.clone(),
-        targetNode: edge.targetNode.clone(),
-        targetPort: edge.targetPort.clone(),
-        nodeId: edge.sourceNode.id,
-        timestamp: new Date(),
-        version: edge.sourceNode.getVersion(),
-      }),
-    ])
+        edge.sourceNode.emit({
+          type: NodeEventType.PortConnected,
+          sourceNode: edge.sourceNode.clone(),
+          sourcePort: edge.sourcePort.clone(),
+          targetNode: edge.targetNode.clone(),
+          targetPort: edge.targetPort.clone(),
+          nodeId: edge.sourceNode.id,
+          timestamp: new Date(),
+          version: edge.sourceNode.getVersion(),
+        }),
+      ])
+    }
 
     this.edges.set(edge.id, edge)
   }
@@ -908,7 +910,7 @@ export class Flow implements IFlow {
         { ...edge.metadata },
       )
 
-      edgePromises.push(newFlow.addEdge(clonedEdge))
+      edgePromises.push(newFlow.addEdge(clonedEdge, true))
     }
 
     await Promise.all(edgePromises)
diff --git a/packages/chaingraph-types/src/flow/interface.ts b/packages/chaingraph-types/src/flow/interface.ts
@@ -73,7 +73,7 @@ export interface IFlow {
    * Adds an edge to the flow.
    * @param edge The edge to add.
    */
-  addEdge: (edge: IEdge) => Promise<void>
+  addEdge: (edge: IEdge, disableEvents?: boolean) => Promise<void>
 
   /**
    * Adds an edge to the flow synchronously, without triggering events.
diff --git a/packages/chaingraph-types/src/node/implementations/node-serializer.ts b/packages/chaingraph-types/src/node/implementations/node-serializer.ts
@@ -174,7 +174,24 @@ export class NodeSerializer implements ISerializable<INodeComposite> {
       throw new Error('Node reference is required for cloning')
     }
 
-    const serialized = this.serialize()
-    return this.createInstance(this.nodeRef.id).deserialize(serialized)
+    const newNode = this.createInstance(this.nodeRef.id)
+
+    // Deep copy metadata
+    newNode.setMetadata(deepCopy(this.nodeRef.metadata))
+    // Copy status
+    newNode.setStatus(this.nodeRef.status, false)
+    // Copy version
+    newNode.setVersion(this.nodeRef.getVersion())
+
+    // Clone ports
+    const clonedPorts = new Map<string, IPort>()
+    for (const [portId, port] of this.portManager.ports.entries()) {
+      clonedPorts.set(portId, port.clone())
+    }
+    newNode.setPorts(clonedPorts)
+
+    newNode.bindPortBindings()
+
+    return newNode
   }
 }
diff --git a/packages/chaingraph-types/src/port/base/BasePort.ts b/packages/chaingraph-types/src/port/base/BasePort.ts
@@ -126,10 +126,13 @@ export abstract class BasePort<C extends IPortConfig = IPortConfig> implements I
     }
   }
 
+  // New faster implementation with direct object cloning
   clone(): IPort<C> {
-    const serialized = this.serialize()
-    const newPort = new (this.constructor as new (config: C) => BasePort<C>)(this.config)
-    return newPort.deserialize(serialized)
+    const newConfig = deepCopy(this.config)
+    const newPort = new (this.constructor as new (config: C) => BasePort<C>)(newConfig)
+    const currentValue = this.getValue()
+    newPort.setValue(deepCopy(currentValue))
+    return newPort
   }
 
   isSystem() {
diff --git a/packages/typescript-config/CHANGELOG.md b/packages/typescript-config/CHANGELOG.md
@@ -1,5 +1,11 @@
 # @badaitech/typescript-config
 
+## 0.5.5-dev.28
+
+### Patch Changes
+
+- feat: enhance node and port cloning with deep copy for improved performance, add option to disable events when adding edges to the flow
+
 ## 0.5.5-dev.27
 
 ### Patch Changes
diff --git a/packages/typescript-config/package.json b/packages/typescript-config/package.json
@@ -1,6 +1,6 @@
 {
   "name": "@badaitech/typescript-config",
-  "version": "0.5.5-dev.27",
+  "version": "0.5.5-dev.28",
   "private": true,
   "license": "MIT",
   "files": [

Original file line number	Diff line number	Diff line change
`@@ -1,7 +1,7 @@`
`1`	`1`	`{`
`2`	`2`	`"name": "@badaitech/chaingraph-backend",`
`3`	`3`	`"type": "module",`
`4`		`- "version": "0.5.5-dev.27",`
	`4`	`+ "version": "0.5.5-dev.28",`
`5`	`5`	`"private": false,`
`6`	`6`	`"description": "Backend server for the Chaingraph project",`
`7`	`7`	`"license": "BUSL-1.1",`
Original file line number	Diff line number	Diff line change
`@@ -1,7 +1,7 @@`
`1`	`1`	`{`
`2`	`2`	`"name": "@badaitech/chaingraph-execution-api",`
`3`	`3`	`"type": "module",`
`4`		`- "version": "0.5.5-dev.27",`
	`4`	`+ "version": "0.5.5-dev.28",`
`5`	`5`	`"private": false,`
`6`	`6`	`"description": "Chaingraph tRPC Server - Scalable API server for Chaingraph execution management",`
`7`	`7`	`"license": "BUSL-1.1",`
Original file line number	Diff line number	Diff line change
`@@ -1,7 +1,7 @@`
`1`	`1`	`{`
`2`	`2`	`"name": "@badaitech/chaingraph-frontend",`
`3`	`3`	`"type": "module",`
`4`		`- "version": "0.5.5-dev.27",`
	`4`	`+ "version": "0.5.5-dev.28",`
`5`	`5`	`"private": false,`
`6`	`6`	`"description": "Frontend application for the Chaingraph project",`
`7`	`7`	`"license": "BUSL-1.1",`
Original file line number	Diff line number	Diff line change
`@@ -1,7 +1,7 @@`
`1`	`1`	`{`
`2`	`2`	`"name": "@badaitech/badai-api-example",`
`3`	`3`	`"type": "module",`
`4`		`- "version": "0.5.5-dev.27",`
	`4`	`+ "version": "0.5.5-dev.28",`
`5`	`5`	`"private": true,`
`6`	`6`	`"description": "Bad AI GraphQL API client example",`
`7`	`7`	`"license": "BUSL-1.1",`