Class ServerSocketAdapter

packages/sync-core/src/lib/ServerSocketAdapter.ts:130–171

 * ```
 */
export class ServerSocketAdapter<R extends UnknownRecord> implements TLRoomSocket<R> {
	/**
	 * Creates a new ServerSocketAdapter instance.
	 *
	 * opts - Configuration options for the adapter
	 */
	constructor(public readonly opts: ServerSocketAdapterOptions<R>) {}

	/**
	 * Checks if the underlying WebSocket connection is currently open and ready to send messages.
	 *
	 * @returns True if the connection is open (readyState === 1), false otherwise
	 */
	// eslint-disable-next-line tldraw/no-setter-getter
	get isOpen(): boolean {
		return this.opts.ws.readyState === 1 // ready state open
	}

	/**
	 * Sends a sync protocol message to the connected client. The message is JSON stringified
	 * before being sent through the WebSocket. If configured, the onBeforeSendMessage callback
	 * is invoked before sending.
	 *
	 * @param msg - The sync protocol message to send
	 */
	// see TLRoomSocket for details on why this accepts a union and not just arrays
	sendMessage(msg: TLSocketServerSentEvent<R>) {
		const message = JSON.stringify(msg)
		this.opts.onBeforeSendMessage?.(msg, message)
		this.opts.ws.send(message)
	}

	/**
	 * Closes the WebSocket connection with an optional close code and reason.
	 *
	 * @param code - Optional close code (default: 1000 for normal closure)
	 * @param reason - Optional human-readable reason for closing
	 */
	close(code?: number, reason?: string) {
		this.opts.ws.close(code, reason)
	}
}