From 695cb4a82ebe0bdf36d1ae8ebaaa5d2ab6d7d361 Mon Sep 17 00:00:00 2001
From: Ed_ <edwardgz@gmail.com>
Date: Thu, 26 Feb 2026 20:33:51 -0500
Subject: [PATCH] feat(mma): Implement AsyncEventQueue in events.py

---
 events.py                  | 30 +++++++++++++++++++++++-
 tests.toml                 |  3 ++-
 tests/test_async_events.py | 47 ++++++++++++++++++++++++++++++++++++++
 3 files changed, 78 insertions(+), 2 deletions(-)
 create mode 100644 tests/test_async_events.py

diff --git a/events.py b/events.py
index 8cc59c9..1882205 100644
--- a/events.py
+++ b/events.py
@@ -1,7 +1,8 @@
 """
 Decoupled event emission system for cross-module communication.
 """
-from typing import Callable, Any, Dict, List
+import asyncio
+from typing import Callable, Any, Dict, List, Tuple
 
 class EventEmitter:
     """
@@ -35,3 +36,30 @@ class EventEmitter:
         if event_name in self._listeners:
             for callback in self._listeners[event_name]:
                 callback(*args, **kwargs)
+
+class AsyncEventQueue:
+    """
+    Asynchronous event queue for decoupled communication using asyncio.Queue.
+    """
+    def __init__(self):
+        """Initializes the AsyncEventQueue with an internal asyncio.Queue."""
+        self._queue: asyncio.Queue = asyncio.Queue()
+
+    async def put(self, event_name: str, payload: Any = None):
+        """
+        Puts an event into the queue.
+        
+        Args:
+            event_name: The name of the event.
+            payload: Optional data associated with the event.
+        """
+        await self._queue.put((event_name, payload))
+
+    async def get(self) -> Tuple[str, Any]:
+        """
+        Gets an event from the queue.
+        
+        Returns:
+            A tuple containing (event_name, payload).
+        """
+        return await self._queue.get()
diff --git a/tests.toml b/tests.toml
index d73fbd4..2e30b71 100644
--- a/tests.toml
+++ b/tests.toml
@@ -18,7 +18,8 @@ files = [
     "tests/test_headless_service.py",
     "tests/test_performance_monitor.py",
     "tests/test_token_usage.py",
-    "tests/test_layout_reorganization.py"
+    "tests/test_layout_reorganization.py",
+    "tests/test_async_events.py"
 ]
 
 [categories.conductor]
diff --git a/tests/test_async_events.py b/tests/test_async_events.py
new file mode 100644
index 0000000..186a34e
--- /dev/null
+++ b/tests/test_async_events.py
@@ -0,0 +1,47 @@
+import asyncio
+import pytest
+from events import AsyncEventQueue
+
+def test_async_event_queue_put_get():
+    """Verify that an event can be asynchronously put and retrieved from the queue."""
+    async def run_test():
+        queue = AsyncEventQueue()
+        event_name = "test_event"
+        payload = {"data": "hello"}
+        
+        await queue.put(event_name, payload)
+        ret_name, ret_payload = await queue.get()
+        
+        assert ret_name == event_name
+        assert ret_payload == payload
+
+    asyncio.run(run_test())
+
+def test_async_event_queue_multiple():
+    """Verify that multiple events can be asynchronously put and retrieved in order."""
+    async def run_test():
+        queue = AsyncEventQueue()
+        
+        await queue.put("event1", 1)
+        await queue.put("event2", 2)
+        
+        name1, val1 = await queue.get()
+        name2, val2 = await queue.get()
+        
+        assert name1 == "event1"
+        assert val1 == 1
+        assert name2 == "event2"
+        assert val2 == 2
+
+    asyncio.run(run_test())
+
+def test_async_event_queue_none_payload():
+    """Verify that an event with None payload works correctly."""
+    async def run_test():
+        queue = AsyncEventQueue()
+        await queue.put("no_payload")
+        name, payload = await queue.get()
+        assert name == "no_payload"
+        assert payload is None
+
+    asyncio.run(run_test())