Class WebsocketFrontendConnectionService

Implements

FrontendConnectionService

Index

Constructors

Properties

channelsMarkedForClose closeTimeouts connectionsByFrontend container logger websocketServer wsHandlers

Methods

closeConnection createConnection handleConnection handleSocketDisconnect markForClose registerConnectionHandler

Constructors

constructor

new WebsocketFrontendConnectionService(): WebsocketFrontendConnectionService
Returns WebsocketFrontendConnectionService

Properties

`Protected` `Readonly`channelsMarkedForClose

channelsMarkedForClose: Set<string> = ...

`Protected` `Readonly`closeTimeouts

closeTimeouts: Map<string, Timeout> = ...

`Protected` `Readonly`connectionsByFrontend

connectionsByFrontend: Map<string, ReconnectableSocketChannel> = ...

`Protected` `Readonly`container

container: Container

`Protected` `Readonly`logger

logger: ILogger

`Protected` `Readonly`websocketServer

websocketServer: WebsocketEndpoint

`Protected` `Readonly`wsHandlers

wsHandlers: ConnectionHandlers<unknown> = ...

Methods

`Protected`closeConnection

closeConnection(frontEndId: string, reason: string): void
Parameters
- frontEndId: string
- reason: string
Returns void
- Defined in packages/core/src/node/messaging/websocket-frontend-connection-service.ts:87

`Protected`createConnection

createConnection(socket: Socket, frontEndId: string): ReconnectableSocketChannel
Parameters
- socket: Socket
- frontEndId: string
Returns ReconnectableSocketChannel
- Defined in packages/core/src/node/messaging/websocket-frontend-connection-service.ts:102

`Protected`handleConnection

handleConnection(
socket: Socket,
channelCreatedHandler: (channel: Channel) => void,
): Promise<void>
Parameters
- socket: Socket
- channelCreatedHandler: (channel: Channel) => void
Returns Promise<void>
- Defined in packages/core/src/node/messaging/websocket-frontend-connection-service.ts:51

handleSocketDisconnect

handleSocketDisconnect(
    socket: Socket,
    channel: ReconnectableSocketChannel,
    frontEndId: string,
): void
Parameters
- socket: Socket
- channel: ReconnectableSocketChannel
- frontEndId: string
Returns void
- Defined in packages/core/src/node/messaging/websocket-frontend-connection-service.ts:111

markForClose

markForClose(channelId: string): void
Parameters
- channelId: string
Returns void
- Defined in packages/core/src/node/messaging/websocket-frontend-connection-service.ts:132

registerConnectionHandler

registerConnectionHandler(
spec: string,
callback: (params: MessagingService.PathParams, channel: Channel) => void,
): void
Parameters
- spec: string
- callback: (params: MessagingService.PathParams, channel: Channel) => void
Returns void
Implementation of FrontendConnectionService.registerConnectionHandler
- Defined in packages/core/src/node/messaging/websocket-frontend-connection-service.ts:47