gitops

type ArgoCDAppConfig struct {
	Name                 string
	Project              string
	RepoURL              string
	Path                 string
	TargetRevision       string
	DestinationServer    string
	DestinationNamespace string
	SyncOptions          []string
	AutoSync             bool
	Values               map[string]string
	IgnoreDifferences    []observabilityv1beta1.ResourceIgnoreDifferences
	RetryPolicy          *observabilityv1beta1.ArgoCDRetryPolicy
}

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

type BackoffPolicy struct {
	// Duration is the base duration
	Duration metav1.Duration `json:"duration"`

	// Factor is the multiplication factor
	Factor int `json:"factor"`

	// MaxDuration is the maximum duration
	MaxDuration metav1.Duration `json:"maxDuration"`
}

type DriftAction string

type DriftDetail struct {
	// Path is the field path
	Path string

	// Expected is the expected value
	Expected interface{}

	// Actual is the actual value
	Actual interface{}
}

type DriftDetectionConfig struct {
	// Enabled enables drift detection
	Enabled bool `json:"enabled"`

	// Interval is the drift check interval
	Interval metav1.Duration `json:"interval"`

	// Action defines what to do when drift is detected
	Action DriftAction `json:"action"`

	// IgnoreFields lists fields to ignore during drift detection
	IgnoreFields []string `json:"ignoreFields,omitempty"`
}

type DriftDetector interface {
	// DetectDrift detects configuration drift
	DetectDrift(ctx context.Context, expected, actual runtime.Object) (*DriftResult, error)

	// Remediate remediates detected drift
	Remediate(ctx context.Context, drift *DriftResult) error
}

type DriftResult struct {
	// HasDrift indicates if drift was detected
	HasDrift bool

	// DriftedFields lists fields with drift
	DriftedFields map[string]DriftDetail
}

type DriftStatus struct {
	// Detected indicates if drift was detected
	Detected bool `json:"detected"`

	// LastCheckTime is when drift was last checked
	LastCheckTime *metav1.Time `json:"lastCheckTime,omitempty"`

	// DriftedResources lists resources with drift
	DriftedResources []DriftedResource `json:"driftedResources,omitempty"`
}

type DriftedResource struct {
	// Name is the resource name
	Name string `json:"name"`

	// Kind is the resource kind
	Kind string `json:"kind"`

	// Namespace is the resource namespace
	Namespace string `json:"namespace,omitempty"`

	// Fields lists drifted fields
	Fields []string `json:"fields"`
}

type Environment struct {
	// Name is the environment name
	Name string `json:"name"`

	// Namespace is the target namespace
	Namespace string `json:"namespace"`

	// Branch is the Git branch for this environment
	Branch string `json:"branch"`

	// AutoPromote enables automatic promotion to next environment
	AutoPromote bool `json:"autoPromote"`

	// PromotionPolicy defines promotion requirements
	PromotionPolicy *PromotionPolicy `json:"promotionPolicy,omitempty"`
}

type FileChange struct {
	// Path is the file path
	Path string `json:"path"`

	// Action is the change action (added, modified, deleted)
	Action string `json:"action"`

	// Additions is the number of lines added
	Additions int `json:"additions"`

	// Deletions is the number of lines deleted
	Deletions int `json:"deletions"`
}

type FluxKustomizationConfig struct {
	Name            string
	SourceRef       string
	Path            string
	TargetNamespace string
	ServiceAccount  string
	Interval        string
	Timeout         string
	Prune           bool
	Values          map[string]string
	HealthChecks    []observabilityv1beta1.FluxHealthCheck
}

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

type GitCredentials struct {
	Username string
	Password string
	SSHKey   string
}

type GitOpsConfig struct {
	// Provider specifies the GitOps provider (argocd or flux)
	Provider GitOpsProvider `json:"provider"`

	// Repository contains Git repository configuration
	Repository GitRepository `json:"repository"`

	// SyncPolicy defines how to sync resources
	SyncPolicy SyncPolicy `json:"syncPolicy"`

	// Promotion defines multi-environment promotion settings
	Promotion *PromotionConfig `json:"promotion,omitempty"`

	// Rollback defines rollback configuration
	Rollback *RollbackConfig `json:"rollback,omitempty"`

	// DriftDetection enables drift detection and remediation
	DriftDetection *DriftDetectionConfig `json:"driftDetection,omitempty"`
}

type GitOpsController interface {
	// Reconcile reconciles GitOps state
	Reconcile(ctx context.Context, platform *observabilityv1.ObservabilityPlatform) error

	// Sync synchronizes resources with Git
	Sync(ctx context.Context, platform *observabilityv1.ObservabilityPlatform) error

	// GetStatus returns current GitOps status
	GetStatus(ctx context.Context, platform *observabilityv1.ObservabilityPlatform) (*GitOpsStatus, error)

	// Rollback performs a rollback
	Rollback(ctx context.Context, platform *observabilityv1.ObservabilityPlatform, revision string) error

	// Promote promotes to the next environment
	Promote(ctx context.Context, platform *observabilityv1.ObservabilityPlatform, targetEnv string) error
}

type GitOpsProvider string

type GitOpsStatus struct {
	// Provider is the active GitOps provider
	Provider GitOpsProvider `json:"provider"`

	// SyncStatus represents current sync status
	SyncStatus SyncStatus `json:"syncStatus"`

	// LastSyncTime is when the last sync occurred
	LastSyncTime *metav1.Time `json:"lastSyncTime,omitempty"`

	// LastSyncRevision is the last synced Git revision
	LastSyncRevision string `json:"lastSyncRevision,omitempty"`

	// DriftStatus represents drift detection status
	DriftStatus *DriftStatus `json:"driftStatus,omitempty"`

	// PromotionStatus represents promotion pipeline status
	PromotionStatus *PromotionStatus `json:"promotionStatus,omitempty"`

	// Conditions represents GitOps conditions
	Conditions []metav1.Condition `json:"conditions,omitempty"`
}

type GitRepository struct {
	// URL is the Git repository URL
	URL string `json:"url"`

	// Branch is the Git branch to track
	Branch string `json:"branch"`

	// Path is the path within the repository
	Path string `json:"path"`

	// SecretRef references a secret containing Git credentials
	SecretRef *SecretReference `json:"secretRef,omitempty"`

	// Interval is the sync interval
	Interval metav1.Duration `json:"interval,omitempty"`
}

type GitSyncConfig struct {
	Repository   string
	Branch       string
	Path         string
	PollInterval string
	Credentials  *GitCredentials
	WebhookURL   string
}

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

type GitSynchronizer interface {
	// Clone clones a Git repository
	Clone(ctx context.Context, repo GitRepository) (string, error)

	// Pull pulls latest changes
	Pull(ctx context.Context, repoPath string) error

	// GetRevision gets current revision
	GetRevision(ctx context.Context, repoPath string) (string, error)

	// GetFiles gets files from repository
	GetFiles(ctx context.Context, repoPath string, pattern string) ([]string, error)

	// Cleanup cleans up cloned repository
	Cleanup(ctx context.Context, repoPath string) error
}

type Manager struct {
	Client        client.Client
	Scheme        *runtime.Scheme
	Log           logr.Logger
	ArgoCDManager *argocd.Manager
	FluxManager   *flux.Manager
	SyncManager   *sync.Manager
	RollbackMgr   *rollback.Manager
	DriftDetector *drift.Detector
}

type MetricThreshold struct {
	// Name is the metric name
	Name string `json:"name"`

	// Query is the PromQL query
	Query string `json:"query"`

	// Threshold is the threshold value
	Threshold float64 `json:"threshold"`

	// Operator is the comparison operator (>, <, >=, <=, ==)
	Operator string `json:"operator"`
}

type PromotionConfig struct {
	// Environments defines the promotion pipeline
	Environments []Environment `json:"environments"`

	// Strategy defines promotion strategy
	Strategy PromotionStrategy `json:"strategy"`

	// ApprovalRequired indicates if manual approval is needed
	ApprovalRequired bool `json:"approvalRequired"`
}

type PromotionEvent struct {
	// From is the source environment
	From string `json:"from"`

	// To is the target environment
	To string `json:"to"`

	// Time is when the promotion occurred
	Time metav1.Time `json:"time"`

	// Revision is the Git revision promoted
	Revision string `json:"revision"`

	// Status is the promotion status
	Status string `json:"status"`
}

type PromotionManager interface {
	// CanPromote checks if promotion is allowed
	CanPromote(ctx context.Context, platform *observabilityv1.ObservabilityPlatform, targetEnv string) (bool, error)

	// Promote performs the promotion
	Promote(ctx context.Context, platform *observabilityv1.ObservabilityPlatform, targetEnv string) error

	// GetPromotionHistory gets promotion history
	GetPromotionHistory(ctx context.Context, platform *observabilityv1.ObservabilityPlatform) ([]PromotionEvent, error)
}

type PromotionPolicy struct {
	// MinReplicaAvailability is the minimum replica availability percentage
	MinReplicaAvailability int `json:"minReplicaAvailability"`

	// HealthCheckDuration is how long to monitor health before promotion
	HealthCheckDuration metav1.Duration `json:"healthCheckDuration"`

	// MetricThresholds defines metric-based promotion gates
	MetricThresholds []MetricThreshold `json:"metricThresholds,omitempty"`
}

type PromotionRequest struct {
	FromEnvironment string
	ToEnvironment   string
	Revision        string
	RequestedBy     string
	ApprovedBy      string
	Status          string
	CreatedAt       time.Time
	CompletedAt     *time.Time
	Reason          string
}

type PromotionStatus struct {
	// CurrentEnvironment is the current environment
	CurrentEnvironment string `json:"currentEnvironment"`

	// PromotionHistory lists recent promotions
	PromotionHistory []PromotionEvent `json:"promotionHistory,omitempty"`
}

type PromotionStrategy string

type PullRequest struct {
	// Number is the PR number
	Number int `json:"number"`

	// Title is the PR title
	Title string `json:"title"`

	// Description is the PR description
	Description string `json:"description"`

	// State is the PR state (open, closed, merged)
	State string `json:"state"`

	// Action is the PR action (opened, closed, reopened, synchronize)
	Action string `json:"action"`

	// SourceBranch is the source branch
	SourceBranch string `json:"source_branch"`

	// TargetBranch is the target branch
	TargetBranch string `json:"target_branch"`

	// Author is the PR author
	Author string `json:"author"`

	// Labels are the PR labels
	Labels []string `json:"labels"`

	// Reviewers are the requested reviewers
	Reviewers []string `json:"reviewers"`

	// Approved indicates if the PR is approved
	Approved bool `json:"approved"`

	// MergeCommit is the merge commit SHA (if merged)
	MergeCommit string `json:"merge_commit,omitempty"`
}

type PullRequestEvent struct {
	// Repository is the repository URL
	Repository string `json:"repository"`

	// Number is the PR number
	Number int `json:"number"`

	// Action is the PR action (opened, closed, merged)
	Action string `json:"action"`

	// SourceBranch is the source branch
	SourceBranch string `json:"sourceBranch"`

	// TargetBranch is the target branch
	TargetBranch string `json:"targetBranch"`
}

type PushEvent struct {
	// Repository is the repository URL
	Repository string `json:"repository"`

	// Branch is the branch name
	Branch string `json:"branch"`

	// Revision is the new revision
	Revision string `json:"revision"`

	// Author is the commit author
	Author string `json:"author"`

	// Message is the commit message
	Message string `json:"message"`

	// Timestamp is the push timestamp
	Timestamp time.Time `json:"timestamp"`
}

type Release struct {
	// Name is the release name
	Name string `json:"name"`

	// Tag is the release tag
	Tag string `json:"tag"`

	// Description is the release description
	Description string `json:"description"`

	// Prerelease indicates if this is a pre-release
	Prerelease bool `json:"prerelease"`

	// Draft indicates if this is a draft
	Draft bool `json:"draft"`

	// Assets are the release assets
	Assets []ReleaseAsset `json:"assets,omitempty"`
}

type ReleaseAsset struct {
	// Name is the asset name
	Name string `json:"name"`

	// URL is the download URL
	URL string `json:"url"`

	// Size is the asset size in bytes
	Size int64 `json:"size"`

	// ContentType is the MIME type
	ContentType string `json:"content_type"`
}

type RetryPolicy struct {
	// Limit is the maximum number of retries
	Limit int `json:"limit"`

	// Backoff defines backoff strategy
	Backoff *BackoffPolicy `json:"backoff,omitempty"`
}

type RevisionHistory struct {
	Revision    string
	DeployTime  time.Time
	Status      string
	Health      string
	Environment string
	Metrics     map[string]float64
}

type RollbackConfig struct {
	// Enabled enables automatic rollback
	Enabled bool `json:"enabled"`

	// MaxHistory is the maximum number of rollback points to keep
	MaxHistory int `json:"maxHistory"`

	// Triggers defines rollback triggers
	Triggers []RollbackTrigger `json:"triggers"`
}

type RollbackManager interface {
	// CreateSnapshot creates a rollback snapshot
	CreateSnapshot(ctx context.Context, platform *observabilityv1.ObservabilityPlatform) error

	// ListSnapshots lists available snapshots
	ListSnapshots(ctx context.Context, platform *observabilityv1.ObservabilityPlatform) ([]RollbackSnapshot, error)

	// Rollback performs a rollback to a snapshot
	Rollback(ctx context.Context, platform *observabilityv1.ObservabilityPlatform, snapshotID string) error

	// ShouldRollback checks if rollback should be triggered
	ShouldRollback(ctx context.Context, platform *observabilityv1.ObservabilityPlatform) (bool, string, error)
}

type RollbackSnapshot struct {
	// ID is the snapshot ID
	ID string `json:"id"`

	// Revision is the Git revision
	Revision string `json:"revision"`

	// Timestamp is when the snapshot was created
	Timestamp metav1.Time `json:"timestamp"`

	// Platform is the platform configuration
	Platform *observabilityv1.ObservabilityPlatform `json:"platform"`

	// Status is the platform status at snapshot time
	Status observabilityv1.ObservabilityPlatformStatus `json:"status"`
}

type RollbackTrigger struct {
	// Type is the trigger type
	Type RollbackTriggerType `json:"type"`

	// Threshold is the threshold for the trigger
	Threshold string `json:"threshold"`

	// Duration is how long the condition must persist
	Duration metav1.Duration `json:"duration"`
}

type RollbackTriggerType string

type SecretReference struct {
	// Name is the secret name
	Name string `json:"name"`

	// Namespace is the secret namespace
	Namespace string `json:"namespace,omitempty"`
}

type SyncPolicy struct {
	// Automated enables automated sync
	Automated bool `json:"automated"`

	// Prune enables resource pruning
	Prune bool `json:"prune"`

	// SelfHeal enables automatic remediation
	SelfHeal bool `json:"selfHeal"`

	// Retry defines retry configuration
	Retry *RetryPolicy `json:"retry,omitempty"`

	// SyncOptions provides additional sync options
	SyncOptions []string `json:"syncOptions,omitempty"`
}

type SyncStatus string

type TagEvent struct {
	// Repository is the repository URL
	Repository string `json:"repository"`

	// Tag is the tag name
	Tag string `json:"tag"`

	// Revision is the tagged revision
	Revision string `json:"revision"`

	// Message is the tag message
	Message string `json:"message"`
}

type WebhookConfig struct {
	// Provider is the webhook provider
	Provider WebhookProvider `json:"provider"`

	// Secret is the webhook secret for validation
	Secret string `json:"secret"`

	// Events are the events to listen for
	Events []WebhookEventType `json:"events"`

	// Filters are optional event filters
	Filters *WebhookFilters `json:"filters,omitempty"`
}

type WebhookEvent struct {
	// Type is the type of event
	Type WebhookEventType `json:"type"`

	// Repository is the Git repository URL
	Repository string `json:"repository"`

	// Branch is the branch name (for push events)
	Branch string `json:"branch,omitempty"`

	// Tag is the tag name (for tag events)
	Tag string `json:"tag,omitempty"`

	// Commit is the commit SHA
	Commit string `json:"commit,omitempty"`

	// Author is the author of the change
	Author string `json:"author,omitempty"`

	// Message is the commit/tag message
	Message string `json:"message,omitempty"`

	// Timestamp is when the event occurred
	Timestamp time.Time `json:"timestamp"`

	// PullRequest contains PR details
	PullRequest *PullRequest `json:"pull_request,omitempty"`

	// Release contains release details
	Release *Release `json:"release,omitempty"`

	// Changes contains file changes
	Changes []FileChange `json:"changes,omitempty"`
}

type WebhookEventType string

type WebhookFilters struct {
	// Branches to include
	Branches []string `json:"branches,omitempty"`

	// Tags to include (supports patterns)
	Tags []string `json:"tags,omitempty"`

	// Paths to watch (supports patterns)
	Paths []string `json:"paths,omitempty"`

	// ExcludePaths to ignore
	ExcludePaths []string `json:"exclude_paths,omitempty"`

	// Authors to include
	Authors []string `json:"authors,omitempty"`

	// Labels required on PRs
	Labels []string `json:"labels,omitempty"`
}

type WebhookHandler interface {
	// HandlePush handles push events
	HandlePush(ctx context.Context, event PushEvent) error

	// HandlePullRequest handles pull request events
	HandlePullRequest(ctx context.Context, event PullRequestEvent) error

	// HandleTag handles tag events
	HandleTag(ctx context.Context, event TagEvent) error
}

type WebhookProvider string