[IO][canutils]: add direction support (#1244)

Co-authored-by: Nadhmi JAZI <[email protected]>

Author: jazi007

can/io/canutils.py

@@ -51,7 +51,12 @@ def __iter__(self) -> Generator[Message, None, None]:
                 continue
 
             channel_string: str
-            timestamp_string, channel_string, frame = temp.split()
+            if temp[-2:].lower() in (" r", " t"):
+                timestamp_string, channel_string, frame, is_rx_string = temp.split()
+                is_rx = is_rx_string.strip().lower() == "r"
+            else:
+                timestamp_string, channel_string, frame = temp.split()
+                is_rx = True
             timestamp = float(timestamp_string[1:-1])
             can_id_string, data = frame.split("#", maxsplit=1)
 
@@ -101,6 +106,7 @@ def __iter__(self) -> Generator[Message, None, None]:
                     is_extended_id=is_extended,
                     is_remote_frame=is_remote_frame,
                     is_fd=is_fd,
+                    is_rx=is_rx,
                     bitrate_switch=brs,
                     error_state_indicator=esi,
                     dlc=dlc,
@@ -164,8 +170,13 @@ def on_message_received(self, msg):
         else:
             framestr += " %03X#" % (msg.arbitration_id)
 
+        if msg.is_error_frame:
+            eol = "\n"
+        else:
+            eol = " R\n" if msg.is_rx else " T\n"
+
         if msg.is_remote_frame:
-            framestr += "R\n"
+            framestr += f"R{eol}"
         else:
             if msg.is_fd:
                 fd_flags = 0
@@ -174,6 +185,6 @@ def on_message_received(self, msg):
                 if msg.error_state_indicator:
                     fd_flags |= CANFD_ESI
                 framestr += "#%X" % fd_flags
-            framestr += "%s\n" % (msg.data.hex().upper())
+            framestr += f"{msg.data.hex().upper()}{eol}"
 
         self.file.write(framestr)

test/test_logger.py

@@ -132,7 +132,7 @@ def test_compressed_logfile(self):
         with gzip.open(self.testfile.name, "rt") as testlog:
             last_line = testlog.readlines()[-1]
 
-        self.assertEqual(last_line, "(0.000000) vcan0 00C0FFEE#0019000103010401\n")
+        self.assertEqual(last_line, "(0.000000) vcan0 00C0FFEE#0019000103010401 R\n")
 
     def tearDown(self) -> None:
         self.testfile.close()