workflow

type Checkpoint struct {
	ID        string         `json:"id"`
	StepID    string         `json:"step_id"`
	State     map[string]any `json:"state"`
	CreatedAt time.Time      `json:"created_at"`
}

type ExecuteOptions struct {
	// ResumeFromCheckpoint enables resumption from last checkpoint
	ResumeFromCheckpoint bool
	// Context provides initial workflow context
	Context map[string]any
	// ExecutionID allows specifying a custom execution ID
	ExecutionID string
}

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

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

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

type State struct {
	ID          string         `json:"id"`
	WorkflowID  string         `json:"workflow_id"`
	Status      Status         `json:"status"`
	CurrentStep string         `json:"current_step"`
	StepStates  map[string]any `json:"step_states"`
	Context     map[string]any `json:"context"`
	StartedAt   time.Time      `json:"started_at"`
	UpdatedAt   time.Time      `json:"updated_at"`
	CompletedAt *time.Time     `json:"completed_at,omitempty"`
	Error       string         `json:"error,omitempty"`
	Checkpoints []Checkpoint   `json:"checkpoints,omitempty"`
}

type Status string

type Step struct {
	ID          string         `json:"id"`
	Name        string         `json:"name"`
	Description string         `json:"description,omitempty"`
	Handler     StepHandler    `json:"-"`
	NextSteps   []string       `json:"next_steps,omitempty"`
	Config      map[string]any `json:"config,omitempty"`
	Retries     int            `json:"retries,omitempty"`
	Timeout     time.Duration  `json:"timeout,omitempty"`
}

type StepHandler func(ctx context.Context, input map[string]any) (map[string]any, error)

type Store interface {
	// Save persists the current workflow state
	Save(state *State) error

	// Load retrieves a workflow state by execution ID
	Load(executionID string) (*State, error)

	// List returns all workflow states, optionally filtered by workflow ID
	List(workflowID string) ([]*State, error)

	// Delete removes a workflow state
	Delete(executionID string) error

	// SaveCheckpoint saves a checkpoint for recovery
	SaveCheckpoint(executionID string, checkpoint *Checkpoint) error

	// LoadLatestCheckpoint loads the most recent checkpoint
	LoadLatestCheckpoint(executionID string) (*Checkpoint, error)
}

type Workflow struct {
	ID          string           `json:"id"`
	Name        string           `json:"name"`
	Description string           `json:"description,omitempty"`
	Steps       map[string]*Step `json:"steps"`
	StartStep   string           `json:"start_step"`
}