diff --git a/sidra_chain_integration/sidra_chain_event_listener.py b/sidra_chain_integration/sidra_chain_event_listener.py
new file mode 100644
index 000000000..a735be7ba
--- /dev/null
+++ b/sidra_chain_integration/sidra_chain_event_listener.py
@@ -0,0 +1,23 @@
+# sidra_chain_event_listener.py
+import asyncio
+from sidra_chain_api import SidraChainAPI
+
+class SidraChainEventListener:
+    def __init__(self, sidra_chain_api: SidraChainAPI):
+        self.sidra_chain_api = sidra_chain_api
+
+    async def listen_for_events(self):
+        # Listen for events on the Sidra Chain using WebSockets
+        async with websockets.connect('wss://api.sidra.com/events') as ws:
+            while True:
+                message = await ws.recv()
+                event_data = json.loads(message)
+                # Process event data using the Sidra Chain Data Processor
+                data_processor = SidraChainDataProcessor(self.sidra_chain_api)
+                predictions = data_processor.process_chain_data(event_data)
+                # Take action based on the predictions (e.g., send alerts, update dashboards)
+                self.take_action(predictions)
+
+    def take_action(self, predictions: list):
+        # Take action based on the predictions (e.g., send alerts, update dashboards)
+        pass