Function getMessageHandler

src/synchronizers/synchronizer-ws-server/index.ts:173–189

(clientId: Id, clients: IdMap<WebSocket>, serverClient: ServerClient)

  const getMessageHandler =
    (clientId: Id, clients: IdMap<WebSocket>, serverClient: ServerClient) =>
    (payload: string) =>
      ifPayloadValid(payload, (toClientId, remainder) => {
        const forwardedPayload = createRawPayload(clientId, remainder);
        if (toClientId === EMPTY_STRING) {
          if (clientId !== SERVER_CLIENT_ID) {
            serverClient[Sc.Send]?.(forwardedPayload);
          }
          mapForEach(clients, (otherClientId, otherClient) =>
            otherClientId !== clientId ? otherClient.send(forwardedPayload) : 0,
          );
        } else if (toClientId === SERVER_CLIENT_ID) {
          serverClient[Sc.Send]?.(forwardedPayload);
        } else {
          mapGet(clients, toClientId)?.send(forwardedPayload);
        }
      });

  webSocketServer.on('connection', (client, request) =>
    ifNotUndefined(strMatch(request.url, PATH_REGEX), ([, pathId]) =>