|
28 | 28 | import json
|
29 | 29 | import shortuuid
|
30 | 30 | import zmq
|
31 |
| -from .sim767x import SIM767X, ERROR_State |
| 31 | +from .sim767x import Sim767x, ErrorState |
32 | 32 | from .constants import CONNECTION_PUB_URL
|
33 | 33 | from .device import Device
|
34 | 34 | from .iotcontrol.enums import ConnectionState
|
|
40 | 40 | class Lte767xConnection(threading.Thread):
|
41 | 41 | """Under Active Development - DOES NOT WORK!"""
|
42 | 42 |
|
43 |
| - def on_mqtt_connect(self, connected: bool, error_state: ERROR_State): |
| 43 | + def on_mqtt_connect(self, connected: bool, error_state: ErrorState): |
44 | 44 | if connected:
|
45 | 45 | logger.debug("connected OK")
|
46 | 46 | self.connection_state = ConnectionState.CONNECTED
|
@@ -152,7 +152,7 @@ def __init__(
|
152 | 152 | self._device_id_list = []
|
153 | 153 | self.serial_port = serial_port
|
154 | 154 | self.baud_rate = baud_rate
|
155 |
| - self.lte_con = SIM767X(self.serial_port, "", self.apn, self.baud_rate) |
| 155 | + self.lte_con = Sim767x(self.serial_port, "", self.apn, self.baud_rate) |
156 | 156 | self.lte_con.mqtt_setup(self.host, self.port, self.username, self.password)
|
157 | 157 | self.lte_con.set_callbacks(self.on_mqtt_connect, self.on_mqtt_subscribe, self.on_mqtt_receive_message)
|
158 | 158 | self.connection_state = ConnectionState.CONNECTING
|
|
0 commit comments