Function getRepositoryFeatures

pkg/workflow/repository_features_validation.go:191–251

getRepositoryFeatures gets repository features with caching to amortize API calls

(repo string, verbose bool)

// getRepositoryFeatures gets repository features with caching to amortize API calls
func getRepositoryFeatures(repo string, verbose bool) (*RepositoryFeatures, error) {
	// Check cache first using sync.Map
	if cached, exists := repositoryFeaturesCache.Load(repo); exists {
		features, ok := cached.(*RepositoryFeatures)
		if !ok {
			repositoryFeaturesCache.Delete(repo)
			return nil, fmt.Errorf("invalid repository feature cache entry for %s: expected *RepositoryFeatures, got %T", repo, cached)
		}
		repositoryFeaturesLog.Printf("Using cached repository features for: %s", repo)
		return features, nil
	}

	repositoryFeaturesLog.Printf("Fetching repository features from API for: %s", repo)

	// Fetch from API
	features := &RepositoryFeatures{}

	// Check discussions
	hasDiscussions, err := checkRepositoryHasDiscussionsUncached(repo)
	if err != nil {
		return nil, fmt.Errorf("failed to check discussions: %w", err)
	}
	features.HasDiscussions = hasDiscussions

	// Check issues
	hasIssues, err := checkRepositoryHasIssuesUncached(repo)
	if err != nil {
		return nil, fmt.Errorf("failed to check issues: %w", err)
	}
	features.HasIssues = hasIssues

	// Cache the result using sync.Map's LoadOrStore for atomic caching
	// This handles the race condition where multiple goroutines might fetch the same repo
	actual, loaded := repositoryFeaturesCache.LoadOrStore(repo, features)
	actualFeatures, ok := actual.(*RepositoryFeatures)
	if !ok {
		repositoryFeaturesCache.Delete(repo)
		return nil, fmt.Errorf("invalid repository feature cache entry for %s: expected *RepositoryFeatures, got %T", repo, actual)
	}

	repositoryFeaturesLog.Printf("Cached repository features for: %s (discussions: %v, issues: %v)", repo, actualFeatures.HasDiscussions, actualFeatures.HasIssues)

	// Only log the success messages if this is the first time we're caching these features
	// and we haven't logged them before (checking loaded flag and logged cache)
	if !loaded {
		// Mark as logged atomically
		// Log success messages only if we haven't logged them before
		if _, alreadyLogged := repositoryFeaturesLoggedCache.LoadOrStore(repo, true); !alreadyLogged && verbose {
			if actualFeatures.HasDiscussions {
				fmt.Fprintln(os.Stderr, console.FormatInfoMessage(
					fmt.Sprintf("✓ Repository %s has discussions enabled", repo)))
			}
			if actualFeatures.HasIssues {
				fmt.Fprintln(os.Stderr, console.FormatInfoMessage(
					fmt.Sprintf("✓ Repository %s has issues enabled", repo)))
			}
		}
	}