Add UART

LICENSE

@@ -1,6 +1,6 @@
 MIT License
 
-Copyright (c) 2018, Pierre Clisson <pierre@clisson.net>
+Copyright (c) 2023, Pierre Clisson <pierre@clisson.net>
 
 Permission is hereby granted, free of charge, to any person obtaining a copy
 of this software and associated documentation files (the "Software"), to deal

examples/uart.yaml

@@ -12,6 +12,9 @@ graphs:
           filter_type: bandstop
           frequencies: [45, 55]
           order: 2
+      # - id: display
+      #   module: timeflux.nodes.debug
+      #   class: Display
       - id: ui
         module: timeflux_ui.nodes.ui
         class: UI
@@ -20,5 +23,7 @@ graphs:
         target: notch
       - source: notch
         target: ui:data
+      # - source: data
+      #   target: display
     rate: 10
 

timeflux_upsidedownlabs/nodes/driver.py

@@ -1,5 +1,4 @@
-# import sys
-import numpy as np
+import pandas as pd
 from timeflux.core.node import Node
 from threading import Lock
 from pyfirmata2 import Arduino
@@ -33,6 +32,8 @@ def __init__(self, port=None, rate=500):
         self.rate = rate
         self.pin = 0
         self.timestamp = 0
+        self.timestamps = []
+        self.data = []
         self.board = Arduino(port)
         self.meta = {"rate": rate}
         self._lock = Lock()
@@ -52,14 +53,22 @@ def _blink(self):
 
     def _callback(self, data):
         """Acquire and cache data."""
+        if self.timestamp == 0:
+            self.timestamp = time.time()
         self._lock.acquire()
-        print(f"{self.timestamp:.3f}\t{data}")
-        self.timestamp += 1 / self.samplingRate
+        # print(f"{self.timestamp:.3f}\t{data}")
+        self.timestamps.append(self.timestamp)
+        self.data.append(data)
         self._lock.release()
+        self.timestamp += 1 / self.rate
 
     def update(self):
         """Update the node output."""
         self._lock.acquire()
+        index = pd.to_datetime(self.timestamps, unit="s")
+        self.o.set(self.data, index, meta=self.meta)
+        self.data = []
+        self.timestamps = []
         self._lock.release()
 
     def terminate(self):