"""
MicroPython IoT Weather Station Example for Wokwi.com
Copyright (C) 2022, Uri Shaked - https://wokwi.com/arduino/projects/322577683855704658

Para visualizar los datos:
1. Visitar http://www.hivemq.com/demos/websocket-client/
2. Conectar al broker
3. Suscribirse al tópico "wokwi-weather"
"""
# =============================================================================
# UNIVERSIDAD INTERNACIONAL DE LA RIOJA (UNIR) - MAESTRÍA INDUSTRIA 4.0
# DESCRIPCIÓN: Estación meteorológica IoT con MicroPython para ESP32/Wokwi
# - Lectura de temperatura y humedad con sensor DHT22
# - Transmisión de datos mediante MQTT con protocolo QoS 0
# - Conexión WiFi automática a red abierta
# - Detección de cambios para optimización de transmisiones
# - Intervalo de muestreo configurable (1 segundo por defecto)
# =============================================================================

# ========== CONFIGURACIÓN GENERAL ==========
import network          # Manejo de conexiones WiFi (protocolo 802.11)          
import time             # Control de tiempos y delays precisos                  
from machine import Pin # Interfaz para control de pines GPIO                  
import dht              # Driver para sensores DHT11/DHT22                      
import ujson            # Serialización JSON optimizada para MicroPython        
from umqtt.simple import MQTTClient # Cliente MQTT con soporte QoS 0           

MQTT_CLIENT_ID = "micropython-weather-demo" # Identificador único cliente MQTT  
MQTT_BROKER    = "broker.mqttdashboard.com" # Broker público MQTT (puerto 1883) 
MQTT_USER      = ""                         # Usuario para autenticación MQTT   
MQTT_PASSWORD  = ""                         # Contraseña para autenticación MQTT
MQTT_TOPIC     = "wokwi-weather"            # Tópico para publicación de datos  

DHT_PIN = 16                 # Pin GPIO conectado al sensor DHT22              
sensor = dht.DHT22(Pin(16))  # Instancia del sensor con precisión ±0.5°C       

sta_if = network.WLAN(network.STA_IF)    # Configurar interfaz WiFi modo estación
sta_if.active(True)                      # Activar interfaz de red              
sta_if.connect('Wokwi-GUEST', '')        # Conectar a red WiFi abierta          

print("Conectando a WiFi", end="")       # Mostrar mensaje inicial conexión     
while not sta_if.isconnected():          # Esperar hasta conexión exitosa       
  print(".", end="")                     # Indicador de progreso conexión       
  time.sleep(0.1)                        # Pausa no bloqueante entre checks     
print(" Connected!")                     # Confirmar conexión WiFi exitosa      

client = MQTTClient(                     # Crear instancia cliente MQTT         
    MQTT_CLIENT_ID,                      # Usar ID único para sesión            
    MQTT_BROKER,                         # Especificar broker destino           
    user=MQTT_USER,                      # Parámetro opcional de usuario        
    password=MQTT_PASSWORD               # Parámetro opcional de contraseña     
)
client.connect()              # Establecer conexión segura con broker           
print("Connected!")           # Confirmar conexión MQTT exitosa                 

prev_weather = ""             # Almacenar último estado para detección cambios  

while True:                   # Bucle principal de monitoreo                   
  print("Measuring weather conditions... ", end="")  # Inicio ciclo medición    
  sensor.measure()            # Leer valores del sensor (bloqueante ≈2ms)       
  
  message = ujson.dumps({     # Crear payload JSON optimizado                   
      "temp": sensor.temperature(),   # Incluir temperatura con 1 decimal      
      "humidity": sensor.humidity()   # Incluir humedad con 1 decimal           
  })
  
  if message != prev_weather:         # Detectar cambios en mediciones          
      print("Updated!")               # Notificar actualización de valores      
      print("Reporting to MQTT topic {}: {}".format(MQTT_TOPIC, message))  # Log 
      client.publish(MQTT_TOPIC, message)  # Publicar datos en broker           
      prev_weather = message          # Actualizar referencia de estado         
  else:
      print("No change")              # No se detectaron cambios               
  
  time.sleep(1)  # Esperar 1 segundo entre ciclos de medición