"""
Projet IoT ESP32 Weather Station
ws broker :broker.mqttdashboard.com
"""

import network
import time
from machine import Pin,SoftI2C
import dht
import ujson
from umqtt.simple import MQTTClient
from time import sleep_ms, ticks_ms 
from i2c_lcd import I2cLcd 

def sub_cb(topic, msg): 
    recieved_data = str(msg,'utf-8') 
    print("Data",recieved_data)

# MQTT Server Parameters
MQTT_CLIENT_ID = "ESP32-client"
MQTT_BROKER    = "broker.hivemq.com"
MQTT_USER      = "project1"
MQTT_PASSWORD  = "0000"
MQTT_TOPIC     = "ESP32-PROJECT"
MQTT_TOPIC2     = "ESP32-PROJECT-SUBS"
#Temperature AND Humidity Config 
sensor = dht.DHT22(Pin(15))
t = 0
h = 0


# LCD Config
i2c = SoftI2C(scl=Pin(26), sda=Pin(14),freq=100000)
lcd = I2cLcd(i2c, 0x27,2,16)
time.sleep(1)
lcd.clear()
# START
text = 'Starting...'
lcd.putstr(text)

# WIFI Config

print("Connecting to 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(" Connected!")

# MQTT Config


print("Connecting to MQTT server... ", end="")
client = MQTTClient(client_id=MQTT_CLIENT_ID, server=MQTT_BROKER, user=MQTT_USER, password=MQTT_PASSWORD, port=1883)
client.set_callback(sub_cb)
client.connect()
client.subscribe(MQTT_TOPIC2) 
print("Connected!")

prev_weather = ""
while True:
  client.check_msg()  
  # Measuring weather
  
  print("Measuring weather conditions... ", end="")
  sensor.measure() 
  message = ujson.dumps({
    "temp": sensor.temperature(),
    "humidity": sensor.humidity(),
  })
  # Sending data 

  if message != prev_weather:
    print("Updated!")
    print("Reporting to MQTT topic {}: {}".format(MQTT_TOPIC, message))
    client.publish(MQTT_TOPIC, message)

    prev_weather = message
  else:
    print("No change")
  
   # Displaying on LCD 

  t = sensor.temperature()
  h = sensor.humidity()
  temp = 'Temp: {:.0f} C'.format(t)
  humid = 'Humidity: {:.0f} %'.format(h)
  print('DHT11:', t, h)
  lcd.clear()
  lcd.putstr(temp)
  lcd.move_to(0,1)
  lcd.putstr(humid)
  time.sleep(2)