driftpipeline

type DriftResult struct {
	// Status is the detected drift status
	Status DriftStatus

	// DeployedSHA is the commit SHA currently deployed
	DeployedSHA string

	// ExpectedSHA is the commit SHA from the PR
	ExpectedSHA string

	// Health is the ArgoCD application health status
	Health string

	// SyncStatus is the ArgoCD application sync status
	SyncStatus string

	// Message provides additional context about the result
	Message string

	// Error contains any error that occurred during detection
	Error error
}

type DriftStatus string

type DriftWorkItem struct {
	// PR is the merged pull request to monitor
	PR github.PullRequest

	// Cluster is the name of the ArgoCD cluster to check
	Cluster string

	// Application is the ArgoCD application name mapped from the PR
	Application string

	// Priority for processing (0 = lowest)
	Priority int

	// CreatedAt is when this work item was created
	CreatedAt time.Time

	// Metadata for additional context
	Metadata map[string]string
}

type GitHubClient interface {
	// ListPRs retrieves pull requests from a repository
	ListPRs(ctx context.Context, repo github.Repository) ([]github.PullRequest, error)

	// GetPR retrieves a specific pull request
	GetPR(ctx context.Context, repo github.Repository, number int) (*github.PullRequest, error)
}

type LabelManager interface {
	// GetCurrentState determines the current state of a PR from its labels
	GetCurrentState(pr github.PullRequest) labels.State

	// ApplyState applies a state to a PR by updating its labels
	ApplyState(ctx context.Context, pr github.PullRequest, state labels.State) error

	// TransitionState performs a validated state transition
	TransitionState(ctx context.Context, pr github.PullRequest, toState labels.State) error
}

type Logger interface {
	// Sugar returns a sugared logger interface for key-value logging
	Sugar() *zap.SugaredLogger
}

type Mapper interface {
	// GetApplicationName maps a PR to its ArgoCD application name
	GetApplicationName(pr github.PullRequest, cluster string) string
}

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

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

type PipelineConfig struct {
	// ArgoCDClients map cluster names to ArgoCD application services
	ArgoCDClients map[string]applications.Service

	// GitHubClient for PR operations
	GitHubClient GitHubClient

	// LabelManager for updating PR labels
	LabelManager LabelManager

	// Mapper for PR → ArgoCD app name mapping
	Mapper Mapper

	// Logger for structured logging
	Logger Logger

	// ReconcileInterval is how often to check for drift (default: 60s)
	ReconcileInterval time.Duration

	// WorkerCount is the number of concurrent drift detection workers (default: 5)
	WorkerCount int
}

type ProcessResult struct {
	// Success indicates whether processing completed without errors
	Success bool

	// DriftResult contains the drift detection result
	DriftResult DriftResult

	// NewState is the label state to apply to the PR
	NewState labels.State

	// Duration is how long processing took
	Duration time.Duration

	// Error contains any error that occurred during processing
	Error error
}

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

type ProcessorConfig struct {
	Monitor      *Monitor
	LabelManager LabelManager
	Logger       Logger
}

type SugaredLogger interface {
	Debugw(msg string, keysAndValues ...interface{})
	Infow(msg string, keysAndValues ...interface{})
	Warnw(msg string, keysAndValues ...interface{})
	Errorw(msg string, keysAndValues ...interface{})
}