Add GNUmakefile for test

GNUmakefile

@@ -0,0 +1,26 @@
+# Standard stuff
+
+.SUFFIXES:
+
+MAKEFLAGS+= --no-builtin-rules
+MAKEFLAGS+= --warn-undefined-variables
+
+.PHONY: all format test lint
+
+all: build
+	ninja -C build
+
+build: CMakeLists.txt
+	cmake -S . -B $@
+
+lint: build
+	run-clang-tidy -p build -check='-*,readability-use-std-min-max,misc-include-cleaner' -fix rrcp_*.cpp
+
+test: all
+	-killall blocking_tcp_echo_server
+	build/blocking_tcp_echo_server 8000 &
+	cat rrcp.txt | build/rrcp_client localhost 8000
+
+format: .clang-format
+	git ls-files ::*.cpp ::*.hpp | xargs clang-format -i
+	gersemi -i CMakeLists.txt

rrcp.txt

@@ -0,0 +1,22 @@
+// GET-request TU SET-request TU GET-request TU:
+GFRQ;MOD SFRQ10000000;MOD13;BW80000 GFRQ;MOD
+// GET-response TU SET-response TU GET-response TU:
+gFRQ18000000;MOD12 s5BW gFRQ18000000;MOD12
+// NOTE:
+// There is an error within the BW command, the complete SET-request TU is cancelled.
+// The GET-request TU is replied by the corresponding GET-response TU.
+M:WF.FF.Main 123456 T Octet 1   // without Logical Address:
+M:WF.FF.Main 123456 t
+M:Bit L:1 123456 G Octet
+M:Audio SOctet    // without optionl parts
+M:Radio SString"\rhallo\tworld\n"
+M:Log SStruct1,-1,3.14   // multiple parameters
+M:MultilCmd S Octet 1;Long-1;String"hallo world\n";Struct 1,+1,+3.14   // multiple commands's
+M:Test 123456 S FREQ123456;MOD12;LOGIN"user","pasword" G FREQ;MOD;STATUS    // multiple TU
+M:Test gFREQ180000;MOD12 s5BW gFREQ180000;MOD12;STATUS"Running"   // TU partly failed
+M:eRADIO S FREQUENCY 123456789
+E:12  // MU error
+M:RADIO T FREQUENCY 1
+M:RADIO t
+M:RADIO d FREQUENCY 123456789 // trap data
+M:Utility S Binary #36:AAECAwQFBgcICQoLDA0OD8KAwoHDvsO/Cg==   // bas64 encoded binary data

rrcp_client.cpp

@@ -14,10 +14,11 @@
 #include <boost/asio/ip/tcp.hpp>
 #include <boost/asio/post.hpp>
 #include <boost/asio/read.hpp>
-#include <boost/asio/steady_timer.hpp>
 #include <boost/asio/write.hpp>
-#include <boost/system/error_code.hpp>
+#include <boost/system/detail/error_code.hpp>
+#include <chrono>
 #include <cstdlib>
+#include <cstring>
 #include <deque>
 #include <exception>
 #include <iostream>
@@ -153,15 +154,20 @@ int main(int argc, char* argv[])
 
     std::thread t([&io_context]() { io_context.run(); });
 
+    std::this_thread::sleep_for(std::chrono::seconds(1));
+    int i{};
     char line[rrcp_message::max_msg_length + 1];
     while (std::cin.getline(line, rrcp_message::max_msg_length + 1))
     {
+      std::cout << ++i << line << '\n';
+
       rrcp_message msg;
       msg.body_length(std::strlen(line));
       std::memcpy(msg.body(), line, msg.body_length());
       msg.encode_header();
       c.write(msg);
     }
+    std::this_thread::sleep_for(std::chrono::seconds(1));
 
     c.close();
     t.join();

rrcp_helper.cpp

@@ -1,5 +1,8 @@
 #include "rrcp_helper.hpp"
 
+#include <cstddef>
+#include <string>
+
 constexpr const char ESC = 0x1B;
 constexpr const char REPLACE_LF = 0x01;
 constexpr const char REPLACE_CR = 0x02;

rrcp_message.hpp

@@ -11,9 +11,11 @@
 #ifndef RRCP_MESSAGE_HPP
 #define RRCP_MESSAGE_HPP
 
+#include <algorithm>
 #include <cstdio>
 #include <cstdlib>
 #include <cstring>
+#include <string>
 
 class rrcp_message
 {
@@ -23,32 +25,34 @@ class rrcp_message
 
   rrcp_message() {}
 
-  [[nodiscard]] const char* data() const { return data_; }
+  [[nodiscard]] const char* data() const { return data_.data(); }
 
-  char* data() { return data_; }
+  char* data() { return data_.data(); }
 
   [[nodiscard]] std::size_t length() const
   {
     return header_length + msg_length_;
   }
 
-  [[nodiscard]] const char* body() const { return data_ + header_length; }
+  [[nodiscard]] const char* body() const
+  {
+    return data_.data() + header_length;
+  }
 
-  char* body() { return data_ + header_length; }
+  char* body() { return data_.data() + header_length; }
 
   [[nodiscard]] std::size_t body_length() const { return msg_length_; }
 
   void body_length(std::size_t new_length)
   {
     msg_length_ = new_length;
-    if (msg_length_ > max_msg_length) msg_length_ = max_msg_length;
+    msg_length_ = std::min(msg_length_, max_msg_length);
   }
 
   bool decode_header()
   {
-    char header[header_length + 1] = "";
-    std::strncat(header, data_, header_length);
-    msg_length_ = std::atoi(header);
+    std::string header(data_.data(), header_length);
+    msg_length_ = std::stoi(header);
     if (msg_length_ > max_msg_length)
     {
       msg_length_ = 0;
@@ -59,14 +63,14 @@ class rrcp_message
 
   void encode_header()
   {
-    char header[header_length + 1] = "";
-    std::snprintf(
-        header, header_length + 1, "%4d", static_cast< int >(msg_length_));
-    std::memcpy(data_, header, header_length);
+    std::array< char, header_length + 1 > header;
+    std::snprintf(header.data(), header_length + 1, "%4d",
+        static_cast< int >(msg_length_));
+    std::memcpy(data_.data(), header.data(), header_length);
   }
 
  private:
-  char data_[header_length + max_msg_length];
+  std::array< char, header_length + max_msg_length > data_;
   std::size_t msg_length_{0};
 };