add a circutpython MQTT version.

Author: LelandSindt

circutpythonMQTT/code.py

@@ -0,0 +1,85 @@
+import os
+import ipaddress
+import wifi
+import socketpool
+import ssl
+import adafruit_requests
+import supervisor
+import pwmio
+import board
+import time
+import adafruit_minimqtt.adafruit_minimqtt as MQTT
+
+
+#https://stackoverflow.com/questions/1969240/mapping-a-range-of-values-to-another
+def translate(sensor_val, in_from, in_to, out_from, out_to):
+  out_range = out_to - out_from
+  in_range = in_to - in_from
+  in_val = sensor_val - in_from
+  val=(float(in_val)/in_range)*out_range
+  out_val = out_from+val
+  return int(out_val)
+
+#https://stackoverflow.com/questions/5996881/how-to-limit-a-number-to-be-within-a-specified-range-python
+def clamp(n, minn, maxn):
+  return max(min(maxn, n), minn)
+
+def connect(mqtt_client, userdata, flags, rc):
+  print("Connected to MQTT Broker!")
+  print("Flags: {0}\n RC: {1}".format(flags, rc))
+
+def subscribe(mqtt_client, userdata, topic, granted_qos):
+  print("Subscribed to {0} with QOS level {1}".format(topic, granted_qos))
+
+def message(client, topic, message):
+  if not("envoy_20223xxxxxxxx_current_power_" in topic):
+    return
+  print("New message on topic {0}: {1}".format(topic, message))
+  try:
+    value = int(message)
+  except:
+    return
+  if topic == "homeassistant/sensor/envoy_2022xxxxxxxx_current_power_production/state":
+    productionPWM.duty_cycle = translate(clamp(value,0,9000),0,9000,0,65535)
+  if topic == "homeassistant/sensor/envoy_2022xxxxxxxx_current_power_consumption/state":
+    consumptionPWM.duty_cycle = translate(clamp(value,0,9000),0,9000,0,65535)
+
+productionPWM   = pwmio.PWMOut(board.GP6, frequency=5000, duty_cycle=0)
+consumptionPWM  = pwmio.PWMOut(board.GP7, frequency=5000, duty_cycle=0)
+
+print()
+print("Connecting to WiFi")
+wifi.radio.connect(os.getenv('CIRCUITPY_WIFI_SSID'), os.getenv('CIRCUITPY_WIFI_PASSWORD'))
+
+print("Connected to WiFi")
+print("My MAC addr:", [hex(i) for i in wifi.radio.mac_address])
+
+print("My IP address is", wifi.radio.ipv4_address)
+
+pool = socketpool.SocketPool(wifi.radio)
+
+mqtt_client = MQTT.MQTT(
+    broker="192.168.1.50",
+    socket_pool=pool,
+    ssl_context=ssl.create_default_context(),
+)
+
+mqtt_client.on_connect = connect
+mqtt_client.on_subscribe = subscribe
+mqtt_client.on_message = message
+
+# long topic strings cause problems so we will just subscribe to _all_ the sensor states and filter them out later. 
+# https://github.com/adafruit/Adafruit_CircuitPython_MiniMQTT/issues/160
+topics = [("homeassistant/sensor/+/state",0)]
+
+try:
+  mqtt_client.connect()
+  mqtt_client.subscribe(topics)
+except:
+  supervisor.reload()
+
+while True:
+  try:
+    mqtt_client.loop()
+  except:
+    supervisor.reload()

circutpythonMQTT/settings.toml

@@ -0,0 +1,2 @@
+CIRCUITPY_WIFI_SSID="yourssid"
+CIRCUITPY_WIFI_PASSWORD="wifipassword"

readme.md

@@ -1,5 +1,5 @@
 # analoguEnvoy
-This project contains three variations of scripts that can display Solar Production and Power Consumption as measured by an Enphase Envoy Communications Gateway.  
+This project contains four variations of scripts that can display Solar Production and Power Consumption as measured by an Enphase Envoy Communications Gateway.  
 
 ## Python MQTT
 [solar.py](/pythonMQTT/solar.py) connectes to an MQTT server and subscribes to production and consumption messages published by [homeassistant](https://www.home-assistant.io/) and collected by a [custom envoy integration](https://github.com/briancmpbll/home_assistant_custom_envoy). This variation was developed on a Raspberry Pi Zero W.
@@ -10,6 +10,9 @@ This project contains three variations of scripts that can display Solar Product
 ## CircutPython http
 Written in [CircutPython](https://circuitpython.org/), [code.py](/circutpython/code.py) reads [settings.toml](/circutpython/settings.toml) for an ssid and password to make a wifi connecton. Simiar to the python version your username, password and serial number are used to obtain a token from `enlighten` which is used to query `envoy` locally for consumption and producion information. This variation was developed on a [Raspberry Pi Pico W](https://www.raspberrypi.com/documentation/microcontrollers/raspberry-pi-pico.html#raspberry-pi-pico-w-and-pico-wh).
 
+## CircutPython MQTT 
+Written in [CircutPython](https://circuitpython.org/), [code.py](/circutpythonMQTT/code.py) reads [settings.toml](/circutpython/settings.toml) for an ssid and password to make a wifi connecton. Similar to the python MQTT vairant it subscribes to production and consumption messages published by homeassistant and collected by a custom envoy integration. This variation was developed on a [Raspberry Pi Pico W](https://www.raspberrypi.com/documentation/microcontrollers/raspberry-pi-pico.html#raspberry-pi-pico-w-and-pico-wh).
+
 ## PWM
 All three versions use PWM to drive analogue gauges with a 3v range.