Method handleTunnelRequest

apps/yalt/src/index.ts:221–247

(request: Request)

	}

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

		if (this.socket.readyState !== WebSocket.READY_STATE_OPEN) {
			return createErrorResponse();
		}

		const id = crypto.randomUUID();

		const promise = new Promise<Response>((resolve, reject) => {
			this.responseResolvers[id] = { resolve, reject };
		});

		try {
			const message = await createRequestMessage(id, request);
			this.socket.send(JSON.stringify(message));
		} catch (error) {
			console.error(error);
			delete this.responseResolvers[id];

			return createErrorResponse();
		}

		return promise;
	}
}

const createErrorResponse = () =>