Function waitForAnyMessage

api/src/websocket/utils/wait-for-message.ts:6–25

(client: WebSocket, timeout: number)

import { getMessageType } from './message.js';

export const waitForAnyMessage = (client: WebSocket, timeout: number): Promise<Record<string, any>> => {
	return new Promise((resolve, reject) => {
		client.on('message', awaitMessage);

		const timer = setTimeout(() => {
			client.off('message', awaitMessage);
			reject();
		}, timeout);

		function awaitMessage(event: RawData) {
			try {
				clearTimeout(timer);
				client.off('message', awaitMessage);
				resolve(parseJSON(event.toString()));
			} catch (err) {
				reject(err);
			}
		}
	});
};

export const waitForMessageType = (client: WebSocket, type: string, timeout: number): Promise<WebSocketMessage> => {
	return new Promise((resolve, reject) => {