remove expired persisted states

pkg/app/dispatcher.go

@@ -104,6 +104,15 @@ func NewClientTester(n UI) ClientDispatcher {
 	e := &engine{
 		ActionHandlers: actionHandlers,
 	}
+
+	if IsClient {
+		e.LocalStorage = newJSStorage("localStorage")
+		e.LocalStorage.Clear()
+
+		e.SessionStorage = newJSStorage("sessionStorage")
+		e.SessionStorage.Clear()
+	}
+
 	e.init()
 	e.Mount(n)
 	e.Consume()

pkg/app/engine.go

@@ -323,6 +323,7 @@ func (e *engine) start(ctx context.Context) {
 		currentFrameDuration := frameDuration
 		frames := time.NewTicker(frameDuration)
 
+		e.states.Cleanup()
 		cleanups := time.NewTicker(time.Minute)
 		defer cleanups.Stop()
 

pkg/app/state.go

@@ -286,6 +286,7 @@ func (s *store) Cleanup() {
 
 	s.removeUnusedObservers()
 	s.expireExpiredValues()
+	s.expireExpriredPersistentValues()
 }
 
 func (s *store) Close() {
@@ -371,6 +372,29 @@ func (s *store) expireExpiredValues() {
 	}
 }
 
+func (s *store) expireExpriredPersistentValues() {
+	object := Window().Get("Object")
+	if !object.Truthy() {
+		return
+	}
+
+	keys := object.Call("keys", Window().Get("localStorage"))
+	for i, l := 0, keys.Get("length").Int(); i < l; i++ {
+		key := keys.Index(i).String()
+
+		var state persistentState
+		s.disp.getLocalStorage().Get(key, &state)
+
+		if state.EncryptedValue == nil && state.Value == nil && state.ExpiresAt == (time.Time{}) {
+			continue
+		}
+
+		if state.isExpired(time.Now()) {
+			s.disp.getLocalStorage().Del(key)
+		}
+	}
+}
+
 func (s *store) expire(key string, state State) State {
 	s.disp.getLocalStorage().Del(key)
 	state.value = nil

pkg/app/state_test.go

@@ -576,3 +576,43 @@ type copyTester struct {
 	slice      []int
 	mapp       map[string]int
 }
+
+func TestExpireExpriredPersistentValues(t *testing.T) {
+	if IsServer {
+		t.Skip()
+	}
+
+	d := NewClientTester(&foo{})
+	defer d.Close()
+	localStorage := d.getLocalStorage()
+
+	s := newStore(d)
+	defer s.Close()
+
+	t.Run("non expired state is not removed", func(t *testing.T) {
+		localStorage.Clear()
+		s.setPersistent("/hello", false, time.Now().Add(time.Minute), "hello")
+		require.Equal(t, 1, localStorage.Len())
+
+		s.expireExpriredPersistentValues()
+		require.Equal(t, 1, localStorage.Len())
+	})
+
+	t.Run("expired state is removed", func(t *testing.T) {
+		localStorage.Clear()
+		s.setPersistent("/bye", false, time.Now().Add(-time.Minute), "bye")
+		require.Equal(t, 1, localStorage.Len())
+
+		s.expireExpriredPersistentValues()
+		require.Equal(t, 0, localStorage.Len())
+	})
+
+	t.Run("non state value is not removed", func(t *testing.T) {
+		localStorage.Clear()
+		localStorage.Set("/hi", "hi")
+		require.Equal(t, 1, localStorage.Len())
+
+		s.expireExpriredPersistentValues()
+		require.Equal(t, 1, localStorage.Len())
+	})
+}