import time
import wifi
import ssl
import socketpool
import adafruit_minimqtt.adafruit_minimqtt as MQTT
from adafruit_io.adafruit_io import IO_MQTT
from secrets import secrets


def aio_message_callback(client, feed_id, payload):
    pass
    # print(f"{feed_id} = {payload}")

wifi.radio.connect(secrets["ssid"], secrets["password"])
print('Wifi Connected')

pool = socketpool.SocketPool(wifi.radio)

# Initialize a new MQTT Client object
mqtt_client = MQTT.MQTT(
    broker="io.adafruit.com",
    username=secrets["aio_username"],
    password=secrets["aio_key"],
    socket_pool=pool,
    ssl_context=ssl.create_default_context(),
)

io = IO_MQTT(mqtt_client)
io.on_message = aio_message_callback

# Connect to Adafruit IO
io.connect()
print("Connected to Adafruit IO")

io.subscribe_to_time("seconds")

# Also bust, I think!
# io.subscribe_to_time("ISO-8601") 

timer_100ms = 0

while True:

    if (time.monotonic() - timer_100ms) >= 0.1:
        timer_100ms = time.monotonic()
        io.loop()