threadrespond

type AcquireFunc func(string) (Lock, error)

type Lock interface {
	Release() error
}

type Options struct {
	Store        Store
	Provider     outbox.LiveProvider
	Adapter      llm.Adapter
	Limiter      outbox.Limiter
	Layout       statepaths.Layout
	Acquire      AcquireFunc
	TaskProgress llmlifecycle.Progress
	Now          func() time.Time

	NewRunID       func() string
	NewActionID    func(reviewplan.ActionKind) (string, error)
	NewStepID      func() string
	ModelTier      config.ModelTier
	ModelOverride  string
	EffortOverride string
}

type Request struct {
	PRRef            gitprovider.PRRef
	PRURL            string
	ProfileName      string
	Profile          config.Profile
	PostingIdentity  gitprovider.Identity
	DryRun           bool
	NoResolveThreads bool
	Rerun            bool
	RetryRunID       string
}

type Result struct {
	Run             ledger.Run
	PR              gitprovider.PR
	PRKey           string
	Artifacts       runartifact.Paths
	Threads         []threadcontext.Thread
	EligibleThreads []threadcontext.Thread
	Analyses        []threadanalysis.Result
	Responses       []review.ThreadResponseAction
	Plan            reviewplan.Plan
	PlannedActions  []ledger.PlannedAction
	Outbox          outbox.Result
	ExitCode        int
	Message         string
}

type Store interface {
	llmlifecycle.Store
	GetRun(context.Context, string) (ledger.Run, error)
	ListRunsForHeadScope(context.Context, ledger.ListRunsForHeadScopeParams) ([]ledger.Run, error)
	AllocateRun(context.Context, ledger.AllocateRunParams) (ledger.Run, error)
	InsertPlannedAction(context.Context, ledger.PlannedAction) error
	InsertPlannedActions(context.Context, []ledger.PlannedAction) error
	ListPlannedActions(context.Context, string) ([]ledger.PlannedAction, error)
	UpdatePlannedAction(context.Context, ledger.PlannedAction) error
	CompleteRun(context.Context, string, ledger.Outcome, time.Time) error
}