ensure that first presenceMap will be fired

AndreKoepke · Nov 1, 2024 · aca66d9 · aca66d9
1 parent b6ece5b
commit aca66d9
Show file tree

Hide file tree

Showing 2 changed files with 2 additions and 1 deletion.
diff --git a/backend/src/main/java/ch/akop/homesystem/services/impl/UserService.java b/backend/src/main/java/ch/akop/homesystem/services/impl/UserService.java
@@ -61,6 +61,7 @@ void setupPresenceMap() {
             UserConfig::getName,
             user -> user.getFailedPings() < ALLOWED_FAILS
         ));
+    presenceMap$.onNext(presenceMap);
   }
 
   @ConsumeEvent(value = GENERAL, blocking = true)
@@ -141,6 +142,7 @@ private boolean canPingIp(UserConfig userConfig) {
 
   public Flowable<Boolean> isAnyoneAtHome$() {
     return presenceMap$
+        .distinctUntilChanged()
         .subscribeOn(RxHelper.blockingScheduler(vertx))
         .map(presenceMapUpdate -> presenceMapUpdate.values().stream().anyMatch(isAtHome -> isAtHome))
         .toFlowable(BackpressureStrategy.ERROR);

diff --git a/backend/src/main/java/ch/akop/homesystem/states/NormalState.java b/backend/src/main/java/ch/akop/homesystem/states/NormalState.java
@@ -120,7 +120,6 @@ public void entered(boolean quiet) {
 
     super.disposeWhenClosed(userService.isAnyoneAtHome$()
         .skip(1)
-        .distinctUntilChanged()
         .filter(anyOneAtHome -> deviceService.isAnyLightOn())
         .delay(10, TimeUnit.MINUTES)
         .switchMap(this::shouldLightsTurnedOff)