Functional RunIn Mock and Time Travel functionality (#299)

* Added State() Functionality to RxAppMock

* Added Mock for RunIn

Co-authored-by: Eugene Niemand <[email protected]>

Author: eugeneniemand

src/Fakes/NetDaemon.Fakes/NetDaemon.Fakes.csproj

@@ -28,6 +28,7 @@
     <ProjectReference Include="..\..\Daemon\NetDaemon.Daemon\NetDaemon.Daemon.csproj" />
   </ItemGroup>
     <ItemGroup>
+    <PackageReference Include="Microsoft.Reactive.Testing" Version="5.0.0" />
     <PackageReference Include="Moq" Version="4.16.0" />
     <PackageReference Include="xunit" Version="2.4.1" />
     <PackageReference Include="xunit.runner.visualstudio" Version="2.4.3">

src/Fakes/NetDaemon.Fakes/RxAppMock.cs

@@ -7,6 +7,7 @@
 using System.Collections.Generic;
 using System.Linq;
 using System.Reactive.Linq;
+using Microsoft.Reactive.Testing;
 
 namespace NetDaemon.Daemon.Fakes
 {
@@ -27,10 +28,15 @@ public class RxAppMock : Mock<INetDaemonRxApp>
         public ObservableBase<(EntityState Old, EntityState New)> StateChangesObservable { get; }
 
         /// <summary>
-        ///     Observalbe fake events
+        ///     Observable fake events
         /// </summary>
         public ObservableBase<RxEvent> EventChangesObservable { get; }
 
+        /// <summary>
+        /// This is a Scheduler to support time travel for Observable Timer and Interval 
+        /// </summary>
+        public TestScheduler TestScheduler { get; } = new();
+
         /// <summary>
         ///     Default constructor
         /// </summary>
@@ -76,6 +82,13 @@ public RxAppMock()
                 m.Setup(e => e.TurnOff(It.IsAny<object?>())).Throws(new NotImplementedException());
                 return m.Object;
             });
+
+            Setup(s => s.RunIn(It.IsAny<TimeSpan>(), It.IsAny<Action>()))
+                .Callback<TimeSpan, Action>((span, action) =>
+                {
+                    Observable.Timer(span, TestScheduler)
+                        .Subscribe(_ => action());
+                });
         }
 
         private void UpdateMockState(string[] entityIds, string newState, object? attributes)

tests/NetDaemon.Daemon.Tests/FakesTests/FakeMockableApp.cs

@@ -76,6 +76,8 @@ public void Initialize()
                     if (_app.State("sensor.some_other_entity")?.State == "on")
                         _app.Entity("light.state_light").TurnOn();
                 });
+
+            _app.RunIn(TimeSpan.FromMilliseconds(100), () => _app.Entity("binary_sensor.fake_run_in_happened").TurnOn());
         }
 
     }

tests/NetDaemon.Daemon.Tests/FakesTests/RxMockTests.cs

@@ -128,6 +128,20 @@ public void TestFakeMockableBinarySensorAppEntitiesFalse()
             VerifyEntityTurnOn("light.kitchen", times: Times.Never());
         }
 
+        [Fact]
+        public void TestFakeRunIn()
+        {
+            // ARRANGE
+            FakeMockableAppImplementation app = new(Object);
+            app.Initialize();
+
+            // ACT
+            TestScheduler.AdvanceBy(TimeSpan.FromMilliseconds(100).Ticks);
+
+            // ASSERT
+            VerifyEntityTurnOn("binary_sensor.fake_run_in_happened", times: Times.Once());
+        }
+
         [Fact]
         public void TestFakeEventTurnsOnLight()
         {