add dify agent in examples

Author: kingstonwen

examples/dify/README.md

@@ -0,0 +1,41 @@
+# Dify Integration Example
+
+This example demonstrates an A2A agent that integrates with the Dify API.
+
+## Features
+
+- Makes HTTP POST requests to the Dify workflow API endpoint
+- Demonstrates how to wrap an external API in an A2A agent
+- Includes both regular and streaming response handling
+
+## Getting started
+
+1. Start the server
+
+   ```bash
+   python __main__.py
+   ```
+
+2. Run the test client in another terminal
+
+   ```bash
+   python test_client.py
+   ```
+
+## API Details
+
+The agent makes requests to the following Dify endpoint:
+
+- URL: `http://192.168.8.41:8080/v1/workflows/run`
+- Method: POST
+- Headers:
+  - Authorization: Bearer app-wd1WTcAnHPLqRjTAm4QmswI9
+  - Content-Type: application/json
+- Request Body:
+  ```json
+  {
+    "inputs": {},
+    "response_mode": "blocking",
+    "user": "[email protected]"
+  }
+  ```

examples/dify/__init__.py

@@ -0,0 +1 @@
+ 

examples/dify/__main__.py

@@ -0,0 +1,44 @@
+from a2a.server.apps import A2AStarletteApplication
+from a2a.server.request_handlers import DefaultRequestHandler
+from a2a.server.tasks import InMemoryTaskStore
+from a2a.types import (
+    AgentAuthentication,
+    AgentCapabilities,
+    AgentCard,
+    AgentSkill,
+)
+
+from agent_executor import DifyAgentExecutor
+
+if __name__ == "__main__":
+    skill = AgentSkill(
+        id="dify_api_call",
+        name="Call Dify API",
+        description="Makes a request to the Dify API endpoint",
+        tags=["dify", "api", "workflow"],
+        examples=["call dify", "run workflow"],
+    )
+
+    agent_card = AgentCard(
+        name="Dify Agent",
+        description="Agent that wraps Dify API",
+        url="http://localhost:8888/",
+        version="1.0.0",
+        defaultInputModes=["text/plain", "application/json"],
+        defaultOutputModes=["text/plain", "application/json"],
+        capabilities=AgentCapabilities(streaming=True),
+        skills=[skill],
+        authentication=AgentAuthentication(schemes=["public"]),
+    )
+
+    request_handler = DefaultRequestHandler(
+        agent_executor=DifyAgentExecutor(),
+        task_store=InMemoryTaskStore(),
+    )
+
+    server = A2AStarletteApplication(
+        agent_card=agent_card, http_handler=request_handler
+    )
+    import uvicorn
+
+    uvicorn.run(server.build(), host="0.0.0.0", port=8888)

examples/dify/agent_executor copy.py

@@ -0,0 +1,62 @@
+# import httpx
+
+# from typing_extensions import override
+
+# from a2a.server.agent_execution import AgentExecutor, RequestContext
+# from a2a.server.events import EventQueue
+# from a2a.utils import new_agent_text_message
+
+
+# class DifyAgent:
+#     """Dify Agent wrapper."""
+
+#     async def invoke(self, city: str, response_mode: str = 'blocking') -> str:
+#         """Make HTTP POST request to Dify API in blocking mode."""
+#         url = 'https://api.dify.ai/v1/workflows/run'
+#         headers = {
+#             'Authorization': 'Bearer app-SXqTiCm89mGr2IJhKvwWgR7s',
+#             'Content-Type': 'application/json',
+#         }
+#         payload = {
+#             'inputs': {'city': city},
+#             'response_mode': response_mode,
+#             'user': '[email protected]',
+#         }
+
+#         async with httpx.AsyncClient(timeout=None) as client:
+#             try:
+#                 response = await client.post(url, json=payload, headers=headers)
+#                 response.raise_for_status()
+#                 return f"Dify API Response: {response.json()}"
+#             except httpx.HTTPError as e:
+#                 return f"Error calling Dify API: {str(e)}"
+
+
+# class DifyAgentExecutor(AgentExecutor):
+#     """Dify Agent Executor Implementation."""
+
+#     def __init__(self):
+#         self.agent = DifyAgent()
+
+#     @override
+#     async def execute(
+#         self,
+#         context: RequestContext,
+#         event_queue: EventQueue,
+#     ) -> None:
+#         city = None
+
+#         # Extract city from DataPart if available
+#         for part in context.message.parts:
+#             data = part.root.data
+#             city = data['city']
+
+#         print(city)
+#         result = await self.agent.invoke(city, 'blocking')
+#         event_queue.enqueue_event(new_agent_text_message(result))
+
+#     @override
+#     async def cancel(
+#         self, context: RequestContext, event_queue: EventQueue
+#     ) -> None:
+#         raise Exception('cancel not supported')