Merge pull request #351 from badaitech/feat/fix-number-default-value

yakud · web-flow · commit 5211114097a8 · 2025-10-06T12:56:31.000+03:00
fix: for the paste node trpc procedure emit the migrated nodes instead of original one. Add support for updating multiple nodes and introduce NodesUpdated event
diff --git a/.changeset/petite-emus-taste.md b/.changeset/petite-emus-taste.md
@@ -0,0 +1,15 @@
+---
+"@badaitech/chaingraph-execution-worker": patch
+"@badaitech/chaingraph-execution-api": patch
+"@badaitech/chaingraph-executor": patch
+"@badaitech/badai-api-example": patch
+"@badaitech/typescript-config": patch
+"@badaitech/chaingraph-nodes": patch
+"@badaitech/chaingraph-types": patch
+"@badaitech/chaingraph-frontend": patch
+"@badaitech/chaingraph-trpc": patch
+"@badaitech/chaingraph-backend": patch
+"@badaitech/badai-api": patch
+---
+
+fix: for the paste node trpc procedure emit the migrated nodes instead of original one. Add support for updating multiple nodes and introduce NodesUpdated event
diff --git a/.changeset/pre.json b/.changeset/pre.json
@@ -27,6 +27,7 @@
     "little-drinks-travel",
     "lovely-actors-film",
     "olive-ears-camp",
+    "petite-emus-taste",
     "real-nights-try",
     "stupid-carpets-wear",
     "tired-days-sleep"
diff --git a/apps/chaingraph-backend/CHANGELOG.md b/apps/chaingraph-backend/CHANGELOG.md
@@ -1,5 +1,15 @@
 # @badaitech/chaingraph-backend
 
+## 0.5.5-dev.44
+
+### Patch Changes
+
+- fix: for the paste node trpc procedure emit the migrated nodes instead of original one. Add support for updating multiple nodes and introduce NodesUpdated event
+- Updated dependencies
+  - @badaitech/chaingraph-nodes@0.5.5-dev.44
+  - @badaitech/chaingraph-types@0.5.5-dev.44
+  - @badaitech/chaingraph-trpc@0.5.5-dev.44
+
 ## 0.5.5-dev.43
 
 ### 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.43",
+  "version": "0.5.5-dev.44",
   "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.44
+
+### Patch Changes
+
+- fix: for the paste node trpc procedure emit the migrated nodes instead of original one. Add support for updating multiple nodes and introduce NodesUpdated event
+- Updated dependencies
+  - @badaitech/chaingraph-executor@0.5.5-dev.44
+  - @badaitech/chaingraph-types@0.5.5-dev.44
+  - @badaitech/chaingraph-trpc@0.5.5-dev.44
+
 ## 0.5.5-dev.43
 
 ### 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.43",
+  "version": "0.5.5-dev.44",
   "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.44
+
+### Patch Changes
+
+- fix: for the paste node trpc procedure emit the migrated nodes instead of original one. Add support for updating multiple nodes and introduce NodesUpdated event
+- Updated dependencies
+  - @badaitech/chaingraph-executor@0.5.5-dev.44
+  - @badaitech/chaingraph-nodes@0.5.5-dev.44
+  - @badaitech/chaingraph-types@0.5.5-dev.44
+  - @badaitech/chaingraph-trpc@0.5.5-dev.44
+
 ## 0.5.5-dev.43
 
 ### 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.43",
+  "version": "0.5.5-dev.44",
   "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.44
+
+### Patch Changes
+
+- fix: for the paste node trpc procedure emit the migrated nodes instead of original one. Add support for updating multiple nodes and introduce NodesUpdated event
+- Updated dependencies
+  - @badaitech/chaingraph-executor@0.5.5-dev.44
+  - @badaitech/chaingraph-nodes@0.5.5-dev.44
+  - @badaitech/chaingraph-types@0.5.5-dev.44
+  - @badaitech/chaingraph-trpc@0.5.5-dev.44
+  - @badaitech/badai-api@0.5.5-dev.44
+
 ## 0.5.5-dev.43
 
 ### 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.43",
+  "version": "0.5.5-dev.44",
   "private": false,
   "description": "Frontend application for the Chaingraph project",
   "license": "BUSL-1.1",
diff --git a/apps/chaingraph-frontend/src/store/flow/stores.ts b/apps/chaingraph-frontend/src/store/flow/stores.ts
@@ -51,6 +51,7 @@ import {
   removeNode,
   setNodeVersion,
   updateNode,
+  updateNodes,
   updateNodeUILocal,
 } from '../nodes/stores'
 import {
@@ -432,14 +433,11 @@ function createEventHandlers(flowId: string, nodes: Record<string, INode>): Flow
 
     [FlowEventType.NodeUpdated]: (data) => {
       const node = nodes[data.node.id]
-      if (!node) {
-        console.error(`[NodeUpdated] Node ${data.node.id} not found`)
-        return
-      }
-
-      if (data.node.getVersion() && data.node.getVersion() < node.getVersion()) {
-        // console.warn(`[NodeUpdated] Received outdated node update event for node ${data.node.id}`)
-        return
+      if (node) {
+        if (data.node.getVersion() && data.node.getVersion() < node.getVersion()) {
+          // console.warn(`[NodeUpdated] Received outdated node update event for node ${data.node.id}`)
+          return
+        }
       }
 
       // console.log(`[NodeUpdated] Updating node ${data.node.id} to version ${data.node.getVersion()}`)
@@ -448,6 +446,27 @@ function createEventHandlers(flowId: string, nodes: Record<string, INode>): Flow
       nodeUpdated(data.node.id)
     },
 
+    [FlowEventType.NodesUpdated]: (data) => {
+      const validNodes = data.nodes.filter((node) => {
+        const existingNode = nodes[node.id]
+        if (existingNode) {
+          if (node.getVersion() && node.getVersion() < existingNode.getVersion()) {
+            // console.warn(`[NodesUpdated] Skipping outdated node update event for node ${node.id}`)
+            return false
+          }
+        }
+        return true
+      })
+
+      if (validNodes.length === 0) {
+        return
+      }
+
+      // console.log(`[NodesUpdated] Updating nodes:`, validNodes.map(n => n.id).join(', '))
+      updateNodes(validNodes)
+      validNodes.forEach(node => nodeUpdated(node.id))
+    },
+
     [FlowEventType.NodeRemoved]: (data) => {
       removeNode(data.nodeId)
     },
diff --git a/apps/chaingraph-frontend/src/store/nodes/stores.ts b/apps/chaingraph-frontend/src/store/nodes/stores.ts
@@ -42,6 +42,7 @@ import { positionInterpolator } from './position-interpolation-advanced'
 export const addNode = nodesDomain.createEvent<INode>()
 export const addNodes = nodesDomain.createEvent<INode[]>()
 export const updateNode = nodesDomain.createEvent<INode>()
+export const updateNodes = nodesDomain.createEvent<INode[]>()
 export const removeNode = nodesDomain.createEvent<string>()
 export const setNodeMetadata = nodesDomain.createEvent<{ nodeId: string, metadata: NodeState['metadata'] }>()
 export const setNodeVersion = nodesDomain.createEvent<{ nodeId: string, version: number }>()
@@ -214,6 +215,16 @@ export const $nodes = nodesDomain.createStore<Record<string, INode>>({})
     return newState
   })
 
+  // Update nodes operation
+  .on(updateNodes, (state, nodes) => {
+    const newState = { ...state }
+    nodes.forEach((node) => {
+      newState[node.id] = node
+    })
+
+    return newState
+  })
+
   .on(updateNode, (state, node) => {
     return { ...state, [node.id]: node }
   })
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.43",
+  "version": "0.5.5-dev.44",
   "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.44
+
+### Patch Changes
+
+- fix: for the paste node trpc procedure emit the migrated nodes instead of original one. Add support for updating multiple nodes and introduce NodesUpdated event
+
 ## 0.5.5-dev.43
 
 ### 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.43",
+  "version": "0.5.5-dev.44",
   "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.43",
+  "version": "0.5.5-dev.44",
   "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,14 @@
 # @badaitech/chaingraph-nodes
 
+## 0.5.5-dev.44
+
+### Patch Changes
+
+- fix: for the paste node trpc procedure emit the migrated nodes instead of original one. Add support for updating multiple nodes and introduce NodesUpdated event
+- Updated dependencies
+  - @badaitech/chaingraph-types@0.5.5-dev.44
+  - @badaitech/badai-api@0.5.5-dev.44
+
 ## 0.5.5-dev.43
 
 ### 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.43",
+  "version": "0.5.5-dev.44",
   "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,15 @@
 # @badaitech/chaingraph-trpc
 
+## 0.5.5-dev.44
+
+### Patch Changes
+
+- fix: for the paste node trpc procedure emit the migrated nodes instead of original one. Add support for updating multiple nodes and introduce NodesUpdated event
+- Updated dependencies
+  - @badaitech/chaingraph-nodes@0.5.5-dev.44
+  - @badaitech/chaingraph-types@0.5.5-dev.44
+  - @badaitech/badai-api@0.5.5-dev.44
+
 ## 0.5.5-dev.43
 
 ### 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.43",
+  "version": "0.5.5-dev.44",
   "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
@@ -7,12 +7,14 @@
  */
 
 import type {
-  Flow,
   IEdge,
   INode,
   IPort,
   SerializedEdge,
 } from '@badaitech/chaingraph-types'
+import {
+  Flow,
+} from '@badaitech/chaingraph-types'
 import {
   FlowMigration,
 } from '@badaitech/chaingraph-types'
@@ -81,10 +83,12 @@ export const pasteNodes = flowContextProcedure
       throw new Error(`Flow ${flowId} not found`)
     }
 
+    const emptyFlow = new Flow()
+
     await ctx.flowStore.lockFlow(flowId)
 
     try {
-      flow.setIsDisabledPropagationEvents(true)
+      emptyFlow.setIsDisabledPropagationEvents(true)
 
       // Step 1: Clone nodes with new IDs using cloneWithNewId()
       const nodeIdMapping = new Map<string, string>()
@@ -192,7 +196,7 @@ export const pasteNodes = flowContextProcedure
         }
       }
 
-      const addedNodes = await flow.addNodes(createdNodes, false)
+      const addedNodes = await emptyFlow.addNodes(createdNodes, true)
 
       // Step 2: Recreate edges using new IDs
       const createdEdges: SerializedEdge[] = []
@@ -241,10 +245,13 @@ export const pasteNodes = flowContextProcedure
         })
         .filter((edge): edge is NonNullable<typeof edge> => edge !== null)
 
-      await flow.addEdges(edgesToAdd, false)
+      await emptyFlow.addEdges(edgesToAdd, true)
 
       // Force migrate flow to v2
-      FlowMigration.migrateFlowFromV1ToV2(flow)
+      const flowWithPastedNodes = FlowMigration.migrateFlowFromV1ToV2(emptyFlow)
+
+      await flow.addNodes(Array.from(flowWithPastedNodes.nodes.values()), false)
+      await flow.addEdges(Array.from(flowWithPastedNodes.edges.values()), false)
 
       // Save the updated flow
       await ctx.flowStore.updateFlow(flow as Flow)
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.44
+
+### Patch Changes
+
+- fix: for the paste node trpc procedure emit the migrated nodes instead of original one. Add support for updating multiple nodes and introduce NodesUpdated event
+
 ## 0.5.5-dev.43
 
 ### 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.43",
+  "version": "0.5.5-dev.44",
   "private": false,
   "description": "Core type definitions for the Chaingraph project",
   "license": "BUSL-1.1",
diff --git a/packages/chaingraph-types/src/flow/events.ts b/packages/chaingraph-types/src/flow/events.ts
@@ -25,6 +25,7 @@ export enum FlowEventType {
   NodesAdded = 'flow:nodes:added',
   NodeAdded = 'flow:node:added',
   NodeRemoved = 'flow:node:removed',
+  NodesUpdated = 'flow:nodes:updated',
   NodeUpdated = 'flow:node:updated',
   NodeParentUpdated = 'flow:node:parent-updated',
 
@@ -69,6 +70,11 @@ export interface NodeUpdatedEventData {
   node: INode
 }
 
+/** Data for NodesUpdated event */
+export interface NodesUpdatedEventData {
+  nodes: INode[]
+}
+
 /** Data for PortCreated event */
 export interface PortCreatedEventData {
   port: IPort
@@ -183,6 +189,7 @@ export interface EventDataMap {
   [FlowEventType.NodeAdded]: NodeAddedEventData
   [FlowEventType.NodeRemoved]: NodeRemovedEventData
   [FlowEventType.NodeUpdated]: NodeUpdatedEventData
+  [FlowEventType.NodesUpdated]: NodesUpdatedEventData
   [FlowEventType.PortCreated]: PortCreatedEventData
   [FlowEventType.PortRemoved]: PortRemovedEventData
   [FlowEventType.PortUpdated]: PortUpdatedEventData
diff --git a/packages/chaingraph-types/src/flow/flow.ts b/packages/chaingraph-types/src/flow/flow.ts
diff --git a/packages/chaingraph-types/src/flow/interface.ts b/packages/chaingraph-types/src/flow/interface.ts
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

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.43",`
	`4`	`+ "version": "0.5.5-dev.44",`
`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.43",`
	`4`	`+ "version": "0.5.5-dev.44",`
`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.43",`
	`4`	`+ "version": "0.5.5-dev.44",`
`5`	`5`	`"private": false,`
`6`	`6`	`"description": "Frontend application for the Chaingraph project",`
`7`	`7`	`"license": "BUSL-1.1",`