one single host for tcp connection

Author: marcomelloni

agents/matlab/README.md

@@ -184,9 +184,8 @@ logging:
   file: logs/matlab_agent.log # The file path where logs will be stored.
 
 tcp:
-  input_host: localhost # Host for receiving input stream
+  host: localhost # Host for receiving input stream
   input_port: 5679 # Port for receiving input stream
-  output_host: localhost # Host for output stream
   output_port: 5678 # Port for output stream
 
 response_templates:

agents/matlab/matlab_agent/api/simulation.yaml.template

@@ -21,9 +21,9 @@ simulation:
 
   inputs:
     # Input variables to be passed to the simulation.
-    # If the simulation type is 'streaming' or 'interactive', it is mandatory to specify 'stream_source' to indicate the source of the input stream.
+    # If the simulation type is 'interactive', it is mandatory to specify 'stream_source' to indicate the source of the input stream.
     # stream_source: The source of the input stream, e.g., RabbitMQ, which streams real-time input data to the simulation.
-    # This is required for interactive or streaming simulations.
+    # This is required for interactive simulations.
     stream_source: # Source of the input stream, typically RabbitMQ for streaming mode.
 
     i1: ..

agents/matlab/matlab_agent/config/config.yaml.template

@@ -32,9 +32,8 @@ performance:
   log_filename: performance_metrics.csv  # Name of the CSV file for performance metrics
 
 tcp:
-  input_host: localhost
+  host: localhost
   input_port: 5679
-  output_host: localhost
   output_port: 5678
 
 response_templates:

agents/matlab/matlab_agent/src/core/interactive.py

@@ -131,11 +131,11 @@ def __init__(
         self.agent_id = agent_id
 
         self.out_srv = _TcpServer(
-            tcp_cfg.get("output_host", "localhost"),
+            tcp_cfg.get("host", "localhost"),
             tcp_cfg.get("output_port", 5678),
         )
         self.in_srv = _TcpServer(
-            tcp_cfg.get("input_host", "localhost"),
+            tcp_cfg.get("host", "localhost"),
             tcp_cfg.get("input_port", 5679),
         )
 

agents/matlab/matlab_agent/src/utils/config_manager.py

@@ -59,9 +59,8 @@ class Config(BaseModel):
     performance_log_filename: str = Field(default="performance_metrics.csv")
 
     # TCP configuration
-    tcp_input_host: str = Field(default="localhost")
+    tcp_host: str = Field(default="localhost")
     tcp_input_port: int = Field(default=5679)
-    tcp_output_host: str = Field(default="localhost")
     tcp_output_port: int = Field(default=5678)
 
     # Response templates
@@ -130,9 +129,8 @@ def to_dict(self) -> Dict[str, Any]:
                 "log_filename": self.performance_log_filename
             },
             "tcp": {
-                "input_host": self.tcp_input_host,
+                "host": self.tcp_host,
                 "input_port": self.tcp_input_port,
-                "output_host": self.tcp_output_host,
                 "output_port": self.tcp_output_port
             },
             "response_templates": {
@@ -217,10 +215,8 @@ def from_dict(cls, config_dict: Dict[str, Any]) -> 'Config':
 
         # Extract tcp section if present
         if tcp := config_dict.get("tcp", {}):
-            flat_config["tcp_input_host"] = tcp.get("input_host", "localhost")
+            flat_config["tcp_host"] = tcp.get("host", "localhost")
             flat_config["tcp_input_port"] = tcp.get("input_port", 5679)
-            flat_config["tcp_output_host"] = tcp.get(
-                "output_host", "localhost")
             flat_config["tcp_output_port"] = tcp.get("output_port", 5678)
 
         # Extract response_templates section if present