graph

type Command[S any] struct {
	Update    *S
	Goto      string
	Interrupt *Interrupt
	End       bool
}

type EdgeKind string

type EdgeSnapshot struct {
	From        string `json:"from"`
	To          string `json:"to"`
	Kind        string `json:"kind"`
	Label       string `json:"label,omitempty"`
	Description string `json:"description,omitempty"`
	Order       int    `json:"order,omitempty"`
	Default     bool   `json:"default,omitempty"`
}

type Interrupt struct {
	ID           string
	Kind         string
	Reason       string
	Payload      any
	RunID        string
	NodeID       string
	CheckpointID string
	ResumeNode   string
}

type NodeFunc[S any] func(context.Context, S) (Command[S], error)

type NodeKind string

type NodeSnapshot struct {
	ID       string            `json:"id"`
	Kind     string            `json:"kind"`
	Metadata map[string]string `json:"metadata,omitempty"`
}

type NodeSpec[S any] struct {
	ID       string
	Kind     NodeKind
	Run      NodeFunc[S]
	Metadata map[string]string
}

type Predicate[S any] func(context.Context, S) (bool, error)

type ReachableOption func(*dynamicEdge)

type RouteBuilder[S any] struct {
	// contains filtered or unexported fields
}

type RouteSelection struct {
	Target  string
	Kind    EdgeKind
	Order   int
	Default bool
}

type Snapshot struct {
	WorkflowID string         `json:"workflow_id"`
	Start      string         `json:"start"`
	Finish     []string       `json:"finish"`
	Nodes      []NodeSnapshot `json:"nodes"`
	Edges      []EdgeSnapshot `json:"edges"`
}

type StateGraph[S any] struct {
	// contains filtered or unexported fields
}

type Workflow interface {
	WorkflowID() string
	Snapshot() Snapshot
	Validate() error
}