runstate

type BlobRef struct {
	ID     string `json:"id"`
	Size   int64  `json:"size"`
	Sha256 string `json:"sha256"`
}

type BlobStore interface {
	Put(ctx context.Context, data []byte) (BlobRef, error)
	Get(ctx context.Context, ref BlobRef) ([]byte, error)
}

type ListFilter struct {
	// Status, when non-empty, restricts results to snapshots with this status.
	Status RunStatus
	// ScenarioName, when non-empty, restricts results to a specific scenario.
	ScenarioName string
	// Limit is the maximum number of results to return. 0 means no limit.
	Limit int
}

type Repository interface {
	Save(ctx context.Context, snapshot *RunSnapshot, expectedVersion int64) error
	Load(ctx context.Context, runID string) (RunSnapshot, error)
	Delete(ctx context.Context, runID string) error
	// List returns snapshots that match the filter. Implementations may
	// return results in any order. An empty filter matches all snapshots.
	List(ctx context.Context, filter ListFilter) ([]RunSnapshot, error)
}

type RunSnapshot struct {
	RunID         string                     `json:"run_id"`
	Version       int64                      `json:"version"`
	ScenarioName  string                     `json:"scenario_name"`
	CurrentNodeID string                     `json:"current_node_id,omitempty"`
	Status        RunStatus                  `json:"status"`
	Variables     map[string]json.RawMessage `json:"variables,omitempty"`
	StepOutputs   map[string]StepOutputRef   `json:"step_outputs,omitempty"`
	PendingGate   *core.CheckpointState      `json:"pending_gate,omitempty"`
}

type RunStatus string

type StepOutputRef struct {
	Inline json.RawMessage `json:"inline,omitempty"`
	Blob   *BlobRef        `json:"blob,omitempty"`
}

type TokenPayload struct {
	RunID     string    `json:"run_id"`
	Version   int64     `json:"version"`
	ExpiresAt time.Time `json:"expires_at,omitempty"`
}

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