Class NotificationStore

Constructors

constructor

new NotificationStore(main: MainStore): NotificationStore
Parameters
- main: MainStore
Returns NotificationStore
- Defined in src/lib/stores/notificationStore.ts:46

Properties

connected

connected: boolean = false

listeners

listeners: Map<string, Subscription[]> = ...

main

main: MainStore

`Optional`mqttClient

mqttClient?: Client

reconnectAttempts

reconnectAttempts: number = 0

`Optional`reconnectHandler

reconnectHandler?: () => void

subscribedTopics

subscribedTopics: {
    handler: (data: any) => void;
    referenceId: string;
    topic: string;
}[] = []

subscribeQueue

subscribeQueue: {
    handler: (data: any) => void;
    referenceId: string;
    topic: string;
}[] = []

Accessors

topicStage

get topicStage(): "stage" | "prod"
Returns "stage" | "prod"
- Defined in src/lib/stores/notificationStore.ts:42

Methods

connect

connect(credentials?: IotCredentials): Promise<void>
Parameters
- Optionalcredentials: IotCredentials
Returns Promise<void>
- Defined in src/lib/stores/notificationStore.ts:73

connectWithCredentials

connectWithCredentials(data: IotCredentials): void
Parameters
- data: IotCredentials
Returns void
- Defined in src/lib/stores/notificationStore.ts:92

executeListeners

executeListeners(subscriptions: Subscription[], message: unknown): void
Parameters
- subscriptions: Subscription[]
- message: unknown
Returns void
- Defined in src/lib/stores/notificationStore.ts:193

getCredentials

getCredentials(): Promise<undefined | IotCredentials>
Returns Promise<undefined | IotCredentials>
- Defined in src/lib/stores/notificationStore.ts:62

isConnected

isConnected(): boolean
Returns boolean
- Defined in src/lib/stores/notificationStore.ts:50

resolveSubscriptionQueue

resolveSubscriptionQueue(): void
Returns void
- Defined in src/lib/stores/notificationStore.ts:209

resolveSubscriptions

resolveSubscriptions(): void
Returns void
- Defined in src/lib/stores/notificationStore.ts:203

setReconnectHandler

setReconnectHandler(handler: () => void): void
Parameters
- handler: () => void
Returns void
- Defined in src/lib/stores/notificationStore.ts:58

subscribe

subscribe(
    topicPostfix: string,
    onMessage: (data: any) => void,
    reference?: string,
): undefined | string
Parameters
- topicPostfix: string
- onMessage: (data: any) => void
- Optionalreference: string
Returns undefined | string
- Defined in src/lib/stores/notificationStore.ts:222

unsubscribe

unsubscribe(topicPostfix: string, reference: string): void
Parameters
- topicPostfix: string
- reference: string
Returns void
- Defined in src/lib/stores/notificationStore.ts:291