import time
from umqtt.simple import MQTTClient


import network
import time
from math import sin

# Received messages from subscriptions will be delivered to this callback
def sub_cb(topic, msg):
    print((topic, msg))


def main(server="192.168.1.59"):
    # Fill in your WiFi network name (ssid) and password here:
    wifi_ssid = "OddlyAsus"
    wifi_password = "8699869986"

    # Connect to WiFi
    wlan = network.WLAN(network.STA_IF)
    wlan.active(True)
    wlan.connect(wifi_ssid, wifi_password)
    while wlan.isconnected() == False:
        print('Waiting for connection...')
        time.sleep(1)
    print("Connected to WiFi")

    c = MQTTClient("pico_board", server, 1883)
    c.set_callback(sub_cb)
    c.connect()
    c.subscribe(b"godot/#")
    while True:
        if True:
            # Blocking wait for message
            c.wait_msg()
        else:
            # Non-blocking wait for message
            c.check_msg()
            # Then need to sleep to avoid 100% CPU usage (in a real
            # app other useful actions would be performed instead)
            time.sleep(1)

    c.disconnect()


if __name__ == "__main__":
    main()