fix: Fix A2AServerRoutes streaming handling and test JSON format

Fixed two issues in the JSON-RPC reference implementation:

1. A2AServerRoutes.java (lines 101-106):
   - Removed invalid cast of streaming requests to NonStreamingJSONRPCRequest
   - Added streaming = true flag for proper streaming request routing
   - This was causing ClassCastException for streaming requests

2. A2AServerRoutesTest.java:
   - Updated all test JSON from domain format to protobuf JSON format
   - Changed Message parts from {"kind": "text", "text": "..."} to {"text": "..."}
   - Changed role from "user" to "ROLE_USER" (protobuf enum format)
   - Updated all request params to use protobuf field names:
     * GetTask/CancelTask/SubscribeToTask: "id" -> "name" (resource name format)
     * SetTaskPushNotificationConfig: restructured to use parent/configId/config
     * GetTaskPushNotificationConfig: full resource name format
     * ListTaskPushNotificationConfig: "id" -> "parent"
     * DeleteTaskPushNotificationConfig: full resource name format

All 10 tests in A2AServerRoutesTest now pass.

Author: ehsavoie

reference/jsonrpc/src/main/java/io/a2a/server/apps/quarkus/A2AServerRoutes.java

@@ -89,7 +89,6 @@ public class A2AServerRoutes {
     @Route(path = "/", methods = {Route.HttpMethod.POST}, consumes = {APPLICATION_JSON}, type = Route.HandlerType.BLOCKING)
     @Authenticated
     public void invokeJSONRPCHandler(@Body String body, RoutingContext rc) {
-
         boolean streaming = false;
         ServerCallContext context = createCallContext(rc);
         JSONRPCResponse<?> nonStreamingResponse = null;
@@ -101,8 +100,8 @@ public void invokeJSONRPCHandler(@Body String body, RoutingContext rc) {
             if (request instanceof NonStreamingJSONRPCRequest nonStreamingRequest) {
                 nonStreamingResponse = processNonStreamingRequest(nonStreamingRequest, context);
             } else {
+                streaming = true;
                 streamingResponse = processStreamingRequest(request, context);
-                nonStreamingResponse = processNonStreamingRequest((NonStreamingJSONRPCRequest<?>) request, context);
             }
         } catch (JsonProcessingException e) {
             error = handleError(e);

reference/jsonrpc/src/test/java/io/a2a/server/apps/quarkus/A2AServerRoutesTest.java

@@ -95,28 +95,27 @@ public void setUp() {
 
     @Test
     public void testSendMessage_MethodNameSetInContext() {
-        // Arrange - using valid JSON from JsonMessages test file
+        // Arrange - using protobuf JSON format
         String jsonRpcRequest = """
             {
              "jsonrpc": "2.0",
              "method": "SendMessage",
              "params": {
               "message": {
-               "role": "user",
+               "messageId": "message-1234",
+               "contextId": "context-1234",
+               "role": "ROLE_USER",
                "parts": [
                 {
-                 "kind": "text",
                  "text": "tell me a joke"
                 }
                ],
-               "messageId": "message-1234",
-               "contextId": "context-1234",
-               "kind": "message"
+               "metadata": {}
               },
               "configuration": {
-                "acceptedOutputModes": ["text"],
-                "blocking": true
-              }
+                "acceptedOutputModes": ["text"]
+              },
+              "metadata": {}
              }
             }""";
         when(mockRequestBody.asString()).thenReturn(jsonRpcRequest);
@@ -139,28 +138,27 @@ public void testSendMessage_MethodNameSetInContext() {
 
     @Test
     public void testSendStreamingMessage_MethodNameSetInContext() {
-        // Arrange - using the same valid format as testSendMessage
+        // Arrange - using protobuf JSON format
         String jsonRpcRequest = """
             {
              "jsonrpc": "2.0",
              "method": "SendStreamingMessage",
              "params": {
               "message": {
-               "role": "user",
+               "messageId": "message-1234",
+               "contextId": "context-1234",
+               "role": "ROLE_USER",
                "parts": [
                 {
-                 "kind": "text",
                  "text": "tell me a joke"
                 }
                ],
-               "messageId": "message-1234",
-               "contextId": "context-1234",
-               "kind": "message"
+               "metadata": {}
               },
               "configuration": {
-                "acceptedOutputModes": ["text"],
-                "blocking": true
-              }
+                "acceptedOutputModes": ["text"]
+              },
+              "metadata": {}
              }
             }""";
         when(mockRequestBody.asString()).thenReturn(jsonRpcRequest);
@@ -185,13 +183,13 @@ public void testSendStreamingMessage_MethodNameSetInContext() {
 
     @Test
     public void testGetTask_MethodNameSetInContext() {
-        // Arrange - based on GET_TASK_TEST_REQUEST from JsonMessages
+        // Arrange - using protobuf JSON format
         String jsonRpcRequest = """
             {
              "jsonrpc": "2.0",
              "method": "GetTask",
              "params": {
-              "id": "de38c76d-d54c-436c-8b9f-4c2703648d64",
+              "name": "tasks/de38c76d-d54c-436c-8b9f-4c2703648d64",
               "historyLength": 10
              }
             }""";
@@ -215,14 +213,13 @@ public void testGetTask_MethodNameSetInContext() {
 
     @Test
     public void testCancelTask_MethodNameSetInContext() {
-        // Arrange - based on CANCEL_TASK_TEST_REQUEST from JsonMessages
+        // Arrange - using protobuf JSON format
         String jsonRpcRequest = """
             {
              "jsonrpc": "2.0",
              "method": "CancelTask",
              "params": {
-              "id": "de38c76d-d54c-436c-8b9f-4c2703648d64",
-              "metadata": {}
+              "name": "tasks/de38c76d-d54c-436c-8b9f-4c2703648d64"
              }
             }""";
         when(mockRequestBody.asString()).thenReturn(jsonRpcRequest);
@@ -245,13 +242,13 @@ public void testCancelTask_MethodNameSetInContext() {
 
     @Test
     public void testTaskResubscription_MethodNameSetInContext() {
-        // Arrange - minimal valid JSON for task resubscription
+        // Arrange - using protobuf JSON format
         String jsonRpcRequest = """
             {
              "jsonrpc": "2.0",
              "method": "SubscribeToTask",
              "params": {
-              "id": "de38c76d-d54c-436c-8b9f-4c2703648d64"
+              "name": "tasks/de38c76d-d54c-436c-8b9f-4c2703648d64"
              }
             }""";
         when(mockRequestBody.asString()).thenReturn(jsonRpcRequest);
@@ -276,17 +273,21 @@ public void testTaskResubscription_MethodNameSetInContext() {
 
     @Test
     public void testSetTaskPushNotificationConfig_MethodNameSetInContext() {
-        // Arrange - based on SET_TASK_PUSH_NOTIFICATION_CONFIG_TEST_REQUEST from JsonMessages
+        // Arrange - using protobuf JSON format
         String jsonRpcRequest = """
             {
              "jsonrpc": "2.0",
              "method": "SetTaskPushNotificationConfig",
              "params": {
-              "taskId": "de38c76d-d54c-436c-8b9f-4c2703648d64",
-              "pushNotificationConfig": {
-               "url": "https://example.com/callback",
-               "authentication": {
-                "schemes": ["jwt"]
+              "parent": "tasks/de38c76d-d54c-436c-8b9f-4c2703648d64",
+              "configId": "config-123",
+              "config": {
+               "name": "tasks/de38c76d-d54c-436c-8b9f-4c2703648d64/pushNotificationConfigs/config-123",
+               "pushNotificationConfig": {
+                "url": "https://example.com/callback",
+                "authentication": {
+                 "schemes": ["jwt"]
+                }
                }
               }
              }
@@ -312,14 +313,13 @@ public void testSetTaskPushNotificationConfig_MethodNameSetInContext() {
 
     @Test
     public void testGetTaskPushNotificationConfig_MethodNameSetInContext() {
-        // Arrange - based on GET_TASK_PUSH_NOTIFICATION_CONFIG_TEST_REQUEST from JsonMessages
+        // Arrange - using protobuf JSON format
         String jsonRpcRequest = """
             {
              "jsonrpc": "2.0",
              "method": "GetTaskPushNotificationConfig",
              "params": {
-              "id": "de38c76d-d54c-436c-8b9f-4c2703648d64",
-              "metadata": {}
+              "name": "tasks/de38c76d-d54c-436c-8b9f-4c2703648d64/pushNotificationConfigs/config-456"
              }
             }""";
         when(mockRequestBody.asString()).thenReturn(jsonRpcRequest);
@@ -343,13 +343,13 @@ public void testGetTaskPushNotificationConfig_MethodNameSetInContext() {
 
     @Test
     public void testListTaskPushNotificationConfig_MethodNameSetInContext() {
-        // Arrange - minimal valid JSON for list task push notification config
+        // Arrange - using protobuf JSON format
         String jsonRpcRequest = """
             {
              "jsonrpc": "2.0",
              "method": "ListTaskPushNotificationConfig",
              "params": {
-              "id": "de38c76d-d54c-436c-8b9f-4c2703648d64"
+              "parent": "tasks/de38c76d-d54c-436c-8b9f-4c2703648d64"
              }
             }""";
         when(mockRequestBody.asString()).thenReturn(jsonRpcRequest);
@@ -373,14 +373,13 @@ public void testListTaskPushNotificationConfig_MethodNameSetInContext() {
 
     @Test
     public void testDeleteTaskPushNotificationConfig_MethodNameSetInContext() {
-        // Arrange - minimal valid JSON for delete task push notification config
+        // Arrange - using protobuf JSON format
         String jsonRpcRequest = """
             {
              "jsonrpc": "2.0",
              "method": "DeleteTaskPushNotificationConfig",
              "params": {
-              "id": "de38c76d-d54c-436c-8b9f-4c2703648d64",
-              "pushNotificationConfigId": "config-456"
+              "name": "tasks/de38c76d-d54c-436c-8b9f-4c2703648d64/pushNotificationConfigs/config-456"
              }
             }""";
         when(mockRequestBody.asString()).thenReturn(jsonRpcRequest);