tg-ws-proxy/docs/CfWorker.md

Cloudflare Worker

Альтернативный (полностью бесплатный, не нужно покупать домен в отличии от CfProxy) способ проксирования.

Прокси возвращает доступ к тому, что раньше не загружалось (реакции, некоторые стикеры). Если на аккаунте без Premium с данным способом все еще не загружаются фото/видео, оставьте в блоке DC → IP только 4:149.154.167.220

1. Добавьте в zapret или в любое другое ПО следующие домены:

cloudflare.com
cloudflare.dev
workers.dev

2. Создайте аккаунт в Cloudflare (или войдите в существующий)

   • После создания аккаунта подтвердите почту с помощью письма, который вам пришел на email

3. Слева в панели выберите Compute → Workers & Pages
   

4. Нажмите сверху справа кнопку Create application → Start with Hello World! → Deploy
   
   
   

5. Сверху справа нажмите кнопку Edit code, замените код слева на тот, что находится внизу этой страницы

   • Если у вас не загружается код, то вы не выполнили первый пункт
     
     

6. Нажмите сверху справа кнопку Deploy
   

7. Скопируйте домен из поля справа и укажите его в настройках Cloudflare Worker (или через аргумент --cfproxy-worker-domain)

   • Пример домена: random-symbols-1234.username.workers.dev
     

Код Worker'а

import { connect } from "cloudflare:sockets";

function toBytes(data) {
	if (data instanceof ArrayBuffer) {
		return new Uint8Array(data);
	}
	if (typeof data === "string") {
		return new TextEncoder().encode(data);
	}
	if (data && typeof data.arrayBuffer === "function") {
		return data.arrayBuffer().then((ab) => new Uint8Array(ab));
	}
	return new Uint8Array();
}

export default {
	async fetch(request) {
		if ((request.headers.get("Upgrade") || "").toLowerCase() !== "websocket") {
			return new Response("Expected websocket", { status: 426 });
		}

		const url = new URL(request.url);
		if (url.pathname !== "/apiws") {
			return new Response("Not found", { status: 404 });
		}

		const dst = url.searchParams.get("dst");
		const pair = new WebSocketPair();
		const client = pair[0];
		const server = pair[1];
		server.accept();

		const socket = connect({ hostname: dst, port: 443 });
		const tcpReader = socket.readable.getReader();
		const tcpWriter = socket.writable.getWriter();

		server.addEventListener("message", async (event) => {
			try {
				await tcpWriter.write(await toBytes(event.data));
			} catch {
				try {
					server.close(1011, "tcp write failed");
				} catch {}
			}
		});

		server.addEventListener("close", async () => {
			try {
				await tcpWriter.close();
			} catch {}
			try {
				socket.close();
			} catch {}
		});

		(async () => {
			try {
				while (true) {
					const { value, done } = await tcpReader.read();
					if (done) {
						break;
					}
					if (value) {
						server.send(value);
					}
				}
			} catch {
			} finally {
				try {
					server.close();
				} catch {}
				try {
					tcpReader.releaseLock();
				} catch {}
				try {
					socket.close();
				} catch {}
			}
		})();

		return new Response(null, { status: 101, webSocket: client });
	},
};