platform_connector_lib

type AsyncCommandHandler func(commandRequest model.ProtocolMsg, requestMsg CommandRequestMsg, t time.Time) (err error)

type CommandRequestMsg = map[ProtocolSegmentName]string

type CommandResponseMsg = map[ProtocolSegmentName]string

type Config struct {
	EventTimeProvider func(msg EventMsg) (EventMsg, time.Time)

	KafkaUrl           string
	KafkaResponseTopic string
	KafkaGroupName     string
	FatalKafkaError    bool
	Protocol           string

	DeviceManagerUrl string
	DeviceRepoUrl    string
	PermissionsV2Url string

	AuthClientId             string //keycloak-client
	AuthClientSecret         string //keycloak-secret
	AuthExpirationTimeBuffer float64
	AuthEndpoint             string

	JwtPrivateKey string
	JwtExpiration int64
	JwtIssuer     string

	DeviceExpiration      int32
	DeviceTypeExpiration  int32
	TokenCacheExpiration  int32
	IotCacheUrl           []string
	TokenCacheUrl         []string
	Debug                 bool
	SerializationFallback string

	Validate                  bool
	ValidateAllowUnknownField bool
	ValidateAllowMissingField bool

	CharacteristicExpiration int32
	PartitionsNum            int
	ReplicationFactor        int

	PublishToPostgres bool
	PostgresHost      string
	PostgresPort      int
	PostgresUser      string
	PostgresPw        string
	PostgresDb        string

	HttpCommandConsumerPort string

	AsyncPgThreadMax    int
	AsyncFlushMessages  int
	AsyncFlushFrequency time.Duration
	AsyncCompression    sarama.CompressionCodec
	SyncCompression     sarama.CompressionCodec

	KafkaConsumerMaxWait  string
	KafkaConsumerMinBytes int
	KafkaConsumerMaxBytes int

	IotCacheTimeout      string
	IotCacheMaxIdleConns int

	NotificationUrl string

	DeviceTypeTopic string

	KafkaTopicConfigs map[string][]kafka.ConfigEntry

	NotificationsIgnoreDuplicatesWithinS int
	NotificationUserOverwrite            string

	DeveloperNotificationUrl string //optional

	MutedUserNotificationTitles []string

	InitTopics bool

	LogLevel string       `json:"log_level"`
	Logger   *slog.Logger `json:"-"` // optional, will be created if not set
}

type Connector struct {
	Config Config

	IotCache *iot.PreparedCache
	// contains filtered or unexported fields
}

type DeviceCommandHandler func(deviceId string, deviceUri string, serviceId string, serviceUri string, requestMsg CommandRequestMsg) (responseMsg CommandResponseMsg, qos Qos, err error)

type DeviceTypeCommand struct {
	Command string `json:"command"`
	Id      string `json:"id"`
}

type EventMsg = map[ProtocolSegmentName]string

type HandledDeviceInfo struct {
	DeviceId     string
	DeviceTypeId string
	ServiceIds   []string
}

type Notification struct {
	UserId  string `json:"userId" bson:"userId"`
	Title   string `json:"title" bson:"title"`
	Message string `json:"message" bson:"message"`
	Topic   string `json:"topic" bson:"topic"`
}

type ProtocolSegmentName = string

type Qos int

type Security interface {
	Access() (token security.JwtToken, err error)
	ResetAccess()
	GenerateUserTokenById(userid string) (token security.JwtToken, err error)
	GenerateUserToken(username string) (token security.JwtToken, err error)
	ExchangeUserToken(userid string, remoteInfo model.RemoteInfo) (token security.JwtToken, err error)
	GetUserToken(username string, password string, remoteInfo model.RemoteInfo) (token security.JwtToken, err error)
	GetCachedUserToken(username string, remoteInfo model.RemoteInfo) (token security.JwtToken, err error)
	GetUserId(username string) (userid string, err error)
	GetUserRoles(userid string) (roles []string, err error)
}