import time
import hmac
import hashlib
from paho.mqtt import client as mqtt_client
from paho.mqtt.client import CallbackAPIVersion

print("▶ Avvio script MQTT Tuya...")

# ===== DATI TUYA =====
ACCESS_ID = "xxx"
ACCESS_SECRET = "xxxx"
DEVICE_ID = "xxx"

# ===== BROKER TUYA EU (CORRETTO) =====
BROKER = "mqe.tuyaeu.com"
PORT = 8883
TOPIC = f"/sys/{DEVICE_ID}/thing/event/property/post"

print("▶ Genero firma...")

timestamp = str(int(time.time() * 1000))
sign_content = ACCESS_ID + timestamp

password = hmac.new(
    ACCESS_SECRET.encode(),
    sign_content.encode(),
    hashlib.sha256
).hexdigest().upper()

client_id = f"{ACCESS_ID}|securemode=3,signmethod=hmacsha256,timestamp={timestamp}|"

print("▶ Creo client MQTT...")

def on_connect(client, userdata, flags, rc, properties=None):
    if rc == 0:
        print("✅ CONNESSO A TUYA MQTT")
        print("📡 Topic:", TOPIC)
        client.subscribe(TOPIC)
    else:
        print("❌ Connessione fallita, codice:", rc)

def on_message(client, userdata, msg):
    print("\n🔔 EVENTO RICEVUTO DAL CAMPANELLO")
    print(msg.payload.decode())

client = mqtt_client.Client(
    client_id=client_id,
    callback_api_version=CallbackAPIVersion.VERSION2
)

client.username_pw_set(ACCESS_ID, password)
client.tls_set()
client.on_connect = on_connect
client.on_message = on_message

print("▶ Mi connetto a Tuya...")

client.connect(BROKER, PORT)

print("▶ In ascolto...")

client.loop_forever()