converted to json-rpc

app.py

@@ -19,7 +19,7 @@ def fetch_agent_card(url: str) -> dict:
         url = url[:-1]
     agent_card_url = f"{url}/.well-known/agent.json"
     try:
-        resp = requests.get(agent_card_url, timeout=5)
+        resp = requests.get(agent_card_url, timeout=15)
         resp.raise_for_status()
         agent_card = resp.json()
         return agent_card

requirements.txt

@@ -1,4 +1,4 @@
-gradio==5.29.1
+gradio==5.29
 requests
 pydantic==2.10.6
 google-genai==1.5.0

task_management.py

@@ -6,13 +6,17 @@ def send_task(server_url, task_id, thread, content):
         "jsonrpc": "2.0",
         "method": "tasks/send",
         "params": {
-            "id": task_id,
-            "thread": thread,
-            "content": content
+            "sessionId": thread,
+            "message": content
         },
         "id": task_id
     }
-    response = requests.post(server_url, json=payload)
+    #remove trailing slash if present
+    if server_url.endswith("/"):
+        server_url = server_url[:-1]
+    json_endpoint = f"{server_url}/jsonrpc"
+    response = requests.post(json_endpoint, json=payload)
+    response.raise_for_status()
     return response.json()
 
 def get_task_status(server_url, task_id):
@@ -58,22 +62,19 @@ def a2a_respond(user_message, history, server_url):
         return "", history
 
     session_id = str(uuid.uuid4())
-    request_body = {
-        "user_input": user_message,
-        "session_id": session_id
-    }
 
     history = history or []
     history.append({"role": "user", "content": user_message})
 
     try:
-        # spec has {url}/tasks/send as the endpoint
-        # update the path to /tasks/send
-        path = server_url.rstrip("/") + "/tasks/send"
-        response = requests.post(path, json=request_body)
-        response.raise_for_status()
-        data = response.json()
-        agent_reply = data.get("content", "")
+        # Call send_task with the server_url and session_id
+        response = send_task(server_url, session_id, "thread", user_message)
+        if response.get("error"):
+            error_message = response["error"].get("message", "Unknown error")
+            history.append({"role": "assistant", "content": f"Error: {error_message}"})
+            return "", history
+        # get the result.content from the json
+        agent_reply = response.get("result", {}).get("content", "")
         if agent_reply:
             history.append({"role": "assistant", "content": agent_reply})
     except Exception as e: