remove functional dir, add requirements.txt and correct imports

Author: KarolinaPomian

tests/validation/Engine/mcm_apps.py

@@ -5,7 +5,7 @@
 import threading
 from pathlib import Path
 
-from mcm.Engine.const import *
+from Engine.const import *
 
 logger = logging.getLogger(__name__)
 STOP_GRACEFULLY_PERIOD = 2  # seconds

tests/validation/Engine/rx_tx_app_connection.py

@@ -4,7 +4,7 @@
 
 from enum import Enum
 
-from mcm.Engine.const import (
+from Engine.const import (
     DEFAULT_REMOTE_IP_ADDR, DEFAULT_REMOTE_PORT, DEFAULT_PACING, 
     DEFAULT_PAYLOAD_TYPE_ST2110_20, DEFAULT_PIXEL_FORMAT,
     DEFAULT_MPG_URN, DEFAULT_PAYLOAD_TYPE_ST2110_30,

tests/validation/Engine/rx_tx_app_connection_json_usage_example.py

@@ -2,10 +2,10 @@
 # Copyright 2024-2025 Intel Corporation
 # Media Communications Mesh
 
-from mcm.Engine.rx_tx_app_connection import (ConnectionMode, Rdma, St2110,
+from Engine.rx_tx_app_connection import (ConnectionMode, Rdma, St2110,
                                              TransportType)
-from mcm.Engine.rx_tx_app_connection_json import ConnectionJson
-from mcm.Engine.rx_tx_app_payload import Audio, Video
+from Engine.rx_tx_app_connection_json import ConnectionJson
+from Engine.rx_tx_app_payload import Audio, Video
 
 rx_tx_app_connection_rdma = Rdma(connectionMode=ConnectionMode.UC, maxLatencyNs=30000)
 

tests/validation/Engine/rx_tx_app_connection_usage_example.py

@@ -2,7 +2,7 @@
 # Copyright 2024-2025 Intel Corporation
 # Media Communications Mesh
 
-from mcm.Engine.rx_tx_app_connection import (ConnectionMode, Rdma, St2110,
+from Engine.rx_tx_app_connection import (ConnectionMode, Rdma, St2110,
                                              TransportType)
 
 rx_tx_app_connection_rdma = Rdma(connectionMode=ConnectionMode.UC, maxLatencyNs=30000)

tests/validation/Engine/rx_tx_app_engine_mcm.py

@@ -9,16 +9,16 @@
 
 from mfd_connect.exceptions import RemoteProcessInvalidState
 
-import mcm.Engine.rx_tx_app_client_json
-import mcm.Engine.rx_tx_app_connection_json
-from mcm.Engine.const import LOG_FOLDER, RX_TX_APP_ERROR_KEYWORDS, DEFAULT_OUTPUT_PATH
-from mcm.Engine.mcm_apps import get_media_proxy_port, output_validator, save_process_log, get_mcm_path
-from mcm.Engine.rx_tx_app_file_validation_utils import validate_file
+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.rx_tx_app_file_validation_utils import validate_file
 
 logger = logging.getLogger(__name__)
 
 
-def create_client_json(build: str, client: mcm.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)
@@ -28,7 +28,7 @@ def create_client_json(build: str, client: mcm.Engine.rx_tx_app_client_json.Clie
 
 
 def create_connection_json(
-    build: str, rx_tx_app_connection: mcm.Engine.rx_tx_app_connection_json.ConnectionJson
+    build: str, rx_tx_app_connection: Engine.rx_tx_app_connection_json.ConnectionJson
 ) -> None:
     logger.debug("Connection JSON:")
     for line in rx_tx_app_connection.to_json().splitlines():
@@ -63,11 +63,11 @@ def __init__(
         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.media_proxy_port = get_media_proxy_port(host)
-        self.rx_tx_app_client_json = mcm.Engine.rx_tx_app_client_json.ClientJson(
+        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}"
         )
-        self.rx_tx_app_connection_json = mcm.Engine.rx_tx_app_connection_json.ConnectionJson(
+        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")
@@ -291,7 +291,7 @@ def log_output():
 
         def cleanup(self):
             """Clean up the output file created by the Rx app."""
-            from mcm.Engine.rx_tx_app_file_validation_utils import cleanup_file
+            from Engine.rx_tx_app_file_validation_utils import cleanup_file
 
             if self.output:
                 success = cleanup_file(self.host.connection, str(self.output))

tests/validation/Engine/rx_tx_app_payload_usage_example.py

@@ -2,7 +2,7 @@
 # Copyright 2024-2025 Intel Corporation
 # Media Communications Mesh
 
-from mcm.Engine.rx_tx_app_payload import Audio, Video
+from Engine.rx_tx_app_payload import Audio, Video
 
 payload = Video(width=3840, height=2160)
 

tests/validation/conftest.py

@@ -2,6 +2,7 @@
 # Copyright 2024-2025 Intel Corporation
 # Media Communications Mesh
 import logging
+import sys
 import os
 import shutil
 from ipaddress import IPv4Interface
@@ -11,14 +12,16 @@
 from mfd_connect.exceptions import ConnectionCalledProcessError, RemoteProcessTimeoutExpired
 import pytest
 
+# Add the path to the 'common' module
+common_path = os.path.join(os.path.expanduser('~'), 'Media-Transport-Library', 'tests', 'validation')
+sys.path.append(common_path)
 from common.nicctl import Nicctl
-from mcm.Engine.const import *
-from mcm.Engine.mcm_apps import MediaProxy, MeshAgent, get_mcm_path, get_mtl_path
+from Engine.const import *
+from Engine.mcm_apps import MediaProxy, MeshAgent, get_mcm_path, get_mtl_path
 from datetime import datetime
 
 logger = logging.getLogger(__name__)
 
-
 @pytest.fixture(scope="function")
 def media_proxy(hosts, mesh_agent, media_config, log_path):
     """