diff options
| author | Ophestra <cat@gensokyo.uk> | 2025-02-14 14:11:02 +0900 |
|---|---|---|
| committer | Ophestra <cat@gensokyo.uk> | 2025-02-14 14:11:02 +0900 |
| commit | 1f74b636d31e816907ff6adbf1472f9e0fb37ab7 (patch) | |
| tree | 5aecb9dbf912d5e2fae089f88adeeeb49bb01103 /internal/state/util.go | |
| parent | e431ab3c24acc5309531a26d71e761619bd69eec (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.go | 49 |
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 -} |
