import paho.mqtt.client as mqtt
import logging
import sys

logging.basicConfig(
    level=logging.INFO,
    format="%(asctime)s [%(levelname)s] %(message)s",
    datefmt="%Y-%m-%dT%H:%M:%S",
    stream=sys.stdout,   # Docker lit stdout par défaut
    force=True
)

log = logging.getLogger(__name__)


def on_connect(client, userdata, flags, reason_code, properties):
    log.info(f"Connected with result code {reason_code}")
    client.subscribe("application/+/device/+/event/up")

def on_message(client, userdata, msg):
    log.info(msg.topic+" "+str(msg.payload))


if __name__ == "__main__":
    mqttc = mqtt.Client(mqtt.CallbackAPIVersion.VERSION2)
    mqttc.on_connect = on_connect
    mqttc.on_message = on_message

    mqttc.connect("mosquitto", 1883, 60)
    mqttc.loop_forever()