services

type AuditEvent struct {
	ID             string         `bson:"_id,omitempty"`
	Timestamp      time.Time      `bson:"timestamp"`
	EventType      AuditEventType `bson:"event_type"`
	RuleName       string         `bson:"rule_name,omitempty"`
	SourceRepo     string         `bson:"source_repo"`
	SourcePath     string         `bson:"source_path"`
	TargetRepo     string         `bson:"target_repo,omitempty"`
	TargetPath     string         `bson:"target_path,omitempty"`
	CommitSHA      string         `bson:"commit_sha,omitempty"`
	PRNumber       int            `bson:"pr_number,omitempty"`
	Success        bool           `bson:"success"`
	ErrorMessage   string         `bson:"error_message,omitempty"`
	DurationMs     int64          `bson:"duration_ms,omitempty"`
	FileSize       int64          `bson:"file_size,omitempty"`
	AdditionalData map[string]any `bson:"additional_data,omitempty"`
}

type AuditEventType string

type AuditLogger interface {
	LogCopyEvent(ctx context.Context, event *AuditEvent) error
	LogDeprecationEvent(ctx context.Context, event *AuditEvent) error
	LogErrorEvent(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)
	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"`
	TotalCopies  int    `bson:"total_copies"`
	SuccessCount int    `bson:"success_count"`
	FailureCount int    `bson:"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 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 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 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 RuleStats struct {
	RuleName     string  `bson:"_id"`
	TotalCopies  int     `bson:"total_copies"`
	SuccessCount int     `bson:"success_count"`
	FailureCount int     `bson:"failure_count"`
	AvgDuration  float64 `bson:"avg_duration"`
}

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

	// 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 WorkflowProcessor interface {
	ProcessWorkflow(ctx context.Context, workflow types.Workflow, changedFiles []types.ChangedFile, prNumber int, sourceCommitSHA string) error
}