Special Case 0 to mean no caching at all (#10221)

libs/common/src/platform/state/implementations/default-single-user-state.spec.ts

@@ -100,6 +100,24 @@ describe("DefaultSingleUserState", () => {
       );
       expect(state).toBeTruthy();
     });
+
+    it("should go to disk each subscription if a cleanupDelayMs of 0 is given", async () => {
+      const state = new DefaultSingleUserState(
+        userId,
+        new UserKeyDefinition(testStateDefinition, "test", {
+          cleanupDelayMs: 0,
+          deserializer: TestState.fromJSON,
+          clearOn: [],
+        }),
+        diskStorageService,
+        stateEventRegistrarService,
+      );
+
+      await firstValueFrom(state.state$);
+      await firstValueFrom(state.state$);
+
+      expect(diskStorageService.mock.get).toHaveBeenCalledTimes(2);
+    });
   });
 
   describe("combinedState$", () => {

libs/common/src/platform/state/implementations/state-base.ts

@@ -48,15 +48,22 @@ export abstract class StateBase<T, KeyDef extends KeyDefinitionRequirements<T>>
       }),
     );
 
-    this.state$ = merge(
+    let state$ = merge(
       defer(() => getStoredValue(key, storageService, keyDefinition.deserializer)),
       storageUpdate$,
-    ).pipe(
-      share({
-        connector: () => new ReplaySubject(1),
-        resetOnRefCountZero: () => timer(keyDefinition.cleanupDelayMs),
-      }),
     );
+
+    // If 0 cleanup is chosen, treat this as absolutely no cache
+    if (keyDefinition.cleanupDelayMs !== 0) {
+      state$ = state$.pipe(
+        share({
+          connector: () => new ReplaySubject(1),
+          resetOnRefCountZero: () => timer(keyDefinition.cleanupDelayMs),
+        }),
+      );
+    }
+
+    this.state$ = state$;
   }
 
   async update<TCombine>(