fix(repeater): specify a default ping interval to 10s (#116)

closes #115
NeuraLegion · Dec 13, 2022 · 57add9d · 57add9d
1 parent 82ade0c
commit 57add9d
Show file tree

Hide file tree

Showing 2 changed files with 3 additions and 0 deletions.
diff --git a/src/SecTester.Repeater/Repeater.cs b/src/SecTester.Repeater/Repeater.cs
@@ -12,6 +12,7 @@ namespace SecTester.Repeater;
 
 public class Repeater : IRepeater
 {
+  private static readonly TimeSpan DefaultPingInterval = TimeSpan.FromSeconds(10);
   private readonly EventBus _eventBus;
   private readonly TimerProvider _heartbeat;
   private readonly ILogger _logger;
@@ -72,6 +73,7 @@ private void SubscribeToEvents()
   private async Task SchedulePing()
   {
     await SendStatus(RepeaterStatus.Connected).ConfigureAwait(false);
+    _heartbeat.Interval = DefaultPingInterval.TotalMilliseconds;
     _heartbeat.Elapsed += async (_, _) => await SendStatus(RepeaterStatus.Connected).ConfigureAwait(false);
     _heartbeat.Start();
   }

diff --git a/test/SecTester.Repeater.Tests/RepeaterTests.cs b/test/SecTester.Repeater.Tests/RepeaterTests.cs
@@ -107,6 +107,7 @@ public async Task Start_SendsPingPeriodically()
     await _sut.Start();
 
     // assert
+    _timerProvider.Interval.Should().BeGreaterOrEqualTo(10_000);
     _timerProvider.Elapsed += Raise.Event<ElapsedEventHandler>(new object(), elapsedEventArgs);
     await _eventBus.Received(2).Publish(Arg.Is<RepeaterStatusEvent>(x => x.Status == RepeaterStatus.Connected && x.RepeaterId == Id));
   }