repository

type Entity struct {
	EntityType EntityType `sql:"entity_type"`
	EntityId   int        `sql:"entity_id"`
}

type EntityType int

type HistoryReference struct {
	HistoryReferenceId   int                  `sql:"history_reference_id"`
	HistoryReferenceType HistoryReferenceType `sql:"history_reference_type"`
}

type HistoryReferenceType int

type ScopedVariableRepository interface {
	//transaction util funcs
	sql.TransactionWrapper
	// Create
	CreateVariableDefinition(variableDefinition []*VariableDefinition, tx *pg.Tx) ([]*VariableDefinition, error)
	CreateVariableData(variableDefinition []*VariableData, tx *pg.Tx) error

	// Get
	GetAllVariables() ([]*VariableDefinition, error)
	GetAllVariableMetadata() ([]*VariableDefinition, error)
	GetVariablesForVarIds(ids []int) ([]*VariableDefinition, error)
	GetVariablesByNames(vars []string) ([]*VariableDefinition, error)
	GetAllVariableDefinition() ([]*VariableDefinition, error)
	GetDataForScopeIds(scopeIds []int) ([]*VariableData, error)

	// Delete
	DeleteVariables(auditLog sql.AuditLog, tx *pg.Tx) error

	GetVariableTypeForVariableNames(variableNames []string) ([]*VariableDefinition, error)
}

type ScopedVariableRepositoryImpl struct {
	*sql.TransactionUtilImpl
	// contains filtered or unexported fields
}

type VariableData struct {
	Id              int    `sql:"id,pk"`
	VariableScopeId int    `sql:"variable_scope_id"`
	Data            string `sql:"data"`
	sql.AuditLog
	// contains filtered or unexported fields
}

type VariableDefinition struct {
	Id               int                 `sql:"id,pk"`
	Name             string              `sql:"name"`
	DataType         models.DataType     `sql:"data_type"`
	VarType          models.VariableType `sql:"var_type"`
	Active           bool                `sql:"active"`
	Description      string              `sql:"description"`
	ShortDescription string              `json:"short_description"`
	sql.AuditLog
	// contains filtered or unexported fields
}

type VariableEntityMapping struct {
	Id           int    `sql:"id,pk"`
	VariableName string `sql:"variable_name"`
	IsDeleted    bool   `sql:"is_deleted,notnull"`
	Entity
	sql.AuditLog
	// contains filtered or unexported fields
}

type VariableEntityMappingRepository interface {
	sql.TransactionWrapper
	GetVariablesForEntities(entities []Entity) ([]*VariableEntityMapping, error)
	SaveVariableEntityMappings(tx *pg.Tx, mappings []*VariableEntityMapping) error
	DeleteAllVariablesForEntities(tx *pg.Tx, entities []Entity, userId int32) error
	DeleteVariablesForEntity(tx *pg.Tx, variableIDs []string, entity Entity, userId int32) error
}

type VariableEntityMappingRepositoryImpl struct {
	*sql.TransactionUtilImpl
	// contains filtered or unexported fields
}

type VariableSnapshotHistory struct {
	Id int `sql:"id,pk"`
	VariableSnapshotHistoryBean
	sql.AuditLog
	// contains filtered or unexported fields
}

type VariableSnapshotHistoryBean struct {
	VariableSnapshot json.RawMessage `sql:"variable_snapshot"`
	HistoryReference
}

type VariableSnapshotHistoryBeanRaw struct {
	VariableSnapshot map[string]string
	HistoryReference
}

type VariableSnapshotHistoryRepository interface {
	SaveVariableSnapshots(variableSnapshotHistories []*VariableSnapshotHistory) error
	CheckIfVariableSnapshotExists(historyReference HistoryReference) (bool, error)
	GetVariableSnapshots(historyReferences []HistoryReference) ([]*VariableSnapshotHistory, error)
}

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