Merge pull request #309 from badaitech/fix/imoport-nodes-legacy

yakud · web-flow · commit d09b893cb49a · 2025-09-22T17:21:39.000+03:00
fix/import-nodes-legacy
diff --git a/.changeset/pre.json b/.changeset/pre.json
@@ -21,6 +21,7 @@
     "brave-webs-refuse",
     "chubby-numbers-enjoy",
     "cold-news-fold",
+    "cold-turtles-laugh",
     "dirty-glasses-drop",
     "easy-candies-smile",
     "full-readers-itch",
@@ -30,6 +31,7 @@
     "lovely-areas-count",
     "modern-pants-train",
     "olive-ears-camp",
+    "petite-paws-cut",
     "proud-clouds-report",
     "rude-parts-heal",
     "sixty-humans-smile",
diff --git a/apps/chaingraph-backend/CHANGELOG.md b/apps/chaingraph-backend/CHANGELOG.md
@@ -1,5 +1,17 @@
 # @badaitech/chaingraph-backend
 
+## 0.5.5-dev.22
+
+### Patch Changes
+
+- feat: enhance edge connection handling with parallel execution and improved error logging
+
+## 0.5.5-dev.21
+
+### Patch Changes
+
+- feat: extend ClipboardDataSchema to support legacy SerializedNodeSchemaV1
+
 ## 0.5.5-dev.20
 
 ### 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.20",
+  "version": "0.5.5-dev.22",
   "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,25 @@
 # @badaitech/chaingraph-execution-api
 
+## 0.5.5-dev.22
+
+### Patch Changes
+
+- feat: enhance edge connection handling with parallel execution and improved error logging
+- Updated dependencies
+  - @badaitech/chaingraph-executor@0.5.5-dev.22
+  - @badaitech/chaingraph-types@0.5.5-dev.22
+  - @badaitech/chaingraph-trpc@0.5.5-dev.22
+
+## 0.5.5-dev.21
+
+### Patch Changes
+
+- feat: extend ClipboardDataSchema to support legacy SerializedNodeSchemaV1
+- Updated dependencies
+  - @badaitech/chaingraph-trpc@0.5.5-dev.21
+  - @badaitech/chaingraph-executor@0.5.5-dev.21
+  - @badaitech/chaingraph-types@0.5.5-dev.21
+
 ## 0.5.5-dev.20
 
 ### 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.20",
+  "version": "0.5.5-dev.22",
   "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,27 @@
 # @badaitech/chaingraph-execution-worker
 
+## 0.5.5-dev.22
+
+### Patch Changes
+
+- feat: enhance edge connection handling with parallel execution and improved error logging
+- Updated dependencies
+  - @badaitech/chaingraph-executor@0.5.5-dev.22
+  - @badaitech/chaingraph-nodes@0.5.5-dev.22
+  - @badaitech/chaingraph-types@0.5.5-dev.22
+  - @badaitech/chaingraph-trpc@0.5.5-dev.22
+
+## 0.5.5-dev.21
+
+### Patch Changes
+
+- feat: extend ClipboardDataSchema to support legacy SerializedNodeSchemaV1
+- Updated dependencies
+  - @badaitech/chaingraph-trpc@0.5.5-dev.21
+  - @badaitech/chaingraph-executor@0.5.5-dev.21
+  - @badaitech/chaingraph-nodes@0.5.5-dev.21
+  - @badaitech/chaingraph-types@0.5.5-dev.21
+
 ## 0.5.5-dev.20
 
 ### 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.20",
+  "version": "0.5.5-dev.22",
   "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,29 @@
 # @badaitech/chaingraph-frontend
 
+## 0.5.5-dev.22
+
+### Patch Changes
+
+- feat: enhance edge connection handling with parallel execution and improved error logging
+- Updated dependencies
+  - @badaitech/chaingraph-executor@0.5.5-dev.22
+  - @badaitech/chaingraph-nodes@0.5.5-dev.22
+  - @badaitech/chaingraph-types@0.5.5-dev.22
+  - @badaitech/chaingraph-trpc@0.5.5-dev.22
+  - @badaitech/badai-api@0.5.5-dev.22
+
+## 0.5.5-dev.21
+
+### Patch Changes
+
+- feat: extend ClipboardDataSchema to support legacy SerializedNodeSchemaV1
+- Updated dependencies
+  - @badaitech/chaingraph-trpc@0.5.5-dev.21
+  - @badaitech/badai-api@0.5.5-dev.21
+  - @badaitech/chaingraph-executor@0.5.5-dev.21
+  - @badaitech/chaingraph-nodes@0.5.5-dev.21
+  - @badaitech/chaingraph-types@0.5.5-dev.21
+
 ## 0.5.5-dev.20
 
 ### 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.20",
+  "version": "0.5.5-dev.22",
   "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.20",
+  "version": "0.5.5-dev.22",
   "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,17 @@
 # @badaitech/badai-api
 
+## 0.5.5-dev.22
+
+### Patch Changes
+
+- feat: enhance edge connection handling with parallel execution and improved error logging
+
+## 0.5.5-dev.21
+
+### Patch Changes
+
+- feat: extend ClipboardDataSchema to support legacy SerializedNodeSchemaV1
+
 ## 0.5.5-dev.20
 
 ### 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.20",
+  "version": "0.5.5-dev.22",
   "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.20",
+  "version": "0.5.5-dev.22",
   "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,21 @@
 # @badaitech/chaingraph-nodes
 
+## 0.5.5-dev.22
+
+### Patch Changes
+
+- feat: enhance edge connection handling with parallel execution and improved error logging
+- Updated dependencies
+  - @badaitech/chaingraph-types@0.5.5-dev.22
+
+## 0.5.5-dev.21
+
+### Patch Changes
+
+- feat: extend ClipboardDataSchema to support legacy SerializedNodeSchemaV1
+- Updated dependencies
+  - @badaitech/chaingraph-types@0.5.5-dev.21
+
 ## 0.5.5-dev.20
 
 ### 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.20",
+  "version": "0.5.5-dev.22",
   "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,17 @@
 # @badaitech/chaingraph-trpc
 
+## 0.5.5-dev.22
+
+### Patch Changes
+
+- feat: enhance edge connection handling with parallel execution and improved error logging
+
+## 0.5.5-dev.21
+
+### Patch Changes
+
+- feat: extend ClipboardDataSchema to support legacy SerializedNodeSchemaV1
+
 ## 0.5.5-dev.20
 
 ### 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.20",
+  "version": "0.5.5-dev.22",
   "private": false,
   "description": "tRPC client and server for the Chaingraph V2",
   "license": "BUSL-1.1",
diff --git a/packages/chaingraph-trpc/server/procedures/flow/paste-nodes.ts b/packages/chaingraph-trpc/server/procedures/flow/paste-nodes.ts
@@ -12,6 +12,9 @@ import type {
   IPort,
   SerializedEdge,
 } from '@badaitech/chaingraph-types'
+import {
+  SerializedNodeSchemaV1Legacy,
+} from '@badaitech/chaingraph-types'
 import {
   isObjectPortConfig,
 } from '@badaitech/chaingraph-types'
@@ -27,7 +30,7 @@ const PositionSchema = z.object({
 })
 
 const ClipboardDataSchema = z.object({
-  nodes: z.array(SerializedNodeSchema),
+  nodes: z.array(z.union([SerializedNodeSchema, SerializedNodeSchemaV1Legacy])),
   edges: z.array(SerializedEdgeSchema),
   timestamp: z.number().optional().default(() => Date.now()),
 })
@@ -182,55 +185,81 @@ export const pasteNodes = flowContextProcedure
         }
       }
 
-      const addedNodes = flow.addNodes(createdNodes)
+      const addedNodes = await flow.addNodes(createdNodes)
 
       // Step 2: Recreate edges using new IDs
       const createdEdges: SerializedEdge[] = []
 
-      for (const edgeData of clipboardData.edges) {
-        try {
+      // Prepare edge connection data with validated IDs
+      const edgeConnectionTasks = clipboardData.edges
+        .map((edgeData) => {
           const newSourceNodeId = nodeIdMapping.get(edgeData.sourceNodeId)
           const newTargetNodeId = nodeIdMapping.get(edgeData.targetNodeId)
           const newSourcePortId = portIdMapping.get(edgeData.sourcePortId)
           const newTargetPortId = portIdMapping.get(edgeData.targetPortId)
 
           if (!newSourceNodeId || !newTargetNodeId || !newSourcePortId || !newTargetPortId) {
-            continue
+            return null
           }
 
-          // Connect ports using flow's built-in method
-          const edge = await flow.connectPorts(newSourceNodeId, newSourcePortId, newTargetNodeId, newTargetPortId)
-
-          if (!edge) {
-            console.warn(`[FLOW] Failed to connect ports for edge ${edgeData.id}`)
-            continue
+          return {
+            originalEdgeData: edgeData,
+            newSourceNodeId,
+            newTargetNodeId,
+            newSourcePortId,
+            newTargetPortId,
           }
+        })
+        .filter((task): task is NonNullable<typeof task> => task !== null)
+
+      // Execute all edge connections in parallel
+      const edgeConnectionResults = await Promise.allSettled(
+        edgeConnectionTasks.map(async task => ({
+          task,
+          edge: await flow.connectPorts(
+            task.newSourceNodeId,
+            task.newSourcePortId,
+            task.newTargetNodeId,
+            task.newTargetPortId,
+          ),
+        })),
+      )
 
-          // Set edge metadata if provided
-          if (edgeData.metadata) {
-            if (edgeData.metadata.label && typeof edgeData.metadata.label === 'string') {
-              edge.metadata.label = edgeData.metadata.label
-            }
-            if (edgeData.metadata.description) {
-              edge.metadata.description = edgeData.metadata.description
-            }
-          }
+      // Process results and update metadata
+      for (const result of edgeConnectionResults) {
+        if (result.status === 'rejected') {
+          console.error('[FLOW] Failed to create edge:', result.reason)
+          continue
+        }
 
-          createdEdges.push({
-            id: edge.id,
-            metadata: edge.metadata,
-            status: edge.status,
-            sourceNodeId: newSourceNodeId,
-            sourcePortId: newSourcePortId,
-            targetNodeId: newTargetNodeId,
-            targetPortId: newTargetPortId,
-          })
+        const { task, edge } = result.value
 
-          console.debug(`[FLOW] Created edge ${edge.id}`)
-        } catch (error) {
-          console.error(`[FLOW] Failed to create edge ${edgeData.id}:`, error)
-          // Continue with other edges rather than failing the entire operation
+        if (!edge) {
+          console.warn(`[FLOW] Failed to connect ports for edge ${task.originalEdgeData.id}`)
+          continue
+        }
+
+        // Set edge metadata if provided
+        if (task.originalEdgeData.metadata) {
+          if (task.originalEdgeData.metadata.label && typeof task.originalEdgeData.metadata.label === 'string') {
+            edge.metadata.label = task.originalEdgeData.metadata.label
+          }
+          if (task.originalEdgeData.metadata.description) {
+            edge.metadata.description = task.originalEdgeData.metadata.description
+          }
         }
+
+        createdEdges.push({
+          id: edge.id,
+          metadata: edge.metadata,
+          status: edge.status,
+          sourceNodeId: task.newSourceNodeId,
+          sourcePortId: task.newSourcePortId,
+          targetNodeId: task.newTargetNodeId,
+          targetPortId: task.newTargetPortId,
+        })
+
+        console.debug(`[FLOW] Created edge ${edge.id}`)
       }
 
       // Save the updated flow
diff --git a/packages/chaingraph-types/CHANGELOG.md b/packages/chaingraph-types/CHANGELOG.md
diff --git a/packages/chaingraph-types/package.json b/packages/chaingraph-types/package.json
diff --git a/packages/typescript-config/CHANGELOG.md b/packages/typescript-config/CHANGELOG.md
diff --git a/packages/typescript-config/package.json b/packages/typescript-config/package.json
diff --git a/pnpm-lock.yaml b/pnpm-lock.yaml

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.20",`
	`4`	`+ "version": "0.5.5-dev.22",`
`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.20",`
	`4`	`+ "version": "0.5.5-dev.22",`
`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.20",`
	`4`	`+ "version": "0.5.5-dev.22",`
`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.20",`
	`4`	`+ "version": "0.5.5-dev.22",`
`5`	`5`	`"private": true,`
`6`	`6`	`"description": "Bad AI GraphQL API client example",`
`7`	`7`	`"license": "BUSL-1.1",`