Mashroom WebSocket

Plugin for Mashroom Server, a Microfrontend Integration Platform.

This plugin adds WebSocket support to the Mashroom Server. It exposes a new service that can be used to interact with clients that connect at /websocket/*.

Usage

If node_modules/@mashroom is configured as plugin path just add @mashroom/mashroom-websocket as dependency.

And you can use the security service like this:

import type {MashroomWebSocketService} from '@mashroom/mashroom-websocket/type-definitions';

export default async (req: Request, res: Response) => {
    const webSocketService: MashroomWebSocketService = req.pluginContext.services.websocket.service;

    webSocketService.addMessageListener((path) => path === '/whatever', async (message, client) => {

        // ...

        await webSocketService.sendMessage(client, {
            message: 'Hello there'
        });
    });
}

You can override the default config in your Mashroom config file like this:

{
  "plugins": {
        "Mashroom WebSocket Webapp": {
            "path": "/websocket",
            "reconnectMessageBufferFolder": null,
            "reconnectTimeoutSec": 5,
            "restrictToRoles": ["WebSocketRole"],
            "enableKeepAlive": true,
            "keepAliveIntervalSec": 15,
            "maxConnections": 2000
        }
    }
}

• path: The path where the clients can connect (Default: /websocket)
• reconnectMessageBufferFolder: The path where messages are temporary stored during client reconnect. When set to null or empty string, buffering is disabled. The base for relative paths is the Mashroom config file (Default: null)
• reconnectTimeoutSec: Time for how long are messages buffered during reconnect (Default: 5)
• restrictToRoles: An optional array of roles that are required to connect (Default: null)
• enableKeepAlive: Enable periodic keep alive messages to all clients. This is useful if you want to prevent reverse proxies to close connections because of a read timeout (Default: true)
• keepAliveIntervalSec: Interval for keepalive messages in seconds (Default: 15)
• maxConnections: Max allowed WebSocket connections per node (Default: 2000)

There will also be a test page available under: /websocket/test

Reconnect to a previous session

When you connect with a client you will receive a message with your clientId from the server:

{
    "type": "setClientId",
    "payload": "abcdef"
}

When you get disconnected you should reconnect with the query parameter ?clientId=abcdef to get all messages you missed meanwhile.

This only works if reconnectMessageBufferFolder is set properly.

Services

MashroomWebSocketService

The exposed service is accessible through pluginContext.services.websocket.service

Interface:

export interface MashroomWebSocketService {
    /**
     * Add a listener for message.
     * The matcher defines which messages the listener receives. The match can be based on the connect path
     * (which is the sub path where the client connected, e.g. if it connected on /websocket/test the connect path would be /test)
     * or be based on the message content or both.
     */
    addMessageListener(
        matcher: MashroomWebSocketMatcher,
        listener: MashroomWebSocketMessageListener,
    ): void;

    /**
     * Remove a message listener
     */
    removeMessageListener(
        matcher: MashroomWebSocketMatcher,
        listener: MashroomWebSocketMessageListener,
    ): void;

    /**
     * Add a listener for disconnects
     */
    addDisconnectListener(listener: MashroomWebSocketDisconnectListener): void;

    /**
     * Remove a disconnect listener
     */
    removeDisconnectListener(
        listener: MashroomWebSocketDisconnectListener,
    ): void;

    /**
     * Send a (JSON) message to given client.
     */
    sendMessage(client: MashroomWebSocketClient, message: any): Promise<void>;

    /**
     * Get all clients on given connect path
     */
    getClientsOnPath(connectPath: string): Array<MashroomWebSocketClient>;

    /**
     * Get all clients for a specific username
     */
    getClientsOfUser(username: string): Array<MashroomWebSocketClient>;

    /**
     * Get the number of connected clients
     */
    getClientCount(): number;

    /**
     * Close client connection (this will also trigger disconnect listeners)
     */
    close(client: MashroomWebSocketClient): void;

    /**
     * The base path where clients can connect
     */
    readonly basePath: string;
}