torrent_mqtt remove logging and run inside docker

torrent/torrent_mqtt.py

@@ -1,85 +1,56 @@
-#!/home/lucas/scripts/.venv/bin/python
+#!/config/.venv/bin/python3
+"""
+torrent_mqtt.py
+
+Veröffentlicht die übergebenen Kommandozeilenargumente als MQTT-Nachricht.
+
+Verwendung:
+    torrent_mqtt.py "Download abgeschlossen: Film XYZ"
+
+Topic:
+    serverhost_torrent_sensor/topic
+
+Exit Codes:
+    0 = Erfolgreich
+    1 = Keine Nachricht übergeben
+    2 = MQTT-Fehler
+"""
+
 import sys
 import paho.mqtt.client as mqtt
 
-import logging
+MQTT_BROKER_HOST = "192.168.0.122"
-
-# Set up logging configuration
-log_file = '/home/lucas/logfile.log'  # Replace with your desired log file location
-
-logging.basicConfig(
-    filename=log_file,            # Log file location
-    level=logging.DEBUG,          # Log level: DEBUG, INFO, WARNING, ERROR, CRITICAL
-    format='%(asctime)s - %(levelname)s - %(message)s',  # Log format
-    filemode='a'                  # 'a' to append logs, 'w' to overwrite logs each time
-)
-logging.info(f"Start")
-
-# Define the MQTT broker connection details
-MQTT_BROKER_HOST = "homeassistant"
 MQTT_BROKER_PORT = 1883
 MQTT_USERNAME = "MQTTBrokerUser"
 MQTT_PASSWORD = "mqtt1510##"
-MQTT_TOPIC = "serverhost_torrent_sensor/topic"  # Set the desired topic
+MQTT_TOPIC = "serverhost_torrent_sensor/topic"
 
 
-# Define the on_connect callback
+def main():
-def on_connect(client, userdata, flags, rc):
+    message = " ".join(sys.argv[1:]).strip()
-    print(f"Connected with result code {rc}")
-# Define callback functions
-def on_connect(client, userdata, flags, rc):
-    """Callback when the client connects to the broker."""
-    print(f"Connected with result code {rc}")
-    # Subscribe to a topic if needed
-    client.subscribe(MQTT_TOPIC)
 
-def on_message(client, userdata, msg):
+    if not message:
-    """Callback when a message is received from the broker."""
+        print("No message supplied.")
-    print(f"Received message: {msg.payload.decode()} on topic: {msg.topic}")
+        sys.exit(1)
 
-def on_subscribe(client, userdata, mid, granted_qos):
+    client = mqtt.Client(mqtt.CallbackAPIVersion.VERSION2)
-    """Callback when a subscription is successful."""
+    client.username_pw_set(MQTT_USERNAME, MQTT_PASSWORD)
-    print(f"Subscribed to topic with QoS {granted_qos}")
+
+    try:
+        client.connect(MQTT_BROKER_HOST, MQTT_BROKER_PORT, 60)
+
+        info = client.publish(MQTT_TOPIC, message)
+        info.wait_for_publish()
+
+        print(f"Published to '{MQTT_TOPIC}': {message}")
+
+        client.disconnect()
+        sys.exit(0)
+
+    except Exception as e:
+        print(f"MQTT error: {e}")
+        sys.exit(2)
 
 
-
+if __name__ == "__main__":
-try:
+    main()
-    # Your code that is causing the error
-    # Create an MQTT client instance
-    mqttc = mqtt.Client()
-    
-    # Set username and password for authentication
-    mqttc.username_pw_set(username=MQTT_USERNAME, password=MQTT_PASSWORD)
-    
-    # Connect to the MQTT broker
-    mqttc.connect(MQTT_BROKER_HOST, MQTT_BROKER_PORT, 60)
-    
-    # Attach the callback functions
-    mqttc.on_connect = on_connect
-    mqttc.on_message = on_message
-    mqttc.on_subscribe = on_subscribe
-    
-    
-    # Start the MQTT client loop in the background
-    mqttc.loop_start()
-    
-    # Prepare the message from command-line arguments
-    message = ' '.join(sys.argv[1:])  # Collect all arguments except the script name
-    
-    logging.info(f"Message: {message}")
-    if message:
-        # Publish the message to the specified topic
-        mqttc.publish(MQTT_TOPIC, message)
-        print(f"Message sent: {message}")
-    else:
-        print("No message provided. Please provide some arguments to send.")
-    
-    # Disconnect from the broker
-    mqttc.disconnect()
-    
-    # Stop the MQTT client loop
-    mqttc.loop_stop()
-
-    pass
-except AttributeError as e:
-    logging.error(f"Error: {e}")