From f5807d9f3a6c96e70912b61fac17120f412b5782 Mon Sep 17 00:00:00 2001 From: ewy Date: Sun, 17 May 2026 01:37:24 +0200 Subject: * integration tests with a pik target to run them * add abstraction for paths to facilitate unit tests * flesh out completion (--install-completion) * do sync init before stateless modes so list knows more --- model/new.go | 12 ++++++------ 1 file changed, 6 insertions(+), 6 deletions(-) (limited to 'model/new.go') diff --git a/model/new.go b/model/new.go index 94b039e..e83c314 100644 --- a/model/new.go +++ b/model/new.go @@ -10,7 +10,7 @@ import ( "sync" ) -func NewState(f fs.FS, locations []string, indexers []Indexer, runners []Runner) (*State, []error) { +func NewState(rootFs fs.FS, locations []string, indexers []Indexer, runners []Runner) (*State, []error) { var errs []error st := &State{ All: *flags.All, @@ -32,16 +32,16 @@ func NewState(f fs.FS, locations []string, indexers []Indexer, runners []Runner) return } - myWg := sync.WaitGroup{} + locationWg := sync.WaitGroup{} var targets = make([][]Target, len(indexers), len(indexers)) for ti, indexer := range indexers { - myWg.Go(func() { - s, err := fs.Sub(f, loc) + locationWg.Go(func() { + subFs, err := fs.Sub(rootFs, loc) if err != nil && !errors.Is(err, fs.ErrNotExist) { errs = append(errs, err) return } - result, err := indexer.Index("/"+loc, s, runners) + result, err := indexer.Index("/"+loc, subFs, runners) if err != nil && !errors.Is(err, fs.ErrNotExist) { errs = append(errs, err) return @@ -49,7 +49,7 @@ func NewState(f fs.FS, locations []string, indexers []Indexer, runners []Runner) targets[ti] = result }) } - myWg.Wait() + locationWg.Wait() for _, t := range targets { if t == nil { -- cgit v1.3.1