redis eventpublisher first cut [redis_eventpublisher_first_cut]

hjwp · hjwp · commit 872722b525ad · 2024-03-01T15:05:35.000Z
diff --git a/src/allocation/adapters/redis_eventpublisher.py b/src/allocation/adapters/redis_eventpublisher.py
@@ -0,0 +1,16 @@
+import json
+import logging
+from dataclasses import asdict
+import redis
+
+from allocation import config
+from allocation.domain import events
+
+logger = logging.getLogger(__name__)
+
+r = redis.Redis(**config.get_redis_host_and_port())
+
+
+def publish(channel, event: events.Event):
+    logging.debug("publishing: channel=%s, event=%s", channel, event)
+    r.publish(channel, json.dumps(asdict(event)))
