Method Refresh

coderd/x/gitsync/gitsync.go:138–255

Refresh fetches fresh PR data for a batch of stale rows. Rows are grouped internally by (ownerID, origin) so that provider and token resolution happen once per group. HTTP calls within and across groups run concurrently, bounded by the Refresher's concurrency limit. A top-level error is returned on

(
	ctx context.Context,
	requests []RefreshRequest,
)

// returned RefreshResult slice (one per input request, same
// order).
func (r *Refresher) Refresh(
	ctx context.Context,
	requests []RefreshRequest,
) ([]RefreshResult, error) {
	results := make([]RefreshResult, len(requests))
	for i, req := range requests {
		results[i].Request = req
	}

	// Group request indices by (ownerID, origin).
	groups := make(map[groupKey][]int)
	for i, req := range requests {
		key := groupKey{
			ownerID: req.OwnerID,
			origin:  req.Row.GitRemoteOrigin,
		}
		groups[key] = append(groups[key], i)
	}

	// Pre-resolve providers and tokens sequentially. This is
	// fast (DB + in-memory config lookups) and avoids
	// duplicate resolution for rows in the same group.
	var resolved []resolvedGroup
	for key, indices := range groups {
		provider := r.providers(ctx, key.origin)
		if provider == nil {
			err := xerrors.Errorf("no provider for origin %q", key.origin)
			for _, i := range indices {
				results[i].Error = err
			}
			continue
		}

		token, err := r.tokens(ctx, key.ownerID, key.origin)
		if err != nil {
			err = xerrors.Errorf("resolve token: %w", err)
		} else if token == nil || len(*token) == 0 {
			err = ErrNoTokenAvailable
		}
		if err != nil {
			for _, i := range indices {
				results[i].Error = err
			}
			continue
		}

		resolved = append(resolved, resolvedGroup{
			provider: provider,
			token:    *token,
			indices:  indices,
		})
	}

	// Process all HTTP calls concurrently with a shared
	// semaphore. Each group tracks rate-limit errors
	// independently so that a limit hit on one provider
	// doesn't stall requests to other providers.
	sem := make(chan struct{}, r.concurrency)