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
	Settings          map[string]Setting
	IsDisabled        bool
	IsDefault         bool   // default flows are read only and can't be deleted
	ParallelExecution string // keep_first , keep_last , parallel
}

type FlowOperationalContext struct {
	FlowMeta                    *FlowMeta
	FlowId                      string
	IsFlowRunning               bool
	State                       string
	TriggerControlSignalChannel chan int // the channel should be used to stop all waiting nodes .
	NodeControlSignalChannel    chan int
	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
	SrcNodeId        NodeID
}

type Setting struct {
	Value       interface{}
	ValueType   string // only simple types supported - int,string,float,bool
	Description string `json:"omitempty"` // Human readable description
	InitVar     bool   `json:"omitempty"` // If set , flow will init variable during startup
	TVarSType   string `json:"omitempty"` // Target variable storage type - mem_local, disk_local,disk_global
	TVarPType   string `json:"omitempty"` // Target variable payload type - int , string , float , bool
}

type Variable struct {
	Value     interface{}
	ValueType string
}