http

type CheckpointLister interface {
	ListRunCheckpoints(ctx context.Context, runID string, limit int) (any, error)
}

type CheckpointLoader interface {
	GetRunCheckpoint(ctx context.Context, runID string, version int64) (any, error)
}

type CheckpointResumer interface {
	ResumeFromCheckpoint(ctx context.Context, runID string, version int64) (any, error)
}

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

type HandlerConfig struct {
	Checkpoint   StepResumer
	Steps        StepsLister
	History      CheckpointLister
	Checkpoints  CheckpointLoader
	Restore      CheckpointResumer
	Fork         RunForker
	MaxBodyBytes int64
	// Policy authorizes requests, mirroring the async run handler: reads are
	// authorized as run.read and writes (resume-from-step,
	// resume-from-checkpoint, fork) as hitl.resume / run.submit. When Policy
	// is nil, write endpoints default-deny with 403 auth_required unless
	// InsecureAllowNoAuth explicitly opts out.
	Policy security.Policy
	// Audit receives policy-denied records when configured.
	Audit audit.Sink
	// InsecureAllowNoAuth disables the default-deny protection on write
	// endpoints when no Policy is configured. Only set this behind an
	// authenticating reverse proxy or in tests.
	InsecureAllowNoAuth bool
}

type RunForker interface {
	ForkRun(ctx context.Context, runID string, version int64) (any, error)
}

type StepResumer interface {
	ResumeFromStep(ctx context.Context, runID, nodeID string) (any, error)
}

type StepsLister interface {
	ListRunSteps(ctx context.Context, runID string) (any, error)
}