services

type AuditEvent struct {
	ID           string         `bson:"_id,omitempty" json:"id,omitempty"`
	Timestamp    time.Time      `bson:"timestamp" json:"timestamp"`
	EventType    AuditEventType `bson:"event_type" json:"event_type"`
	RuleName     string         `bson:"rule_name,omitempty" json:"rule_name,omitempty"`
	SourceRepo   string         `bson:"source_repo" json:"source_repo"`
	SourcePath   string         `bson:"source_path" json:"source_path"`
	TargetRepo   string         `bson:"target_repo,omitempty" json:"target_repo,omitempty"`
	TargetPath   string         `bson:"target_path,omitempty" json:"target_path,omitempty"`
	CommitSHA    string         `bson:"commit_sha,omitempty" json:"commit_sha,omitempty"`
	PRNumber     int            `bson:"pr_number,omitempty" json:"pr_number,omitempty"`
	Success      bool           `bson:"success" json:"success"`
	ErrorMessage string         `bson:"error_message,omitempty" json:"error_message,omitempty"`
	DurationMs   int64          `bson:"duration_ms,omitempty" json:"duration_ms,omitempty"`
	FileSize     int64          `bson:"file_size,omitempty" json:"file_size,omitempty"`
	// Actor identifies the GitHub login responsible for an operator-initiated
	// event (e.g. an LLM settings change). Empty for webhook-driven copies.
	Actor          string         `bson:"actor,omitempty" json:"actor,omitempty"`
	AdditionalData map[string]any `bson:"additional_data,omitempty" json:"additional_data,omitempty"`
}

type AuditEventType string

type AuditListQuery struct {
	Limit      int
	EventType  string     // empty = any; otherwise copy | deprecation | error
	Success    *bool      // nil = any
	RuleName   string     // exact match when non-empty
	PRNumber   *int       // nil = any; exact match when set
	PathSearch string     // substring match on source_path OR target_path when non-empty
	Since      *time.Time // inclusive lower bound on timestamp when set
}

type AuditLogger interface {
	LogCopyEvent(ctx context.Context, event *AuditEvent) error
	LogDeprecationEvent(ctx context.Context, event *AuditEvent) error
	LogErrorEvent(ctx context.Context, event *AuditEvent) error
	// LogConfigChangeEvent records an operator-initiated configuration change
	// (e.g. LLM base URL or active model). Used for after-the-fact detection
	// of suspicious changes — the event captures who, what, and old→new value.
	LogConfigChangeEvent(ctx context.Context, event *AuditEvent) error
	GetRecentEvents(ctx context.Context, limit int) ([]AuditEvent, error)
	GetFailedEvents(ctx context.Context, limit int) ([]AuditEvent, error)
	GetEventsByRule(ctx context.Context, ruleName string, limit int) ([]AuditEvent, error)
	GetStatsByRule(ctx context.Context) (map[string]RuleStats, error)
	GetDailyVolume(ctx context.Context, days int) ([]DailyStats, error)
	QueryAuditEvents(ctx context.Context, q AuditListQuery) ([]AuditEvent, error)
	Ping(ctx context.Context) error
	Close(ctx context.Context) error
}

type AuditLoggerHealthStatus struct {
	Status    string `json:"status"`
	Connected bool   `json:"connected"`
}

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

type ConfigDiagnosticResponse struct {
	// Version is the build version (set via -ldflags at build time).
	Version string `json:"version"`

	// Environment summarizes non-secret runtime configuration.
	Environment ConfigEnvironment `json:"environment"`

	// Workflows contains the resolved workflow definitions (if loadable).
	// Nil when the config could not be loaded (see LoadError).
	Workflows []ConfigDiagnosticWorkflow `json:"workflows,omitempty"`

	// LoadError is set when the effective config file cannot be loaded or parsed.
	LoadError string `json:"load_error,omitempty"`
}

type ConfigDiagnosticWorkflow struct {
	Name           string   `json:"name"`
	SourceRepo     string   `json:"source_repo"`
	SourceBranch   string   `json:"source_branch"`
	DestRepo       string   `json:"dest_repo"`
	DestBranch     string   `json:"dest_branch"`
	CommitStrategy string   `json:"commit_strategy"`
	Transforms     int      `json:"transforms"`
	Exclude        []string `json:"exclude,omitempty"`
}

type ConfigEnvironment struct {
	Port             string `json:"port"`
	DryRun           bool   `json:"dry_run"`
	UseMainConfig    bool   `json:"use_main_config"`
	EffectiveConfig  string `json:"effective_config_file"`
	ConfigRepoOwner  string `json:"config_repo_owner"`
	ConfigRepoName   string `json:"config_repo_name"`
	ConfigRepoBranch string `json:"config_repo_branch"`
	WebserverPath    string `json:"webserver_path"`

	// Feature flags
	AuditEnabled   bool `json:"audit_enabled"`
	MetricsEnabled bool `json:"metrics_enabled"`
	SlackEnabled   bool `json:"slack_enabled"`

	// Tuning
	ConfigCacheTTLSeconds           int `json:"config_cache_ttl_seconds"`
	WebhookProcessingTimeoutSeconds int `json:"webhook_processing_timeout_seconds"`
	WebhookMaxRetries               int `json:"webhook_max_retries"`
	GitHubAPIMaxRetries             int `json:"github_api_max_retries"`

	// Secrets (presence only)
	PEMKey        string `json:"pem_key"`
	WebhookSecret string `json:"webhook_secret"`
	MongoURI      string `json:"mongo_uri"`
	SlackWebhook  string `json:"slack_webhook_url"`
}

type ConfigLoader interface {
	LoadConfig(ctx context.Context, config *configs.Config) (*types.YAMLConfig, error)
	LoadConfigFromContent(content string, filename string) (*types.YAMLConfig, error)
}

type DailyStats struct {
	Date         string `bson:"_id" json:"date"`
	TotalCopies  int    `bson:"total_copies" json:"total_copies"`
	SuccessCount int    `bson:"success_count" json:"success_count"`
	FailureCount int    `bson:"failure_count" json:"failure_count"`
}

type DefaultConfigLoader struct{}

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

type DefaultMainConfigLoader struct{}

type DefaultMessageTemplater struct{}

type DefaultPRTemplateFetcher struct{}

type DefaultPathTransformer struct{}

type DefaultPatternMatcher struct{}

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

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

type DeliverySnapshot struct {
	DeliveryID string    `json:"delivery_id"`
	SeenAt     time.Time `json:"seen_at"`
	Duplicate  bool      `json:"duplicate"`
}

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

type DeprecationEvent struct {
	PRNumber   int
	SourceRepo string
	FileCount  int
	Files      []string
}

type ErrorEvent struct {
	Operation      string
	Error          error
	PRNumber       int
	SourceRepo     string
	DeliveryID     string // GitHub webhook delivery ID for tracing
	Attempts       int    // number of processing attempts (0 = not set)
	AdditionalInfo map[string]interface{}
}

type FileMetrics struct {
	Matched           int64               `json:"matched"`
	Uploaded          int64               `json:"uploaded"`
	UploadFailed      int64               `json:"upload_failed"`
	Deprecated        int64               `json:"deprecated"`
	UploadSuccessRate float64             `json:"upload_success_rate"`
	UploadTime        ProcessingTimeStats `json:"upload_time"`
}

type FileStateService interface {
	GetFilesToUpload() map[types.UploadKey]types.UploadFileContent
	// GetFilesToDeprecate returns all deprecated file entries grouped by deprecation file name
	GetFilesToDeprecate() map[string][]types.DeprecatedFileEntry
	AddFileToUpload(key types.UploadKey, content types.UploadFileContent)
	// AddFileToDeprecate adds a file entry to the deprecation list for the given deprecation file
	AddFileToDeprecate(deprecationFile string, entry types.DeprecatedFileEntry)
	ClearFilesToUpload()
	ClearFilesToDeprecate()
}

type FilesCopiedEvent struct {
	PRNumber   int
	SourceRepo string
	TargetRepo string
	FileCount  int
	Files      []string
	RuleName   string
}

type GitHubAPIMetrics struct {
	Calls     int64         `json:"calls"`
	Errors    int64         `json:"errors"`
	ErrorRate float64       `json:"error_rate"`
	RateLimit RateLimitInfo `json:"rate_limit"`
}

type GitHubHealthStatus struct {
	Status        string `json:"status"`
	Authenticated bool   `json:"authenticated"`
}

type HealthStatus struct {
	Status      string                  `json:"status"`
	Started     bool                    `json:"started"`
	GitHub      GitHubHealthStatus      `json:"github"`
	Queues      QueueHealthStatus       `json:"queues"`
	AuditLogger AuditLoggerHealthStatus `json:"audit_logger,omitempty"`
	Uptime      string                  `json:"uptime"`
}

type LLMClient interface {
	// GenerateJSON sends a prompt to the LLM and returns the raw response body.
	GenerateJSON(ctx context.Context, systemPrompt, userPrompt string) (string, error)

	// ProviderName returns a short identifier for logging.
	ProviderName() string

	// Ping checks whether the LLM service is reachable.
	Ping(ctx context.Context) error

	// GetBaseURL returns the current base URL.
	GetBaseURL() string
	// SetBaseURL updates the base URL at runtime.
	SetBaseURL(url string)

	// GetActiveModel returns the model that will be used for generations.
	GetActiveModel() string
	// SetActiveModel updates the active model at runtime.
	SetActiveModel(model string)

	// ListModels returns the models installed/available on the LLM server.
	ListModels(ctx context.Context) ([]LLMModel, error)

	// PullModel asks the server to download a model. Progress updates are
	// written to progress as they arrive. The function blocks until the pull
	// completes or the context is cancelled.
	PullModel(ctx context.Context, name string, progress func(LLMPullProgress)) error

	// DeleteModel removes a model from the server.
	DeleteModel(ctx context.Context, name string) error
}

type LLMClientOptions struct {
	Provider string
	BaseURL  string
	Model    string
	APIKey   string
}

type LLMModel struct {
	Name       string `json:"name"`
	Size       int64  `json:"size,omitempty"`
	ModifiedAt string `json:"modified_at,omitempty"`
}

type LLMPullProgress struct {
	Status    string `json:"status"`
	Completed int64  `json:"completed,omitempty"`
	Total     int64  `json:"total,omitempty"`
	Digest    string `json:"digest,omitempty"`
	Error     string `json:"error,omitempty"`
}

type LogEntry struct {
	Time    time.Time      `json:"time"`
	Level   string         `json:"level"`
	Message string         `json:"message"`
	Fields  map[string]any `json:"fields,omitempty"`
}

type MessageTemplater interface {
	RenderCommitMessage(template string, ctx *types.MessageContext) string
	RenderPRTitle(template string, ctx *types.MessageContext) string
	RenderPRBody(template string, ctx *types.MessageContext) string
}

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

type MetricsData struct {
	Webhooks  WebhookMetrics   `json:"webhooks"`
	Files     FileMetrics      `json:"files"`
	GitHubAPI GitHubAPIMetrics `json:"github_api"`
	Queues    QueueMetrics     `json:"queues"`
	System    SystemMetrics    `json:"system"`
}

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

type NoOpAuditLogger struct{}

type OperatorDeploymentInfo struct {
	Version            string            `json:"version"`
	UptimeSeconds      int64             `json:"uptime_seconds"`
	MongoHealthy       *bool             `json:"mongo_healthy,omitempty"`
	GoogleCloudRegion  string            `json:"google_cloud_region,omitempty"`
	CloudRunService    string            `json:"cloud_run_service,omitempty"`
	CloudRunRevision   string            `json:"cloud_run_revision,omitempty"`
	CloudRunConfig     string            `json:"cloud_run_configuration,omitempty"`
	GoogleCloudProject string            `json:"google_cloud_project,omitempty"`
	Port               string            `json:"port"`
	WebhookPath        string            `json:"webhook_path"`
	DryRun             bool              `json:"dry_run"`
	AuditEnabled       bool              `json:"audit_enabled"`
	AuditDatabase      string            `json:"audit_database,omitempty"`
	AuditCollection    string            `json:"audit_collection,omitempty"`
	ConfigRepo         string            `json:"config_repo,omitempty"`
	EffectiveConfig    string            `json:"effective_config_file,omitempty"`
	OperatorRepoSlug   string            `json:"operator_repo_slug,omitempty"`
	ReleaseAPIMode     ReleaseAPIMode    `json:"release_api_mode"`
	Env                map[string]string `json:"cloud_env,omitempty"`
}

type OperatorRole string

type OperatorUser struct {
	Login     string       `json:"login"`
	AvatarURL string       `json:"avatar_url,omitempty"`
	Role      OperatorRole `json:"role"`
}

type PRProcessedEvent struct {
	PRNumber       int
	PRTitle        string
	PRURL          string
	SourceRepo     string
	TargetRepos    []string // List of target repositories files were copied to
	FilesMatched   int
	FilesCopied    int
	FilesFailed    int
	ProcessingTime time.Duration
}

type PRTemplateFetcher interface {
	// FetchPRTemplate fetches the PR template from a target repository
	// Returns the template content, or empty string if not found
	FetchPRTemplate(ctx context.Context, client *github.Client, repoFullName string, branch string) (string, error)
}

type PathTransformer interface {
	Transform(sourcePath string, template string, variables map[string]string) (string, error)
}

type PatternMatcher interface {
	Match(filePath string, pattern types.SourcePattern) types.MatchResult
}

type ProcessingTimeStats struct {
	AvgMs float64 `json:"avg_ms"`
	MinMs float64 `json:"min_ms"`
	MaxMs float64 `json:"max_ms"`
	P50Ms float64 `json:"p50_ms"`
	P95Ms float64 `json:"p95_ms"`
	P99Ms float64 `json:"p99_ms"`
}

type QueueHealthStatus struct {
	UploadCount      int `json:"upload_count"`
	DeprecationCount int `json:"deprecation_count"`
}

type QueueMetrics struct {
	UploadQueueSize      int `json:"upload_queue_size"`
	DeprecationQueueSize int `json:"deprecation_queue_size"`
	RetryQueueSize       int `json:"retry_queue_size"`
}

type RateLimitInfo struct {
	Remaining int       `json:"remaining"`
	ResetAt   time.Time `json:"reset_at"`
}

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

type ReleaseAPIMode string

type RuleStats struct {
	RuleName     string  `bson:"_id" json:"rule_name"`
	TotalCopies  int     `bson:"total_copies" json:"total_copies"`
	SuccessCount int     `bson:"success_count" json:"success_count"`
	FailureCount int     `bson:"failure_count" json:"failure_count"`
	AvgDuration  float64 `bson:"avg_duration" json:"avg_duration_ms"`
}

type ServiceContainer struct {
	Config           *configs.Config
	FileStateService FileStateService
	TokenManager     *TokenManager

	// New services
	ConfigLoader      ConfigLoader
	PatternMatcher    PatternMatcher
	PathTransformer   PathTransformer
	MessageTemplater  MessageTemplater
	PRTemplateFetcher PRTemplateFetcher
	AuditLogger       AuditLogger
	MetricsCollector  *MetricsCollector
	SlackNotifier     SlackNotifier

	// Webhook deduplication
	DeliveryTracker *DeliveryTracker

	// Recent webhook outcomes for operator troubleshooting (in-memory)
	WebhookTraces *WebhookTraceBuffer

	// Per-delivery log capture for operator diagnostics (in-memory)
	DeliveryLogs *DeliveryLogBuffer

	// Server state
	StartTime time.Time
	// contains filtered or unexported fields
}

type SlackAttachment struct {
	Color      string       `json:"color,omitempty"`
	Title      string       `json:"title,omitempty"`
	TitleLink  string       `json:"title_link,omitempty"`
	Text       string       `json:"text,omitempty"`
	Fields     []SlackField `json:"fields,omitempty"`
	Footer     string       `json:"footer,omitempty"`
	FooterIcon string       `json:"footer_icon,omitempty"`
	Timestamp  int64        `json:"ts,omitempty"`
}

type SlackField struct {
	Title string `json:"title"`
	Value string `json:"value"`
	Short bool   `json:"short"`
}

type SlackMessage struct {
	Channel     string            `json:"channel,omitempty"`
	Username    string            `json:"username,omitempty"`
	IconEmoji   string            `json:"icon_emoji,omitempty"`
	Text        string            `json:"text,omitempty"`
	Attachments []SlackAttachment `json:"attachments,omitempty"`
}

type SlackNotifier interface {
	// NotifyPRProcessed sends a notification when a PR is successfully processed
	NotifyPRProcessed(ctx context.Context, event *PRProcessedEvent) error

	// NotifyError sends a notification when an error occurs
	NotifyError(ctx context.Context, event *ErrorEvent) error

	// NotifyFilesCopied sends a notification when files are copied
	NotifyFilesCopied(ctx context.Context, event *FilesCopiedEvent) error

	// NotifyDeprecation sends a notification when files are deprecated
	NotifyDeprecation(ctx context.Context, event *DeprecationEvent) error

	// IsEnabled returns true if Slack notifications are enabled
	IsEnabled() bool
}

type SystemMetrics struct {
	UptimeSeconds int64 `json:"uptime_seconds"`
}

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

type WebhookMetrics struct {
	Received       int64               `json:"received"`
	Processed      int64               `json:"processed"`
	Failed         int64               `json:"failed"`
	Ignored        int64               `json:"ignored"`     // Non-PR events
	EventTypes     map[string]int64    `json:"event_types"` // Count by event type
	SuccessRate    float64             `json:"success_rate"`
	ProcessingTime ProcessingTimeStats `json:"processing_time"`
}

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

type WebhookTraceEntry struct {
	At         time.Time `json:"at"`
	DeliveryID string    `json:"delivery_id,omitempty"`
	EventType  string    `json:"event_type,omitempty"`
	Action     string    `json:"action,omitempty"`
	Repo       string    `json:"repo,omitempty"`
	BaseBranch string    `json:"base_branch,omitempty"`
	CommitSHA  string    `json:"commit_sha,omitempty"`
	PRNumber   int       `json:"pr_number,omitempty"`
	Outcome    string    `json:"outcome"`
	Detail     string    `json:"detail,omitempty"`
}

type WorkflowProcessor interface {
	ProcessWorkflow(ctx context.Context, workflow types.Workflow, changedFiles []types.ChangedFile, prNumber int, sourceCommitSHA string) error
}