From 19310377ff6917b23cb43f8970b8355f725c5e17 Mon Sep 17 00:00:00 2001
From: Pascal Serrarens <pse@pale.blue>
Date: Thu, 1 May 2025 14:28:03 +0200
Subject: [PATCH] Added participant tests

---
 test/participant_test.cc | 147 ++++++++++++++-------------------------
 1 file changed, 54 insertions(+), 93 deletions(-)

diff --git a/test/participant_test.cc b/test/participant_test.cc
index c826863..42c686b 100644
--- a/test/participant_test.cc
+++ b/test/participant_test.cc
@@ -4,111 +4,72 @@
 // not supported using Visual Studio 2022 compiler...
 #include <gtest/gtest.h>
 
-#include <chrono>
-#include <thread>
-// #include <ws2tcpip.h>
-
-#include "Participant.h"
 #include "Participants/SiteServer.h"
 #include "Thing.h"
 
 using namespace RoboidControl;
 
-// Function to get the current time in milliseconds as unsigned long
-unsigned long get_time_ms() {
-  auto now = std::chrono::steady_clock::now();
-  auto ms = std::chrono::duration_cast<std::chrono::milliseconds>(
-      now.time_since_epoch());
-  return static_cast<unsigned long>(ms.count());
+TEST(Participant, Participant) {
+  ParticipantUDP* participant = new ParticipantUDP("127.0.0.1", 7682);
+
+  unsigned long milliseconds = Thing::GetTimeMs();
+  unsigned long startTime = milliseconds;
+  while (milliseconds < startTime + 7000) {
+    participant->Update(milliseconds);
+    
+    std::this_thread::sleep_for(std::chrono::milliseconds(100));
+    milliseconds = Thing::GetTimeMs();
+  }
+  SUCCEED();
 }
 
-// class RoboidControlSuite : public ::testing::test {
-//   TEST_F(RoboidControlSuite, HiddenParticipant) {
-//     Thing thing = Thing();
-  
-//     unsigned long milliseconds = get_time_ms();
-//     unsigned long startTime = milliseconds;
-//     while (milliseconds < startTime + 1000) {
-//       Thing.Update(milliseconds);
-  
-//       milliseconds = get_time_ms();
-//     }
-//     ASSERT_EQ(1, 1);
-//   }
-// }
+TEST(Participant, SiteServer) {
+  SiteServer* siteServer = new SiteServer();
 
-class ParticipantSuite : public ::testing::Test {
-protected:
-  // SetUp and TearDown can be used to set up and clean up before/after each
-  // test
-  void SetUp() override {
-    // Initialize test data here
+  unsigned long milliseconds = Thing::GetTimeMs();
+  unsigned long startTime = milliseconds;
+  while (milliseconds < startTime + 7000) {
+    siteServer->Update(milliseconds);
+    
+    std::this_thread::sleep_for(std::chrono::milliseconds(100));
+    milliseconds = Thing::GetTimeMs();
   }
+  SUCCEED();
+}
 
-  void TearDown() override {
-    // Clean up test data here
+TEST(Participant, SiteParticipant) {
+  SiteServer* siteServer = new SiteServer(7681);
+  ParticipantUDP* participant = new ParticipantUDP("127.0.0.1", 7681, 7682);
+
+  unsigned long milliseconds = Thing::GetTimeMs();
+  unsigned long startTime = milliseconds;
+  while (milliseconds < startTime + 7000) {
+    siteServer->Update(milliseconds);
+    participant->Update(milliseconds);
+
+    std::this_thread::sleep_for(std::chrono::milliseconds(100));
+    milliseconds = Thing::GetTimeMs();
   }
-};
+  SUCCEED();
+}
 
+TEST(Participant, ThingMsg) {
+  SiteServer* siteServer = new SiteServer(7681);
+  ParticipantUDP* participant = new ParticipantUDP("127.0.0.1", 7681, 7682);
+  Thing* thing = new Thing(participant);
+  thing->SetName("First Thing");
+  thing->SetModel("https://passer.life/extras/ant.jpg");
+  
+  unsigned long milliseconds = Thing::GetTimeMs();
+  unsigned long startTime = milliseconds;
+  while (milliseconds < startTime + 7000) {
+    siteServer->Update(milliseconds);
+    participant->Update(milliseconds);
 
-
-// TEST_F(ParticipantSuite, ParticipantUDP) {
-//   ParticipantUDP* participant = new ParticipantUDP("127.0.0.1", 7681);
-
-//   unsigned long milliseconds = get_time_ms();
-//   unsigned long startTime = milliseconds;
-//   while (milliseconds < startTime + 1000) {
-//     participant->Update(milliseconds);
-
-//     milliseconds = get_time_ms();
-//   }
-//   ASSERT_EQ(1, 1);
-// }
-
-// TEST_F(ParticipantSuite, SiteServer) {
-//   SiteServer site = SiteServer(7681);
-
-//   unsigned long milliseconds = get_time_ms();
-//   unsigned long startTime = milliseconds;
-//   while (milliseconds < startTime + 1000) {
-//     site.Update(milliseconds);
-
-//     milliseconds = get_time_ms();
-//   }
-//   ASSERT_EQ(1, 1);
-// }
-
-// TEST_F(ParticipantSuite, SiteParticipant) {
-//   SiteServer site = SiteServer(7681);
-//   ParticipantUDP participant = ParticipantUDP("127.0.0.1", 7681);
-
-//   unsigned long milliseconds = get_time_ms();
-//   unsigned long startTime = milliseconds;
-//   while (milliseconds < startTime + 1000) {
-//     site.Update(milliseconds);
-//     participant.Update(milliseconds);
-
-//     std::this_thread::sleep_for(std::chrono::milliseconds(100));
-//     milliseconds = get_time_ms();
-//   }
-//   ASSERT_EQ(1, 1);
-// }
-
-// TEST_F(ParticipantSuite, Thing) {
-//   SiteServer site = SiteServer(7681);
-//   ParticipantUDP participant = ParticipantUDP("127.0.0.1", 7681);
-//   Thing thing = Thing(&participant);
-
-//   unsigned long milliseconds = get_time_ms();
-//   unsigned long startTime = milliseconds;
-//   while (milliseconds < startTime + 1000) {
-//     site.Update(milliseconds);
-//     participant.Update(milliseconds);
-
-//     std::this_thread::sleep_for(std::chrono::milliseconds(100));
-//     milliseconds = get_time_ms();
-//   }
-//   ASSERT_EQ(1, 1);
-// }
+    std::this_thread::sleep_for(std::chrono::milliseconds(100));
+    milliseconds = Thing::GetTimeMs();
+  }
+  SUCCEED();
+}
 
 #endif