storage

type AuditLog struct {
	Position           int64     `gorm:"primarykey"`
	ProcessInstanceKey int64     `gorm:"not null"`
	ElementID          string    `gorm:"not null"`
	ElementType        string    `gorm:"not null"`
	Intent             string    `gorm:"not null"`
	Time               time.Time `gorm:"not null"`
}

type BpmnResource struct {
	ProcessDefinitionKey int64 `gorm:"primarykey;autoIncrement:false"`
	// A base64 encoded string of the BPMN XML file.
	BpmnFile string `gorm:"not null"`
}

type DsnConfig struct {
	// Username used to log in to the database.
	User string
	// Password of the logging in user.
	Password string
	// Database name to be accessed.
	DatabaseName string
	// The host used to host the database.
	Host string
	// The port used to connect to the database.
	Port uint16
}

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

type Filter struct {
	Input string
	Type  FilterType
}

type FilterType string

type Incident struct {
	Key                int64     `gorm:"primarykey"`
	ProcessInstanceKey int64     `gorm:"not null"`
	ElementID          string    `gorm:"not null"`
	ErrorType          string    `gorm:"not null"`
	ErrorMessage       string    `gorm:"not null"`
	State              string    `gorm:"not null"`
	Time               time.Time `gorm:"not null"`
}

type Instance struct {
	ProcessInstanceKey   int64     `gorm:"primarykey"`
	ProcessDefinitionKey int64     `gorm:"not null"`
	Version              int64     `gorm:"not null"`
	Status               string    `gorm:"not null"`
	StartTime            time.Time `gorm:"not null"`
	EndTime              sql.NullTime
	AuditLogs            []AuditLog `gorm:"foreignKey:ProcessInstanceKey;references:ProcessInstanceKey"`
	Incidents            []Incident `gorm:"foreignKey:ProcessInstanceKey;references:ProcessInstanceKey"`
	Jobs                 []Job      `gorm:"foreignKey:ProcessInstanceKey;references:ProcessInstanceKey"`
	Variables            []Variable `gorm:"foreignKey:ProcessInstanceKey;references:ProcessInstanceKey"`
}

type Job struct {
	Key                int64     `gorm:"primarykey"`
	ElementID          string    `gorm:"not null"`
	ProcessInstanceKey int64     `gorm:"not null"`
	Type               string    `gorm:"not null"`
	Retries            int64     `gorm:"not null"`
	Worker             string    `gorm:"not null"`
	State              string    `gorm:"not null"`
	Time               time.Time `gorm:"not null"`
}

type Paginated[T any] struct {
	TotalCount int64
	Items      []T
}

type Pagination struct {
	Offset int
	Limit  int
}

type Process struct {
	ProcessDefinitionKey int64        `gorm:"primarykey"`
	BpmnProcessID        string       `gorm:"not null"`
	Version              int64        `gorm:"not null"`
	DeploymentTime       time.Time    `gorm:"not null"`
	BpmnResource         BpmnResource `gorm:"foreignKey:ProcessDefinitionKey;references:ProcessDefinitionKey"`
	Instances            []Instance   `gorm:"foreignKey:ProcessDefinitionKey;references:ProcessDefinitionKey"`
}

type Storer interface {
	ProcessDeployed(
		processDefinitionKey int64,
		bpmnProcessID string,
		version int64,
		deploymentTime time.Time,
		bpmnResourceRaw []byte,
	) error

	ProcessInstanceActivated(
		processInstanceKey int64,
		processDefinitionKey int64,
		version int64,
		startTime time.Time,
	) error

	ProcessInstanceCompleted(
		processInstanceKey int64,
		endTime time.Time,
	) error

	ProcessInstanceTerminated(
		processInstanceKey int64,
		endTime time.Time,
	) error

	VariableCreated(
		processInstanceKey int64,
		name string,
		value string,
		time time.Time,
	) error

	VariableUpdated(
		processInstanceKey int64,
		name string,
		value string,
		time time.Time,
	) error

	IncidentCreated(
		key int64,
		processInstanceKey int64,
		elementID string,
		errorType string,
		errorMessage string,
		time time.Time,
	) error

	IncidentResolved(
		key int64,
		time time.Time,
	) error

	AuditLogEventOccurred(
		position int64,
		processInstanceKey int64,
		elementID string,
		elementType string,
		intent string,
		time time.Time,
	) error

	JobCreated(
		key int64,
		elementID string,
		processInstanceKey int64,
		jobType string,
		retries int64,
		worker string,
		time time.Time,
	) error

	JobUpdated(
		key int64,
		retries int64,
		worker string,
		state string,
		time time.Time,
	) error
}

type Tabler interface {
	TableName() string
}

type Variable struct {
	ProcessInstanceKey int64     `gorm:"primarykey;autoIncrement:false"`
	Name               string    `gorm:"primarykey"`
	Value              string    `gorm:"not null"`
	Time               time.Time `gorm:"not null"`
}