add groups, simpletest, fix regular example

Author: brentru

adafruit_io/adafruit_io.py

@@ -99,6 +99,16 @@ def __enter__(self):
     def __exit__(self, exception_type, exception_value, traceback):
         self.disconnect()
 
+    def reconnect(self):
+        """Attempts to reconnect to the Adafruit IO MQTT Broker.
+
+        """
+        try:
+            self._client.reconnect()
+        except:
+            raise AdafruitIO_MQTTError("Unable to reconnect to Adafruit IO.")
+
+
     def connect(self):
         """Connects to the Adafruit IO MQTT Broker.
         Must be called before any other API methods are called.

examples/mqtt/adafruit_io_groups.py

@@ -11,7 +11,7 @@
 from digitalio import DigitalInOut
 import neopixel
 from adafruit_io.adafruit_io import IO_MQTT
-from adafruit_minimqtt import MQTT
+import adafruit_minimqtt as MQTT
 
 ### WiFi ###
 
@@ -74,18 +74,19 @@ def message(client, feed_id, payload):
     # the new value.
     print("Feed {0} received new value: {1}".format(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)
 wifi.connect()
 
 # 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)
@@ -103,6 +104,7 @@ def message(client, feed_id, payload):
 humid_feed = "weatherstation.humidity"
 
 # Connect to Adafruit IO
+print("Connecting to Adafruit IO...")
 io.connect()
 
 print("Publishing new messages to group feeds every 5 seconds...")

examples/mqtt/adafruit_io_simpletest.py

@@ -16,7 +16,7 @@
 from digitalio import DigitalInOut
 import neopixel
 from adafruit_io.adafruit_io import IO_MQTT
-from adafruit_minimqtt import MQTT
+import adafruit_minimqtt as MQTT
 
 ### WiFi ###
 
@@ -85,18 +85,19 @@ def message(client, feed_id, payload):
     # the new value.
     print("Feed {0} received new value: {1}".format(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)
 wifi.connect()
 
 # 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)
@@ -109,6 +110,7 @@ def message(client, feed_id, payload):
 io.on_message = message
 
 # Connect to Adafruit IO
+print("Connecting to Adafruit IO...")
 io.connect()
 
 # Below is an example of manually publishing a new  value to Adafruit IO.
@@ -123,8 +125,3 @@ def message(client, feed_id, payload):
         print("Publishing {0} to DemoFeed.".format(value))
         io.publish("DemoFeed", value)
         last = time.monotonic()
-
-
-# You can also call loop_blocking if you only want to receive values.
-# NOTE: If uncommented, no code below this line will run.
-# io.loop_blocking()