From 1f74b636d31e816907ff6adbf1472f9e0fb37ab7 Mon Sep 17 00:00:00 2001 From: Ophestra Date: Fri, 14 Feb 2025 14:11:02 +0900 Subject: state/join: use Join method when available Signed-off-by: Ophestra --- internal/state/util.go | 49 ------------------------------------------------- 1 file changed, 49 deletions(-) delete mode 100644 internal/state/util.go (limited to 'internal/state/util.go') 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 -} -- cgit v1.3.1