black linter code correction

Author: KarolinaPomian

tests/validation/Engine/rx_tx_app_client_json.py

@@ -32,8 +32,8 @@ def set_client(self, edits: dict) -> None:
         )
         self.maxMediaConnections = edits.get(
             "maxMediaConnections", self.maxMediaConnections
-        )    
-        
+        )
+
     def to_json(self) -> str:
         json_dict = {
             "apiVersion": self.apiVersion,

tests/validation/Engine/rx_tx_app_connection_json_usage_example.py

@@ -3,8 +3,9 @@
 # Media Communications Mesh
 
 from Engine.rx_tx_app_connection import (
-    ConnectionMode, 
-    Rdma, St2110, 
+    ConnectionMode,
+    Rdma,
+    St2110,
     TransportType,
 )
 from Engine.rx_tx_app_connection_json import ConnectionJson

tests/validation/Engine/rx_tx_app_connection_usage_example.py

@@ -4,9 +4,10 @@
 
 from Engine.rx_tx_app_connection import (
     ConnectionMode,
-    Rdma, St2110,
+    Rdma,
+    St2110,
     TransportType,
-    )
+)
 
 rx_tx_app_connection_rdma = Rdma(connectionMode=ConnectionMode.UC, maxLatencyNs=30000)
 

tests/validation/Engine/rx_tx_app_engine_mcm.py

@@ -12,13 +12,20 @@
 import Engine.rx_tx_app_client_json
 import Engine.rx_tx_app_connection_json
 from Engine.const import LOG_FOLDER, RX_TX_APP_ERROR_KEYWORDS, DEFAULT_OUTPUT_PATH
-from Engine.mcm_apps import get_media_proxy_port, output_validator, save_process_log, get_mcm_path
+from Engine.mcm_apps import (
+    get_media_proxy_port,
+    output_validator,
+    save_process_log,
+    get_mcm_path,
+)
 from Engine.rx_tx_app_file_validation_utils import validate_file
 
 logger = logging.getLogger(__name__)
 
 
-def create_client_json(build: str, client: Engine.rx_tx_app_client_json.ClientJson) -> None:
+def create_client_json(
+    build: str, client: Engine.rx_tx_app_client_json.ClientJson
+) -> None:
     logger.debug("Client JSON:")
     for line in client.to_json().splitlines():
         logger.debug(line)
@@ -33,7 +40,9 @@ def create_connection_json(
     logger.debug("Connection JSON:")
     for line in rx_tx_app_connection.to_json().splitlines():
         logger.debug(line)
-    output_path = str(Path(build, "tests", "tools", "TestApp", "build", "connection.json"))
+    output_path = str(
+        Path(build, "tests", "tools", "TestApp", "build", "connection.json")
+    )
     logger.debug(f"Connection JSON path: {output_path}")
     rx_tx_app_connection.prepare_and_save_json(output_path=output_path)
 
@@ -61,29 +70,40 @@ def __init__(
         self.file_dict = file_dict
         self.file = file
         self.rx_tx_app_connection = rx_tx_app_connection()
-        self.payload = payload_type.from_file_info(media_path=self.media_path, file_info=file_dict)
+        self.payload = payload_type.from_file_info(
+            media_path=self.media_path, file_info=file_dict
+        )
         self.media_proxy_port = get_media_proxy_port(host)
         self.rx_tx_app_client_json = Engine.rx_tx_app_client_json.ClientJson(
-            host, 
-            apiConnectionString=f"Server=127.0.0.1; Port={self.media_proxy_port}"
+            host, apiConnectionString=f"Server=127.0.0.1; Port={self.media_proxy_port}"
+        )
+        self.rx_tx_app_connection_json = (
+            Engine.rx_tx_app_connection_json.ConnectionJson(
+                host=host,
+                rx_tx_app_connection=self.rx_tx_app_connection,
+                payload=self.payload,
+            )
         )
-        self.rx_tx_app_connection_json = Engine.rx_tx_app_connection_json.ConnectionJson(
-            host=host, rx_tx_app_connection=self.rx_tx_app_connection, payload=self.payload
+        self.app_path = host.connection.path(
+            self.mcm_path, "tests", "tools", "TestApp", "build"
         )
-        self.app_path = host.connection.path(self.mcm_path, "tests", "tools", "TestApp", "build")
         self.client_cfg_file = host.connection.path(self.app_path, "client.json")
-        self.connection_cfg_file = host.connection.path(self.app_path, "connection.json")
+        self.connection_cfg_file = host.connection.path(
+            self.app_path, "connection.json"
+        )
         self.input = input_file
-        self.output_path = getattr(host.topology.extra_info, "output_path", DEFAULT_OUTPUT_PATH)
-        
+        self.output_path = getattr(
+            host.topology.extra_info, "output_path", DEFAULT_OUTPUT_PATH
+        )
+
         # Handle output file path construction
         if output_file and output_path:
             self.output = host.connection.path(output_path, output_file)
         elif output_file:
             self.output = host.connection.path(self.output_path, output_file)
         else:
             self.output = None
-            
+
         self.no_proxy = no_proxy
         self.loop = loop
         self.process = None
@@ -133,7 +153,7 @@ def start(self):
     def stop(self):
         validation_info = []
         file_validation_passed = True
-        
+
         if self.process:
             try:
                 if self.process.running:
@@ -158,11 +178,13 @@ def stop(self):
                 logger.warning(f"Errors found: {result['errors']}")
 
             self.is_pass = result["is_pass"]
-            
+
             # Collect log validation info
             validation_info.append(f"=== {self.direction} App Log Validation ===")
             validation_info.append(f"Log file: {log_file_path}")
-            validation_info.append(f"Validation result: {'PASS' if result['is_pass'] else 'FAIL'}")
+            validation_info.append(
+                f"Validation result: {'PASS' if result['is_pass'] else 'FAIL'}"
+            )
             validation_info.append(f"Errors found: {len(result['errors'])}")
             if result["errors"]:
                 validation_info.append("Error details:")
@@ -171,40 +193,50 @@ def stop(self):
             if result["phrase_mismatches"]:
                 validation_info.append("Phrase mismatches:")
                 for phrase, found, expected in result["phrase_mismatches"]:
-                    validation_info.append(f"  - {phrase}: found '{found}', expected '{expected}'")
+                    validation_info.append(
+                        f"  - {phrase}: found '{found}', expected '{expected}'"
+                    )
 
         # File validation for Rx only run if output path isn't "/dev/null"
         if self.direction == "Rx" and self.output and self.output_path != "/dev/null":
             validation_info.append(f"\n=== {self.direction} Output File Validation ===")
             validation_info.append(f"Expected output file: {self.output}")
-            
-            file_info, file_validation_passed = validate_file(self.host.connection, self.output, cleanup=False)
+
+            file_info, file_validation_passed = validate_file(
+                self.host.connection, self.output, cleanup=False
+            )
             validation_info.extend(file_info)
             self.is_pass = self.is_pass and file_validation_passed
 
         # Save validation report to file
         if validation_info:
             validation_info.append(f"\n=== Overall Validation Summary ===")
-            overall_status = "PASS" if self.is_pass and file_validation_passed else "FAIL"
+            overall_status = (
+                "PASS" if self.is_pass and file_validation_passed else "FAIL"
+            )
             validation_info.append(f"Overall validation: {overall_status}")
-            validation_info.append(f"App log validation: {'PASS' if result['is_pass'] else 'FAIL'}")
+            validation_info.append(
+                f"App log validation: {'PASS' if result['is_pass'] else 'FAIL'}"
+            )
             if self.direction == "Rx":
                 file_status = "PASS" if file_validation_passed else "FAIL"
                 validation_info.append(f"File validation: {file_status}")
                 # Add note about overall validation logic
                 if not self.is_pass or not file_validation_passed:
-                    validation_info.append("Note: Overall validation fails if either app log or file validation fails")
-            
+                    validation_info.append(
+                        "Note: Overall validation fails if either app log or file validation fails"
+                    )
+
             # Save to validation report file
             log_dir = self.log_path if self.log_path else LOG_FOLDER
             subdir = f"RxTx/{self.host.name}"
             validation_filename = f"{self.direction.lower()}_validation.log"
-            
+
             save_process_log(
                 subdir=subdir,
                 filename=validation_filename,
                 text="\n".join(validation_info),
-                log_dir=log_dir
+                log_dir=log_dir,
             )
 
     @property
@@ -225,9 +257,13 @@ def __init__(self, *args, **kwargs):
 
         def start(self):
             super().start()
-            logger.debug(f"Starting Tx app with payload: {self.payload.payload_type} on {self.host}")
+            logger.debug(
+                f"Starting Tx app with payload: {self.payload.payload_type} on {self.host}"
+            )
             cmd = self._get_app_cmd("Tx")
-            self.process = self.host.connection.start_process(cmd, shell=True, stderr_to_stdout=True, cwd=self.app_path)
+            self.process = self.host.connection.start_process(
+                cmd, shell=True, stderr_to_stdout=True, cwd=self.app_path
+            )
 
             # Start background logging thread
             subdir = f"RxTx/{self.host.name}"
@@ -240,7 +276,7 @@ def log_output():
                         filename=filename,
                         text=line.rstrip(),
                         cmd=cmd,
-                        log_dir=self.log_path
+                        log_dir=self.log_path,
                     )
 
             threading.Thread(target=log_output, daemon=True).start()