Merge pull request #313 from badaitech/feat/execution-context-detailed-debug

yakud · web-flow · commit 21b6590674b4 · 2025-09-22T19:02:32.000+03:00
feat: add integration details for ArchAI and Wallet in execution details view
diff --git a/.changeset/pre.json b/.changeset/pre.json
@@ -24,6 +24,7 @@
     "cold-turtles-laugh",
     "dirty-glasses-drop",
     "easy-candies-smile",
+    "empty-coats-care",
     "full-readers-itch",
     "hip-doors-notice",
     "hungry-words-hang",
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.24
+
+### Patch Changes
+
+- feat: add integration details for ArchAI and Wallet in execution details view
+
 ## 0.5.5-dev.23
 
 ### 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.23",
+  "version": "0.5.5-dev.24",
   "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.24
+
+### Patch Changes
+
+- feat: add integration details for ArchAI and Wallet in execution details view
+- Updated dependencies
+  - @badaitech/chaingraph-executor@0.5.5-dev.24
+  - @badaitech/chaingraph-trpc@0.5.5-dev.24
+  - @badaitech/chaingraph-types@0.5.5-dev.24
+
 ## 0.5.5-dev.23
 
 ### 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.23",
+  "version": "0.5.5-dev.24",
   "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.24
+
+### Patch Changes
+
+- feat: add integration details for ArchAI and Wallet in execution details view
+- Updated dependencies
+  - @badaitech/chaingraph-executor@0.5.5-dev.24
+  - @badaitech/chaingraph-nodes@0.5.5-dev.24
+  - @badaitech/chaingraph-trpc@0.5.5-dev.24
+  - @badaitech/chaingraph-types@0.5.5-dev.24
+
 ## 0.5.5-dev.23
 
 ### 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.23",
+  "version": "0.5.5-dev.24",
   "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.24
+
+### Patch Changes
+
+- feat: add integration details for ArchAI and Wallet in execution details view
+- Updated dependencies
+  - @badaitech/chaingraph-executor@0.5.5-dev.24
+  - @badaitech/badai-api@0.5.5-dev.24
+  - @badaitech/chaingraph-nodes@0.5.5-dev.24
+  - @badaitech/chaingraph-trpc@0.5.5-dev.24
+  - @badaitech/chaingraph-types@0.5.5-dev.24
+
 ## 0.5.5-dev.23
 
 ### 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.23",
+  "version": "0.5.5-dev.24",
   "private": false,
   "description": "Frontend application for the Chaingraph project",
   "license": "BUSL-1.1",
diff --git a/apps/chaingraph-frontend/src/components/sidebar/tabs/execution-tree/components/ExecutionDetails.tsx b/apps/chaingraph-frontend/src/components/sidebar/tabs/execution-tree/components/ExecutionDetails.tsx
@@ -7,7 +7,7 @@
  */
 
 import type { ExecutionTreeNode } from '@badaitech/chaingraph-executor/types'
-import { AlertCircle, Clock, Copy, ExternalLink, Hash, Layers, Zap } from 'lucide-react'
+import { AlertCircle, Bot, Clock, Copy, ExternalLink, Hash, Layers, Wallet, Zap } from 'lucide-react'
 import { Badge } from '@/components/ui/badge'
 import { Button } from '@/components/ui/button'
 import { Separator } from '@/components/ui/separator'
@@ -31,7 +31,6 @@ export function ExecutionDetails({ execution: node, onClose, className }: Execut
   const nodeId = node.id
   const parentId = node.parentId
   const rootId = execution.rootExecutionId
-  const level = node.level
 
   // Format timestamps
   const createdAt = execution.createdAt ? new Date(execution.createdAt) : undefined
@@ -177,6 +176,102 @@ export function ExecutionDetails({ execution: node, onClose, className }: Execut
         </>
       )}
 
+      {/* Integration Info */}
+      {execution.integration && (
+        <>
+          <Separator />
+          <div className="space-y-3">
+            {execution.integration?.archai && (
+              <div className="space-y-2">
+                <div className="flex items-center gap-2 text-sm font-medium">
+                  <Bot className="w-4 h-4 text-green-500" />
+                  <span>ArchAI Integration</span>
+                </div>
+                <div className="bg-muted/50 rounded-md p-3 space-y-2">
+                  {execution.integration.archai.agentID && (
+                    <div className="flex items-center justify-between text-sm">
+                      <span className="text-muted-foreground">Agent ID</span>
+                      <code className="font-mono text-xs bg-muted px-2 py-0.5 rounded">
+                        {execution.integration.archai.agentID}
+                      </code>
+                    </div>
+                  )}
+                  {execution.integration.archai.chatID && (
+                    <div className="flex items-center justify-between text-sm">
+                      <span className="text-muted-foreground">Chat ID</span>
+                      <code className="font-mono text-xs bg-muted px-2 py-0.5 rounded">
+                        {execution.integration.archai.chatID}
+                      </code>
+                    </div>
+                  )}
+                  {execution.integration.archai.messageID !== undefined && (
+                    <div className="flex items-center justify-between text-sm">
+                      <span className="text-muted-foreground">Message ID</span>
+                      <code className="font-mono text-xs bg-muted px-2 py-0.5 rounded">
+                        {execution.integration.archai.messageID}
+                      </code>
+                    </div>
+                  )}
+                  {!execution.integration.archai.agentID && !execution.integration.archai.chatID && !execution.integration.archai.messageID && (
+                    <div className="text-sm text-muted-foreground">No context available</div>
+                  )}
+                </div>
+              </div>
+            )}
+
+            {execution.integration?.wallet && (
+              <div className="space-y-2">
+                <div className="flex items-center gap-2 text-sm font-medium">
+                  <Wallet className="w-4 h-4 text-purple-500" />
+                  <span>Wallet Integration</span>
+                  {execution.integration.wallet.isConnected && (
+                    <Badge variant="outline" className="text-xs">
+                      Connected
+                    </Badge>
+                  )}
+                </div>
+                <div className="bg-muted/50 rounded-md p-3 space-y-2">
+                  {execution.integration.wallet.address && (
+                    <div className="flex items-center justify-between text-sm">
+                      <span className="text-muted-foreground">Address</span>
+                      <div className="flex items-center gap-1">
+                        <code className="font-mono text-xs bg-muted px-2 py-0.5 rounded">
+                          {execution.integration.wallet.address.slice(0, 6)}
+                          ...
+                          {execution.integration.wallet.address.slice(-4)}
+                        </code>
+                        <Button
+                          variant="ghost"
+                          size="icon"
+                          className="h-6 w-6"
+                          onClick={() => copyToClipboard(execution.integration?.wallet?.address || '')}
+                        >
+                          <Copy className="h-3 w-3" />
+                        </Button>
+                      </div>
+                    </div>
+                  )}
+                  {execution.integration.wallet.chainId && (
+                    <div className="flex items-center justify-between text-sm">
+                      <span className="text-muted-foreground">Chain ID</span>
+                      <code className="font-mono text-xs bg-muted px-2 py-0.5 rounded">
+                        {execution.integration.wallet.chainId}
+                      </code>
+                    </div>
+                  )}
+                  <div className="flex items-center justify-between text-sm">
+                    <span className="text-muted-foreground">Status</span>
+                    <span className="text-xs">
+                      {execution.integration.wallet.isConnected ? 'Connected' : 'Disconnected'}
+                    </span>
+                  </div>
+                </div>
+              </div>
+            )}
+          </div>
+        </>
+      )}
+
       {/* Timestamps */}
       <Separator />
       <div className="space-y-2">
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.23",
+  "version": "0.5.5-dev.24",
   "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.24
+
+### Patch Changes
+
+- feat: add integration details for ArchAI and Wallet in execution details view
+
 ## 0.5.5-dev.23
 
 ### 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.23",
+  "version": "0.5.5-dev.24",
   "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.23",
+  "version": "0.5.5-dev.24",
   "private": false,
   "description": "Chaingraph Message Bus for inter-service communication",
   "license": "BUSL-1.1",
diff --git a/packages/chaingraph-executor/server/implementations/distributed/KafkaTaskQueue.ts b/packages/chaingraph-executor/server/implementations/distributed/KafkaTaskQueue.ts
@@ -43,7 +43,7 @@ export class KafkaTaskQueue implements ITaskQueue {
         value: safeSuperJSONStringify(task),
         timestamp: Date.now().toString(),
       }],
-      acks: 1, // Only wait for leader acknowledgment (faster)
+      acks: -1, // Only wait for leader acknowledgment (faster)
       timeout: 5000, // 5 second timeout for lower latency
       compression: 0, // No compression for lowest latency
     })
diff --git a/packages/chaingraph-executor/server/services/ExecutionService.ts b/packages/chaingraph-executor/server/services/ExecutionService.ts
@@ -140,6 +140,17 @@ export class ExecutionService implements IExecutionService {
       parentId: executionRow.parentExecutionId,
       rootId: executionRow.rootExecutionId,
       depth: currentDepth,
+      integration: {
+        ...(executionRow.integration?.archai
+          ? {
+              archai: {
+                agentID: executionRow.integration.archai.agentID,
+                chatID: executionRow.integration.archai.chatID,
+                messageID: executionRow.integration.archai.messageID,
+              },
+            }
+          : {}),
+      },
     }, 'Execution created')
 
     return instance
@@ -276,6 +287,24 @@ export class ExecutionService implements IExecutionService {
       maxRetries: parentInstance.task.maxRetries,
     }
 
+    logger.debug({
+      parentId: parentInstance.row.id,
+      childId: childExecutionId,
+      eventType: event.type,
+      flowId: parentInstance.flow.id,
+      integration: {
+        ...(childIntegrationContext.archai
+          ? {
+              archai: {
+                agentID: childIntegrationContext.archai.agentID,
+                chatID: childIntegrationContext.archai.chatID,
+                messageID: childIntegrationContext.archai.messageID,
+              },
+            }
+          : {}),
+      },
+    }, 'Child execution task publish prepared')
+
     // Publish task to queue (will be executed by worker)
     try {
       await this.taskQueue.publishTask(childTask)
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.24
+
+### Patch Changes
+
+- feat: add integration details for ArchAI and Wallet in execution details view
+- Updated dependencies
+  - @badaitech/chaingraph-types@0.5.5-dev.24
+
 ## 0.5.5-dev.23
 
 ### 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.23",
+  "version": "0.5.5-dev.24",
   "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.24
+
+### Patch Changes
+
+- feat: add integration details for ArchAI and Wallet in execution details view
+
 ## 0.5.5-dev.23
 
 ### 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.23",
+  "version": "0.5.5-dev.24",
   "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.24
+
+### Patch Changes
+
+- feat: add integration details for ArchAI and Wallet in execution details view
+
 ## 0.5.5-dev.23
 
 ### 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.23",
+  "version": "0.5.5-dev.24",
   "private": false,
   "description": "Core type definitions for the Chaingraph project",
   "license": "BUSL-1.1",
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.24
+
+### Patch Changes
+
+- feat: add integration details for ArchAI and Wallet in execution details view
+
 ## 0.5.5-dev.23
 
 ### Patch Changes
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.23",`
	`4`	`+ "version": "0.5.5-dev.24",`
`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.23",`
	`4`	`+ "version": "0.5.5-dev.24",`
`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.23",`
	`4`	`+ "version": "0.5.5-dev.24",`
`5`	`5`	`"private": false,`
`6`	`6`	`"description": "Frontend application for the Chaingraph project",`
`7`	`7`	`"license": "BUSL-1.1",`