Method message

packages/server/src/adapters/websocket/handler.ts:44–63

* Handles a single message received from a WebSocket. * * @warning Avoid calling this directly if `.upgrade()` is used. * * @param ws The WebSocket instance * @param data The message payload, usually place in `event.data`

(
    ws: MinimalWebsocket,
    data: string | ArrayBuffer | Blob,
    ...rest: MaybeOptionalOptions<HandleStandardServerPeerMessageOptions<T>>
  )

   * @param data The message payload, usually place in `event.data`
   */
  async message(
    ws: MinimalWebsocket,
    data: string | ArrayBuffer | Blob,
    ...rest: MaybeOptionalOptions<HandleStandardServerPeerMessageOptions<T>>
  ): Promise<void> {
    let peer = this.#peers.get(ws)

    if (!peer) {
      this.#peers.set(ws, peer = new ServerPeer(ws.send.bind(ws)))
    }

    const message = data instanceof Blob
      ? await readAsBuffer(data)
      : data

    await peer.message(
      message,
      createServerPeerHandleRequestFn(this.#handler, resolveMaybeOptionalOptions(rest)),
    )
  }

  /**
   * Closes the WebSocket peer and cleans up.