# Timer Object
tim = Timer(-1)

# MQTT Server Parameters
MQTT_CLIENT_ID = "mqttx_d97fe9eb"
MQTT_BROKER = "broker.emqx.io"
MQTT_USER = ""
MQTT_PASSWORD = ""
MQTT_TOPIC = "BrainWave/AriAbdulAziz"

# Connection to MQTT Server
print("Connecting to MQTT server... ", end="")
client = MQTTClient(MQTT_CLIENT_ID, MQTT_BROKER, user=MQTT_USER, password=MQTT_PASSWORD)
client.connect()
print("Connected!")

# Callback funcion for Topic Subscription
def sub_cb(topic, msg):
  print(str(topic,'UTF-8'))
  print(str(msg,'UTF-8'))

# Callback funcion for Publish Data
def pub_topic(tim,topic:str,msg=""):
  msg = str("Ari Abdul Aziz")
  client.publish(topic, msg)

# Timer for Periodic Data Publish
tim.init(period=5000, mode=Timer.PERIODIC,callback=lambda pub: pub_topic(tim,MQTT_TOPIC))

# MQTT Subcribtion details
client.set_callback(sub_cb)
client.subscribe(MQTT_TOPIC)

while True:
  client.check_msg()