Method RefreshAll

internal/metadata/refresh.go:131–199

RefreshAll downloads every enabled repository for each kind (skill, agent, instruction, plugin), discovers the individual resources inside each repo, and indexes them into SQLite as cached metadata. Each resource — not each repo — becomes one searchable/installable item, so the counts reflect real r

(ctx context.Context)

// goroutine, which keeps the single DB connection safe and the summary
// deterministic.
func (svc *Service) RefreshAll(ctx context.Context) (RefreshSummary, error) {
	if err := svc.store.Init(ctx); err != nil {
		return RefreshSummary{}, err
	}
	summary := RefreshSummary{}

	kinds := []struct {
		kind       string
		entityKind entities.Kind
	}{
		{"skill", entities.KindSkill},
		{"agent", entities.KindAgent},
		{"instruction", entities.KindInstruction},
		{"plugin", entities.KindPlugin},
	}

	cacheDir := filepath.Join(pathutil.CacheDir(), "metadata-repos")
	startedAt := timeNow()

	for _, k := range kinds {
		repos, err := repoconfig.LoadEnabled(k.entityKind)
		if err != nil {
			summary.FailedSources = append(summary.FailedSources, fmt.Sprintf("%s: %v", k.kind, err))
			continue
		}

		// Build the work list for this kind.
		var jobs []repoJob
		for _, entry := range repos {
			owner := entry.EffectiveOwner()
			repo := entry.EffectiveName()
			if owner == "" || repo == "" {
				continue
			}
			jobs = append(jobs, repoJob{
				owner:       owner,
				repo:        repo,
				branch:      entry.EffectiveBranch(),
				subPath:     entry.SubPath(k.entityKind),
				catalogFile: entry.CatalogFile,
			})
		}
		summary.SourcesScanned += len(jobs)

		// Fan out downloads+discovery; fan in results for serialized DB writes.
		results := svc.fetchAndDiscover(ctx, k.kind, k.entityKind, cacheDir, jobs)
		var batch []Item
		for r := range results {
			if r.err != "" {
				summary.FailedSources = append(summary.FailedSources, r.err)
				continue
			}
			batch = append(batch, r.items...)
		}
		written, err := svc.store.UpsertItems(ctx, batch)
		if err != nil {
			summary.FailedSources = append(summary.FailedSources, fmt.Sprintf("%s: index: %v", k.kind, err))
		}