Merge branch 'ag-ui-protocol:main' into kotlinsdk

Author: contextablemark

.gitignore

@@ -1,3 +1,5 @@
 **/.claude/settings.local.json
 .vscode/
 .idea/
+
+.DS_Store

docs/development/contributing.mdx

@@ -14,4 +14,4 @@ contributor use the `community` prefix, i.e.
 (`typescript-sdk/integrations/community-your-integration`).
 
 For questions and discussions, please use
-[GitHub Discussions](https://github.com/orgs/ag-ui-protocol/discussions).
+[GitHub Discussions](https://github.com/ag-ui-protocol/ag-ui/discussions).

typescript-sdk/apps/dojo/e2e/tests/copilotkit-home.spec.ts

@@ -1,7 +1,7 @@
 {
   "name": "@ag-ui/a2a-middleware",
   "author": "Markus Ecker <[email protected]>",
-  "version": "0.0.1",
+  "version": "0.0.2",
   "main": "./dist/index.js",
   "module": "./dist/index.mjs",
   "types": "./dist/index.d.ts",
@@ -20,14 +20,15 @@
   },
   "dependencies": {
     "@a2a-js/sdk": "^0.2.2",
-    "@ag-ui/client": "workspace:*",
+    "@ag-ui/client": ">=0.0.40",
     "ai": "^4.3.16",
     "zod": "^3.22.4"
   },
   "peerDependencies": {
     "rxjs": "7.8.1"
   },
   "devDependencies": {
+    "@ag-ui/client": "workspace:*",
     "@types/jest": "^29.5.14",
     "@types/node": "^20.11.19",
     "jest": "^29.7.0",

typescript-sdk/apps/dojo/e2e/tests/integration/ai-features.spec.ts

@@ -20,7 +20,6 @@ import { AgentCard, SendMessageResponse, SendMessageSuccessResponse } from "@a2a
 import { Observable, Subscriber, tap } from "rxjs";
 import { createSystemPrompt, sendMessageToA2AAgentTool } from "./utils";
 import { randomUUID } from "crypto";
-import { text } from "stream/consumers";
 
 export interface A2AAgentConfig extends AgentConfig {
   agentUrls: string[];
@@ -129,6 +128,9 @@ export class A2AMiddlewareAgent extends AbstractAgent {
             this.finishTextMessages(observer, pendingTextMessages);
 
             if (pendingA2ACalls.size > 0) {
+              // Array to collect all new tool result messages
+              const newToolMessages: Message[] = [];
+
               const callProms = [...pendingA2ACalls].map((toolCallId) => {
                 const toolCallsFromMessages = this.messages
                   .filter((message) => message.role === "assistant")
@@ -160,6 +162,9 @@ export class A2AMiddlewareAgent extends AbstractAgent {
                     this.addMessage(newMessage);
                     this.orchestrationAgent.addMessage(newMessage);
 
+                    // Collect the message so we can add it to input.messages
+                    newToolMessages.push(newMessage);
+
                     const newEvent: ToolCallResultEvent = {
                       type: EventType.TOOL_CALL_RESULT,
                       toolCallId: toolCallId,
@@ -184,6 +189,12 @@ export class A2AMiddlewareAgent extends AbstractAgent {
                   runId: input.runId,
                 } as RunFinishedEvent);
 
+                // Add all tool result messages to input.messages BEFORE triggering new run
+                // This ensures the orchestrator sees the tool results in its context
+                newToolMessages.forEach((msg) => {
+                  input.messages.push(msg);
+                });
+
                 this.triggerNewRun(observer, input, pendingA2ACalls, pendingTextMessages);
               });
             } else {

typescript-sdk/apps/dojo/e2e/tests/smoke-only/basic-loading.spec.ts

@@ -651,7 +651,13 @@ async def _handle_single_event(self, event: Any, state: State) -> AsyncGenerator
                     )
                 )
                 yield self._dispatch_event(
-                    ToolCallArgsEvent(type=EventType.TOOL_CALL_ARGS, tool_call_id=event["data"]["id"], delta=event["data"]["args"], raw_event=event)
+                    ToolCallArgsEvent(
+                        type=EventType.TOOL_CALL_ARGS,
+                        tool_call_id=event["data"]["id"],
+                        delta=event["data"]["args"] if isinstance(event["data"]["args"], str) else json.dumps(
+                            event["data"]["args"]),
+                        raw_event=event
+                    )
                 )
                 yield self._dispatch_event(
                     ToolCallEndEvent(type=EventType.TOOL_CALL_END, tool_call_id=event["data"]["id"], raw_event=event)

typescript-sdk/apps/dojo/e2e/tests/vercelAISdkTests/agenticChatPage.spec.ts

@@ -1,6 +1,6 @@
 [tool.poetry]
 name = "ag-ui-langgraph"
-version = "0.0.14"
+version = "0.0.15"
 description = "Implementation of the AG-UI protocol for LangGraph."
 authors = ["Ran Shem Tov <[email protected]>"]
 readme = "README.md"