fix(client): update rest transport URL construction and integration tests

Signed-off-by: Luca Muscariello <muscariello@ieee.org>

Author: muscariello

src/a2a/client/transports/rest.py

@@ -339,7 +339,7 @@ async def subscribe(
         async with aconnect_sse(
             self.httpx_client,
             'GET',
-            f'{self.url}/v1/{request.id}:subscribe',
+            f'{self.url}/v1/tasks/{request.id}:subscribe',
             **modified_kwargs,
         ) as event_source:
             try:

tests/integration/test_client_server_integration.py

@@ -491,7 +491,7 @@ def channel_factory(address: str) -> Channel:
     transport = GrpcTransport(channel=channel, agent_card=agent_card)
 
     # Use CancelTaskRequest with name (AIP resource format)
-    params = CancelTaskRequest(id=CANCEL_TASK_RESPONSE.id)
+    params = CancelTaskRequest(id=f'tasks/{CANCEL_TASK_RESPONSE.id}')
     result = await transport.cancel_task(request=params)
 
     assert result.id == CANCEL_TASK_RESPONSE.id
@@ -556,7 +556,7 @@ def channel_factory(address: str) -> Channel:
 
     # Create CreateTaskPushNotificationConfigRequest with required fields
     params = CreateTaskPushNotificationConfigRequest(
-        task_id='task-callback-123',
+        task_id='tasks/task-callback-123',
         config_id='pnc-abc',
         config=CALLBACK_CONFIG.push_notification_config,
     )
@@ -631,7 +631,7 @@ def channel_factory(address: str) -> Channel:
 
     # Use GetTaskPushNotificationConfigRequest with name field (resource name)
     params = GetTaskPushNotificationConfigRequest(
-        task_id=CALLBACK_CONFIG.task_id, id=CALLBACK_CONFIG.id
+        task_id=f'tasks/{CALLBACK_CONFIG.task_id}', id=CALLBACK_CONFIG.id
     )
     result = await transport.get_task_callback(request=params)
 
@@ -668,7 +668,7 @@ async def test_http_transport_resubscribe(
     handler = transport_setup.handler
 
     # Use SubscribeToTaskRequest with name (AIP resource format)
-    params = SubscribeToTaskRequest(id=f'tasks/{RESUBSCRIBE_EVENT.task_id}')
+    params = SubscribeToTaskRequest(id=RESUBSCRIBE_EVENT.task_id)
     stream = transport.subscribe(request=params)
     first_event = await anext(stream)