latest client

client.py

@@ -38,7 +38,12 @@ async def test_coro():
 if __name__ == '__main__':
     formatter = "[%(asctime)s] %(name)s {%(filename)s:%(lineno)d} %(levelname)s - %(message)s"
     logging.basicConfig(level=logging.INFO, format=formatter)
+    with open('client.yaml', 'r') as fileread:
+        clientconfig = yaml.safe_load(fileread)
+    subdict(clientconfig, None)
+    print(sublist)
     x = 0
+    
     while x < 5:
         asyncio.get_event_loop().run_until_complete(test_coro())
         x = x + 1

client.yaml

@@ -0,0 +1,5 @@
+client:
+  name: "pi1"
+  sensors: 
+    camera:
+      path: /dev/v4l/by-id/

client/waggle-mqtt-sensor/platformio.ini

@@ -8,9 +8,8 @@
 ; Please visit documentation for the other options and examples
 ; https://docs.platformio.org/page/projectconf.html
 
-[env:pico]
-platform = https://github.com/maxgerhardt/platform-raspberrypi.git
-board = rpipicow
+[env:esp32]
+platform = espressif32
+board = esp32doit-devkit-v1
 framework = arduino
-upload_port = /run/media/amelia/RPI-RP2/
-board_build.core = earlephilhower
+lib_deps = knolleary/PubSubClient@^2.8

main.py

@@ -89,5 +89,5 @@ if __name__ == "__main__":
     asyncio.get_event_loop().run_until_complete(uptime_coro())
     asyncio.get_event_loop().run_forever()
 
-    publishData(1, "0", sensortypes[0], time.time_ns())
+    #publishData(1, "0", sensortypes[0], time.time_ns())
 

requirements.txt

@@ -1,3 +1,4 @@
 pywaggle[all]
 amqtt==0.11.0b1
-pyyaml
+pyyaml
+alive-progress

subscribe.yaml

@@ -7,4 +7,5 @@ sensors:
       - "1"
       - "2"
   pi1:
-    - "humidity"
+    - "humidity"
+    - "camera"