server

type AdmitResult struct {
	Status AdmitStatus
	Reason string
}

type AdmitStatus int

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

type DashboardMetrics struct {
	TotalPRs           int            `json:"total_prs"`
	TotalJobs          int            `json:"total_jobs"`
	ActiveWorkers      int            `json:"active_workers"`
	RunningJobs        int            `json:"running_jobs"`
	QueuedJobs         int            `json:"queued_jobs"`
	DeferredJobs       int            `json:"deferred_jobs"`
	NeedsAttentionJobs int            `json:"needs_attention_jobs"`
	AutonomousCommits  int            `json:"autonomous_commits"`
	Decisions          map[string]int `json:"decisions"`
	JobsByKind         map[string]int `json:"jobs_by_kind"`
	JobsByStatus       map[string]int `json:"jobs_by_status"`
	SuccessRate        float64        `json:"success_rate"`
	RecentJobs         []*JobSummary  `json:"recent_jobs"`
}

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

type DecisionRecord struct {
	PRKey       PRKey          `json:"pr_key"`
	HeadSHA     string         `json:"head_sha"`
	Event       string         `json:"event"`
	JobID       string         `json:"job_id"`
	ReviewID    int64          `json:"review_id,omitempty"`
	Status      DecisionStatus `json:"status"`
	ClaimedAt   time.Time      `json:"claimed_at"`
	PublishedAt *time.Time     `json:"published_at,omitempty"`
	Error       string         `json:"error,omitempty"`
}

type DecisionReviewClient interface {
	PostDecisionReview(ctx context.Context, owner, repo string, number int, commitSHA string, event string, body string, suggestions []ghclient.InlineSuggestion) (*github.PullRequestReview, error)
}

type DecisionStatus string

type Delivery struct {
	Host        string    `json:"host"`
	RepoID      int64     `json:"repo_id"`
	DeliveryID  string    `json:"delivery_id"`
	EventKind   string    `json:"event_kind"`
	PayloadHash string    `json:"payload_hash"` // SHA-256 hex
	ReceivedAt  time.Time `json:"received_at"`
	JobIDs      []string  `json:"job_ids,omitempty"`
}

type HealthCounts struct {
	Queued         int  `json:"queued"`
	Running        int  `json:"running"`
	Uncertain      int  `json:"uncertain"`
	NeedsAttention int  `json:"needs_attention"`
	Deferred       int  `json:"deferred"`
	OldWaitWarning bool `json:"old_wait_warning"`
}

type IntentVerdict struct {
	Intent     string  `json:"intent"`
	Confidence float64 `json:"confidence"`
	Summary    string  `json:"summary"`
}

type Job struct {
	ID              string     `json:"id"`
	Sequence        uint64     `json:"sequence"`
	Kind            string     `json:"kind"`    // "review", "labels", "describe", "summary", "docs", "changelog", "improve", "assistant", "edit"
	Trigger         string     `json:"trigger"` // "automatic", "explicit"
	Author          string     `json:"author"`
	CommentID       int64      `json:"comment_id,omitempty"`
	PRKey           PRKey      `json:"pr_key"`
	Owner           string     `json:"owner"`
	Repo            string     `json:"repo"`
	PRNumber        int        `json:"pr_number"`
	BaseSHA         string     `json:"base_sha"`
	HeadSHA         string     `json:"head_sha"`
	Generation      uint64     `json:"generation"`
	Status          string     `json:"status"` // "queued", "running", "completed", "failed", "superseded", "uncertain", "needs_attention"
	CreatedAt       time.Time  `json:"created_at"`
	StartedAt       *time.Time `json:"started_at,omitempty"`
	FinishedAt      *time.Time `json:"finished_at,omitempty"`
	RecoveryPhase   string     `json:"recovery_phase,omitempty"`
	Reservations    int64      `json:"reservations"`
	StatusCommentID int64      `json:"status_comment_id,omitempty"`
	OutputMarker    string     `json:"output_marker,omitempty"`
	// NotBeforeAt parks a deferred attempt in the durable queue until the due
	// time arrives. Zero value means immediately eligible; old rows unmarshal
	// unchanged and schema version stays 1.
	NotBeforeAt time.Time `json:"not_before_at,omitempty"`
	Payload     string    `json:"payload,omitempty"`
	// NetworkFetch opts this job's agent tools into the gateway-mediated
	// fetch path for this job only. False is the default (offline, D-02);
	// true is valid only for the job that carried an explicit trusted
	// opt-in (D-03) and resets to false at terminal state.
	NetworkFetch bool   `json:"network_fetch,omitempty"`
	Error        string `json:"error,omitempty"`
}

type JobExecutor interface {
	ExecuteJob(ctx context.Context, job *Job) error
}

type JobStore interface {
	Close() error
	Admit(ctx context.Context, delivery Delivery, jobs []Job) (AdmitResult, error)
	GetDelivery(ctx context.Context, key string) (*Delivery, error)
	GetJob(ctx context.Context, id string) (*Job, error)
	ListQueuedJobs(ctx context.Context) ([]*Job, error)
	UpdateJob(ctx context.Context, job *Job) error
	// GetDashboardMetrics computes the read-only operations telemetry snapshot
	// inside a single bbolt read transaction.
	GetDashboardMetrics(ctx context.Context) (*DashboardMetrics, error)
	GetPRState(ctx context.Context, key PRKey) (*PRState, error)
	UpdatePRState(ctx context.Context, state *PRState) error
	SaveOutputIntent(ctx context.Context, intent *OutputIntent) error
	GetOutputIntent(ctx context.Context, marker string) (*OutputIntent, error)
	UpdateOutputIntent(ctx context.Context, intent *OutputIntent) error
	// CommitPublicationOutcome atomically commits intent, job and (for confirmed
	// current-head review publication) PRState.LastReviewedHead in one transaction.
	CommitPublicationOutcome(ctx context.Context, intent *OutputIntent, job *Job, prState *PRState) error
	// CommitSupersededOutcome atomically commits a superseded outcome and the
	// latest-head successor obligation (when successor head is non-empty).
	CommitSupersededOutcome(ctx context.Context, intent *OutputIntent, job *Job, successorBaseSHA, successorHeadSHA string) error
	RecoverInterruptedJobs(ctx context.Context) ([]*Job, error)
	RecoverJobs(ctx context.Context) ([]*Job, error)
	InspectJobs(ctx context.Context) ([]*Job, error)
	ResolveJob(ctx context.Context, jobID string, resolution string, ackDuplicateRisk bool) error
	GetHealthCounts(ctx context.Context, oldWaitWarning time.Duration) (HealthCounts, error)
	ClaimNextJob(ctx context.Context, activePRs map[string]bool) (*Job, error)
	ReleasePR(ctx context.Context, prKey PRKey) error
	ScheduleSuccessorReview(ctx context.Context, prKey PRKey, owner, repo string, prNum int, baseSHA, headSHA string) (*Job, error)
	// DeferJob atomically parks a job as a deferred attempt due at dueAt: the
	// job returns to queued with NotBeforeAt set so workers are freed while
	// the wait persists durably. Repeating the same deferral is idempotent.
	DeferJob(ctx context.Context, jobID string, dueAt time.Time, reason string) (*Job, error)
	// EarliestDeferredDue reports the earliest future due time among queued
	// deferred attempts, so the scheduler can bound its idle poll.
	EarliestDeferredDue(ctx context.Context) (time.Time, bool, error)
	ListPendingStatusIntents(ctx context.Context, limit int) ([]*OutputIntent, error)
	MaintainTerminalRecords(ctx context.Context, now time.Time, limit int) (MaintenanceResult, error)
}

type JobSummary struct {
	ID         string     `json:"id"`
	PRKey      string     `json:"pr_key"`
	Owner      string     `json:"owner"`
	Repo       string     `json:"repo"`
	PRNumber   int        `json:"pr_number"`
	Kind       string     `json:"kind"`
	Trigger    string     `json:"trigger"`
	Author     string     `json:"author"`
	Status     string     `json:"status"`
	HeadSHA    string     `json:"head_sha"`
	PRURL      string     `json:"pr_url"`
	CreatedAt  time.Time  `json:"created_at"`
	FinishedAt *time.Time `json:"finished_at,omitempty"`
	Error      string     `json:"error,omitempty"`
}

type LLMCaller interface {
	ChatCompletion(ctx context.Context, systemPrompt string, userMessage string) (string, error)
}

type MaintenanceResult struct {
	Scanned  int `json:"scanned"`
	Deleted  int `json:"deleted"`
	Released int `json:"released"`
	Pinned   int `json:"pinned"`
}

type NeedsAttentionRecorder func(ctx context.Context, job *Job, reason string)

type OutputIntent struct {
	Marker        string `json:"marker"`
	JobID         string `json:"job_id"`
	Action        string `json:"action"`
	PRKey         PRKey  `json:"pr_key"`
	Owner         string `json:"owner"`
	Repo          string `json:"repo"`
	PRNumber      int    `json:"pr_number"`
	ExactHead     string `json:"exact_head"`
	BodyDigest    string `json:"body_digest"` // hex SHA-256
	Body          string `json:"body"`
	VerifiedActor string `json:"verified_actor"`
	Status        string `json:"status"` // "pending", "in_progress", "completed", "uncertain", "needs_attention"
	CommentID     int64  `json:"comment_id,omitempty"`
	// SupersededBody/SupersededDigest record the intended updated body of an owned
	// comment before it is edited as superseded, so restart can match either the
	// original or the updated owned content (additive, optional; schema stays v1).
	SupersededBody   string    `json:"superseded_body,omitempty"`
	SupersededDigest string    `json:"superseded_digest,omitempty"`
	CreatedAt        time.Time `json:"created_at"`
	UpdatedAt        time.Time `json:"updated_at"`
}

type PRKey struct {
	Host   string `json:"host"`
	RepoID int64  `json:"repo_id"`
	Number int    `json:"number"`
}

type PRState struct {
	PRKey                PRKey  `json:"pr_key"`
	Owner                string `json:"owner"`
	Repo                 string `json:"repo"`
	Number               int    `json:"number"`
	Generation           uint64 `json:"generation"`
	LastReviewedHead     string `json:"last_reviewed_head,omitempty"`
	ActiveJobID          string `json:"active_job_id,omitempty"`
	HasReservedSuccessor bool   `json:"has_reserved_successor,omitempty"`
	PendingAutoJobID     string `json:"pending_auto_job_id,omitempty"`
	LatestHeadSHA        string `json:"latest_head_sha,omitempty"`
	HasBlockedAction     bool   `json:"has_blocked_action,omitempty"`
	BlockedReason        string `json:"blocked_reason,omitempty"`
	// LastBotCommitSHA records the commit OID created by the most recent
	// successful edit push on this PR, so the next edit job can surface the
	// prior bot diff as sticky context. Empty when no bot edit landed yet.
	LastBotCommitSHA string `json:"last_bot_commit_sha,omitempty"`
	// LastBotBaseSHA records the PR head the last bot edit applied to.
	LastBotBaseSHA string `json:"last_bot_base_sha,omitempty"`
	// EditHistory carries the most recent user edit instructions (oldest
	// first), capped at MaxEditHistoryEntries with oldest dropped on
	// overflow. Additive omitempty evolution; schema version stays 1.
	EditHistory []string `json:"edit_history,omitempty"`
}

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

type PublishDecisionResult struct {
	Duplicate bool
	Record    *DecisionRecord
	Review    *github.PullRequestReview
}

type ReconcileResult struct {
	Status    string // "completed", "superseded", "uncertain", "needs_attention"
	CommentID int64
	Reused    bool
	Error     error
}

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

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

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

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

type StoreOptions struct {
	BacklogLimit  int
	DeliveryLimit int
	StateMaxBytes int64
	DeliveryTTL   time.Duration
	OpenTimeout   time.Duration
}