aboutsummaryrefslogtreecommitdiffhomepage
path: root/internal/state/util.go
diff options
context:
space:
mode:
authorOphestra <cat@gensokyo.uk>2025-02-14 14:11:02 +0900
committerOphestra <cat@gensokyo.uk>2025-02-14 14:11:02 +0900
commit1f74b636d31e816907ff6adbf1472f9e0fb37ab7 (patch)
tree5aecb9dbf912d5e2fae089f88adeeeb49bb01103 /internal/state/util.go
parente431ab3c24acc5309531a26d71e761619bd69eec (diff)
state/join: use Join method when available
Signed-off-by: Ophestra <cat@gensokyo.uk>
Diffstat (limited to 'internal/state/util.go')
-rw-r--r--internal/state/util.go49
1 files changed, 0 insertions, 49 deletions
diff --git a/internal/state/util.go b/internal/state/util.go
deleted file mode 100644
index 473ae51d..00000000
--- a/internal/state/util.go
+++ /dev/null
@@ -1,49 +0,0 @@
-package state
-
-import (
- "errors"
- "maps"
-)
-
-var (
- ErrDuplicate = errors.New("store contains duplicates")
-)
-
-// Join returns joined state entries of all active aids.
-func Join(s Store) (Entries, error) {
- var (
- aids []int
- entries = make(Entries)
-
- el int
- res Entries
- loadErr error
- )
-
- if ln, err := s.List(); err != nil {
- return nil, err
- } else {
- aids = ln
- }
-
- for _, aid := range aids {
- if _, err := s.Do(aid, func(c Cursor) {
- res, loadErr = c.Load()
- }); err != nil {
- return nil, err
- }
-
- if loadErr != nil {
- return nil, loadErr
- }
-
- // save expected length
- el = len(entries) + len(res)
- maps.Copy(entries, res)
- if len(entries) != el {
- return nil, ErrDuplicate
- }
- }
-
- return entries, nil
-}