leitor-cli - add timeout, add log policy stdout default

Author: RGNagel

app/leitor/leitor-cli.cpp

@@ -6,17 +6,18 @@
 
 using namespace NBR14522;
 
+#define TIMEOUT_SEM_RESPOSTA_MS 5000
+
 template <typename T, size_t N>
 void print_arr_hex(const std::array<T, N>& arr) {
     for (const auto i : arr)
         printf("%02X", (int)i);
 }
 
-// TODO
 void print_usage() {
     printf(
-        "Este programa recebe dois argumentos:\n\n"
-        "1 - porta serial que o medidor está conectado. Em sistemas unix será\n" 
+        "Este programa recebe dois argumentos obrigatórios:\n\n"
+        "1 - porta serial que o medidor está conectado. Em sistemas unix será\n"
         "um pseudo-arquivo localizado em /dev/, por exemplo: /dev/ttyUSB0,\n"
         "/dev/ttyUSB1, etc. No Windows: COM1, COM2, etc\n\n"
 
@@ -31,8 +32,7 @@ void print_usage() {
         "./leitor-cli /dev/ttyUSB0 14\n"
         "./leitor-cli /dev/ttyUSB0 14123456\n"
         "./leitor-cli /dev/ttyUSB0 20\n"
-        "./leitor-cli /dev/ttyUSB0 204455660101\n\n"
-    );
+        "./leitor-cli /dev/ttyUSB0 204455660101\n\n");
 }
 
 std::vector<byte_t> get_hex_bytes(const std::string& hexbytes) {
@@ -78,15 +78,18 @@ int main(int argc, char* argv[]) {
     }
 
     for (auto& comando : comandos) {
-        setCRC(comando, CRC16(comando.data(), comando.size()-2));
+        setCRC(comando, CRC16(comando.data(), comando.size() - 2));
         printf("\nComando:\n");
         print_arr_hex(comando);
 
         printf("\nResposta(s):\n");
-        leitor.leitura(comando, [&](const resposta_t& rsp) {
-            print_arr_hex(rsp);
-            printf("\n");
-        });
+        leitor.leitura(
+            comando,
+            [&](const resposta_t& rsp) {
+                print_arr_hex(rsp);
+                printf("\n");
+            },
+            TIMEOUT_SEM_RESPOSTA_MS);
     }
 
     printf("\n");

include/leitor.h

@@ -2,10 +2,13 @@
 
 #include <functional>
 #include <leitor_fsm.h>
+#include <log_policy.h>
 #include <serial/serial_policy_win_unix.h>
 #include <timer/timer_policy_win_unix.h>
 
-template <class TimerPolicy, class SerialPolicy> class Leitor {
+template <class TimerPolicy, class SerialPolicy,
+          class LogPolicy = LogPolicyStdout>
+class Leitor {
 
     using FSM = LeitorFSM<TimerPolicy, SerialPolicy>;
 
@@ -33,7 +36,9 @@ template <class TimerPolicy, class SerialPolicy> class Leitor {
         });
 
         while (true) {
-            switch (_leitor.processaEstado()) {
+            typename FSM::estado_t estado = _leitor.processaEstado();
+
+            switch (estado) {
             case FSM::estado_t::Dessincronizado:
             case FSM::estado_t::Sincronizado:
             case FSM::estado_t::ComandoTransmitido:
@@ -44,22 +49,42 @@ template <class TimerPolicy, class SerialPolicy> class Leitor {
                 if (_leitor.status() == FSM::status_t::Sucesso) {
                     return true;
                 } else {
-                    printf("%s\n", _status2verbose(_leitor.status()));
+                    LogPolicy::log("Processo falhou. Status: %s\n",
+                                   _status2verbose(_leitor.status()));
                     return false;
                 }
                 break;
             }
 
             if (timeout_resposta_ms && leituraDeadline.timedOut()) {
-                printf("O processo de leitura excedeu o tempo informado pelo "
-                       "usuário (%i ms) sem receber nenhuma resposta\n",
-                       timeout_resposta_ms);
+                LogPolicy::log(
+                    "O processo de leitura excedeu o tempo informado pelo "
+                    "usuário (%i ms) sem receber nenhuma resposta. Estado: "
+                    "%s\n",
+                    timeout_resposta_ms, _estado2string(estado));
                 return false;
             }
         }
     }
 
   private:
+    const char* _estado2string(const typename FSM::estado_t estado) {
+        switch (estado) {
+        case FSM::estado_t::Dessincronizado:
+            return "Dessincronizado";
+        case FSM::estado_t::Sincronizado:
+            return "Sincronizado";
+        case FSM::estado_t::ComandoTransmitido:
+            return "Comando Transmitido";
+        case FSM::estado_t::AtrasoDeSequenciaRecebido:
+            return "Atraso de Sequência Recebido";
+        case FSM::estado_t::CodigoRecebido:
+            return "Código Recebido";
+        case FSM::estado_t::AguardaNovoComando:
+            return "Aguarda Novo Comando";
+        }
+        return "";
+    }
     const char* _status2verbose(const typename FSM::status_t status) {
         switch (status) {
         case FSM::status_t::Sucesso:

include/log_policy.h

@@ -8,8 +8,8 @@ class LogPolicyNull {
 
 class LogPolicyStdout {
   public:
-    static void log(const std::string& input) { std::cout << input; }
-    // static void log(...) {
-    //   fprintf(stdout, __VA_ARGS__);
-    // }
+    template <typename... Args>
+    static void log(char const* const format, Args const&... args) noexcept {
+        printf(format, args...);
+    }
 };