interfaces

type Devices interface {
	GetDeviceInfosOfGroup(groupId string) (devices []model.Device, deviceTypeIds []string, err error, code int)
	GetDeviceInfosOfDevices(deviceIds []string) (devices []model.Device, deviceTypeIds []string, err error, code int)
	GetDeviceTypeSelectables(criteria []model.FilterCriteria) (result []model.DeviceTypeSelectable, err error, code int)
	GetConcept(conceptId string) (result model.Concept, err error, code int)
	GetFunction(functionId string) (result model.Function, err error, code int)
	GetService(serviceId string) (result models.Service, err error, code int)
}

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

type Events interface {
	HandleCommand(msg []byte) error
	Remove(owner string, deploymentId string) (err error)
	Deploy(owner string, deployment models.Deployment) (err error)
	HandleDeviceGroupUpdate(msg []byte) error
	UpdateDeviceGroup(groupId string) (err error)
	CheckEvent(token string, id string) int
	GetEventStates(token string, ids []string) (states map[string]bool, err error, code int)
}

type EventsFactory interface {
	New(ctx context.Context, config config.Config, devices Devices, imports Imports, doneProducer Producer, m *metrics.Metrics) (Events, error)
}

type Imports interface {
	GetTopic(user string, importId string) (topic string, err error, code int)
	GetImportInstance(user string, importId string) (importInstance models.Import, err error, code int)
	GetImportType(user string, importTypeId string) (importInstance models.ImportType, err error, code int)
}

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

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

type SourcingFactory interface {
	NewConsumer(ctx context.Context, config config.Config, topic string, listener func(delivery []byte) error) error
	NewProducer(ctx context.Context, config config.Config, topic string) (Producer, error)
}