model

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

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

type ContextRecord struct {
	Name        string
	Description string
	UpdatedAt   time.Time
	Variable    Variable
	InMemory    bool
}

type FlowMeta struct {
	Id          string // Instance id . Is different for every instance
	ClassId     string // Class id , all instances share the same ClassId
	Author      string
	Version     int
	CreatedAt   time.Time
	UpdatedAt   time.Time
	Name        string
	Group       string
	Description string
	Nodes       []MetaNode
}

type FlowOperationalContext struct {
	FlowId                   string
	IsFlowRunning            bool
	State                    string
	NodeControlSignalChannel chan int  // the channel should be used to stop all waiting nodes .
	NodeIsReady              chan bool // Flow should notify message router when next node is ready to process new message .
	StoragePath              string
	ExtLibsDir               string
}

type FlowRunner func(ReactorEvent)

type FlowStatsReport struct {
	CurrentNodeId          NodeID
	CurrentNodeLabel       string
	NumberOfNodes          int
	NumberOfTriggers       int
	NumberOfActiveTriggers int
	NumberOfActiveSubflows int
	State                  string
	StartedAt              time.Time
	WaitingSince           time.Time
	LastExecutionTime      int64
}

type Message struct {
	AddressStr string
	Address    fimpgo.Address
	Payload    fimpgo.FimpMessage
	RawPayload []byte
	Header     map[string]string
	CancelOp   bool // if true , listening end should close all operations
}

type MetaNode struct {
	Id                NodeID
	Type              string
	Label             string
	SuccessTransition NodeID
	TimeoutTransition NodeID
	ErrorTransition   NodeID
	Address           string
	Service           string
	ServiceInterface  string
	Config            interface{}
	Ui                interface{}
}

type MsgPipeline chan Message

type Node interface {
	OnInput(msg *Message) ([]NodeID, error)
	// reactor nodes should publish events into the channel
	WaitForEvent(responseChannel chan ReactorEvent)
	GetMetaNode() *MetaNode
	GetNextSuccessNodes() []NodeID
	GetNextErrorNode() NodeID
	GetNextTimeoutNode() NodeID
	LoadNodeConfig() error
	IsStartNode() bool
	IsMsgReactorNode() bool
	IsReactorRunning() bool
	//ConfigureInStream(activeSubscriptions *[]string,msgInStream MsgPipeline)
	// Invoked when node is started
	Init() error
	// Invoked when node is stopped
	Cleanup() error
	SetConnectorRegistry(connectorRegistry *connector.Registry)
	SetFlowRunner(runner FlowRunner)
}

type NodeID string

type ReactorEvent struct {
	Msg              Message
	Err              error
	TransitionNodeId NodeID
}

type Variable struct {
	Value     interface{}
	ValueType string
}