Robust Arduino ADC reader for Wolfram Language

adc.ino

int requestedSamples = -1;

void setup() {
  Serial.begin(115200);
  while (!Serial) {}
}

void loop() {
  if (requestedSamples == 0) {
     requestedSamples = -1;
     Serial.write((uint8_t)(0x0)); // Start
     return;
  }
  
  if (requestedSamples == -1 && Serial.available() >= 2) {
    uint8_t c0 = Serial.read(), c1 = Serial.read();
    requestedSamples = (int)c0 + (int)(c1 << 8);
    while (Serial.available() > 0) (void)Serial.read(); // clean up garbage
    Serial.write((uint8_t)(0xC0)); // End
  }
  
  if (requestedSamples == -1) return;

  uint16_t v = analogRead(A0);
  
  Serial.write((uint8_t)(((v >> 0) & 0xF)  | 0x40));
  Serial.write((uint8_t)(((v >> 4) & 0xF)  | 0x40));
  Serial.write((uint8_t)(((v >> 8) & 0xF)  | 0x40));
  Serial.write((uint8_t)(((v >> 12) & 0xF) | 0x40));
  
  requestedSamples--;
}

path = "/dev/cu.usbserial-140";

Panel[{
  Refresh[If[DeviceOpenQ[dev]//TrueQ, Green, Red], 1],
  Button["Connect", Print["Connecting..."]; dev = DeviceOpen["Serial", {path, "BaudRate"->115200}]],
  Button["Close", dev = DeviceClose[dev]]
} // Row, Style["Control Center", 11, FontFamily->"system-ui"]]

readDevice[dev_, packetSize_:64] := Module[{},
  If[!(DeviceOpenQ[dev]//TrueQ), Return[$Failed, Module]];
  
  DeviceReadBuffer[dev];
  DeviceWrite[dev, ExportByteArray[packetSize, "UnsignedInteger16"]//Normal];
  With[{result = TimeConstrained[DeviceReadBuffer[dev, packetSize 4 + 2], 0.5, $Failed]},
  
    If[FailureQ[result],   Return[$Failed, Module]];
    If[result[[1]] != 192, Return[$Failed, Module]];
    If[result[[-1]] != 0,  Return[$Failed, Module]];

    With[{payload = result[[2;;-2]]},
      If[Sum[BitGet[b, 6], {b, payload}] != packetSize 4, Return[$Failed, Module]];
    
      Map[Function[p,
        BitClear[p[[1]], 6] + BitShiftLeft[BitClear[p[[2]], 6], 4] + BitShiftLeft[BitClear[p[[3]],6], 8] + BitShiftLeft[BitClear[p[[4]],6], 12]
      ], Partition[payload, 4]]
    ]
  ]
]

readDevice[dev, 128] // ListLinePlot

(*VB[*)(FrontEndRef["6377d64f-10b9-4bb8-8f96-fe24a9672540"])(*,*)(*"1:eJxTTMoPSmNkYGAoZgESHvk5KRCeEJBwK8rPK3HNS3GtSE0uLUlMykkNVgEKmxmbm6eYmaTpGhokWeqaJCVZ6FqkWZrppqUamSRampkbmZoYAAB90BUq"*)(*]VB*)

Refresh[ListLinePlot[With[{d = readDevice[dev, 64]}, If[!FailureQ[d],
  d, Table[0, {64}]
]], PlotRange->{{1,64}, {0,1025}}], 0.1]

buffer = Table[0, {2048}];
accumulate[dev_] := With[{data = readDevice[dev, 128]},
  If[!FailureQ[data],
    buffer = RotateLeft[buffer, 128];
    buffer[[2048 - 127 ;;]] = data;
  ];
];

TaskRemove[task] // Quiet;
task = SetInterval[
  accumulate[dev];
  EventFire["scopeUpdate", buffer];
, Quantity[100, "Milliseconds"]];

TaskRemove[task] // Quiet;

With[{
  event = EventClone["scopeUpdate"],
  data = Unique[],
  avg = Unique[]
},
  data = Table[{i,0}, {i,2048}];
  avg = Table[{i,0}, {i,2048}];
  
  EventHandler[ResultCell[], {"Destroy" -> Function[Null,
    EventRemove[event];
  ]}];

  EventHandler[event, Function[d,
    data = MapIndexed[Function[{val, i}, {i[[1]], val}], d];
    avg = MapIndexed[Function[{val, i}, {i[[1]], val}], MovingAverage[d, 16]];
  ]];

  Legended[Graphics[{
    (*VB[*)(RGBColor[0.368417, 0.506779, 0.709798])(*,*)(*"1:eJxTTMoPSmNiYGAo5gUSYZmp5S6pyflFiSX5RcEsQBHn4PCQNGaQPAeQCHJ3cs7PyS8qKpg26anKlOv2RYbTXk7vMH9gX3S8ZYb3qm3P7AF5kRs6"*)(*]VB*), Line[data // Offload], 
    (*VB[*)(RGBColor[0.880722, 0.611041, 0.142051])(*,*)(*"1:eJxTTMoPSmNiYGAo5gUSYZmp5S6pyflFiSX5RcEsQBHn4PCQNGaQPAeQCHJ3cs7PyS8q8jkS/fy+3hv7on/VH24t7X1sX7R51jr1XXqH7AGSkRxD"*)(*]VB*), Line[avg // Offload]
  }, 
    Frame->True, Axes->True,
    PlotRange->{{1,2048}, {0,1024}}, AspectRatio->0.5
  ], SwatchLegend[{(*VB[*)(RGBColor[0.368417, 0.506779, 0.709798])(*,*)(*"1:eJxTTMoPSmNiYGAo5gUSYZmp5S6pyflFiSX5RcEsQBHn4PCQNGaQPAeQCHJ3cs7PyS8qKpg26anKlOv2RYbTXk7vMH9gX3S8ZYb3qm3P7AF5kRs6"*)(*]VB*), (*VB[*)(RGBColor[0.880722, 0.611041, 0.142051])(*,*)(*"1:eJxTTMoPSmNiYGAo5gUSYZmp5S6pyflFiSX5RcEsQBHn4PCQNGaQPAeQCHJ3cs7PyS8q8jkS/fy+3hv7on/VH24t7X1sX7R51jr1XXqH7AGSkRxD"*)(*]VB*)}, {"Actual", "Moving Avg. (16)"}]]
]

With[{
  event = EventClone["scopeUpdate"],
  data = Unique[]
},
  data = Table[{i,0}, {i,127}];
  
  EventHandler[ResultCell[], {"Destroy" -> Function[Null,
    EventRemove[event];
  ]}];

  EventHandler[event, Function[d,
    data = MapIndexed[Function[{val, i}, {i[[1]], val}], 
      Take[Drop[Fourier[Take[d, -256]]//Abs,1], 127]
      (* drop DC and the conjugated half *)
    ];
  ]];

  Graphics[{
    ColorData[97][3], Line[data // Offload]
  }, 
    Frame->True, Axes->True,
    PlotRange->{{1,127}, {0,1024}}, AspectRatio->0.5
  ]
]