daemon

type DocumentMissingError struct {
	Kind         string
	WorkflowSlug string
	RelativePath string
}

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

type Info struct {
	PID        int        `json:"pid"`
	Version    string     `json:"version,omitempty"`
	SocketPath string     `json:"socket_path,omitempty"`
	StartedAt  time.Time  `json:"started_at"`
	State      ReadyState `json:"state"`
}

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

type MarkdownDocument struct {
	ID        string
	Kind      string
	Title     string
	UpdatedAt time.Time
	Markdown  string
	Metadata  map[string]any
}

type ProbeOptions struct {
	ProcessAlive func(int) bool
	Healthy      func(context.Context, Info) error
}

type QueryService interface {
	WorkflowOverview(ctx context.Context, workspaceRef string, workflowSlug string) (WorkflowOverviewPayload, error)
	TaskBoard(ctx context.Context, workspaceRef string, workflowSlug string) (TaskBoardPayload, error)
	WorkflowSpec(ctx context.Context, workspaceRef string, workflowSlug string) (WorkflowSpecDocument, error)
	WorkflowMemoryIndex(ctx context.Context, workspaceRef string, workflowSlug string) (WorkflowMemoryIndex, error)
	WorkflowMemoryFile(
		ctx context.Context,
		workspaceRef string,
		workflowSlug string,
		fileID string,
	) (MarkdownDocument, error)
	TaskDetail(ctx context.Context, workspaceRef string, workflowSlug string, taskID string) (TaskDetailPayload, error)
	ReviewDetail(
		ctx context.Context,
		workspaceRef string,
		workflowSlug string,
		round int,
		issueRef string,
	) (ReviewDetailPayload, error)
	RunDetail(ctx context.Context, runID string) (RunDetailPayload, error)
}

type QueryServiceConfig struct {
	GlobalDB   *globaldb.GlobalDB
	RunManager *RunManager
}

type ReadyState string

type ReconcileConfig struct {
	HomePaths    productizeconfig.HomePaths
	Now          func() time.Time
	OpenGlobalDB func(context.Context, string) (*globaldb.GlobalDB, error)
	OpenRunDB    func(context.Context, string) (*rundb.RunDB, error)
}

type ReconcileResult struct {
	ReconciledRuns      int
	CrashEventAppended  int
	CrashEventFailures  int
	LastReconciledRunID string
}

type ReviewDetailPayload struct {
	Workspace   apicore.Workspace
	Workflow    apicore.WorkflowSummary
	Round       apicore.ReviewRound
	Issue       ReviewIssueDetail
	Document    MarkdownDocument
	RelatedRuns []apicore.Run
}

type ReviewIssueDetail struct {
	ID          string
	IssueNumber int
	Severity    string
	Status      string
	UpdatedAt   time.Time
}

type ReviewIssueNotFoundError struct {
	WorkflowSlug string
	Round        int
	IssueRef     string
}

type ReviewWatchGit interface {
	State(ctx context.Context, workspaceRoot string) (ReviewWatchGitState, error)
	Push(ctx context.Context, workspaceRoot string, remote string, branch string) error
}

type ReviewWatchGitState struct {
	Branch          string
	HeadSHA         string
	UpstreamRemote  string
	UpstreamBranch  string
	Dirty           bool
	UnpushedCommits int
}

type RunDetailPayload struct {
	Run          apicore.Run
	Snapshot     apicore.RunSnapshot
	JobCounts    RunJobCounts
	Runtime      RunRuntimeSummary
	Timeline     []eventspkg.Event
	ArtifactSync []rundb.ArtifactSyncRow
}

type RunJobCounts struct {
	Queued    int
	Running   int
	Retrying  int
	Completed int
	Failed    int
	Canceled  int
}

type RunLifecycleSettings struct {
	KeepTerminalDays     int
	KeepMax              int
	ShutdownDrainTimeout time.Duration
}

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

type RunManagerConfig struct {
	GlobalDB               *globaldb.GlobalDB
	LifecycleContext       context.Context
	ShutdownDrainTimeout   time.Duration
	Now                    func() time.Time
	BuildRunID             func(*model.RuntimeConfig) (string, error)
	OpenRunScope           func(context.Context, *model.RuntimeConfig, model.OpenRunScopeOptions) (model.RunScope, error)
	Prepare                func(context.Context, *model.RuntimeConfig, model.RunScope) (*model.SolvePreparation, error)
	Execute                func(context.Context, *model.SolvePreparation, *model.RuntimeConfig) error
	ExecuteExec            func(context.Context, *model.RuntimeConfig, model.RunScope) error
	OpenRunDB              func(context.Context, string) (*rundb.RunDB, error)
	LoadProjectConfig      func(context.Context, string) (workspacecfg.ProjectConfig, error)
	ReviewProviderRegistry reviewProviderRegistryFactory
	ReviewWatchGit         ReviewWatchGit
	WatcherDebounce        time.Duration
	RunDBCacheTTL          time.Duration
	LookupWorkflowSlugs    func(context.Context, []string) (map[string]string, error)
	GetWorkflow            func(context.Context, string) (globaldb.Workflow, error)
}

type RunMode string

type RunOptions struct {
	Version string
	Mode    RunMode
}

type RunPurgeResult struct {
	PurgedRunIDs []string
}

type RunRuntimeSummary struct {
	IDEs              []string
	Models            []string
	ReasoningEfforts  []string
	AccessModes       []string
	PresentationModes []string
}

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

type ServiceConfig struct {
	Host              *Host
	GlobalDB          *globaldb.GlobalDB
	RunManager        *RunManager
	RequestStop       func(context.Context) error
	ReconcileResult   ReconcileResult
	LifecycleSettings RunLifecycleSettings
	Now               func() time.Time
}

type StaleDocumentReferenceError struct {
	Kind         string
	WorkflowSlug string
	Reference    string
}

type StartOptions struct {
	HomePaths    productizeconfig.HomePaths
	Version      string
	PID          int
	Now          func() time.Time
	ProcessAlive func(int) bool
	Healthy      func(context.Context, Info) error
	Prepare      func(context.Context, *Host) error
}

type StartOutcome string

type StartResult struct {
	Outcome StartOutcome
	Paths   productizeconfig.HomePaths
	Info    Info
	Host    *Host
}

type Status struct {
	Paths   productizeconfig.HomePaths
	State   ReadyState
	Healthy bool
	Info    *Info
}

type TaskBoardPayload struct {
	Workspace  apicore.Workspace
	Workflow   apicore.WorkflowSummary
	TaskCounts WorkflowTaskCounts
	Lanes      []TaskLane
}

type TaskCard struct {
	TaskNumber int
	TaskID     string
	Title      string
	Status     string
	Type       string
	DependsOn  []string
	UpdatedAt  time.Time
}

type TaskDetailPayload struct {
	Workspace         apicore.Workspace
	Workflow          apicore.WorkflowSummary
	Task              TaskCard
	Document          MarkdownDocument
	MemoryEntries     []WorkflowMemoryEntry
	RelatedRuns       []apicore.Run
	LiveTailAvailable bool
}

type TaskLane struct {
	Status string
	Title  string
	Items  []TaskCard
}

type WorkflowMemoryEntry struct {
	FileID      string
	DisplayPath string
	Kind        string
	Title       string
	SizeBytes   int64
	UpdatedAt   time.Time
}

type WorkflowMemoryIndex struct {
	Workspace apicore.Workspace
	Workflow  apicore.WorkflowSummary
	Entries   []WorkflowMemoryEntry
}

type WorkflowOverviewPayload struct {
	Workspace       apicore.Workspace
	Workflow        apicore.WorkflowSummary
	TaskCounts      WorkflowTaskCounts
	LatestReview    *apicore.ReviewSummary
	RecentRuns      []apicore.Run
	ArchiveEligible bool
	ArchiveReason   string
}

type WorkflowSpecDocument struct {
	Workspace apicore.Workspace
	Workflow  apicore.WorkflowSummary
	PRD       *MarkdownDocument
	TechSpec  *MarkdownDocument
	ADRs      []MarkdownDocument
}

type WorkflowTaskCounts struct {
	Total     int
	Completed int
	Pending   int
}