# boot.py
import network, utime, machine
from umqttsimple import MQTTClient
import esp
import gc
esp.osdebug(None) # Set Debug Mode
gc.collect() # Active garbage collection

SSID = "MandM2.4GHz"
password = "[email protected]"
mqtt_server = ""
client_id = ubinascii.hexlify(machine.unique_id())
topic_sub = b'notifecation'
topic_pub = b'hello'

last_message = 0
message_interval = 5
counter = 0

station = network.WLAN(network.STA_IF)

station.active(True)
station.connect(ssid, password)

while station.isconnected() == False:
  pass

print('Connection successful')
print(station.ifconfig())

# Main.py
def sub_cb(topic, msg):
  print((topic, msg))
  if topic == b'notification' and msg == b'received':
    print('ESP received hello message')

def connect_and_subscribe():
  global client_id, mqtt_server, topic_sub
  client = MQTTClient(client_id, mqtt_server)
  client.set_callback(sub_cb)
  client.connect()
  client.subscribe(topic_sub)
  print('Connected to %s MQTT broker, subscribed to %s topic' % (mqtt_server, topic_sub))
  return client

def restart_and_reconnect():
  print('Failed to connect to MQTT broker. Reconnecting...')
  time.sleep(10)
  machine.reset()

try:
  client = connect_and_subscribe()
except OSError as e:
  restart_and_reconnect()

while True:
  try:
    client.check_msg()
    if (time.time() - last_message) > message_interval:
      msg = b'Hello #%d' % counter
      client.publish(topic_pub, msg)
      last_message = time.time()
      counter += 1
  except OSError as e:
    restart_and_reconnect()

# main.py mqtt-pub
from machine import Pin
import ubinascii
#from umqtt.simple import MQTTClient
import dht

DHT = dht.DHT11(Pin(22, Pin.IN, Pin.PULL_UP))
DHT.measure()
temp = DHT.temperature()
hum = DHT.humidity()


# CLIENT_ID = ubinascii.hexlify(machine.unique_id())
# mqtt = MQTTClient(CLIENT_ID, '127.0.0.l')
# mqtt.connect()
# mqtt.publish('sensors/temperature/{}'.format(CLIENT_ID).encode(), str(temp).encode())
# mqtt.disconnect()




# main.py mqtt-sub
# import ubinascii
# import machine
# from umqtt.simple import MQTTClient

# from data import conf


# CLIENT_ID = ubinascii.hexlify(machine.unique_id())


# def update_data(topic, msg):
#     topic = topic.decode().split('/')
#     device_id = topic.pop(-1)
#     name = topic[-1]
#     data = msg.decode()

#     ... update the display ...


# mqtt = MQTTClient(CLIENT_ID, conf.MQTT_SERVER)
# mqtt.set_callback(update_data)
# mqtt.connect()
# mqtt.subscribe(b'sensors/+/+')

# try:
#     while True:
#         mqtt.wait_msg()
# finally:
#     mqtt.disconnect()

print("Hello, ESP32!")