76 lines
1.7 KiB
TypeScript
76 lines
1.7 KiB
TypeScript
import { Base64Message } from '../backend/src/Model/Base64Message'
|
|
import { DataSourceState, MqttOptions } from '../backend/src/DataSource'
|
|
import { UpdateInfo } from 'builder-util-runtime'
|
|
import { OpenDialogOptions, OpenDialogReturnValue } from 'electron'
|
|
|
|
export type Event<MessageType> = {
|
|
topic: string
|
|
}
|
|
|
|
export interface AddMqttConnection {
|
|
id: string
|
|
options: MqttOptions
|
|
}
|
|
|
|
export const addMqttConnectionEvent: Event<AddMqttConnection> = {
|
|
topic: 'connection/add/mqtt',
|
|
}
|
|
|
|
export const removeConnection: Event<string> = {
|
|
topic: 'connection/remove',
|
|
}
|
|
|
|
export function makeConnectionStateEvent(connectionId: string): Event<DataSourceState> {
|
|
return {
|
|
topic: `conn/state/${connectionId}`,
|
|
}
|
|
}
|
|
|
|
export const updateAvailable: Event<UpdateInfo> = {
|
|
topic: 'app/update/available',
|
|
}
|
|
|
|
export interface MqttMessage {
|
|
topic: string
|
|
payload: Base64Message | null
|
|
qos: 0 | 1 | 2
|
|
retain: boolean
|
|
// Set if QoS is > 0 on received messages
|
|
messageId: number | undefined
|
|
}
|
|
|
|
export function makePublishEvent(connectionId: string): Event<MqttMessage> {
|
|
return {
|
|
topic: `conn/publish/${connectionId}`,
|
|
}
|
|
}
|
|
|
|
export function makeConnectionMessageEvent(connectionId: string): Event<MqttMessage> {
|
|
return {
|
|
topic: `conn/${connectionId}`,
|
|
}
|
|
}
|
|
|
|
export interface OpenDialogRequest {
|
|
identifier: string
|
|
options: OpenDialogOptions
|
|
}
|
|
|
|
export function requestOpenDialog(): Event<OpenDialogRequest> {
|
|
return {
|
|
topic: `requestOpenDialog`,
|
|
}
|
|
}
|
|
|
|
export interface OpenDialogResponse {
|
|
identifier: string
|
|
result: OpenDialogReturnValue
|
|
}
|
|
|
|
export function openDialogResponse(): Event<OpenDialogResponse> {
|
|
return {
|
|
topic: `openDialogResponse`,
|
|
}
|
|
}
|
|
|