|
1
|
1 import network
|
|
|
2 import secrets
|
|
|
3 from umqttsimple import MQTTClient
|
|
|
4
|
|
|
5
|
|
|
6 class Net:
|
|
|
7 def connect_wifi(self, status):
|
|
|
8 status(1, "wifi: ")
|
|
|
9 station = network.WLAN(network.STA_IF)
|
|
|
10 station.active(True) # activate the interface
|
|
|
11 status(1, "wifi: on")
|
|
|
12
|
|
|
13 station.connect(secrets.ssid, secrets.wifi_pass)
|
|
|
14 status(1, "wifi: on/connect")
|
|
|
15
|
|
|
16 while station.isconnected() == False:
|
|
|
17 pass
|
|
|
18
|
|
|
19 status(1, "wifi: on/connect/ok")
|
|
|
20
|
|
|
21 def connect_mqtt(self, status):
|
|
|
22 client_id = '7key'
|
|
|
23 status(2, "mqtt: ")
|
|
|
24 self.client = MQTTClient(client_id, secrets.mqtt_broker)
|
|
|
25
|
|
|
26 self.client.set_callback(self.on_subscribed_msg)
|
|
|
27 status(2, "mqtt: connect")
|
|
|
28 self.client.connect()
|
|
|
29 status(2, "mqtt: connect/ok")
|
|
|
30
|
|
|
31 def subscribe(self, topic, cb):
|
|
|
32 self.client.subscribe(topic)
|
|
|
33
|
|
|
34 def on_subscribed_msg(self, topic, msg):
|
|
|
35 print('mqtt ->', (topic, msg))
|
|
|
36 if topic == b'notification' and msg == b'received':
|
|
|
37 print('ESP received hello message')
|
|
|
38
|
|
|
39 def mqtt_poll(self):
|
|
|
40 self.client.check_msg()
|
|
|
41
|
|
|
42 def send(self, topic, msg):
|
|
|
43 self.client.publish(topic.encode('ascii'), msg.encode('ascii'))
|
