Move MqttError to rpc and import

This commit is contained in:
Melissa LeBlanc-Williams 2023-09-01 10:17:57 -07:00
parent 9ebdad6d68
commit d17a78b10f
3 changed files with 5 additions and 8 deletions

View file

@ -11,7 +11,7 @@ import terminalio
from adafruit_display_shapes.rect import Rect
from adafruit_display_text import label
from adafruit_macropad import MacroPad
from rpc import RpcClient, RpcError
from rpc import RpcClient, RpcError, MqttError
macropad = MacroPad()
rpc = RpcClient()
@ -26,9 +26,6 @@ NEOPIXEL_COLORS = {
"ON": 0x00FF00,
}
class MqttError(Exception):
"""For MQTT Specific Errors"""
# Set up displayio group with all the labels
group = displayio.Group()
for key_index in range(12):

View file

@ -25,6 +25,9 @@ DATA_TIMEOUT = 0.5
class RpcError(Exception):
"""For RPC Specific Errors"""
class MqttError(Exception):
"""For MQTT Specific Errors"""
class _Rpc:
def __init__(self):
self._serial = None

View file

@ -7,7 +7,7 @@ import json
import ssl
import socket
import adafruit_minimqtt.adafruit_minimqtt as MQTT
from rpc import RpcServer
from rpc import RpcServer, MqttError
mqtt_status = {
"connected": False,
@ -27,9 +27,6 @@ def disconnect(_mqtt_client, _userdata, _rc):
def message(_client, topic, payload):
last_mqtt_messages[topic] = payload
class MqttError(Exception):
"""For MQTT Specific Errors"""
# Default to 1883 since SSL on CPython is not currently supported
def mqtt_init(broker, port=1883, username=None, password=None):
mqtt_status["client"] = MQTT.MQTT(