Read values from VESC motor controller

Change-Id: Icaad5bd270827f1fa1b22a77d0cd0e23dbf999e5

examples/BUILD.bazel

@@ -3,7 +3,10 @@ load("@rules_cc//cc:defs.bzl", "cc_binary")
 cc_binary(
     name = "vesc_cmd",
     srcs = ["vesc_cmd.cpp"],
-    deps = ["//third_party/vesc_uart"],
+    deps = [
+        "//third_party/vesc_uart",
+        "@fmt",
+    ],
 )
 
 cc_binary(

examples/vesc_cmd.cpp

@@ -1,8 +1,47 @@
 #include "third_party/vesc_uart/VescUart.h"
+//#include ""
+
+#include <cstdint>
+#include <fmt/core.h>
+#include <fmt/ranges.h>
+#include <chrono>
+#include <thread>
+#include <array>
+#include <span>
+
+auto buffer = std::array<std::uint8_t, 256>{};
+
+auto read_payload(std::span<std::uint8_t> buf) -> void
+{
+  static constexpr auto serial_device = 0;
+
+  static auto cmd_get_values = std::uint8_t{ COMM_GET_VALUES };
+  ::PackSendPayload(&cmd_get_values, sizeof(cmd_get_values), serial_device);
+
+  {
+    const auto version = Serial.read();
+    assert(version == 2 and "only version 2 is handled");
+  }
+
+  const auto payload_size = Serial.read();
+  static constexpr auto footer_size = 3;
+
+  fmt::print("payload_size: {}\n", payload_size);
+
+  const auto message = std::span{buf.data(), std::size_t(payload_size + footer_size)};
+  Serial.read(message);
+  fmt::print("{::#x}\n", message);
+}
 
 auto main() -> int
 {
   ::VescUartSetCurrent(1.0F);
 
+  while (true) {
+    read_payload({buffer.data(), buffer.size()});
+
+    std::this_thread::sleep_for(std::chrono::milliseconds{100});
+  }
+
   return 0;
 }

uart_abstraction/HardwareSerial.hpp

@@ -1,9 +1,10 @@
-// Fake API for UART read/write.
+// API for UART read/write.
 
 #pragma once
 
 #include <cstddef>
 #include <cstdint>
+#include <span>
 
 struct HardwareSerial
 {
@@ -14,6 +15,8 @@ struct HardwareSerial
 
   auto read() const -> std::uint8_t;
 
+  auto read(std::span<std::uint8_t> buffer) const -> void;
+
   auto write(std::uint8_t* buffer, std::size_t size) const -> void;
 };
 

uart_abstraction/rpi/HardwareSerial.cpp

@@ -65,6 +65,17 @@ auto HardwareSerial::read() const -> std::uint8_t
   return static_cast<std::uint8_t>(c);
 }
 
+// NOLINTNEXTLINE(readability-convert-member-functions-to-static)
+auto HardwareSerial::read(std::span<std::uint8_t> buf) const -> void
+{
+  auto buf_ = asio::buffer(buf.data(), buf.size());
+
+  while (buf_.size() != 0) {
+    // NOLINTNEXTLINE(bugprone-unchecked-optional-access)
+    buf_ += underlying->read_some(buf_);
+  }
+}
+
 // NOLINTNEXTLINE(readability-convert-member-functions-to-static)
 auto HardwareSerial::write(std::uint8_t* buffer, std::size_t size) const -> void
 {