import network
import time
from machine import Pin
import dht
import ujson
from umqtt.simple import MQTTClient

# Parametros do cliente MQTT
MQTT_CLIENT_ID  = "micropython-test-Lab"
MQTT_BROKER     = "broker-mqttdashboard.com"
MQTT_USER       = ""
MQTT_PASSWORD   = ""
MQTT_TOPIC      = "dht"


# Instaciando: objeto: sensor; classe:dht; construtor: DHT22 pino 0
sensor = dht.DHT22(Pin(0))

# Parametros para conexçao WiFi
print("Conectando ao WiFi", end="")
wifi = network.WLAN(network.STA_IF)
wifi.active(True)
wifi.connect('Wokwi-GUEST', '')

#Ciclo de espera da efetivaçao da conecçao do WiFi
while not wifi.isconnected():
    print(".", end="")
    time.sleep(0.1)
print(" Connected ")

# Ciclo da conecçao ao broker MQTT
print(" Conectando ao Broker MQTT ... ", end="")
cliente = MQTTClient(MQTT_CLIENT_ID, MQTT_BROKER, user=MQTT_USER, password=MQTT_PASSWORD,)
cliente.connect()

print(" Conectado ao Broker")

# Ciclo para permitir transmissão de dados apenas quando houver ateração de valores 
anterior = ""
while True:
    print(" Medindo parâmetros atmosféricos ", end="")
    sensor.measure()
    mensagem = ujason.dumps({
        "temperatura" : sensor.temperature(),
        "umidade" : sensor.humidity(),
    })
    if mensagem != anterior:
        print("Atualisando....")
        print("Reportando alterações ao topico MQTT {}: {}". format(MQTT_TOPIC, mensagem))
        cliente.publish(MQTT_TOPIC, mensagem)
        anterior = mensagem
    else:
        print("Nenhuma alteração")
        time.sleep(1)

# Link para acessar o broker publico 
# http://www.hivemq.com/demos/websocket-client/