from umqtt.simple import MQTTClient
import time
import ujson
import network

## WiFi Connecting
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
MQTT_Client_ID = '71f06445-df31-45cb-9fb7-f4aa66cf752c'
MQTT_Token = '2ypv7s5tNBGpUy457EQgutBLw52xeCo3'
MQTT_Secret = '8AZ38JDBJtAMhvEaUwEX9Ygj591EYnsU'
MQTT_Broker = 'mqtt.netpie.io'
MQTT_TOPIC     = "P954646771476"
client = MQTTClient(MQTT_Client_ID, MQTT_Broker, user=MQTT_Token, password=MQTT_Secret)
client.connect()
counter = 0
while True:
    counter += 1
    print(counter)
    time.sleep(3)
    client.publish('@shadow/data/update',ujson.dumps({'data':{'counter':counter}
    }))
    time.sleep(0.5)