Merge pull request #7 from Spchdt/new-actions

Add echo.py

Author: Spchdt

src/actions/client/echo.py

@@ -0,0 +1,29 @@
+import asyncio
+from typing import TYPE_CHECKING, Any
+
+from src.actions.base import ClientActionHandler, register_client_action
+from src.schema.frames import ClientFrame
+
+if TYPE_CHECKING:
+    from src.engine.connection_context import ConnectionContext
+
+
+@register_client_action("ECHO")
+class EchoActionHandler(ClientActionHandler):
+    """Example client action for testing."""
+
+    action_type = "ECHO"
+    context_template = "Client sent an echo message."
+
+    def to_context_str(self, payload: dict[str, Any]) -> str:
+        message = payload.get("message", "")
+        return f"[EVENT:ECHO] Client sent an echo message: {message}"
+
+    async def execute(
+        self,
+        frame: ClientFrame,
+        _ctx: "ConnectionContext",
+        content_queue: asyncio.Queue[dict[str, Any]],
+    ) -> None:
+        context_str = self.to_context_str(frame.payload)
+        await content_queue.put({"type": "text", "text": context_str})