docs(examples): Dify agent

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": "test@kingsware.cn"
+  }
+  ```

examples/dify/__init__.py

@@ -0,0 +1 @@
+

examples/dify/__main__.py

@@ -0,0 +1,42 @@
+from a2a.server.apps import A2AStarletteApplication
+from a2a.server.request_handlers import DefaultRequestHandler
+from a2a.server.tasks import InMemoryTaskStore
+from a2a.types import (
+    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],
+    )
+
+    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)