Skip to content

Commit

Permalink
feat: add config path as an parameter
Browse files Browse the repository at this point in the history
  • Loading branch information
SlaviXG committed Jun 20, 2024
1 parent 691593f commit 7821156
Show file tree
Hide file tree
Showing 3 changed files with 18 additions and 3 deletions.
7 changes: 6 additions & 1 deletion commander.py
Original file line number Diff line number Diff line change
@@ -1,3 +1,4 @@
import argparse
import paho.mqtt.client as mqtt
import configparser
import os
Expand Down Expand Up @@ -68,7 +69,11 @@ def init_commander(config_path: os.path) -> BaseCommander:


if __name__ == '__main__':
commander = init_commander('config.ini')
parser = argparse.ArgumentParser(description="Commander for sending commands to clients.")
parser.add_argument('--config', type=str, default='config.ini', help='Path to the configuration file.')
args = parser.parse_args()

commander = init_commander(args.config)
commander.connect()

try:
Expand Down
7 changes: 6 additions & 1 deletion operator.py
Original file line number Diff line number Diff line change
@@ -1,3 +1,4 @@
import argparse
import paho.mqtt.client as mqtt
import configparser
import os
Expand Down Expand Up @@ -166,8 +167,12 @@ def run_realtime_mode(self):


if __name__ == '__main__':
parser = argparse.ArgumentParser(description="Operator for managing commands and clients.")
parser.add_argument('--config', type=str, default='config.ini', help='Path to the configuration file.')
args = parser.parse_args()

config = configparser.ConfigParser()
config.read('config.ini')
config.read(args.config)
broker = os.getenv('MQTT_BROKER') or config['mqtt']['broker']
port = int(config['mqtt']['port'])
command_topic = config['mqtt']['command_topic']
Expand Down
7 changes: 6 additions & 1 deletion sut.py
Original file line number Diff line number Diff line change
@@ -1,3 +1,4 @@
import argparse
import paho.mqtt.client as mqtt
import configparser
import subprocess
Expand Down Expand Up @@ -150,8 +151,12 @@ def stop(self):


if __name__ == '__main__':
parser = argparse.ArgumentParser(description="System Under Test (SUT) for processing commands.")
parser.add_argument('--config', type=str, default='config.ini', help='Path to the configuration file.')
args = parser.parse_args()

config = configparser.ConfigParser()
config.read('config.ini')
config.read(args.config)
broker = os.getenv('MQTT_BROKER') if os.getenv('MQTT_BROKER') is not None else config['mqtt']['broker']
port = int(config['mqtt']['port'])
command_topic = config['mqtt']['command_topic']
Expand Down

0 comments on commit 7821156

Please sign in to comment.