wip

guglielmo-san · Jan 15, 2026 · Dec 16, 2025 · Dec 16, 2025 · Dec 17, 2025 · Dec 17, 2025
commit 8f549aead86b3ca27f5ae5f4311b0a3d7ea63f16
diff --git a/src/grpc/utils/proto_type_converter.ts b/src/grpc/utils/proto_type_converter.ts
@@ -43,14 +43,6 @@ import {
     TaskStatus,
     TaskStatusUpdateEvent,
 } from '../a2a.js';
-import { Struct } from '../google/protobuf/struct.js';
-import { ServerError, InvalidParamsError } from '../../server/errors.js';
-
-// Regexp patterns for matching
-const _TASK_NAME_MATCH = /tasks\/([^/]+)/;
-const _TASK_PUSH_CONFIG_NAME_MATCH = /tasks\/([^/]+)\/pushNotificationConfigs\/([^/]+)/;
-
-
 /**
  * Converts proto types to internal types.
  */
@@ -59,12 +51,12 @@ export class FromProto {
         return {
             kind: 'message',
             messageId: message.messageId,
-            parts: message.parts.map(p => this.part(p)),
+            parts: message.parts.map(p => this.parts(p)),
             contextId: message.contextId || null,
             taskId: message.taskId || null,
-            role: this.role(message.role),
+            role: message.role === Role.ROLE_AGENT ? "agent" : "user",
             metadata: message.metadata,
-            extensions: message.extensions.length > 0 ? messages.extensions : null,
+            extensions: message.extensions.length > 0 ? message.extensions : null,
         };
     }
 
@@ -116,9 +108,9 @@ export class FromProto {
             throw new Error("SendMessageRequest is missing 'request' field.");
         }
         return {
-            configuration: this.messageSendConfiguration(request.configuration),
+            configuration: request.configuration,
             message: this.message(request.request),
-            metadata: this.metadata(request.metadata),
+            metadata: request.metadata,
         };
     }
 }
diff --git a/src/samples/agents/sample-agent/client.ts b/src/samples/agents/sample-agent/client.ts
@@ -0,0 +1,44 @@
+import { ServiceError, credentials } from "@grpc/grpc-js";
+import { A2AServiceClient, SendMessageRequest, Role, SendMessageResponse} from "../../../grpc/a2a.js";
+
+const client = new A2AServiceClient(
+  "localhost:8080",
+  credentials.createInsecure()
+);
+
+function sendMessageExample() {
+  const request: SendMessageRequest = {
+    tenant: "sample-tenant",
+    configuration: {
+        blocking: true,
+        acceptedOutputModes: ["text"],
+        pushNotificationConfig: undefined,
+    },
+    metadata: {},
+    request: {
+      messageId: "msg-1",
+      parts: [
+        {
+          part: { $case: "text", value: "Hello, Agent!" },
+          metadata: {},
+        },
+      ],
+      role: Role.ROLE_USER,
+      contextId: "context-1",
+        taskId: undefined,
+        metadata: {},
+        extensions: [],
+        referenceTaskIds: [],
+    },
+  };
+
+  client.sendMessage(request, (error: ServiceError | null, response: SendMessageResponse) => {
+    if (error) {
+      console.error("Error sending message:", error);
+    } else {
+      console.log("Received response:", response);
+    }
+  });
+}
+
+sendMessageExample();
diff --git a/src/samples/agents/sample-agent/grpc.ts b/src/samples/agents/sample-agent/grpc.ts
@@ -0,0 +1,65 @@
+import * as grpc from '@grpc/grpc-js';
+import { AgentCard, AGENT_CARD_PATH } from '../../../index.js';
+import {
+  InMemoryTaskStore,
+  TaskStore,
+  AgentExecutor,
+  DefaultRequestHandler,
+} from '../../../server/index.js';
+import { agentCardHandler, jsonRpcHandler, UserBuilder } from '../../../server/express/index.js';
+import { SampleAgentExecutor } from './agent_executor.js';
+import { A2AServiceService } from '../../../grpc/a2a.js';
+import { createGRPCHandler } from '../../../server/transports/grpc/grpc_transport_handler.js';
+
+// --- Server Setup ---
+
+const sampleAgentCard: AgentCard = {
+  name: 'Sample Agent',
+  description:
+    'A sample agent to test the stream functionality and simulate the flow of tasks statuses.',
+  url: 'http://localhost:41241/',
+  provider: {
+    organization: 'A2A Samples',
+    url: 'https://example.com/a2a-samples', // Added provider URL
+  },
+  version: '1.0.0', // Incremented version
+  protocolVersion: '0.3.0',
+  capabilities: {
+    streaming: true, // The new framework supports streaming
+    pushNotifications: false, // Assuming not implemented for this agent yet
+    stateTransitionHistory: true, // Agent uses history
+  },
+  defaultInputModes: ['text'],
+  defaultOutputModes: ['text', 'task-status'], // task-status is a common output mode
+  skills: [
+    {
+      id: 'sample_agent',
+      name: 'Sample Agent',
+      description: 'Simulate the general flow of a streaming agent.',
+      tags: ['sample'],
+      examples: ['hi', 'hello world', 'how are you', 'goodbye'],
+      inputModes: ['text'], // Explicitly defining for skill
+      outputModes: ['text', 'task-status'], // Explicitly defining for skill
+    },
+  ],
+  supportsAuthenticatedExtendedCard: false,
+};
+
+async function main() {
+  // 1. Create TaskStore
+  const taskStore: TaskStore = new InMemoryTaskStore();
+
+  // 2. Create AgentExecutor
+  const agentExecutor: AgentExecutor = new SampleAgentExecutor();
+
+  // 3. Create DefaultRequestHandler
+  const requestHandler = new DefaultRequestHandler(sampleAgentCard, taskStore, agentExecutor);
+
+  const server = new grpc.Server();
+  server.addService(A2AServiceService, createGRPCHandler(requestHandler));
+  server.bindAsync("localhost:8080", grpc.ServerCredentials.createInsecure(), () => {
+  console.log("Server running at http://localhost:8080");
+});
+}
+
+main().catch(console.error);