Function FetchDescriptionsConcurrent

internal/skills/discovery/discovery.go:665–703

FetchDescriptionsConcurrent fetches descriptions with bounded concurrency.

(client *api.Client, host, owner, repo string, skills []Skill, onProgress func(done, total int))

// FetchDescriptionsConcurrent fetches descriptions with bounded concurrency.
func FetchDescriptionsConcurrent(client *api.Client, host, owner, repo string, skills []Skill, onProgress func(done, total int)) {
	total := 0
	for _, s := range skills {
		if s.Description == "" {
			total++
		}
	}
	if total == 0 {
		return
	}

	const maxWorkers = 10
	var wg sync.WaitGroup
	var done atomic.Int32

	jobs := make(chan *Skill)

	workers := min(maxWorkers, total)
	for range workers {
		wg.Go(func() {
			for s := range jobs {
				s.Description = fetchDescription(client, host, owner, repo, s)

				d := int(done.Add(1))
				if onProgress != nil {
					onProgress(d, total)
				}
			}
		})
	}

	for i := range skills {
		if skills[i].Description == "" {
			jobs <- &skills[i]
		}
	}
	close(jobs)
	wg.Wait()
}

// DiscoverSkillByPathOptions controls optional behavior for DiscoverSkillByPathWithOptions.
type DiscoverSkillByPathOptions struct {