Function fetchRepoStars

pkg/cmd/skills/search/search.go:896–936

fetchRepoStars fetches stargazer counts for each unique repository in the result set, using bounded concurrency.

(client *api.Client, host string, skills []skillResult)

// fetchRepoStars fetches stargazer counts for each unique repository in
// the result set, using bounded concurrency.
func fetchRepoStars(client *api.Client, host string, skills []skillResult) map[int]int {
	const maxWorkers = 10
	sem := make(chan struct{}, maxWorkers)
	var wg sync.WaitGroup
	var mu sync.Mutex

	repoStars := make(map[string]int)
	seen := make(map[string]bool)

	for _, s := range skills {
		if seen[s.Repo] {
			continue
		}
		seen[s.Repo] = true

		wg.Add(1)
		go func(owner, repo, fullName string) {
			defer wg.Done()
			sem <- struct{}{}
			defer func() { <-sem }()

			apiPath := fmt.Sprintf("repos/%s/%s", owner, repo)
			var info repoInfo
			if err := client.REST(host, "GET", apiPath, nil, &info); err != nil {
				return
			}
			mu.Lock()
			repoStars[fullName] = info.StargazersCount
			mu.Unlock()
		}(s.Owner, s.RepoName, s.Repo)
	}
	wg.Wait()

	result := make(map[int]int, len(skills))
	for i, s := range skills {
		if stars, ok := repoStars[s.Repo]; ok {
			result[i] = stars
		}
	}
	return result
}