wfexec

type ExecRequest struct {
	SessionID uint64
	StateID   uint64

	// Current input received on session resume
	Input *expr.Vars

	// Current scope
	Scope *expr.Vars

	// Helps with gateway join/merge steps
	// that needs info about the step it's currently merging
	Parent Step
}

type ExecResponse interface{}

type Frame struct {
	CreatedAt time.Time  `json:"createdAt"`
	SessionID uint64     `json:"sessionID"`
	StateID   uint64     `json:"stateID"`
	Input     *expr.Vars `json:"input"`
	Scope     *expr.Vars `json:"scope"`
	Results   *expr.Vars `json:"results"`
	ParentID  uint64     `json:"parentID"`
	StepID    uint64     `json:"stepID"`
	NextSteps []uint64   `json:"nextSteps"`

	// How much time from the 1st step to the start of this step in milliseconds
	ElapsedTime uint `json:"elapsedTime"`

	// How much time it took to execute this step in milliseconds
	StepTime uint `json:"stepTime"`

	Action string `json:"action,omitempty"`
	Error  string `json:"error,omitempty"`
}

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

type GatewayPaths []*GatewayPath

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

type Iterator interface {
	// Is the given step this iterator step
	Is(Step) bool

	// Initialize iterator
	Start(context.Context, *expr.Vars) error

	// Break fn is called when loop is forcefully broken
	Break() Step

	Iterator() Step

	// Next is called before each iteration and returns
	// 1st step of the iteration branch and variables that are added to the scope
	Next(context.Context, *expr.Vars) (Step, *expr.Vars, error)
}

type IteratorHandler interface {
	Start(context.Context, *expr.Vars) error
	More(context.Context, *expr.Vars) (bool, error)
	Next(context.Context, *expr.Vars) (*expr.Vars, error)
}

type PendingPrompt struct {
	Ref       string     `json:"ref"`
	SessionID uint64     `json:"sessionID,string"`
	CreatedAt time.Time  `json:"createdAt"`
	StateID   uint64     `json:"stateID,string"`
	Payload   *expr.Vars `json:"payload"`
	OwnerId   uint64     `json:"-"`

	Original *prompted `json:"-"`
}

type ResultEvaluator interface {
	EvalResults(ctx context.Context, results *expr.Vars) (out *expr.Vars, err error)
}

type ResumedPrompt struct {
	StateID uint64 `json:"stateID,string"`
	OwnerId uint64 `json:"-"`
}

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

type SessionOpt func(*Session)

type SessionStatus int

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

type StateChangeHandler func(SessionStatus, *State, *Session)

type Step interface {
	ID() uint64
	SetID(uint64)
	Exec(context.Context, *ExecRequest) (ExecResponse, error)
}

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

type Steps []Step