interfaces

type Camunda interface {
	StopProcessInstance(id string, tenantId string) (err error)
	GetProcessName(id string, tenantId string) (string, error)
	StartProcess(processDefinitionId string, userId string) (err error)
	GetIncidents() (result []messages.CamundaIncident, err error)
}

type CamundaFactory interface {
	Get(ctx context.Context, config configuration.Config) (Camunda, error)
}

type Controller interface {
	HandleIncidentMessage(incident []byte) error
}

type Database interface {
	DeleteByDefinitionId(id string) error
	SaveIncident(incident messages.Incident) error
	DeleteIncidentByInstanceId(id string) error
	SaveOnIncident(handler messages.OnIncident) error
	GetOnIncident(definitionId string) (incident messages.OnIncident, exists bool, err error)
}

type DatabaseFactory interface {
	Get(ctx context.Context, config configuration.Config) (Database, error)
}

type SourceFactory interface {
	Start(ctx context.Context, config configuration.Config, control Controller, runtimeErrorHandler func(err error)) (err error)
}