queue

type BulkActionResult struct {
	Processed int `json:"processed"`
	Succeeded int `json:"succeeded"`
	Failed    int `json:"failed"`
}

type CleanupPayload struct {
	RepositoryID   int64  `json:"repository_id"`
	RepositoryName string `json:"repository_name"`
	DataDir        string `json:"data_dir"` // Base data directory for repos and index
}

type CleanupResult struct {
	DeletedCount int `json:"deleted_count"`
	ScannedCount int `json:"scanned_count"`
}

type IndexPayload struct {
	RepositoryID int64    `json:"repository_id"`
	ConnectionID int64    `json:"connection_id"`
	RepoName     string   `json:"repo_name"`
	CloneURL     string   `json:"clone_url"`
	Branch       string   `json:"branch"`             // Default/primary branch (backward compat)
	Branches     []string `json:"branches,omitempty"` // Additional branches to index
}

type Job struct {
	ID          string          `json:"id"`
	Type        JobType         `json:"type"`
	Status      JobStatus       `json:"status"`
	Payload     json.RawMessage `json:"payload"`
	Error       string          `json:"error,omitempty"`
	CreatedAt   time.Time       `json:"created_at"`
	UpdatedAt   time.Time       `json:"updated_at"`
	StartedAt   *time.Time      `json:"started_at,omitempty"`
	CompletedAt *time.Time      `json:"completed_at,omitempty"`
	Progress    *JobProgress    `json:"progress,omitempty"`
	// Retry fields
	Attempts    int        `json:"attempts"`               // Number of attempts so far
	MaxAttempts int        `json:"max_attempts,omitempty"` // Max attempts (0 = use default)
	NextRetryAt *time.Time `json:"next_retry_at,omitempty"`
	LastError   string     `json:"last_error,omitempty"` // Error from last attempt
}

type JobListOptions struct {
	Type          JobType    // Filter by job type (empty = all)
	Status        JobStatus  // Filter by status (empty = all)
	ExcludeStatus JobStatus  // Exclude jobs with this status (empty = none)
	RepoName      string     // Filter by repo name (partial match, empty = all)
	CreatedAfter  *time.Time // Filter to jobs created after this time (nil = no filter)
	Limit         int        // Max results (default 50)
	Offset        int        // Pagination offset
}

type JobListResult struct {
	Jobs       []*Job `json:"jobs"`
	TotalCount int    `json:"total_count"`
	Limit      int    `json:"limit"`
	Offset     int    `json:"offset"`
	HasMore    bool   `json:"has_more"`
}

type JobProgress struct {
	Current int    `json:"current"`
	Total   int    `json:"total"`
	Message string `json:"message,omitempty"`
}

type JobStatus string

type JobType string

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

type ReplaceMatch struct {
	RepositoryID   int64  `json:"repository_id"`
	RepositoryName string `json:"repository_name"`
	FilePath       string `json:"file_path"`
}

type ReplacePayload struct {
	// Search parameters (kept for reference/logging, not used for search)
	SearchPattern string   `json:"search_pattern"`
	ReplaceWith   string   `json:"replace_with"`
	IsRegex       bool     `json:"is_regex"`
	CaseSensitive bool     `json:"case_sensitive"`
	FilePatterns  []string `json:"file_patterns,omitempty"`

	// Matches from preview (required - Execute uses these directly)
	Matches []ReplaceMatch `json:"matches"`

	// MR/PR options (MR is always created)
	BranchName    string `json:"branch_name,omitempty"`
	MRTitle       string `json:"mr_title,omitempty"`
	MRDescription string `json:"mr_description,omitempty"`

	// User-provided tokens for repos without server-side authentication
	// Map of connection_id (as string) -> token
	UserTokens map[string]string `json:"user_tokens,omitempty"`

	// ReposReadOnly indicates if the system is in read-only mode
	// When true, only user-provided tokens can be used (DB tokens are for indexing only)
	ReposReadOnly bool `json:"repos_readonly,omitempty"`
}

type ShardedQueue struct {
	*Queue
	// contains filtered or unexported fields
}

type SyncPayload struct {
	ConnectionID int64 `json:"connection_id"`
}

type TLSConfig struct {
	Enabled    bool   // Enable TLS
	SkipVerify bool   // Skip certificate verification (insecure)
	CertFile   string // Path to client certificate file (for mTLS)
	KeyFile    string // Path to client key file (for mTLS)
	CACertFile string // Path to CA certificate file
	ServerName string // Override server name for TLS verification
}