connector

type Connector struct {
	MaxCorrelationIdAge time.Duration
	// contains filtered or unexported fields
}

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

type DeviceDescription interface {
	GetDeviceName() string
	GetDeviceTypeId() string
	GetLocalDeviceId() string
}

type GenericMgwFactory[T MgwClient] func(ctx context.Context, config configuration.Config, refreshNotifier func()) (T, error)

type GenericMqttFactory[T MqttClient] func(ctx context.Context, brokerUrl string, clientId string, username string, password string) (T, error)

type GenericTopicDescriptionProvider[T TopicDescription] func(config configuration.Config, deviceRepo *devicerepo.DeviceRepo) ([]T, error)

type MgwClient interface {
	ListenToDeviceCommands(deviceId string, commandHandler mgw.DeviceCommandHandler) error
	StopListenToDeviceCommands(deviceId string) error
	SetDevice(deviceId string, name string, deviceTypeid string, state string) error
	RemoveDevice(deviceId string) error
	SendEvent(deviceId string, serviceId string, value []byte) error
	Respond(deviceId string, serviceId string, response mgw.Command) error

	SendClientError(message string)
	SendDeviceError(localDeviceId string, message string)
	SendCommandError(correlationId string, message string)
}

type MgwFactory = GenericMgwFactory[MgwClient]

type MqttClient interface {
	Subscribe(topic string, qos byte, handler func(topic string, retained bool, payload []byte)) error
	Unsubscribe(topic string) error
	Publish(topic string, qos byte, retained bool, payload []byte) error
}

type MqttFactory = GenericMqttFactory[MqttClient]

type OnlineChecker interface {
	Preprocess(events []TopicDescription) error
	LoadState(desc TopicDescription) (state mgw.State, found bool)
	CheckAndStoreState(desc TopicDescription, retained bool, payload []byte) (state mgw.State, ignore bool)
}

type TopicDescription interface {
	DeviceDescription
	GetEventTopic() string
	GetCmdTopic() string
	GetResponseTopic() string
	GetLocalServiceId() string
}

type TopicDescriptionProvider = GenericTopicDescriptionProvider[TopicDescription]