persist.go RawHistoryFolder

1package core
2
3import (
4	"context"
5	"fmt"
6	"maps"
7	"slices"
8	"time"
9
10	"github.com/bnema/neferwl/internal/ports"
11)
12
13// PersistScales saves the scales set by scale binds once they settle for
14// debounce, so a burst of Cmd+= presses writes the config once, and tells
15// the user through notes. It runs until ctx ends; pending scales are then
16// dropped.
17func PersistScales(ctx context.Context, changes <-chan ports.ScaleChanged, store ports.OutputScaleStore, notes ports.Notifier, clock ports.Clock, debounce time.Duration) {
18	pending := map[string]float64{}
19	timer := clock.NewTimer(debounce)
20	timer.Stop()
21	for {
22		select {
23		case <-ctx.Done():
24			timer.Stop()
25			return
26		case ev := <-changes:
27			pending[ev.Output] = ev.Scale
28			timer.Reset(debounce)
29		case <-timer.C():
30			// Sorted: several outputs save and notify in a stable order.
31			for _, name := range slices.Sorted(maps.Keys(pending)) {
32				scale := pending[name]
33				if err := store.SaveOutputScale(name, scale); err != nil {
34					notes.Notify(name+" scale not saved", err.Error())
35					continue
36				}
37				notes.Notify(name+" scale saved", fmt.Sprintf("Scale %.4g is kept after restart", scale))
38			}
39			clear(pending)
40		}
41	}
42}