EOS-27256: IEM server integration with new event message changes (Sea…

…gate#702) * Iem server event message integrations changes Signed-off-by: suryakumar.kumaravelan <[email protected]> * code optimize Signed-off-by: suryakumar.kumaravelan <[email protected]> Co-authored-by: Sachin Punadikar <[email protected]> Signed-off-by: suryakumar.kumaravelan <[email protected]>
suryakumar1024 · Mar 21, 2022 · 171df19 · 171df19
1 parent e40ae22
commit 171df19
Showing 1 changed file with 16 additions and 2 deletions.
diff --git a/py-utils/src/utils/iem_framework/iem_server.py b/py-utils/src/utils/iem_framework/iem_server.py
@@ -23,13 +23,23 @@
 from cortx.utils.iem_framework.error import EventMessageError
 from cortx.utils.log import Log
 from cortx.utils.common import CortxConf
+from cortx.utils.conf_store import Conf
 
 routes = web.RouteTableDef()
 
 
 class IemRequestHandler(MessageServer):
     """ Rest interface of Iem """
 
+    @staticmethod
+    def _get_cluster_data(config_path):
+        message_bus_backend = Conf.get('config',\
+            'cortx>utils>message_bus_backend')
+        message_server_endpoints = Conf.get('config',\
+            f'cortx>external>{message_bus_backend}>endpoints')
+        cluster_id = Conf.get('config','cluster>id')
+        return message_server_endpoints, cluster_id
+
     @staticmethod
     async def send(request):
         try:
@@ -38,8 +48,10 @@ async def send(request):
             component = payload['component']
             source = payload['source']
             cluster_conf = CortxConf.get_cluster_conf_path()
+            endpoint, cluster_id = IemRequestHandler._get_cluster_data(cluster_conf)
+
             EventMessage.init(component=component, source=source,\
-                cluster_conf=cluster_conf)
+                cluster_id=cluster_id, message_server_endpoints=endpoint)
 
             del payload['component']
             del payload['source']
@@ -79,7 +91,9 @@ async def receive(request):
         try:
             cluster_conf = CortxConf.get_cluster_conf_path()
             component = request.rel_url.query['component']
-            EventMessage.subscribe(component=component, cluster_conf=cluster_conf)
+            endpoint, _ = IemRequestHandler._get_cluster_data(cluster_conf)
+            EventMessage.subscribe(component=component,\
+                message_server_endpoints=endpoint)
             alert = EventMessage.receive()
         except EventMessageError as e:
             status_code = e.rc