Method fetch

apps/yalt/src/index.ts:145–173

(request: Request<unknown, CfProperties<unknown>>)

	) {}

	async fetch(request: Request<unknown, CfProperties<unknown>>): Promise<Response> {
		const url = new URL(request.url);

		switch (url.pathname) {
			case '/connect': {
				console.log(`Handling connect request`);

				// This is a request from the client to connect to the tunnel
				if (request.headers.get('Upgrade') !== 'websocket') {
					return new Response('expected websocket', { status: 400 });
				}

				const pair = new WebSocketPair();
				const [clientSocket, serverSocket] = Object.values(pair);

				await this.handleSocket(serverSocket);

				console.log(`Successfully connected to tunnel`);

				return new Response(null, { status: 101, webSocket: clientSocket });
			}
			case '/api/trigger': {
				return this.handleTunnelRequest(request);
			}
			default: {
				return new Response('Not Found', { status: 404 });
			}
		}
	}

	private async handleSocket(socket: WebSocket) {
		if (this.socket) {