use keep_alive in examples; add funding.yaml

Author: 2bndy5

.github/FUNDING.yaml

@@ -0,0 +1,12 @@
+# These are supported funding model platforms
+
+github: 2bndy5
+patreon: # Replace with a single Patreon username
+open_collective: # Replace with a single Open Collective username
+ko_fi: # Replace with a single Ko-fi username
+tidelift: # Replace with a single Tidelift platform-name/package-name e.g., npm/babel
+community_bridge: # Replace with a single Community Bridge project-name e.g., cloud-foundry
+liberapay: # Replace with a single Liberapay username
+issuehunt: # Replace with a single IssueHunt username
+otechie: # Replace with a single Otechie username
+custom: ["https://www.paypal.me/Brendan884"] # Replace with up to 4 custom sponsorship URLs e.g., ['link1', 'link2']

examples/homie_button_test.py

@@ -86,7 +86,8 @@ def on_disconnected(client: MQTT, user_data, rc):
 mqtt_client.on_connect = lambda *args: print("Connected to the MQTT broker!")
 
 # connect to the broker and publish/subscribe the device's topics
-device.begin()
+device.begin(keep_alive=3000)
+# keep_alive must be set to avoid the device's `$state` being considered "lost"
 
 # a forever loop
 try:

examples/homie_clock_test.py

@@ -81,7 +81,8 @@ def on_disconnected(client: MQTT, user_data, rc):
 mqtt_client.on_connect = lambda *args: print("Connected to the MQTT broker!")
 
 # connect to the broker and publish/subscribe the device's topics
-device.begin()
+device.begin(keep_alive=3000)
+# keep_alive must be set to avoid the device's `$state` being considered "lost"
 
 # a forever loop
 try:

examples/homie_dht_sensor_test.py

@@ -30,15 +30,15 @@
 mqtt_client = MQTT(**mqtt_settings, socket_pool=pool)
 
 # create a light_sensor object for analog readings
-dht_in = board.A3  # change this accordingly
+dht_in = board.A0  # change this accordingly
 dht_sensor = adafruit_dht.DHT11(dht_in)
 dht_sensor.measure()  # update current data for Homie init
 
 # create the objects that describe our device
 device = HomieDevice(mqtt_client, "my device name", "lib-dht-sensor-test-id")
 dht_node = HomieNode("DHT11", "temperature/humidity sensor")
 dht_temperature_property = PropertyFloat(
-    "temperature", init_value=dht_sensor.temperature, unit="°F"
+    "temperature", init_value=dht_sensor.temperature * (9 / 5) + 32, unit="°F"
 )
 dht_humidity_property = PropertyPercent(
     "humidity", datatype="integer", init_value=dht_sensor.humidity
@@ -60,7 +60,8 @@ def on_disconnected(client: MQTT, user_data, rc):
 mqtt_client.on_connect = lambda *args: print("Connected to the MQTT broker!")
 
 # connect to the broker and publish/subscribe the device's topics
-device.begin()
+device.begin(keep_alive=3000)
+# keep_alive must be set to avoid the device's `$state` being considered "lost"
 
 # a forever loop
 try:
@@ -73,9 +74,9 @@ def on_disconnected(client: MQTT, user_data, rc):
                 mqtt_client.loop()
                 dht_sensor.measure()  # update current data
                 temp = device.set_property(
-                    dht_temperature_property, dht_sensor.temperature
+                    dht_temperature_property, dht_sensor.temperature * (9 / 5) + 32
                 )
-                print("Temp:", temp, dht_temperature_property.unit, end=" ")
+                print("Temp:", temp, dht_temperature_property.unit[-1], end=" ")
                 humid = device.set_property(dht_humidity_property, dht_sensor.humidity)
                 print("Humidity:", humid, dht_humidity_property.unit, end="\r")
         except MMQTTException:

examples/homie_light_sensor_test.py

@@ -54,7 +54,8 @@ def on_disconnected(client: MQTT, user_data, rc):
 mqtt_client.on_connect = lambda *args: print("Connected to the MQTT broker!")
 
 # connect to the broker and publish/subscribe the device's topics
-device.begin()
+device.begin(keep_alive=3000)
+# keep_alive must be set to avoid the device's `$state` being considered "lost"
 
 # a forever loop
 try:

examples/homie_simpletest.py

@@ -76,7 +76,8 @@ def on_disconnected(client: MQTT, user_data, rc):
 mqtt_client.on_connect = lambda *args: print("Connected to the MQTT broker!")
 
 # connect to the broker and publish/subscribe the device's topics
-device.begin()
+device.begin(keep_alive=3000)
+# keep_alive must be set to avoid the device's `$state` being considered "lost"
 
 # a forever loop
 try:
@@ -86,7 +87,6 @@ def on_disconnected(client: MQTT, user_data, rc):
             now = time.time()
             if now - refresh_last > 0.5:  # refresh every 0.5 seconds
                 refresh_last = now
-                assert mqtt_client.is_connected()
                 mqtt_client.loop()
         except MMQTTException:
             print("!!! Connection with broker is lost.")