From 94e738992ca8a12c2d9bb7bdeeaab4713543773e Mon Sep 17 00:00:00 2001
From: SnakeOnex <romakcz@gmail.com>
Date: Sun, 30 Mar 2025 23:15:39 +0200
Subject: [PATCH] data value checking in TestPubSubSockets::test_conflate
 (#644)

* check each message value in test_messaging

* check correctness with conflate False
---
 msgq/tests/test_messaging.py | 4 +++-
 1 file changed, 3 insertions(+), 1 deletion(-)

diff --git a/msgq/tests/test_messaging.py b/msgq/tests/test_messaging.py
index 40dfd7f..b3fee36 100644
--- a/msgq/tests/test_messaging.py
+++ b/msgq/tests/test_messaging.py
@@ -52,9 +52,11 @@ class TestPubSubSockets:
         recvd_msgs = msgq.drain_sock_raw(sub_sock)
         if conflate:
           assert len(recvd_msgs) == 1
+          assert recvd_msgs[0] == sent_msgs[-1]
         else:
-          # TODO: compare actual data
           assert len(recvd_msgs) == len(sent_msgs)
+          for rec_msg, sent_msg in zip(recvd_msgs, sent_msgs):
+            assert rec_msg == sent_msg
 
   def test_receive_timeout(self):
     sock = random_sock()