interfaces

type Database interface {
	CheckDeploymentAccess(user string, deploymentId string) (error, int)
	ListDeployments(user string, options model.DeploymentListOptions) (deployments []deploymentmodel.Deployment, err error)
	GetDeployment(user string, deploymentId string) (deployment *deploymentmodel.Deployment, err error, code int)
	GetDeploymentIds(user string) (deployments []string, err error)
	GetDependencies(user string, deploymentId string) (dependencymodel.Dependencies, error, int)
	GetDependenciesList(user string, limit int, offset int) ([]dependencymodel.Dependencies, error, int)
	GetSelectedDependencies(user string, ids []string) ([]dependencymodel.Dependencies, error, int)
	SetDependencies(dependencies dependencymodel.Dependencies) error
	DeleteDependencies(id string) error

	SetDeployment(depl messages.DeploymentCommand, syncHandler func(messages.DeploymentCommand) error) error
	DeleteDeployment(id string, syncDeleteHandler func(messages.DeploymentCommand) error) error
	RetryDeploymentSync(lockduration time.Duration, syncDeleteHandler func(messages.DeploymentCommand) error, syncHandler func(messages.DeploymentCommand) error) error
}

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

type DeploymentParser interface {
	PrepareDeployment(xml string) (deploymentmodel.Deployment, error)
	EstimateStartParameter(xml string) ([]deploymentmodel.ProcessStartParameter, error)
}

type DeploymentProducer interface {
	Produce(command messages.DeploymentCommand) error
}

type DeploymentStringifier interface {
	Deployment(deployment deploymentmodel.Deployment, userId string, token auth.Token) (string, error)
}

type Devices interface {
	GetDevice(token auth.Token, id string) (devicemodel.Device, error, int)
	GetService(token auth.Token, id string) (devicemodel.Service, error, int)
	GetDeviceGroup(token auth.Token, id string) (result devicemodel.DeviceGroup, err error, code int)
	CheckAccess(token auth.Token, kind string, ids []string) (map[string]bool, error)
	GetDeviceSelection(token auth.Token, descriptions deviceselectionmodel.FilterCriteriaAndSet, filterByInteraction devicemodel.Interaction) (result []deviceselectionmodel.Selectable, err error, code int)
	GetBulkDeviceSelection(token auth.Token, bulk deviceselectionmodel.BulkRequest) (result deviceselectionmodel.BulkResult, err error, code int)
	GetBulkDeviceSelectionV2(token auth.Token, bulk deviceselectionmodel.BulkRequestV2) (result deviceselectionmodel.BulkResult, err error, code int)
	GetAspectNode(token auth.Token, id string) (aspectNode devicemodel.AspectNode, err error)
}

type DevicesFactory interface {
	New(ctx context.Context, config config.Config) (Devices, error)
}

type Engine interface {
	Deploy(token string, depl client.DeploymentMessage) (err error, code int)
	DeleteDeployment(token string, userId string, deplId string) (err error, code int)
}

type EventDeployment interface {
	Deploy(token string, depl client.Deployment) (err error, code int)
	DeleteDeployment(token string, userId string, deplId string) (err error, code int)
	UpdateDeploymentsOfDeviceGroup(token string, dgId string) (err error, code int)
}

type Imports interface {
	CheckAccess(token auth.Token, ids []string, alsoCheckTypes bool) (bool, error)
}

type ImportsFactory interface {
	New(config config.Config) (Imports, error)
}

type ProcessRepo interface {
	GetProcessModel(impersonate auth.Token, id string) (result processmodel.ProcessModel, err error, errCode int)
}

type ProcessRepoFactory interface {
	New(ctx context.Context, config config.Config) (ProcessRepo, error)
}

type Producer interface {
	Produce(key string, message []byte) error
}

type SourcingFactory interface {
	NewUserCommandConsumer(ctx context.Context, config config.Config, listener func(delivery messages.UserCommandMsg) error) error
	NewDeviceGroupConsumer(ctx context.Context, config config.Config, listener func(groupId string) error) error
	NewDeploymentProducer(ctx context.Context, config config.Config) (DeploymentProducer, error)
}