planstore

type Plan struct {
	ID        string     `json:"id"`
	Name      string     `json:"name"`
	Goal      string     `json:"goal"`
	Status    PlanStatus `json:"status"`
	SessionID string     `json:"session_id"`
	CreatedAt time.Time  `json:"created_at"`
	UpdatedAt time.Time  `json:"updated_at"`
}

type PlanStatus string

type PlanStep struct {
	ID              string     `json:"id"`
	PlanID          string     `json:"plan_id"`
	Ordinal         int        `json:"ordinal"`
	Description     string     `json:"description"`
	Status          StepStatus `json:"status"`
	ExecutionResult string     `json:"execution_result"`
	ExecutedAt      time.Time  `json:"executed_at"` // Zero time if not executed
}

type StepStatus string

type Store interface {
	// Plan operations
	CreatePlan(ctx context.Context, plan *Plan) error
	GetPlanByID(ctx context.Context, id string) (*Plan, error)
	GetPlanByName(ctx context.Context, name string) (*Plan, error)
	// GetActivePlan returns the most recently updated active plan, or ErrNotFound.
	GetActivePlan(ctx context.Context) (*Plan, error)
	ListPlans(ctx context.Context) ([]*Plan, error)
	DeletePlan(ctx context.Context, id string) error
	UpdatePlanStatus(ctx context.Context, planID string, status PlanStatus) error

	// Step operations
	CreatePlanSteps(ctx context.Context, steps ...*PlanStep) error
	ListPlanSteps(ctx context.Context, planID string) ([]*PlanStep, error)
	UpdatePlanStepStatus(ctx context.Context, stepID string, status StepStatus, result string) error
	DeletePendingPlanSteps(ctx context.Context, planID string) error
	// ClaimNextPendingStep atomically marks the next pending step as running
	// and returns it. Returns ErrNotFound when no pending step exists.
	ClaimNextPendingStep(ctx context.Context, planID string) (*PlanStep, error)

	// Bulk operations for efficiency
	// DeleteFinishedPlans removes all completed/archived plans; returns count.
	DeleteFinishedPlans(ctx context.Context) (int, error)
	// ArchiveActivePlans sets all active plans to archived status.
	ArchiveActivePlans(ctx context.Context) error
}