diff --git a/src/main.py b/src/main.py index c1c60e3..9363c18 100644 --- a/src/main.py +++ b/src/main.py @@ -49,10 +49,8 @@ try: context['boxes'] = boxes # add context dict to each box in the list - for box_name, config in boxes.items(): + for _, config in boxes.items(): config['context'] = {} - - logger.info(f"{boxes=}") except json.JSONDecodeError as e: logger.error(f"Error parsing JSON configuration for boxes: {e}") sys.exit(1) diff --git a/src/message_processor.py b/src/message_processor.py index 446628b..ffe1391 100644 --- a/src/message_processor.py +++ b/src/message_processor.py @@ -9,9 +9,10 @@ from loguru import logger # store here what ever is require to represent the state of the box def process_message(box_name, topic_key, payload, context): - logger.info(f"{context=}") + # logger.info(f"{context=}") try: - logger.info(f"[{box_name}] Processing message for '{topic_key}': {payload}") + box = context['boxes'][box_name] + logger.info(f"[{box_name}, {box['label']}] Processing message for '{topic_key}': {payload}") match topic_key.split('/'): case [ primary_key, sub_key ] if primary_key == 'window': @@ -28,7 +29,7 @@ def process_message(box_name, topic_key, payload, context): raise Error(f"Unexcepted topic_key: {topic_key}, {payload}") if result: - publish_topic = context["boxes"]["output_topic"] + publish_topic = box["output_topic"] context['client'].publish(publish_topic, result) logger.info(f"[{box_name}] Result published on '{publish_topic}': {result}") except Exception as e: