bpmn_engine

type ActivatedJob interface {
	// Key the key, a unique identifier for the job
	Key() int64

	// ProcessInstanceKey the job's process instance key
	ProcessInstanceKey() int64

	// BpmnProcessId Retrieve id of the job process definition
	BpmnProcessId() string

	// ProcessDefinitionVersion Retrieve version of the job process definition
	ProcessDefinitionVersion() int32

	// ProcessDefinitionKey Retrieve key of the job process definition
	ProcessDefinitionKey() int64

	// ElementId Get element id of the job
	ElementId() string

	// Variable from the process instance's variable context
	Variable(key string) interface{}

	// SetVariable in the variables context of the given process instance
	SetVariable(key string, value interface{})

	// InstanceKey get instance key from ProcessInfo
	InstanceKey() int64

	// CreatedAt when the job was created
	CreatedAt() time.Time

	// Fail does set the State the worker missed completing the job
	// Fail and Complete mutual exclude each other
	Fail(reason string)

	// Complete does set the State the worker successfully completing the job
	// Fail and Complete mutual exclude each other
	Complete()
}

type Activity interface {
	Key() int64
	State() ActivityState
	Element() *BPMN20.BaseElement
}

type ActivityState string

type BpmnEngine interface {
	LoadFromFile(filename string) (*ProcessInfo, error)
	LoadFromBytes(xmlData []byte) (*ProcessInfo, error)
	NewTaskHandler() NewTaskHandlerCommand1
	CreateInstance(processKey int64, variableContext map[string]interface{}) (*processInstanceInfo, error)
	CreateInstanceById(processId string, variableContext map[string]interface{}) (*processInstanceInfo, error)
	CreateAndRunInstance(processKey int64, variableContext map[string]interface{}) (*processInstanceInfo, error)
	CreateAndRunInstanceById(processId string, variableContext map[string]interface{}) (*processInstanceInfo, error)
	RunOrContinueInstance(processInstanceKey int64) (*processInstanceInfo, error)
	Name() string
	ProcessInstances() []*processInstanceInfo
	FindProcessInstanceById(processInstanceKey int64) *processInstanceInfo
	FindProcessesById(id string) []*ProcessInfo
}

type BpmnEngineError struct {
	Msg string
}

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

type BpmnEngineUnmarshallingError struct {
	Msg string
	Err error
}

type ErrorCommand interface {
	ElementId() string
	ElementName() string
	Error() error
	// contains filtered or unexported methods
}

type EventBasedGatewayActivity interface {
	Activity
	SetOutboundCompleted(id string)
	OutboundCompleted() bool
}

type ExpressionEvaluationError struct {
	Msg string
	Err error
}

type GatewayActivity interface {
	Activity
	IsParallel() bool
	AreInboundFlowsCompleted() bool
	SetInboundFlowIdCompleted(id string)
	SetState(completed ActivityState)
}

type MessageSubscription struct {
	ElementId          string        `json:"id"`
	ElementInstanceKey int64         `json:"ik"`
	ProcessInstanceKey int64         `json:"pik"`
	Name               string        `json:"n"`
	State              ActivityState `json:"s"`
	CreatedAt          time.Time     `json:"c"`
	// contains filtered or unexported fields
}

type NewTaskHandlerCommand1 interface {
	// Id defines a handler for a given element ID (as defined in the task element in the BPMN file)
	// This is 1:1 relation between a handler and a task definition (since IDs are supposed to be unique).
	Id(id string) NewTaskHandlerCommand2

	// Type defines a handler for a Service Task with a given 'type';
	// Hereby 'type' is defined as 'taskDefinition' extension element in the BPMN file.
	// This allows a single handler to be used for multiple task definitions.
	Type(taskType string) NewTaskHandlerCommand2

	// Assignee defines a handler for a User Task with a given 'assignee';
	// Hereby 'assignee' is defined as 'assignmentDefinition' extension element in the BPMN file.
	Assignee(assignee string) NewTaskHandlerCommand2

	// CandidateGroups defines a handler for a User Task with given 'candidate groups';
	// For the handler you can specify one or more groups.
	// If at least one matches a given user task, the handler will be called.
	CandidateGroups(groups ...string) NewTaskHandlerCommand2
}

type NewTaskHandlerCommand2 interface {
	// Handler is the actual handler to be executed
	Handler(func(job ActivatedJob))
}

type ProcessInfo struct {
	BpmnProcessId string // The ID as defined in the BPMN file
	Version       int32  // A version of the process, default=1, incremented, when another process with the same ID is loaded
	ProcessKey    int64  // The engines key for this given process with version
	// contains filtered or unexported fields
}

type ProcessInstance interface {
	GetProcessInfo() *ProcessInfo
	GetInstanceKey() int64

	// GetVariable from the process instance's variable context
	GetVariable(key string) interface{}

	// SetVariable to the process instance's variable context
	SetVariable(key string, value interface{})

	GetCreatedAt() time.Time
	GetState() ActivityState
}

type ProcessInstanceInfoAlias processInstanceInfo

type Timer struct {
	ElementId          string        `json:"id"`
	ElementInstanceKey int64         `json:"ik"`
	ProcessKey         int64         `json:"pk"`
	ProcessInstanceKey int64         `json:"pik"`
	TimerState         TimerState    `json:"s"`
	CreatedAt          time.Time     `json:"c"`
	DueAt              time.Time     `json:"da"`
	Duration           time.Duration `json:"du"`
	// contains filtered or unexported fields
}

type TimerState string