"""
IoT Weather Station for ESP32-S3
لرؤية البيانات:
1. اذهب إلى http://www.hivemq.com/demos/websocket-client/
2. اضغط "Connect"
3. تحت Subscriptions، اضغط "Add New Topic Subscription"
4. في حقل Topic، اكتب "IOT-weather" ثم اضغط "Subscribe"
"""
import network
import time
from machine import Pin
import dht
import ujson
from umqtt.simple import MQTTClient

# MQTT Server Parameters
MQTT_CLIENT_ID = "esp32s3-weather-station"
MQTT_BROKER = "broker.mqttdashboard.com"
MQTT_USER = ""
MQTT_PASSWORD = ""
MQTT_TOPIC = "IOT-weather"

# تهيئة حساس DHT22 - استخدم المنفذ المناسب لـ ESP32-S3
sensor = dht.DHT22(Pin(9))  # يمكنك تغيير رقم المنفذ

print("جاري الاتصال بالواي فاي...", end="")
sta_if = network.WLAN(network.STA_IF)
sta_if.active(True)
sta_if.connect('Wokwi-GUEST', '')  # في الواقع الفعلي، ضع بيانات شبكتك

# الانتظار حتى الاتصال
for _ in range(20):
    if sta_if.isconnected():
        break
    print(".", end="")
    time.sleep(0.5)

if sta_if.isconnected():
    print(" متصل!")
    print("عنوان IP:", sta_if.ifconfig()[0])
else:
    print(" فشل الاتصال!")
    # يمكنك الاستمرار أو إيقاف البرنامج

print("جاري الاتصال بخادم MQTT...", end="")
try:
    client = MQTTClient(MQTT_CLIENT_ID, MQTT_BROKER, 
                       user=MQTT_USER, password=MQTT_PASSWORD)
    client.connect()
    print("متصل!")
except Exception as e:
    print("فشل الاتصال MQTT:", e)
    client = None

prev_weather = ""

while True:
    try:
        print("جاري قياس الظروف الجوية...", end="")
        sensor.measure()
        
        message = ujson.dumps({
            "temp": sensor.temperature(),
            "humidity": sensor.humidity(),
            "device": "ESP32-S3"
        })
        
        if message != prev_weather:
            print("تم التحديث!")
            print("الإبلاغ إلى MQTT topic {}: {}".format(MQTT_TOPIC, message))
            
            if client:
                client.publish(MQTT_TOPIC, message)
            prev_weather = message
        else:
            print("لا يوجد تغيير")
            
    except Exception as e:
        print("خطأ في القياس:", e)
    
    time.sleep(5)  # انتظار 5 ثواني بين القراءات