refactor: Update to Protocol V1 and fix all tests

Author: muscariello

.github/actions/spelling/allow.txt

@@ -1,53 +1,29 @@
+a2a
 A2A
 A2AFastAPI
 AAgent
-ACMRTUXB
 ACard
 AClient
+ACMRTUXB
+aconnect
+adk
 AError
 AException
 AFast
+agentic
 AGrpc
+aio
+aiomysql
+alg
+amannn
+aproject
 ARequest
 ARun
 AServer
 AServers
 AService
 AStarlette
 AUser
-DSNs
-ES256
-EUR
-FastAPI
-GBP
-GVsb
-HS256
-HS384
-INR
-JOSE
-JPY
-JSONRPC
-JSONRPCt
-JWS
-Llm
-OpenAPI
-POSTGRES
-Protobuf
-RS256
-RUF
-SECP256R1
-SLF
-Starlette
-Tful
-a2a
-aconnect
-adk
-agentic
-aio
-aiomysql
-alg
-amannn
-aproject
 autouse
 backticks
 base64url
@@ -60,46 +36,64 @@ coro
 datamodel
 deepwiki
 drivername
+DSNs
 dunders
+ES256
 euo
+EUR
 excinfo
+FastAPI
 fernet
 fetchrow
 fetchval
+GBP
 genai
 getkwargs
 gle
+GVsb
 hazmat
+HS256
+HS384
 ietf
 importlib
 initdb
 inmemory
+INR
 isready
 jku
+JOSE
+JPY
+JSONRPC
+JSONRPCt
 jwk
 jwks
 jws
+JWS
 kid
 kwarg
 langgraph
 lifecycles
 linting
+Llm
 lstrips
 middleware
 mikeas
 mockurl
 notif
 oauthoidc
 oidc
+OpenAPI
 openapiv
 openapiv2
 opensource
 otherurl
 pb2
 postgres
+POSTGRES
 postgresql
 proto
 protobuf
+Protobuf
 protoc
 pydantic
 pyi
@@ -109,13 +103,19 @@ pyversions
 redef
 respx
 resub
+RS256
+RUF
+SECP256R1
+SLF
 socio
 sse
 starlette
+Starlette
 swagger
 tagwords
 taskupdate
 testuuid
+Tful
 tiangolo
 typ
 typeerror

.github/workflows/linter.yaml

@@ -2,7 +2,7 @@
 name: Lint Code Base
 on:
   pull_request:
-    branches: [main]
+    branches: [main, 1.0-a2a_proto_refactor]
 permissions:
   contents: read
 jobs:

.github/workflows/unit-tests.yml

@@ -2,7 +2,7 @@
 name: Run Unit Tests
 on:
   pull_request:
-    branches: [main]
+    branches: [main, 1.0-a2a_proto_refactor]
 permissions:
   contents: read
 jobs:
@@ -36,7 +36,7 @@ jobs:
 
     strategy:
       matrix:
-        python-version: ['3.10', '3.13']
+        python-version: ["3.10", "3.13"]
     steps:
       - name: Checkout code
         uses: actions/checkout@v6

buf.gen.yaml

@@ -3,7 +3,7 @@ version: v2
 inputs:
   - git_repo: https://github.com/a2aproject/A2A.git
     ref: main
-    subdir: specification/grpc
+    subdir: specification
 managed:
   enabled: true
 # Python Generation

src/a2a/client/auth/interceptor.py

@@ -31,12 +31,12 @@ async def intercept(
         # We check for truthiness to see if they are non-empty.
         if (
             agent_card is None
-            or not agent_card.security
+            or not agent_card.security_requirements
             or not agent_card.security_schemes
         ):
             return request_payload, http_kwargs
 
-        for requirement in agent_card.security:
+        for requirement in agent_card.security_requirements:
             for scheme_name in requirement.schemes:
                 credential = await self._credential_service.get_credentials(
                     scheme_name, context

src/a2a/client/base_client.py

@@ -19,7 +19,7 @@
     Message,
     SendMessageConfiguration,
     SendMessageRequest,
-    SetTaskPushNotificationConfigRequest,
+    CreateTaskPushNotificationConfigRequest,
     StreamResponse,
     SubscribeToTaskRequest,
     Task,
@@ -180,7 +180,7 @@ async def cancel_task(
 
     async def set_task_callback(
         self,
-        request: SetTaskPushNotificationConfigRequest,
+        request: CreateTaskPushNotificationConfigRequest,
         *,
         context: ClientCallContext | None = None,
         extensions: list[str] | None = None,

src/a2a/client/client.py

@@ -16,7 +16,7 @@
     GetTaskRequest,
     Message,
     PushNotificationConfig,
-    SetTaskPushNotificationConfigRequest,
+    CreateTaskPushNotificationConfigRequest,
     StreamResponse,
     SubscribeToTaskRequest,
     Task,
@@ -147,7 +147,7 @@ async def cancel_task(
     @abstractmethod
     async def set_task_callback(
         self,
-        request: SetTaskPushNotificationConfigRequest,
+        request: CreateTaskPushNotificationConfigRequest,
         *,
         context: ClientCallContext | None = None,
         extensions: list[str] | None = None,

src/a2a/client/client_factory.py

@@ -282,5 +282,5 @@ def minimal_agent_card(
         skills=[],
         version='',
         name='',
-        protocol_versions=['v1'],
-    )
+
+        )

src/a2a/client/transports/base.py

@@ -9,7 +9,7 @@
     GetTaskRequest,
     SendMessageRequest,
     SendMessageResponse,
-    SetTaskPushNotificationConfigRequest,
+    CreateTaskPushNotificationConfigRequest,
     StreamResponse,
     SubscribeToTaskRequest,
     Task,
@@ -65,7 +65,7 @@ async def cancel_task(
     @abstractmethod
     async def set_task_callback(
         self,
-        request: SetTaskPushNotificationConfigRequest,
+        request: CreateTaskPushNotificationConfigRequest,
         *,
         context: ClientCallContext | None = None,
         extensions: list[str] | None = None,

src/a2a/client/transports/grpc.py

@@ -22,11 +22,11 @@
 from a2a.types.a2a_pb2 import (
     AgentCard,
     CancelTaskRequest,
+    CreateTaskPushNotificationConfigRequest,
     GetTaskPushNotificationConfigRequest,
     GetTaskRequest,
     SendMessageRequest,
     SendMessageResponse,
-    SetTaskPushNotificationConfigRequest,
     StreamResponse,
     SubscribeToTaskRequest,
     Task,
@@ -158,13 +158,13 @@ async def cancel_task(
 
     async def set_task_callback(
         self,
-        request: SetTaskPushNotificationConfigRequest,
+        request: CreateTaskPushNotificationConfigRequest,
         *,
         context: ClientCallContext | None = None,
         extensions: list[str] | None = None,
     ) -> TaskPushNotificationConfig:
         """Sets or updates the push notification configuration for a specific task."""
-        return await self.stub.SetTaskPushNotificationConfig(
+        return await self.stub.CreateTaskPushNotificationConfig(
             request,
             metadata=self._get_grpc_metadata(extensions),
         )