#import atsocket as sockte
from simple import MQTTClient
import binascii
#st = sockte.atsocket("COM2",115200)

SERVER = "180.76.99.118"
PORT = "61613"
CLIENT_ID = "33356"
TOPIC = "MYTOPIC_01"
USER = "admin"
PASSWORD = "password"


state = 0

def sub_cb(topic, msg):
    print((topic, msg))


def start(server=SERVER):
    c = MQTTClient(CLIENT_ID, server, PORT, USER, PASSWORD)
    c.initnetwork("COM2",115200)
    # Subscribed messages will be delivered to this callback
    c.set_callback(sub_cb)

    if c.connect():
        c.disconnect()
        return

    c.subscribe(TOPIC)
    print("Connected to %s:%s, subscribed to %s topic" % (server, PORT, TOPIC))

    try:
        while 1:
            #micropython.mem_info()
            c.wait_msg()
    finally:
        c.disconnect()

if __name__ == "__main__":
    start()