Method handleSocket

apps/yalt/src/index.ts:175–219

(socket: WebSocket)

	}

	private async handleSocket(socket: WebSocket) {
		if (this.socket) {
			this.socket.close(1000, 'replaced');
		}

		this.socket = socket;

		this.socket.addEventListener('message', (event) => {
			// Here we need to listen for "response" messages from the client and send them to the server via stored promises on this object
			const data = JSON.parse(typeof event.data === 'string' ? event.data : new TextDecoder('utf-8').decode(event.data));

			const message = ClientMessages.safeParse(data);

			if (!message.success) {
				console.error(message.error);
				return;
			}

			switch (message.data.type) {
				case 'response': {
					const { id, ...response } = message.data;

					const resolver = this.responseResolvers[id];

					if (!resolver) {
						console.error(`No resolver found for ${id}`);
						return;
					}

					delete this.responseResolvers[id];

					resolver.resolve(
						new Response(response.body, {
							status: response.status,
							headers: response.headers,
						}),
					);

					break;
				}
			}
		});

		this.socket.accept();
	}

	private async handleTunnelRequest(request: Request): Promise<Response> {
		if (!this.socket) {