add health message

telemetry-collector/ecosystem.config.js

@@ -20,6 +20,10 @@ module.exports = {
             "EXTERNAL_UDP_HOST": "ufsolargators.org",
             "UART_PORT": "/tmp/uart",
           }
+        },
+        {
+          name: "pi_health",
+          script: "python src/python/is_alive.py"
         }
     ]
 }

telemetry-collector/src/python/is_alive.py

@@ -0,0 +1,13 @@
+"""Basic script that sends PI diagnostic info"""
+
+import time
+from udp import send_tlm
+
+DELAY_TIME = 5
+
+while 1:
+    print("sending alive message")
+    send_tlm({
+        "model": "pi/alive"
+    })
+    time.sleep(5)

telemetry-collector/src/python/udp.py

@@ -0,0 +1,18 @@
+import os, socket, json
+
+INTERNAL_UDP_PORT = os.environ.get("INTERNAL_UDP_PORT", "8000")
+INTERNAL_UDP_HOST = os.environ.get("INTERNAL_UDP_HOST", "localhost")
+EXTERNAL_UDP_PORT = os.environ.get("EXTERNAL_UDP_PORT", "8000")
+EXTERNAL_UDP_HOST = os.environ.get("EXTERNAL_UDP_HOST", "api.ufsolargators.org")
+
+sock = socket.socket(socket.AF_INET, # Internet
+                        socket.SOCK_DGRAM) # UDP
+
+def send_tlm(data):
+    data = json.dumps(data).encode()
+    sock.sendto(data, (INTERNAL_UDP_HOST, int(INTERNAL_UDP_PORT)))
+    # Try to send to external server, but if it fails then ignore it
+    try:
+        sock.sendto(data, (EXTERNAL_UDP_HOST, int(EXTERNAL_UDP_PORT)))
+    except socket.error:
+        pass