analyze

type Analyzer struct {
	ScmClient ScmClient
	GitClient GitClient
	Formatter Formatter
	Config    *models.Config
	Opa       *opa.Opa
	Observer  ProgressObserver
}

type Formatter interface {
	Format(ctx context.Context, packages []*models.PackageInsights) error
	FormatWithPath(ctx context.Context, packages []*models.PackageInsights, pathAssociation map[string][]*models.RepoInfo) error
}

type GitClient interface {
	Clone(ctx context.Context, clonePath string, url string, token string, ref string) error
	FetchCone(ctx context.Context, clonePath string, url string, token string, ref string, cone string) error
	CommitSHA(clonePath string) (string, error)
	LastCommitDate(ctx context.Context, clonePath string) (time.Time, error)
	GetRemoteOriginURL(ctx context.Context, repoPath string) (string, error)
	GetRepoHeadBranchName(ctx context.Context, repoPath string) (string, error)
	GetUniqWorkflowsBranches(ctx context.Context, clonePath string) (map[string][]models.BranchInfo, error)
	BlobMatches(ctx context.Context, clonePath string, blobsha string, regex *regexp.Regexp) (bool, []byte, error)
	ListFiles(clonePath string, extensions []string) (map[string][]byte, error)
	Cleanup(clonePath string)
}

type ProgressBarObserver struct {
	// contains filtered or unexported fields
}

type ProgressObserver interface {
	// OnAnalysisStarted is called from the main goroutine at the very
	// beginning of any analysis, before any work begins. Useful for
	// rendering an initial status indicator while discovery or cloning runs.
	OnAnalysisStarted(description string)

	// OnDiscoveryCompleted is called from the main goroutine when the
	// total repo count is known (first batch with TotalCount > 0).
	OnDiscoveryCompleted(org string, totalCount int)

	// OnRepoStarted is called from a worker goroutine when analysis
	// of a repo begins. Must be goroutine-safe.
	OnRepoStarted(repo string)

	// OnRepoCompleted is called from a worker goroutine when a repo
	// finishes successfully. Must be goroutine-safe.
	OnRepoCompleted(repo string, pkg *models.PackageInsights)

	// OnRepoError is called from a worker goroutine when a repo
	// analysis fails (non-fatal). Must be goroutine-safe.
	OnRepoError(repo string, err error)

	// OnRepoSkipped is called from the main goroutine when a repo is
	// skipped (fork, empty, etc.).
	OnRepoSkipped(repo string, reason string)

	// OnStepCompleted is called when a sub-step within a single-repo
	// analysis completes (e.g. "Cloning repository", "Analyzing repository").
	// Used by AnalyzeRepo and AnalyzeStaleBranches for step-level progress.
	// Called from the main goroutine.
	OnStepCompleted(description string)

	// OnFinalizeStarted is called from the main goroutine when the
	// formatting/output phase begins, after all repos are processed.
	OnFinalizeStarted(totalPackages int)

	// OnFinalizeCompleted is called from the main goroutine when
	// formatting is done.
	OnFinalizeCompleted()
}

type RepoBatch struct {
	TotalCount   int
	Repositories []Repository
	Err          error
}

type Repository interface {
	GetProviderName() string
	GetRepoIdentifier() string
	GetIsFork() bool
	BuildGitURL(baseURL string) string
	GetHasIssues() bool
	GetHasWiki() bool
	GetHasDiscussion() bool
	GetOpenIssuesCount() int
	GetForksCount() int
	GetStarsCount() int
	GetPrimaryLanguage() string
	GetSize() int
	GetDefaultBranch() string
	GetLicense() string
	GetIsTemplate() bool
	GetOrganizationID() int
	GetRepositoryID() int
	GetIsEmpty() bool
}

type ScmClient interface {
	GetOrgRepos(ctx context.Context, org string) <-chan RepoBatch
	GetRepo(ctx context.Context, org string, name string) (Repository, error)
	GetToken() string
	GetProviderName() string
	GetProviderVersion(ctx context.Context) (string, error)
	GetProviderBaseURL() string
	ParseRepoAndOrg(string) (string, string, error)
}