interfaces

type ComFactory func(ctx context.Context, config configuration.Config, responseListener func(msg messages.ProtocolMsg) error, errorListener func(msg messages.ProtocolMsg) error) (producer Producer, err error)

type Iot interface {
	GetDevice(token string, id string) (result model.Device, err error)
	GetDeviceGroup(token string, id string) (result model.DeviceGroup, err error)
	GetService(token string, device model.Device, id string) (result model.Service, err error)
	GetDeviceType(token string, id string) (result model.DeviceType, err error)
	GetProtocol(token string, id string) (result model.Protocol, err error)
	ListFunctions() (functionInfos []model.Function, err error)
	GetFunction(id string) (result model.Function, err error)
	GetConcept(id string) (result model.Concept, err error)
	GetCharacteristic(id string) (result model.Characteristic, err error)
	GetAspectNode(id string) (model.AspectNode, error)
	GetConceptIds() ([]string, error)
}

type IotFactory func(ctx context.Context, config configuration.Config) (Iot, error)

type Marshaller interface {
	MarshalFromServiceAndProtocol(characteristicId string, service model.Service, protocol model.Protocol, characteristicData interface{}, configurables []marshaller.Configurable) (result map[string]string, err error)
	UnmarshalFromServiceAndProtocol(characteristicId string, service model.Service, protocol model.Protocol, message map[string]string, hints []string) (characteristicData interface{}, err error)

	MarshalV2(service model.Service, protocol model.Protocol, data []marshaller.MarshallingV2RequestData) (result map[string]string, err error)
	UnmarshalV2(request marshaller.UnmarshallingV2Request) (characteristicData interface{}, err error)
}

type MarshallerFactory func(ctx context.Context, config configuration.Config, iot Iot) (Marshaller, error)

type Producer interface {
	SendCommand(msg messages.ProtocolMsg) (err error)
}

type Timescale interface {
	GetLastMessage(token auth.Token, device models.Device, service models.Service, protocol model.Protocol, timeout time.Duration) (result map[string]interface{}, err error)
}

type TimescaleFactory func(ctx context.Context, config configuration.Config) (Timescale, error)