Read and set publisher config from file if not already set from REST request (#231)

Co-authored-by: Ashish Jagadish <ashish.jagadish@intel.com>

Author: Aditya-sonii

microservices/dlstreamer-pipeline-server/src/publisher/publisher.py

@@ -145,14 +145,6 @@ def _get_meta_publisher_config(self,meta_destination):
             if len(self.request["destination"]["metadata"]) == 0: # Remove the metadata from destination if list is empty
                 self.request["destination"].pop("metadata")
 
-        # if no mqtt config in REST request, check if mqtt config is in app_cfg
-        if not self.mqtt_config and self.app_cfg.get("mqtt_publisher"):
-            self.mqtt_config = self.app_cfg.get("mqtt_publisher")
-        if not self.opcua_config and self.app_cfg.get("opcua_publisher"):
-            self.opcua_config = self.app_cfg.get("opcua_publisher")
-        if not self.influx_config and self.app_cfg.get("influx_write"):
-            self.influx_config = self.app_cfg.get("influx_write")
-
     def _get_frame_publisher_config(self,frame_destination):
         """Get config for frame publishers
         :param frame_destination: Frame destination
@@ -169,11 +161,20 @@ def _get_frame_publisher_config(self,frame_destination):
                     self.request["destination"]["frame"].remove(dest)
             if len(self.request["destination"]["frame"]) == 0: # Remove the frame from destination if list is empty
                 self.request["destination"].pop("frame")
-
-        # if no s3 config in REST request, check if s3 config is in app_cfg
+    
+    def _get_publisher_config_from_config_file(self):
+        """Get publisher config from config file
+        """
+        # Get the config only if it is not already set in the REST request
+        if not self.mqtt_config and self.app_cfg.get("mqtt_publisher"):
+            self.mqtt_config = self.app_cfg.get("mqtt_publisher")
+        if not self.opcua_config and self.app_cfg.get("opcua_publisher"):
+            self.opcua_config = self.app_cfg.get("opcua_publisher")
         if not self.s3_config and self.app_cfg.get("S3_write"):
             self.s3_config = self.app_cfg["S3_write"]
-        
+        if not self.influx_config and self.app_cfg.get("influx_write"):
+            self.influx_config = self.app_cfg["influx_write"]
+
     def _get_publishers(self):
         """Get publishers based on config.
 
@@ -202,6 +203,7 @@ def _get_publishers(self):
                     self._get_meta_publisher_config(meta_destination)
                     if not self.request["destination"]:
                         self.request.pop("destination")
+                self._get_publisher_config_from_config_file()
 
                 # NOTE: always add S3_write first in the list of publishers, essential for blocking case
                 if self.s3_config: