@@ -136,12 +136,12 @@ class Hub: # pylint: disable=too-many-instance-attributes
136
136
def __init__ (
137
137
self ,
138
138
display : displayio .Display ,
139
- io_object : IO_MQTT ,
139
+ io_mqtt : IO_MQTT ,
140
140
nav : Tuple [DigitalInOut , ...],
141
141
):
142
142
self .display = display
143
143
144
- self .io_object = io_object
144
+ self .io_mqtt = io_mqtt
145
145
146
146
self .up_btn , self .select , self .down , self .back , self .submit = nav
147
147
@@ -150,13 +150,13 @@ def __init__(
150
150
151
151
self .feeds = OrderedDict ()
152
152
153
- self .io_object .on_mqtt_connect = self .connected
154
- self .io_object .on_mqtt_disconnect = self .disconnected
155
- self .io_object .on_mqtt_subscribe = self .subscribe
156
- self .io_object .on_message = self .message
153
+ self .io_mqtt .on_mqtt_connect = self .connected
154
+ self .io_mqtt .on_mqtt_disconnect = self .disconnected
155
+ self .io_mqtt .on_mqtt_subscribe = self .subscribe
156
+ self .io_mqtt .on_message = self .message
157
157
158
158
print ("Connecting to Adafruit IO..." )
159
- io_object .connect ()
159
+ io_mqtt .connect ()
160
160
161
161
self .display .show (None )
162
162
@@ -211,7 +211,7 @@ def add_device(
211
211
if not default_text :
212
212
default_text = feed_key
213
213
214
- self .io_object .subscribe (feed_key )
214
+ self .io_mqtt .subscribe (feed_key )
215
215
if len (self .splash ) == 1 :
216
216
self .splash .append (
217
217
Label (
@@ -251,9 +251,9 @@ def get(self):
251
251
"""Gets all the subscribed feeds"""
252
252
for feed in self .feeds .keys ():
253
253
print (f"getting { feed } " )
254
- self .io_object .get (feed )
254
+ self .io_mqtt .get (feed )
255
255
time .sleep (0.1 )
256
- self .io_object .loop ()
256
+ self .io_mqtt .loop ()
257
257
258
258
# pylint: disable=unused-argument
259
259
@staticmethod
@@ -282,11 +282,11 @@ def message(self, client: IO_MQTT, feed_id: str, message: str):
282
282
def publish (self , feed : Feed , message : str ):
283
283
"""Callback for publishing a message"""
284
284
print (f"Publishing { message } to { feed } " )
285
- self .io_object .publish (feed , message )
285
+ self .io_mqtt .publish (feed , message )
286
286
287
287
def loop (self ):
288
288
"""Loops Adafruit IO and also checks to see if any buttons have been pressed"""
289
- self .io_object .loop ()
289
+ self .io_mqtt .loop ()
290
290
if self .select .value :
291
291
feed = self .feeds [list (self .feeds .keys ())[self .selected - 1 ]]
292
292
if feed .pub :
0 commit comments