update time, remove xtra wifi.connect call

Author: brentru

examples/mqtt/adafruit_io_groups.py

@@ -81,7 +81,6 @@ def message(client, feed_id, payload):
 
 # Initialize MQTT interface with the esp interface
 MQTT.set_socket(socket, esp)
-wifi.connect()
 
 # Initialize a new MQTT Client object
 mqtt_client = MQTT.MQTT(broker="https://io.adafruit.com",

examples/mqtt/adafruit_io_location.py

@@ -80,7 +80,6 @@ def message(client, feed_id, payload):
 
 # Initialize MQTT interface with the esp interface
 MQTT.set_socket(socket, esp)
-wifi.connect()
 
 # Initialize a new MQTT Client object
 mqtt_client = MQTT.MQTT(broker="https://io.adafruit.com",

examples/mqtt/adafruit_io_simpletest.py

@@ -92,7 +92,6 @@ def message(client, feed_id, payload):
 
 # Initialize MQTT interface with the esp interface
 MQTT.set_socket(socket, esp)
-wifi.connect()
 
 # Initialize a new MQTT Client object
 mqtt_client = MQTT.MQTT(broker="https://io.adafruit.com",

examples/mqtt/adafruit_io_time.py

@@ -10,7 +10,7 @@
 import adafruit_esp32spi.adafruit_esp32spi_socket as socket
 import neopixel
 
-from adafruit_minimqtt import MQTT
+import adafruit_minimqtt as MQTT
 from adafruit_io.adafruit_io import IO_MQTT
 
 ### WiFi ###
@@ -89,16 +89,17 @@ def message(client, feed_id, payload):
 
 
 # Connect to WiFi
+print("Connecting to WiFi...")
 wifi.connect()
+print("Connected!")
+
+# Initialize MQTT interface with the esp interface
+MQTT.set_socket(socket, esp)
 
 # Initialize a new MQTT Client object
-mqtt_client = MQTT(
-    socket=socket,
-    broker="io.adafruit.com",
-    username=secrets["aio_user"],
-    password=secrets["aio_key"],
-    network_manager=wifi,
-)
+mqtt_client = MQTT.MQTT(broker="https://io.adafruit.com",
+                        username=secrets["aio_user"],
+                        password=secrets["aio_key"])
 
 # Initialize an Adafruit IO MQTT Client
 io = IO_MQTT(mqtt_client)
@@ -111,5 +112,16 @@ def message(client, feed_id, payload):
 # Connect to Adafruit IO
 io.connect()
 
-# Listen forever...
-io.loop_blocking()
+
+# Start a blocking message loop...
+# NOTE: NO code below this loop will execute
+# NOTE: Network reconnection is handled within this loop
+while True:
+    try:
+        io.loop()
+    except (ValueError, RuntimeError) as e:
+        print("Failed to get data, retrying\n", e)
+        wifi.reset()
+        io.reconnect()
+        continue
+    time.sleep(1)