"""
MicroPython IoT Weather Station Example for Wokwi.com

To view the data:

1. Go to http://www.hivemq.com/demos/websocket-client/
2. Click "Connect"
3. Under Subscriptions, click "Add New Topic Subscription"
4. In the Topic field, type "wokwi-weather" then click "Subscribe"

Now click on the DHT22 sensor in the simulation,
change the temperature/humidity, and you should see
the message appear on the MQTT Broker, in the "Messages" pane.

Copyright (C) 2022, Uri Shaked

https://wokwi.com/arduino/projects/322577683855704658
"""

import network #importa libreria network
import time #importa libreria time
from machine import Pin, PWM #importar PWM y PIN de Machine
import dht #importa libreria dht
import ujson #importa libreria ujson
from umqtt.simple import MQTTClient #importa MQTTClient de umqtt.simple
from utime import sleep, sleep_us #importa sleep y sleep_us de utime

# Parametros servidor MQTT 
MQTT_CLIENT_ID = "micropython-weather-demo"
MQTT_BROKER    = "broker.mqttdashboard.com"
MQTT_USER      = ""
MQTT_PASSWORD  = ""
MQTT_TOPIC     = "wokwi-weather"

sensor = dht.DHT22(Pin(15)) #configuracion del sensor pin 15
servo = PWM(Pin(18), freq = 50) #configuraion del servomotor pin 18 frecuencia 50

#Establece conexion Wifi
print("Conectando a WiFi", end="")
sta_if = network.WLAN(network.STA_IF)
sta_if.active(True)
sta_if.connect('Wokwi-GUEST', '')
while not sta_if.isconnected():
  print(".", end="")
  time.sleep(0.1)
print(" Connectado!")

#Establece conexion a servidor MQTT
print("Conectado a servidor MQTT... ", end="")
client = MQTTClient(MQTT_CLIENT_ID, MQTT_BROKER, user=MQTT_USER, password=MQTT_PASSWORD)
client.connect()
print("Conectado!")


prev_weather = ""   #definicion objeto prev_wather
umbral_temp_amb = 20.0 #definicion umbral temperatura ambiente
temp_actual = "" #definicion temperatura actual
bajo_umbral_temp = "" #definicion temperatura bajo umbral

while True: #Bucle infinito
  print("Midiendo condiciones climaticas... ", end="")
  sensor.measure() 
  temp_actual = sensor.temperature() #obtener temperatura actual
  message = ujson.dumps({
    "temp": sensor.temperature(),
    "humidity": sensor.humidity(),
  })
  if message != prev_weather:  #condicional si cambia las condiciones
    print("Actualizado!")
    print("Reportando a MQTT {}: {}".format(MQTT_TOPIC, message))
    client.publish(MQTT_TOPIC, message)
    prev_weather = message
    if temp_actual > umbral_temp_amb:  #Condicional si la temperatura actual supera la temperatura ambiente
            print("Temperatura encima del umbral...moviendo el servomotor") 
            while sensor.temperature()>umbral_temp_amb: #Inicio bucle mientras la temperatura supera el umbral 
                for i in range (1800, 8000): #Permite girar el motor 180 grados en sentido de las manecillas del reloj
                    servo.duty_u16(i) #Hará que el brazo del servomotor de un "paso" dentro del rango, en sentido horario
                    sleep_us(1) #Permite detener el programa por 1 microsegundo
                print ("Motor en 0°") #Imprime el texto "Motor en 0°"
                sleep(2) #Detiene el programa 2 segundos
                for i in range (8000, 1800, -1): #Permite girar el motor 180 grados en sentido contrario de las manecillas del reloj
                    servo.duty_u16(i) #Hará que el brazo del servomotor de un "paso" dentro del rango, en sentido antihorario
                    sleep_us(1) #Permite detener el programa por 1 microsegundo  
                print ("Motor en 180°") #Imprime el texto "Motor en 180°"
                sleep(2) #Detiene el programa 2 segundos
                sensor.measure() #obtiene datos del sensor
            temp_actual = sensor.temperature() #Este comando asigna el valor actual de temperatura actual a la variable para su uso
            bajo_umbral_temp="si" #Asignacion del valor si a variable bajo umbral cuando la temperatura es menor que el umbral
    else:
            if bajo_umbral_temp=="si":
                print("Temperatura debajo del umbral...deteniendo el servomotor")
                bajo_umbral_temp="no"
    time.sleep(1)
  else: #si no se cumple la consicional de la temperatura supera el umbral se imprime el texto "Sin cambios"
    print("Sin cambios")
  time.sleep(1)