[OMCProcess] get file with port information from omc log

Author: syntron

OMPython/OMCSession.py

@@ -472,6 +472,9 @@ def __init__(
         except OSError as ex:
             raise OMCSessionException(f"Cannot open log file {logfile}.") from ex
 
+        self._re_portfile_path = re.compile(pattern=r'\nDumped server port in file: (.*?)($|\n)',
+                                            flags=re.MULTILINE | re.DOTALL)
+
     def __del__(self):
         if self._omc_loghandle is not None:
             try:
@@ -506,6 +509,17 @@ def get_log(self) -> str:
 
         return log
 
+    def _get_portfile_path(self) -> Optional[pathlib.Path]:
+        omc_log = self.get_log()
+
+        portfile = self._re_portfile_path.findall(string=omc_log)
+
+        portfile_path = None
+        if portfile:
+            portfile_path = pathlib.Path(portfile[-1][0])
+
+        return portfile_path
+
 
 class OMCProcessPort(OMCProcess):
 
@@ -574,11 +588,11 @@ def _omc_port_get(self) -> str:
         # See if the omc server is running
         attempts = 0
         while True:
-            omc_file_port = self._temp_dir / self._omc_file_port
+            omc_portfile_path = self._get_portfile_path()
 
-            if omc_file_port.is_file():
+            if omc_portfile_path is not None and omc_portfile_path.is_file():
                 # Read the port file
-                with open(file=omc_file_port, mode='r', encoding="utf-8") as f_p:
+                with open(file=omc_portfile_path, mode='r', encoding="utf-8") as f_p:
                     port = f_p.readline()
                 break
 
@@ -588,7 +602,7 @@ def _omc_port_get(self) -> str:
             attempts += 1
             if attempts == 80.0:
                 raise OMCSessionException(f"OMC Server did not start (timeout={self._timeout}). "
-                                          f"Could not open file {omc_file_port}. "
+                                          f"Could not open file {omc_portfile_path}. "
                                           f"Log-file says:\n{self.get_log()}")
             time.sleep(self._timeout / 80.0)
 
@@ -761,7 +775,6 @@ def _omc_command_docker(self, omc_path_and_args_list) -> list:
         return omc_command
 
     def _omc_port_get(self) -> str:
-        omc_file_port = '/tmp/' + self._omc_file_port
         port = None
 
         if not isinstance(self._dockerCid, str):
@@ -770,22 +783,24 @@ def _omc_port_get(self) -> str:
         # See if the omc server is running
         attempts = 0
         while True:
-            try:
-                output = subprocess.check_output(args=["docker",
-                                                       "exec", self._dockerCid,
-                                                       "cat", omc_file_port],
-                                                 stderr=subprocess.DEVNULL)
-                port = output.decode().strip()
-            except subprocess.CalledProcessError:
-                pass
+            omc_portfile_path = self._get_portfile_path()
+            if omc_portfile_path is not None:
+                try:
+                    output = subprocess.check_output(args=["docker",
+                                                           "exec", self._dockerCid,
+                                                           "cat", omc_portfile_path.as_posix()],
+                                                     stderr=subprocess.DEVNULL)
+                    port = output.decode().strip()
+                except subprocess.CalledProcessError:
+                    pass
 
             if port is not None:
                 break
 
             attempts += 1
             if attempts == 80.0:
                 raise OMCSessionException(f"Docker based OMC Server did not start (timeout={self._timeout}). "
-                                          f"Could not open file {omc_file_port}. "
+                                          f"Could not open port file {omc_portfile_path}. "
                                           f"Log-file says:\n{self.get_log()}")
             time.sleep(self._timeout / 80.0)
 
@@ -903,7 +918,6 @@ def _omc_command_docker(self, omc_path_and_args_list) -> list:
         return omc_command
 
     def _omc_port_get(self) -> str:
-        omc_file_port = '/tmp/' + self._omc_file_port
         port = None
 
         if not isinstance(self._dockerCid, str):
@@ -912,22 +926,24 @@ def _omc_port_get(self) -> str:
         # See if the omc server is running
         attempts = 0
         while True:
-            try:
-                output = subprocess.check_output(args=["docker",
-                                                       "exec", self._dockerCid,
-                                                       "cat", omc_file_port],
-                                                 stderr=subprocess.DEVNULL)
-                port = output.decode().strip()
-            except subprocess.CalledProcessError:
-                pass
+            omc_portfile_path = self._get_portfile_path()
+            if omc_portfile_path is not None:
+                try:
+                    output = subprocess.check_output(args=["docker",
+                                                           "exec", self._dockerCid,
+                                                           "cat", omc_portfile_path.as_posix()],
+                                                     stderr=subprocess.DEVNULL)
+                    port = output.decode().strip()
+                except subprocess.CalledProcessError:
+                    pass
 
             if port is not None:
                 break
 
             attempts += 1
             if attempts == 80.0:
                 raise OMCSessionException(f"Docker container based OMC Server did not start (timeout={self._timeout}). "
-                                          f"Could not open file {omc_file_port}. "
+                                          f"Could not open port file {omc_portfile_path}. "
                                           f"Log-file says:\n{self.get_log()}")
             time.sleep(self._timeout / 80.0)