runledger

type AcceptanceCriteriaInput struct {
	Description string        `json:"description"`
	Validator   ValidatorSpec `json:"validator"`
}

type AcceptanceCriterion struct {
	Description string        `json:"description"`
	Validator   ValidatorSpec `json:"validator"`
	Met         bool          `json:"met"`
	MetAt       *time.Time    `json:"met_at,omitempty"`
}

type AppendHookSetter interface {
	SetAppendHook(func(JournalEvent))
}

type ArtifactExistsValidator struct{}

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

type BuildPassValidator struct{}

type CommandPassValidator struct{}

type CriterionMetPayload struct {
	Index       int    `json:"index"`
	Description string `json:"description"`
}

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

type Evidence struct {
	Type    string `json:"type"`
	Content string `json:"content"`
}

type FileChangedValidator struct{}

type JournalEvent struct {
	ID        string           `json:"id"`
	RunID     string           `json:"run_id"`
	Seq       int64            `json:"seq"`
	Type      JournalEventType `json:"type"`
	Timestamp time.Time        `json:"timestamp"`
	Payload   json.RawMessage  `json:"payload"`
}

type JournalEventType string

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

type NoteWrittenPayload struct {
	Key   string `json:"key"`
	Value string `json:"value"`
}

type OrchestratorApprovalValidator struct{}

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

type PlanAttachedPayload struct {
	Steps              []Step                `json:"steps"`
	AcceptanceCriteria []AcceptanceCriterion `json:"acceptance_criteria"`
}

type PlannerOutput struct {
	Goal               string                    `json:"goal"`
	AcceptanceCriteria []AcceptanceCriteriaInput `json:"acceptance_criteria"`
	Steps              []StepInput               `json:"steps"`
}

type PolicyAction string

type PolicyDecision struct {
	Action       PolicyAction   `json:"action"`
	NewSteps     []Step         `json:"new_steps,omitempty"`
	NewValidator *ValidatorSpec `json:"new_validator,omitempty"`
	NewAgent     string         `json:"new_agent,omitempty"`
	Reason       string         `json:"reason,omitempty"`
}

type PolicyDecisionAppliedPayload struct {
	StepID   string         `json:"step_id"`
	Decision PolicyDecision `json:"decision"`
}

type PolicyRequest struct {
	RunID      string            `json:"run_id"`
	StepID     string            `json:"step_id"`
	StepGoal   string            `json:"step_goal"`
	Failure    *ValidationResult `json:"failure"`
	RetryCount int               `json:"retry_count"`
	MaxRetries int               `json:"max_retries"`
}

type ProjectionDrift struct {
	RunID  string
	Target string
	Reason string
}

type ProjectionSyncPayload struct {
	Target string `json:"target"`
	Status string `json:"status"`
	Error  string `json:"error,omitempty"`
}

type ResumeCandidate struct {
	RunID       string    `json:"run_id"`
	Goal        string    `json:"goal"`
	Status      RunStatus `json:"status"`
	LastUpdated time.Time `json:"last_updated"`
	StepSummary string    `json:"step_summary"`
}

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

type RolloutConfig struct {
	Stage RolloutStage
}

type RolloutStage int

type RunCompletedPayload struct {
	Summary string `json:"summary"`
}

type RunCreatedPayload struct {
	SessionKey       string          `json:"session_key"`
	OriginalRequest  string          `json:"original_request"`
	Goal             string          `json:"goal"`
	SourceKind       string          `json:"source_kind,omitempty"`       // "workflow" | "background" | ""
	SourceDescriptor json.RawMessage `json:"source_descriptor,omitempty"` // original workflow/origin JSON
}

type RunFailedPayload struct {
	Reason string `json:"reason"`
}

type RunLedgerStore interface {
	// AppendJournalEvent appends an event to the journal. Seq is auto-assigned.
	AppendJournalEvent(ctx context.Context, event JournalEvent) error

	// GetJournalEvents returns all events for a run, ordered by seq.
	GetJournalEvents(ctx context.Context, runID string) ([]JournalEvent, error)

	// GetJournalEventsSince returns events with seq > afterSeq.
	GetJournalEventsSince(ctx context.Context, runID string, afterSeq int64) ([]JournalEvent, error)

	// MaterializeRunSnapshot replays the full journal to build a snapshot.
	MaterializeRunSnapshot(ctx context.Context, runID string) (*RunSnapshot, error)

	// RecordValidationResult appends a step_validation_passed or step_validation_failed event.
	RecordValidationResult(ctx context.Context, runID, stepID string, result ValidationResult) error

	// GetCachedSnapshot returns the last cached snapshot and its seq, or nil if uncached.
	GetCachedSnapshot(ctx context.Context, runID string) (*RunSnapshot, int64, error)

	// UpdateCachedSnapshot stores/updates the snapshot cache.
	UpdateCachedSnapshot(ctx context.Context, snapshot *RunSnapshot) error

	// ListRuns returns run IDs with their current status, ordered by creation time desc.
	ListRuns(ctx context.Context, limit int) ([]RunSummary, error)

	// GetRunSnapshot returns the most up-to-date snapshot, using cache + tail replay.
	GetRunSnapshot(ctx context.Context, runID string) (*RunSnapshot, error)

	// ListRunSummariesBySession returns recent run summaries for a session.
	ListRunSummariesBySession(ctx context.Context, sessionKey string, limit int) ([]RunSummary, error)

	// MaxJournalSeqForSession returns the highest last_journal_seq across the
	// session's runs, or 0 when the session has no runs.
	MaxJournalSeqForSession(ctx context.Context, sessionKey string) (int64, error)

	// PruneOldRuns removes the oldest terminal runs until at most maxKeep remain.
	PruneOldRuns(ctx context.Context, maxKeep int) error
}

type RunPausedPayload struct {
	Reason string `json:"reason"`
}

type RunResumedPayload struct {
	ResumedBy string `json:"resumed_by"`
}

type RunSnapshot struct {
	RunID            string                `json:"run_id"`
	SessionKey       string                `json:"session_key"`
	OriginalRequest  string                `json:"original_request"`
	Goal             string                `json:"goal"`
	Status           RunStatus             `json:"status"`
	CurrentStepID    string                `json:"current_step_id,omitempty"`
	CurrentBlocker   string                `json:"current_blocker,omitempty"`
	AcceptanceState  []AcceptanceCriterion `json:"acceptance_state"`
	Steps            []Step                `json:"steps"`
	Notes            map[string]string     `json:"notes"`
	SourceKind       string                `json:"source_kind,omitempty"`
	SourceDescriptor json.RawMessage       `json:"source_descriptor,omitempty"`
	LastJournalSeq   int64                 `json:"last_journal_seq"`
	UpdatedAt        time.Time             `json:"updated_at"`
	// contains filtered or unexported fields
}

type RunStatus string

type RunSummary struct {
	RunID              string    `json:"run_id"`
	Goal               string    `json:"goal"`
	Status             RunStatus `json:"status"`
	TotalSteps         int       `json:"total_steps"`
	CompletedSteps     int       `json:"completed_steps"`
	CurrentStepGoal    string    `json:"current_step_goal,omitempty"`
	CurrentStepStatus  string    `json:"current_step_status,omitempty"`
	CurrentBlocker     string    `json:"current_blocker,omitempty"`
	UnmetCriteria      []string  `json:"unmet_criteria,omitempty"`
	LastVerifiedResult string    `json:"last_verified_result,omitempty"`
}

type Step struct {
	StepID      string        `json:"step_id"`
	Index       int           `json:"index"`
	Goal        string        `json:"goal"`
	OwnerAgent  string        `json:"owner_agent"`
	Status      StepStatus    `json:"status"`
	Evidence    []Evidence    `json:"evidence,omitempty"`
	Validator   ValidatorSpec `json:"validator"`
	ToolProfile []string      `json:"tool_profile,omitempty"`
	RetryCount  int           `json:"retry_count"`
	MaxRetries  int           `json:"max_retries"`
	ResumeFrom  string        `json:"resume_from,omitempty"`
	Result      string        `json:"result,omitempty"`
	DependsOn   []string      `json:"depends_on,omitempty"`
}

type StepInput struct {
	ID          string        `json:"id"`
	Goal        string        `json:"goal"`
	OwnerAgent  string        `json:"owner_agent"`
	Validator   ValidatorSpec `json:"validator"`
	ToolProfile []string      `json:"tool_profile,omitempty"`
	DependsOn   []string      `json:"depends_on,omitempty"`
}

type StepResultProposedPayload struct {
	StepID   string     `json:"step_id"`
	Result   string     `json:"result"`
	Evidence []Evidence `json:"evidence,omitempty"`
}

type StepStartedPayload struct {
	StepID     string `json:"step_id"`
	OwnerAgent string `json:"owner_agent"`
}

type StepStatus string

type StepValidationFailedPayload struct {
	StepID string           `json:"step_id"`
	Result ValidationResult `json:"result"`
}

type StepValidationPassedPayload struct {
	StepID string           `json:"step_id"`
	Result ValidationResult `json:"result"`
}

type StoreOption func(*StoreOptions)

type StoreOptions struct {
	// AppendHook is called after a journal event is successfully appended.
	// The hook is invoked synchronously — keep it lightweight.
	AppendHook func(JournalEvent)
}

type TestPassValidator struct{}

type ToolProfile string

type ValidationResult struct {
	Passed  bool              `json:"passed"`
	Reason  string            `json:"reason"`
	Details map[string]string `json:"details,omitempty"`
	Missing []string          `json:"missing,omitempty"`
}

type Validator interface {
	Validate(ctx context.Context, spec ValidatorSpec, evidence []Evidence) (*ValidationResult, error)
}

type ValidatorSpec struct {
	Type    ValidatorType     `json:"type"`
	Target  string            `json:"target,omitempty"`
	Params  map[string]string `json:"params,omitempty"`
	WorkDir string            `json:"work_dir,omitempty"` // set at runtime by workspace manager
}

type ValidatorType string

type WorkflowProjectionStore interface {
	CreateRun(ctx context.Context, w *workflow.Workflow) (string, error)
	CreateRunWithID(ctx context.Context, runID string, w *workflow.Workflow) error
	UpdateRunStatus(ctx context.Context, runID string, status string) error
	CompleteRun(ctx context.Context, runID string, status string, errMsg string) error
	CreateStepRun(ctx context.Context, runID string, step workflow.Step, renderedPrompt string) error
	UpdateStepStatus(ctx context.Context, runID string, stepID string, status string, result string, errMsg string) error
	GetRunStatus(ctx context.Context, runID string) (*workflow.RunStatus, error)
	GetStepResults(ctx context.Context, runID string) (map[string]string, error)
	ListRuns(ctx context.Context, limit int) ([]workflow.RunStatus, error)
}

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

type WorkspaceManager struct{}