Update mqtt_client.py

mqtt_client.py

@@ -3,7 +3,13 @@ import json
 import paho.mqtt.client as mqtt
 from paho.mqtt.enums import CallbackAPIVersion
 
-from config import MQTT_BROKER, MQTT_PORT, MQTT_TOPIC_GAS_IN, MQTT_TOPIC_DOOR_CMD
+import config  # dùng getattr để lấy hằng số với giá trị mặc định
+
+# Lấy cấu hình với fallback an toàn nếu thiếu trong config.py
+MQTT_BROKER = getattr(config, "MQTT_BROKER", "test.mosquitto.org")
+MQTT_PORT = int(getattr(config, "MQTT_PORT", 1883))
+MQTT_TOPIC_GAS_IN = getattr(config, "MQTT_TOPIC_GAS_IN", "balenkano_tuan_gas_data")
+MQTT_TOPIC_DOOR_CMD = getattr(config, "MQTT_TOPIC_DOOR_CMD", "balenkano_tuan_door_2025")
 
 class MQTTService:
     def __init__(self, on_gas_message):
@@ -20,7 +26,7 @@ class MQTTService:
             payload = ""
 
         delivered = False
-        # Thử parse JSON trước
+        # Thử parse JSON trước (ESP32 thường gửi JSON đầy đủ)
         if payload:
             try:
                 m = json.loads(payload)
@@ -32,7 +38,7 @@ class MQTTService:
             except Exception:
                 pass
 
-        # Nếu không phải JSON, thử coi là số gas
+        # Nếu không phải JSON, thử coi là số gas (payload đơn giản)
         if not delivered:
             try:
                 val = float(payload)