mirror of
https://github.com/hackdiaz-dev/free-turn-proxy.git
synced 2026-10-12 09:41:53 +02:00
Compare commits
30 Commits
| Author | SHA1 | Date | |
|---|---|---|---|
 Anton
|
62064a5eca | ||
|
Anton
|
d67c829532 | ||
|
samosvalishe
|
e678ee1fd8 | ||
|
samosvalishe
|
e5874e3c30 | ||
|
samosvalishe
|
8311a2e2f9 | ||
|
samosvalishe
|
5a347bece9 | ||
|
samosvalishe
|
305754cd60 | ||
|
Anton
|
e009db0b9a | ||
|
Anton
|
321a0995c3 | ||
|
samosvalishe
|
6f934f10f4 | ||
|
samosvalishe
|
ea410a044a | ||
|
samosvalishe
|
b4189f8f43 | ||
|
Anton
|
2121b55190 | ||
|
Anton
|
2df39d460e | ||
|
samosvalishe
|
4c0bed1797 | ||
|
samosvalishe
|
ea1cb930cc | ||
|
samosvalishe
|
adcf0a0d21 | ||
|
Anton
|
15111ea72f | ||
|
Anton
|
10e6b375c6 | ||
|
samosvalishe
|
3b33d33b9e | ||
|
Anton
|
623d9a22c2 | ||
|
Anton
|
8a309fbf7e | ||
|
Anton
|
4493fc63a2 | ||
|
Anton
|
859c7ff683 | ||
|
Anton
|
f3d8da6919 | ||
|
samosvalishe
|
b391d7bf25 | ||
|
Anton
|
0a6bc0ae4f | ||
|
Anton
|
805228e62a | ||
|
smediainfo
|
3481de79a3 | ||
|
smediainfo
|
014f964ad9 |
@@ -12,7 +12,7 @@ concurrency:
|
||||
cancel-in-progress: true
|
||||
|
||||
env:
|
||||
GO_VERSION: "1.26.4"
|
||||
GO_VERSION: "1.26.5"
|
||||
GOLANGCI_VERSION: v2.12.2
|
||||
GOVULN_VERSION: v1.1.4
|
||||
GORELEASER_VERSION: v2.15.4
|
||||
|
||||
@@ -10,7 +10,7 @@ permissions:
|
||||
packages: write
|
||||
|
||||
env:
|
||||
GO_VERSION: "1.26.4"
|
||||
GO_VERSION: "1.26.5"
|
||||
GORELEASER_VERSION: v2.15.4
|
||||
GOMOBILE_VERSION: latest
|
||||
TASK_VERSION: 3.51.1
|
||||
@@ -129,3 +129,39 @@ jobs:
|
||||
args: release --clean
|
||||
env:
|
||||
GITHUB_TOKEN: ${{ secrets.GITHUB_TOKEN }}
|
||||
|
||||
notify-telegram:
|
||||
name: Telegram announce
|
||||
runs-on: ubuntu-latest
|
||||
needs: goreleaser
|
||||
steps:
|
||||
- name: Send release message
|
||||
env:
|
||||
GH_TOKEN: ${{ secrets.GITHUB_TOKEN }}
|
||||
BOT_TOKEN: ${{ secrets.TELEGRAM_BOT_TOKEN }}
|
||||
CHAT_ID: ${{ secrets.TELEGRAM_CHAT_ID }}
|
||||
run: |
|
||||
BODY=$(gh release view "$GITHUB_REF_NAME" --repo "$GITHUB_REPOSITORY" --json body -q .body | head -c 3000)
|
||||
URL=$(gh release view "$GITHUB_REF_NAME" --repo "$GITHUB_REPOSITORY" --json url -q .url)
|
||||
# GH-markdown -> Telegram-HTML: сначала экранируем HTML, потом размечаем.
|
||||
# Хвосты "by @user in <PR-url>" из авто-нотов убираем - в посте это шум.
|
||||
HTML=$(printf '%s' "$BODY" \
|
||||
| sed 's/&/\&/g; s/</\</g; s/>/\>/g' \
|
||||
| sed -E \
|
||||
-e 's| by @[[:alnum:]_-]+ in https://[^[:space:]]+||g' \
|
||||
-e 's|\[([^]]+)\]\((https?://[^)]+)\)|<a href="\2">\1</a>|g' \
|
||||
-e 's|\*\*([^*]+)\*\*|<b>\1</b>|g' \
|
||||
-e 's|`([^`]+)`|<code>\1</code>|g' \
|
||||
-e 's|^#{1,6}[[:space:]]+(.*)$|<b>\1</b>|' \
|
||||
-e 's|^[-*][[:space:]]+|• |')
|
||||
TEXT=$(printf '🚀 <b>FreeTurn %s</b>\n\n%s\n\n<a href="%s">Релиз на GitHub</a>' "$GITHUB_REF_NAME" "$HTML" "$URL")
|
||||
send() {
|
||||
curl -fsS -X POST "https://api.telegram.org/bot${BOT_TOKEN}/sendMessage" \
|
||||
--data-urlencode "chat_id=${CHAT_ID}" \
|
||||
--data-urlencode "text=$1" \
|
||||
--data-urlencode "parse_mode=${2:-}" \
|
||||
--data-urlencode "disable_web_page_preview=true" \
|
||||
-o /dev/null
|
||||
}
|
||||
# Кривой HTML роняет весь sendMessage - фолбэк plain text, чтобы анонс не пропал
|
||||
send "$TEXT" HTML || send "$(printf '🚀 FreeTurn %s\n\n%s\n\n%s' "$GITHUB_REF_NAME" "$BODY" "$URL")"
|
||||
|
||||
@@ -1,3 +1,3 @@
|
||||
{
|
||||
".": "1.6.0"
|
||||
".": "1.8.0"
|
||||
}
|
||||
|
||||
+54
-2
@@ -1,5 +1,57 @@
|
||||
# Changelog
|
||||
|
||||
## [1.8.0](https://github.com/samosvalishe/free-turn-proxy/compare/v1.7.3...v1.8.0) (2026-07-13)
|
||||
|
||||
|
||||
### Features
|
||||
|
||||
* автопубликация телеграм анонса при релизе ([e678ee1](https://github.com/samosvalishe/free-turn-proxy/commit/e678ee1fd85c64eb42da3ba9ccc580fccbc79749))
|
||||
|
||||
|
||||
### Bug Fixes
|
||||
|
||||
* **captcha:** persona-модель вместо захвата профиля браузера ([305754c](https://github.com/samosvalishe/free-turn-proxy/commit/305754cd6037fe3b4ec5558b826a89eefc64834b))
|
||||
|
||||
## [1.7.3](https://github.com/samosvalishe/free-turn-proxy/compare/v1.7.2...v1.7.3) (2026-07-12)
|
||||
|
||||
|
||||
### Bug Fixes
|
||||
|
||||
* **captcha:** адаптировать авторешение под SPA-капчу VK ([b4189f8](https://github.com/samosvalishe/free-turn-proxy/commit/b4189f8f4317b1c5c919ab8e0e183ebfb927d8be))
|
||||
* **deps:** обновить Go 1.26.4 -> 1.26.5 ([ea410a0](https://github.com/samosvalishe/free-turn-proxy/commit/ea410a044ad1ebd3fbc14286f41213357a6732f4))
|
||||
|
||||
## [1.7.2](https://github.com/samosvalishe/free-turn-proxy/compare/v1.7.1...v1.7.2) (2026-07-07)
|
||||
|
||||
|
||||
### Bug Fixes
|
||||
|
||||
* **captcha:** linter ([4c0bed1](https://github.com/samosvalishe/free-turn-proxy/commit/4c0bed17976a81301005a4a68d3c660847bf7313))
|
||||
|
||||
|
||||
### Refactoring
|
||||
|
||||
* **captcha:** вынести inject.js из Go и убрать легаси image-капчу ([ea1cb93](https://github.com/samosvalishe/free-turn-proxy/commit/ea1cb930cc886471ec70567fe789cd807ff13da2))
|
||||
|
||||
## [1.7.1](https://github.com/samosvalishe/free-turn-proxy/compare/v1.7.0...v1.7.1) (2026-07-07)
|
||||
|
||||
|
||||
### Bug Fixes
|
||||
|
||||
* **captcha:** устойчивый разбор debug_info и сигнал дрейфа версии скрипта ([3b33d33](https://github.com/samosvalishe/free-turn-proxy/commit/3b33d33b9e3c2d8d459b479e8d8a94fc562f18cb))
|
||||
|
||||
## [1.7.0](https://github.com/samosvalishe/free-turn-proxy/compare/v1.6.0...v1.7.0) (2026-07-02)
|
||||
|
||||
|
||||
### Features
|
||||
|
||||
* **mobile:** add host socket protector (SetProtect) for tun/VPN hosts ([0a6bc0a](https://github.com/samosvalishe/free-turn-proxy/commit/0a6bc0ae4f38f03722855f99461cc91f4181e057))
|
||||
|
||||
|
||||
### Bug Fixes
|
||||
|
||||
* **vkauth:** fast-fail on terminal call/link errors (9000/9008, anonymous-only, full) ([805228e](https://github.com/samosvalishe/free-turn-proxy/commit/805228e62a42f71ab6c0d345e2a510af5cae32c3))
|
||||
* **vkauth:** классификация terminal-ошибок по коду перед текстом ([b391d7b](https://github.com/samosvalishe/free-turn-proxy/commit/b391d7bf255e6f027d655c7e1a20a21ce04ab22a))
|
||||
|
||||
## [1.6.0](https://github.com/samosvalishe/free-turn-proxy/compare/v1.5.2...v1.6.0) (2026-06-30)
|
||||
|
||||
|
||||
@@ -221,7 +273,7 @@
|
||||
* **docker:** исправить сборку, добавить compose, убрать VLESS_BOND ([dfbfae2](https://github.com/samosvalishe/free-turn-proxy/commit/dfbfae29014b3cd246550589640e871ee424807e))
|
||||
* **dtlsdial:** Dial использует хелпер GenerateSelfSignedCert внутри ([21138fe](https://github.com/samosvalishe/free-turn-proxy/commit/21138fef26b61f8ba4b72f8e5389d3b90b7026b2))
|
||||
* **dtlsdial:** унифицировать генерацию self-signed сертификата ([ef549dc](https://github.com/samosvalishe/free-turn-proxy/commit/ef549dc2b8405a1e8378d9c81f2ae3871495121f))
|
||||
* **install:** переписать установщик сервера — TUI, надёжность, non-interactive ([1b154a2](https://github.com/samosvalishe/free-turn-proxy/commit/1b154a2e84057c07344a4d7308ca7d26f5f127ec))
|
||||
* **install:** переписать установщик сервера - TUI, надёжность, non-interactive ([1b154a2](https://github.com/samosvalishe/free-turn-proxy/commit/1b154a2e84057c07344a4d7308ca7d26f5f127ec))
|
||||
* **lint:** устранить замечания golangci-lint + переход на dockers_v2 ([dd82332](https://github.com/samosvalishe/free-turn-proxy/commit/dd8233208ccbe60ea17745ddc17df7a8e6c56872))
|
||||
* **routes:** починить установку маршрутов в routes.ps1 на Windows ([7b0a907](https://github.com/samosvalishe/free-turn-proxy/commit/7b0a9076380bbcdc2f83d6da63ca3800b5d68412))
|
||||
* **server:** ограниченное ожидание второго сигнала; предупреждение при выключенном -wrap ([fb711c1](https://github.com/samosvalishe/free-turn-proxy/commit/fb711c12f5e1f78ee037ceed434b6cdde5a961d8))
|
||||
@@ -266,7 +318,7 @@
|
||||
* **tcpfwd:** заменить busy-loop poll пула на Ready-канал; тихий accept-цикл при shutdown ([2b24471](https://github.com/samosvalishe/free-turn-proxy/commit/2b24471553b7a9acb0c0117d7ce666bac758e97e))
|
||||
* **udprelay:** разбить на run/loop/listener ([d82258f](https://github.com/samosvalishe/free-turn-proxy/commit/d82258f844ef65ba06ba05aa7de4130c43f2c56e))
|
||||
* **vkauth:** разбить token.go на файлы по шагам ([0e2d42c](https://github.com/samosvalishe/free-turn-proxy/commit/0e2d42c9126505599db25d8c6f82956036c193be))
|
||||
* **wire:** переименовать srtpmimicry → rtpopus, заменить bool -obf на -obf-profile ([4bedd00](https://github.com/samosvalishe/free-turn-proxy/commit/4bedd00662bb75a5f2fdd8fc3cee9c8eb6d94e7c))
|
||||
* **wire:** переименовать srtpmimicry -> rtpopus, заменить bool -obf на -obf-profile ([4bedd00](https://github.com/samosvalishe/free-turn-proxy/commit/4bedd00662bb75a5f2fdd8fc3cee9c8eb6d94e7c))
|
||||
* **wrap:** заменить DTLS-мимикрию на noise-only AEAD ([e2dd09a](https://github.com/samosvalishe/free-turn-proxy/commit/e2dd09a7296f972285850786c6552d66006bf19d))
|
||||
* **wrap:** перейти на мимикрию под SRTP в обход content-фильтра VK TURN ([729557d](https://github.com/samosvalishe/free-turn-proxy/commit/729557d00d3f7b16e4d1d876adca23404eff738c))
|
||||
* **wrap:** переписать как мимикрию под DTLS 1.2 ApplicationData с AEAD ([39f95a8](https://github.com/samosvalishe/free-turn-proxy/commit/39f95a8e0c2ca3520c530e425aa55a5b586feadb))
|
||||
|
||||
@@ -10,14 +10,14 @@
|
||||
|
||||
## О проекте
|
||||
|
||||
**Free Turn Proxy** — универсальный прокси-туннель для инкапсуляции UDP/TCP трафика поверх протокола TURN. Клиент извлекает временные TURN-учётки из ссылок на WebRTC-звонки и прозрачно маршрутизирует ваш VPN-трафик (WireGuard, Xray/VLESS) до сервера на VPS, используя DTLS и мощные механизмы маскировки пакетов.
|
||||
**Free Turn Proxy** - универсальный прокси-туннель для инкапсуляции UDP/TCP трафика поверх протокола TURN. Клиент извлекает временные TURN-учётки из ссылок на WebRTC-звонки и прозрачно маршрутизирует ваш VPN-трафик (WireGuard, Xray/VLESS) до сервера на VPS, используя DTLS и мощные механизмы маскировки пакетов.
|
||||
|
||||
## Разработка
|
||||
|
||||
### Зависимости
|
||||
|
||||
- **Go** ≥ 1.26 — `https://go.dev/dl/`
|
||||
- **Task** (runner) — `go install github.com/go-task/task/v3/cmd/task@v3.40.0` или `winget install Task.Task` / `brew install go-task`
|
||||
- **Go** ≥ 1.26 - `https://go.dev/dl/`
|
||||
- **Task** (runner) - `go install github.com/go-task/task/v3/cmd/task@v3.40.0` или `winget install Task.Task` / `brew install go-task`
|
||||
|
||||
Остальные dev-инструменты (`golangci-lint`, `govulncheck`, `goimports`, `goreleaser`) ставит сам Task:
|
||||
|
||||
@@ -34,7 +34,7 @@ task build:all # кросс-сборка всех target через gorelea
|
||||
task build:ios # сборка XCFramework для iOS в dist/Mobile.xcframework
|
||||
task build:android # сборка AAR архива для Android в dist/mobile.aar
|
||||
task test # go test -race
|
||||
task test:cover # тесты + покрытие → cover.html
|
||||
task test:cover # тесты + покрытие -> cover.html
|
||||
task lint # golangci-lint
|
||||
task fmt # gofmt + goimports (форматирование)
|
||||
task fmt:check # проверить форматирование (используется в CI)
|
||||
@@ -63,6 +63,7 @@ task clean # удалить dist/, cover.out, cover.html
|
||||
- [@cacggghp](https://github.com/cacggghp)
|
||||
- [@Moroka8](https://github.com/Moroka8)
|
||||
- [@alxmcp](https://github.com/alxmcp)
|
||||
- [@TheAirBlow](https://github.com/TheAirBlow)
|
||||
|
||||
---
|
||||
|
||||
|
||||
@@ -201,6 +201,7 @@ func buildProvider(cfg *config.Client, dialer net.Dialer, connected *atomic.Int3
|
||||
Dialer: dialer,
|
||||
ManualOnly: cfg.VK.ManualCaptcha,
|
||||
Browser: string(cfg.VK.Browser),
|
||||
Platform: string(cfg.VK.Platform),
|
||||
StreamsPerCache: cfg.VK.StreamsPerCred,
|
||||
StreamsAlive: connected.Load,
|
||||
Log: logger,
|
||||
|
||||
+3
-2
@@ -21,7 +21,8 @@
|
||||
| `-gen-obf-key` | `false` | напечатать новый ключ и выйти |
|
||||
| `-manual-captcha` | `false` | сразу ручной режим captcha (только `-provider vk`) |
|
||||
| `-streams-per-cred` | `10` | потоков на один кеш VK-учёток (только `-provider vk`) |
|
||||
| `-browser` | `firefox` | браузерный профиль VK-auth (UA + TLS JA3 + client hints): `chrome` \| `firefox` \| `safari` (только `-provider vk`) |
|
||||
| `-browser` | `firefox` | семейство персоны VK-auth (UA + TLS JA3 + client hints): `chrome` \| `firefox` \| `safari` (только `-provider vk`) |
|
||||
| `-platform` | `desktop` | класс устройства персоны VK-auth (мобильность UA/device/client hints): `desktop` \| `mobile` (только `-provider vk`) |
|
||||
| `-dns-mode` | `auto` | `plain` (UDP/53) \| `doh` \| `auto` |
|
||||
| `-dns-servers` | пусто | свои UDP/53 резолверы, `ip[:port][,ip[:port]...]` |
|
||||
| `-client-id` | авто | уникальный ID клиента (автогенерация если не задан) |
|
||||
@@ -45,7 +46,7 @@
|
||||
## Управление Client ID (Команды Сервера)
|
||||
|
||||
> [!NOTE]
|
||||
> **Про авторизацию:** клиент **всегда** отправляет свой Client ID первой записью после DTLS-handshake, сервер **всегда** его читает — wire-контракт симметричен. Флаг `-clients-file` на сервере включает **проверку** ID по allowlist (`clients.json`). Без `-clients-file` ID читается и игнорируется.
|
||||
> **Про авторизацию:** клиент **всегда** отправляет свой Client ID первой записью после DTLS-handshake, сервер **всегда** его читает - wire-контракт симметричен. Флаг `-clients-file` на сервере включает **проверку** ID по allowlist (`clients.json`). Без `-clients-file` ID читается и игнорируется.
|
||||
|
||||
Сервер содержит встроенные команды для управления файлом `clients.json` (горячая перезагрузка поддерживается автоматически, перезапускать сервер после изменений не нужно).
|
||||
|
||||
|
||||
+10
-10
@@ -17,13 +17,13 @@
|
||||
./client -listen 127.0.0.1:9000 -peer <vps>:56000 -link "<vk-link>" -mode tcp
|
||||
```
|
||||
|
||||
**Bonding** — распределение одного TCP-соединения по всем активным smux-сессиям, флаг только клиентский:
|
||||
**Bonding** - распределение одного TCP-соединения по всем активным smux-сессиям, флаг только клиентский:
|
||||
|
||||
```bash
|
||||
./client -listen 127.0.0.1:9000 -peer <vps>:56000 -link "<vk-link>" -mode tcp -bond -n 4
|
||||
```
|
||||
|
||||
Серверного `-bond` нет — сервер автоопределяет bond по magic-префиксу в стриме.
|
||||
Серверного `-bond` нет - сервер автоопределяет bond по magic-префиксу в стриме.
|
||||
|
||||
## OBF (wire-профили обфускации)
|
||||
|
||||
@@ -59,30 +59,30 @@
|
||||
```
|
||||
|
||||
> [!WARNING]
|
||||
> Транспорт UDP часто режется или блокируется системами DPI (особенно на мобильных операторах). Если у вас нестабильная связь — используйте стандартный TCP/TLS (просто не указывайте этот флаг).
|
||||
> Транспорт UDP часто режется или блокируется системами DPI (особенно на мобильных операторах). Если у вас нестабильная связь - используйте стандартный TCP/TLS (просто не указывайте этот флаг).
|
||||
|
||||
## Потоки и Лимиты (-n)
|
||||
|
||||
Параметр `-n` задает количество параллельных потоков к TURN-серверу (по умолчанию 10).
|
||||
Увеличение потоков может помочь поднять скорость или улучшить стабильность, **но не стоит этим злоупотреблять**. Слишком высокое значение (например, больше 15-20) повышает риск получения бана со стороны VK. Практика показывает, что значений от `6` до `12` зачастую достаточно для комфортной работы.
|
||||
То же самое касается параметра `-streams-per-cred` — используйте разумные значения.
|
||||
То же самое касается параметра `-streams-per-cred` - используйте разумные значения.
|
||||
|
||||
## Captcha
|
||||
|
||||
Клиент сам проходит VK captcha. Если автоматика не справилась — открывается локальный браузер. Принудительно ручной:
|
||||
Клиент сам проходит VK captcha. Если автоматика не справилась - открывается локальный браузер. Принудительно ручной:
|
||||
|
||||
```bash
|
||||
./client -manual-captcha ...
|
||||
```
|
||||
|
||||
Профиль браузера: `vk_profile.json` рядом с бинарником.
|
||||
Персона auth-запросов (UA + TLS JA3 + client hints + device) задаётся флагами `-browser` (семейство) и `-platform` (desktop/mobile); значения самосогласованы, без внешнего состояния.
|
||||
|
||||
## DNS
|
||||
|
||||
Флаг `-dns-mode` управляет транспортом резолвера самого клиента (VK API, токены, captcha) — не DNS-маршрутизацией пользовательского трафика.
|
||||
Флаг `-dns-mode` управляет транспортом резолвера самого клиента (VK API, токены, captcha) - не DNS-маршрутизацией пользовательского трафика.
|
||||
|
||||
- `plain` — только UDP/53;
|
||||
- `doh` — только DNS-over-HTTPS (Yandex DoH);
|
||||
- `auto` (дефолт) — сначала UDP/53, sticky-fallback на DoH при полном отказе.
|
||||
- `plain` - только UDP/53;
|
||||
- `doh` - только DNS-over-HTTPS (Yandex DoH);
|
||||
- `auto` (дефолт) - сначала UDP/53, sticky-fallback на DoH при полном отказе.
|
||||
|
||||
Свои UDP/53 резолверы: `-dns-servers ip[:port][,ip[:port]...]`.
|
||||
|
||||
+5
-3
@@ -9,8 +9,10 @@
|
||||
VK Calls API. Перебирает встроенные `app_id/app_secret`, получает короткоживущие (≈10 мин) TURN-creds через 4-шаговый token chain. Solver captcha auto+manual.
|
||||
|
||||
**Обязательные флаги:**
|
||||
- `-link` — VK callroom URL вида `https://vk.ru/call/join/<code>` (нормализуется до join-кода).
|
||||
- `-link` - VK callroom URL вида `https://vk.ru/call/join/<code>` (нормализуется до join-кода).
|
||||
|
||||
**Опциональные:**
|
||||
- `-streams-per-cred` (default 10) — сколько TURN-стримов делят один кеш креденшалов.
|
||||
- `-manual-captcha` — пропустить auto-solver, сразу открыть браузер.
|
||||
- `-streams-per-cred` (default 10) - сколько TURN-стримов делят один кеш креденшалов.
|
||||
- `-manual-captcha` - пропустить auto-solver, сразу открыть браузер.
|
||||
- `-browser` (default `firefox`) - семейство персоны auth (UA + TLS JA3 + client hints + device): `chrome` \| `firefox` \| `safari`.
|
||||
- `-platform` (default `desktop`) - класс устройства персоны: `desktop` \| `mobile`.
|
||||
@@ -2,7 +2,7 @@
|
||||
|
||||
- **Сначала запускайте client, потом включайте WireGuard / Xray.**
|
||||
- **Трафик не идет (нет интернета):** Проверьте серверный флаг `-connect`. В нем должен быть указан точный локальный порт, на котором слушает ваш VPN (например, `51820` для WG или `443` для VLESS). Если порт не совпадает, прокси будет стучаться в пустоту.
|
||||
- **WireGuard забирает весь трафик:** пайп с `-debug 2>&1` и скриптом маршрутов обязателен (`scripts/routes.sh` / `scripts/routes.ps1` / `scripts/routes-macos.sh`). Маршруты не добавляются → убедитесь, что в команде есть пайп перед скриптом.
|
||||
- **WireGuard забирает весь трафик:** пайп с `-debug 2>&1` и скриптом маршрутов обязателен (`scripts/routes.sh` / `scripts/routes.ps1` / `scripts/routes-macos.sh`). Маршруты не добавляются -> убедитесь, что в команде есть пайп перед скриптом.
|
||||
- **DPI блокирует UDP:** Если используете `-transport udp` и ничего не работает, попробуйте убрать флаг (использовать TCP по умолчанию).
|
||||
- **Обход шейпинга (кастомный TURN):** Если вы знаете "чистый" IP-адрес TURN-сервера VK, где нет агрессивного шейпинга, вы можете передать его вручную: `-turn <ip_address> -port <port>`. Это перезапишет данные, полученные из ссылки.
|
||||
- **Проблемы с DNS на мобильном интернете:** Резолв ломается. Передайте DNS вашего провайдера явно: `-dns-servers <ip_dns>`.
|
||||
|
||||
@@ -1,6 +1,6 @@
|
||||
module github.com/samosvalishe/free-turn-proxy
|
||||
|
||||
go 1.26.4
|
||||
go 1.26.5
|
||||
|
||||
require (
|
||||
github.com/bogdanfinn/fhttp v0.6.8
|
||||
|
||||
@@ -21,6 +21,7 @@ import (
|
||||
"github.com/miekg/dns"
|
||||
|
||||
"github.com/samosvalishe/free-turn-proxy/internal/logx"
|
||||
"github.com/samosvalishe/free-turn-proxy/internal/netctl"
|
||||
|
||||
// встроенные Mozilla CA roots для CGO_ENABLED=0 сборок (Android).
|
||||
_ "golang.org/x/crypto/x509roots/fallback"
|
||||
@@ -98,7 +99,7 @@ func newBootstrapTransport(endpoints []DohEndpoint) *http.Transport {
|
||||
for _, ep := range endpoints {
|
||||
bootstrap[ep.Hostname] = ep.BootstrapIPs
|
||||
}
|
||||
dialer := &net.Dialer{Timeout: dohDialerTimeout, KeepAlive: dohDialerKeepAlive}
|
||||
dialer := &net.Dialer{Timeout: dohDialerTimeout, KeepAlive: dohDialerKeepAlive, Control: netctl.Apply}
|
||||
|
||||
return &http.Transport{
|
||||
MaxIdleConns: 8,
|
||||
@@ -440,6 +441,7 @@ func newAppDialer(dial dialFunc) net.Dialer {
|
||||
Timeout: appDialerTimeout,
|
||||
KeepAlive: appDialerKeepAlive,
|
||||
Resolver: &net.Resolver{PreferGo: true, Dial: dial},
|
||||
Control: netctl.Apply,
|
||||
}
|
||||
}
|
||||
|
||||
|
||||
@@ -87,12 +87,21 @@ const (
|
||||
BrowserSafari Browser = "safari"
|
||||
)
|
||||
|
||||
// Platform выбирает класс устройства персоны (мобильность UA/device/client hints).
|
||||
type Platform string
|
||||
|
||||
const (
|
||||
PlatformDesktop Platform = "desktop"
|
||||
PlatformMobile Platform = "mobile"
|
||||
)
|
||||
|
||||
// VKOpts - опции VK-учёток и captcha (только клиент, провайдер "vk").
|
||||
type VKOpts struct {
|
||||
Links []string // -links (нормализованные join-коды); несколько = больше стримов
|
||||
StreamsPerCred int // -streams-per-cred
|
||||
ManualCaptcha bool // -manual-captcha
|
||||
Browser Browser // -browser: chrome | firefox | safari
|
||||
Platform Platform // -platform: desktop | mobile
|
||||
}
|
||||
|
||||
// ProviderOpts выбирает реализацию provider.Provider.
|
||||
@@ -192,6 +201,7 @@ func ParseClient(args []string, errOut io.Writer) (*Client, error) {
|
||||
debug := fs.Bool("debug", false, "подробные debug-логи")
|
||||
manualCaptcha := fs.Bool("manual-captcha", false, "ручная VK captcha в браузере вместо авто; только -provider vk")
|
||||
browser := fs.String("browser", string(BrowserFirefox), "браузерный профиль VK-auth: chrome | firefox | safari; только -provider vk")
|
||||
platform := fs.String("platform", string(PlatformDesktop), "класс устройства персоны VK-auth: desktop | mobile; только -provider vk")
|
||||
dnsMode := fs.String("dns-mode", dnsModeAuto, "резолвер клиента: plain | doh | auto")
|
||||
dnsServers := fs.String("dns-servers", "", "свои UDP/53 DNS через запятую: ip[:port][,ip[:port]...]")
|
||||
clientID := fs.String("client-id", "", "уникальный ID клиента (автогенерация если не задан)")
|
||||
@@ -225,6 +235,7 @@ func ParseClient(args []string, errOut io.Writer) (*Client, error) {
|
||||
StreamsPerCred: *streamsPerCred,
|
||||
ManualCaptcha: *manualCaptcha,
|
||||
Browser: Browser(*browser),
|
||||
Platform: Platform(*platform),
|
||||
},
|
||||
DNS: DNSOpts{
|
||||
Mode: *dnsMode,
|
||||
@@ -339,6 +350,14 @@ func ParseClient(args []string, errOut io.Writer) (*Client, error) {
|
||||
default:
|
||||
return nil, fmt.Errorf("invalid -browser value %q: must be %s | %s | %s", c.VK.Browser, BrowserChrome, BrowserFirefox, BrowserSafari)
|
||||
}
|
||||
if c.VK.Platform == "" {
|
||||
c.VK.Platform = PlatformDesktop
|
||||
}
|
||||
switch c.VK.Platform {
|
||||
case PlatformDesktop, PlatformMobile:
|
||||
default:
|
||||
return nil, fmt.Errorf("invalid -platform value %q: must be %s | %s", c.VK.Platform, PlatformDesktop, PlatformMobile)
|
||||
}
|
||||
rawLinks := strings.Split(*links, ",")
|
||||
if len(rawLinks) == 1 && rawLinks[0] == "" {
|
||||
// -links не задан, используем -link (backward compat)
|
||||
|
||||
@@ -134,6 +134,35 @@ func TestParseClient_BrowserInvalid(t *testing.T) {
|
||||
}
|
||||
}
|
||||
|
||||
func TestParseClient_PlatformDefaultDesktop(t *testing.T) {
|
||||
c, err := ParseClient(validClientArgs(), io.Discard)
|
||||
if err != nil {
|
||||
t.Fatal(err)
|
||||
}
|
||||
if c.VK.Platform != PlatformDesktop {
|
||||
t.Errorf("VK.Platform = %q, want %q", c.VK.Platform, PlatformDesktop)
|
||||
}
|
||||
}
|
||||
|
||||
func TestParseClient_PlatformMobile(t *testing.T) {
|
||||
args := append(validClientArgs(), "-platform", "mobile")
|
||||
c, err := ParseClient(args, io.Discard)
|
||||
if err != nil {
|
||||
t.Fatal(err)
|
||||
}
|
||||
if c.VK.Platform != PlatformMobile {
|
||||
t.Errorf("VK.Platform = %q, want %q", c.VK.Platform, PlatformMobile)
|
||||
}
|
||||
}
|
||||
|
||||
func TestParseClient_PlatformInvalid(t *testing.T) {
|
||||
args := append(validClientArgs(), "-platform", "tablet")
|
||||
_, err := ParseClient(args, io.Discard)
|
||||
if err == nil || !strings.Contains(err.Error(), "invalid -platform") {
|
||||
t.Errorf("expected platform error, got %v", err)
|
||||
}
|
||||
}
|
||||
|
||||
func TestParseClient_BondWithoutTCPMode(t *testing.T) {
|
||||
args := append(validClientArgs(), "-bond")
|
||||
_, err := ParseClient(args, io.Discard)
|
||||
|
||||
+69
-10
@@ -12,6 +12,7 @@ import (
|
||||
"time"
|
||||
|
||||
"github.com/pion/transport/v4"
|
||||
"github.com/samosvalishe/free-turn-proxy/internal/netctl"
|
||||
)
|
||||
|
||||
// DirectNet реализует transport.Net через стандартный net.
|
||||
@@ -34,32 +35,84 @@ type directTCPListener struct {
|
||||
*net.TCPListener
|
||||
}
|
||||
|
||||
// All socket-creating methods route through a net.Dialer / net.ListenConfig
|
||||
// carrying netctl.Apply as Control so the host can protect each fd from the
|
||||
// VPN tunnel. (net.DialUDP / net.ListenUDP take no Control, so we go via
|
||||
// Dialer/ListenConfig and type-assert back to the concrete UDP/TCP conn.)
|
||||
func (DirectNet) ListenPacket(network string, address string) (net.PacketConn, error) {
|
||||
return net.ListenPacket(network, address) //nolint:noctx
|
||||
return (&net.ListenConfig{Control: netctl.Apply}).ListenPacket(context.Background(), network, address)
|
||||
}
|
||||
|
||||
func (DirectNet) ListenUDP(network string, locAddr *net.UDPAddr) (transport.UDPConn, error) {
|
||||
return net.ListenUDP(network, locAddr)
|
||||
}
|
||||
|
||||
func (DirectNet) ListenTCP(network string, laddr *net.TCPAddr) (transport.TCPListener, error) {
|
||||
listener, err := net.ListenTCP(network, laddr)
|
||||
addr := ""
|
||||
if locAddr != nil {
|
||||
addr = locAddr.String()
|
||||
}
|
||||
pc, err := (&net.ListenConfig{Control: netctl.Apply}).ListenPacket(context.Background(), network, addr)
|
||||
if err != nil {
|
||||
return nil, err
|
||||
}
|
||||
return directTCPListener{listener}, nil
|
||||
udp, ok := pc.(*net.UDPConn)
|
||||
if !ok {
|
||||
_ = pc.Close()
|
||||
return nil, fmt.Errorf("netconn: expected *net.UDPConn, got %T", pc)
|
||||
}
|
||||
return udp, nil
|
||||
}
|
||||
|
||||
func (DirectNet) ListenTCP(network string, laddr *net.TCPAddr) (transport.TCPListener, error) {
|
||||
addr := ""
|
||||
if laddr != nil {
|
||||
addr = laddr.String()
|
||||
}
|
||||
l, err := (&net.ListenConfig{Control: netctl.Apply}).Listen(context.Background(), network, addr)
|
||||
if err != nil {
|
||||
return nil, err
|
||||
}
|
||||
tl, ok := l.(*net.TCPListener)
|
||||
if !ok {
|
||||
_ = l.Close()
|
||||
return nil, fmt.Errorf("netconn: expected *net.TCPListener, got %T", l)
|
||||
}
|
||||
return directTCPListener{tl}, nil
|
||||
}
|
||||
|
||||
func (DirectNet) Dial(network, address string) (net.Conn, error) {
|
||||
return net.Dial(network, address) //nolint:noctx
|
||||
return (&net.Dialer{Control: netctl.Apply}).Dial(network, address)
|
||||
}
|
||||
|
||||
func (DirectNet) DialUDP(network string, laddr, raddr *net.UDPAddr) (transport.UDPConn, error) {
|
||||
return net.DialUDP(network, laddr, raddr)
|
||||
d := &net.Dialer{Control: netctl.Apply}
|
||||
if laddr != nil {
|
||||
d.LocalAddr = laddr
|
||||
}
|
||||
c, err := d.Dial(network, raddr.String())
|
||||
if err != nil {
|
||||
return nil, err
|
||||
}
|
||||
udp, ok := c.(*net.UDPConn)
|
||||
if !ok {
|
||||
_ = c.Close()
|
||||
return nil, fmt.Errorf("netconn: expected *net.UDPConn, got %T", c)
|
||||
}
|
||||
return udp, nil
|
||||
}
|
||||
|
||||
func (DirectNet) DialTCP(network string, laddr, raddr *net.TCPAddr) (transport.TCPConn, error) {
|
||||
return net.DialTCP(network, laddr, raddr)
|
||||
d := &net.Dialer{Control: netctl.Apply}
|
||||
if laddr != nil {
|
||||
d.LocalAddr = laddr
|
||||
}
|
||||
c, err := d.Dial(network, raddr.String())
|
||||
if err != nil {
|
||||
return nil, err
|
||||
}
|
||||
tcp, ok := c.(*net.TCPConn)
|
||||
if !ok {
|
||||
_ = c.Close()
|
||||
return nil, fmt.Errorf("netconn: expected *net.TCPConn, got %T", c)
|
||||
}
|
||||
return tcp, nil
|
||||
}
|
||||
|
||||
func (DirectNet) ResolveIPAddr(network, address string) (*net.IPAddr, error) {
|
||||
@@ -87,10 +140,16 @@ func (DirectNet) InterfaceByName(name string) (*transport.Interface, error) {
|
||||
}
|
||||
|
||||
func (DirectNet) CreateDialer(dialer *net.Dialer) transport.Dialer {
|
||||
if dialer.Control == nil {
|
||||
dialer.Control = netctl.Apply
|
||||
}
|
||||
return directDialer{Dialer: dialer}
|
||||
}
|
||||
|
||||
func (DirectNet) CreateListenConfig(listenerConfig *net.ListenConfig) transport.ListenConfig {
|
||||
if listenerConfig.Control == nil {
|
||||
listenerConfig.Control = netctl.Apply
|
||||
}
|
||||
return directListenConfig{ListenConfig: listenerConfig}
|
||||
}
|
||||
|
||||
|
||||
@@ -0,0 +1,28 @@
|
||||
// Package netctl carries a process-global socket Control hook applied to every
|
||||
// OUTBOUND socket the vendored free-turn client opens. The host installs it so
|
||||
// those sockets are excluded from the VPN tunnel (Android VpnService.protect on
|
||||
// the raw fd) — without it the client's own TURN/VK/DNS traffic loops back into
|
||||
// the tunnel and hangs. This patch is local to our vendored copy: upstream has
|
||||
// no such hook, and the dialers it creates (netconn.DirectNet, dnsdial,
|
||||
// turndial) are routed through Apply below.
|
||||
package netctl
|
||||
|
||||
import "syscall"
|
||||
|
||||
var control func(network, address string, c syscall.RawConn) error
|
||||
|
||||
// SetControl installs the per-socket protector. Call before the client starts.
|
||||
// nil (the default) makes Apply a no-op, so desktop builds are unaffected.
|
||||
func SetControl(fn func(network, address string, c syscall.RawConn) error) {
|
||||
control = fn
|
||||
}
|
||||
|
||||
// Apply is assigned as the Control func of every outbound net.Dialer /
|
||||
// net.ListenConfig in the vendored client. It reads `control` at dial time so
|
||||
// the host may register the protector before or after the client starts.
|
||||
func Apply(network, address string, c syscall.RawConn) error {
|
||||
if control != nil {
|
||||
return control(network, address, c)
|
||||
}
|
||||
return nil
|
||||
}
|
||||
@@ -1,14 +1,10 @@
|
||||
package browserprofile
|
||||
|
||||
import (
|
||||
"encoding/json"
|
||||
"os"
|
||||
"strings"
|
||||
|
||||
fhttp "github.com/bogdanfinn/fhttp"
|
||||
"github.com/bogdanfinn/tls-client/profiles"
|
||||
)
|
||||
|
||||
// Kind - семейство браузера.
|
||||
type Kind string
|
||||
|
||||
const (
|
||||
@@ -17,8 +13,15 @@ const (
|
||||
Safari Kind = "safari"
|
||||
)
|
||||
|
||||
// KindFromString мапит строку флага -browser в Kind. Пустое/неизвестное -
|
||||
// Firefox (текущий дефолт продукта).
|
||||
type Platform string
|
||||
|
||||
const (
|
||||
Desktop Platform = "desktop"
|
||||
Mobile Platform = "mobile"
|
||||
)
|
||||
|
||||
// KindFromString мапит строку флага -browser в Kind. Пустое/неизвестное - Firefox
|
||||
// (дефолт продукта).
|
||||
func KindFromString(s string) Kind {
|
||||
switch s {
|
||||
case string(Chrome):
|
||||
@@ -29,95 +32,139 @@ func KindFromString(s string) Kind {
|
||||
return Firefox
|
||||
}
|
||||
|
||||
// PlatformFromString мапит строку флага -platform в Platform. Пустое/неизвестное -
|
||||
// Desktop.
|
||||
func PlatformFromString(s string) Platform {
|
||||
if s == string(Mobile) {
|
||||
return Mobile
|
||||
}
|
||||
return Desktop
|
||||
}
|
||||
|
||||
// Profile - самосогласованная браузерная личность: единственный источник UA,
|
||||
// client hints, device-fingerprint и accept-language для VK control-plane и captcha.
|
||||
// Строится один раз из (Family, Platform); не мутируется в рантайме.
|
||||
type Profile struct {
|
||||
Family Kind
|
||||
Platform Platform
|
||||
UserAgent string
|
||||
SecChUa string // пусто для non-Chromium профилей (Chromium-only client hint)
|
||||
SecChUa string // пусто для не-Chromium (Chromium-only client hint)
|
||||
SecChUaMobile string
|
||||
SecChUaPlatform string
|
||||
AcceptLanguage string
|
||||
// DeviceJSON - navigator/screen fingerprint для captcha componentDone.
|
||||
// Согласован с Family/Platform (Chromium-only поля есть только у Chrome).
|
||||
DeviceJSON string
|
||||
}
|
||||
|
||||
// ForKind возвращает канонический профиль для браузера.
|
||||
func ForKind(k Kind) Profile {
|
||||
const (
|
||||
deviceChromeDesktop = `{"screenWidth":1920,"screenHeight":1080,"screenAvailWidth":1920,"screenAvailHeight":1032,"innerWidth":1147,"innerHeight":945,"devicePixelRatio":1,"language":"ru-RU","languages":["ru-RU"],"webdriver":false,"hardwareConcurrency":8,"deviceMemory":16,"connectionEffectiveType":"4g","notificationsPermission":"denied"}`
|
||||
deviceChromeMobile = `{"screenWidth":393,"screenHeight":852,"screenAvailWidth":393,"screenAvailHeight":852,"innerWidth":393,"innerHeight":659,"devicePixelRatio":3,"language":"ru-RU","languages":["ru-RU"],"webdriver":false,"hardwareConcurrency":8,"deviceMemory":8,"connectionEffectiveType":"4g","notificationsPermission":"denied"}`
|
||||
deviceFirefoxDesktop = `{"screenWidth":1920,"screenHeight":1080,"screenAvailWidth":1920,"screenAvailHeight":1032,"innerWidth":1147,"innerHeight":945,"devicePixelRatio":1,"language":"ru-RU","languages":["ru-RU","ru"],"webdriver":false,"hardwareConcurrency":8,"notificationsPermission":"denied"}`
|
||||
deviceFirefoxMobile = `{"screenWidth":393,"screenHeight":852,"screenAvailWidth":393,"screenAvailHeight":852,"innerWidth":393,"innerHeight":659,"devicePixelRatio":3,"language":"ru-RU","languages":["ru-RU","ru"],"webdriver":false,"hardwareConcurrency":8,"notificationsPermission":"denied"}`
|
||||
deviceSafariDesktop = `{"screenWidth":1512,"screenHeight":982,"screenAvailWidth":1512,"screenAvailHeight":944,"innerWidth":1147,"innerHeight":870,"devicePixelRatio":2,"language":"ru-RU","languages":["ru-RU"],"webdriver":false,"hardwareConcurrency":8,"notificationsPermission":"denied"}`
|
||||
deviceSafariMobile = `{"screenWidth":393,"screenHeight":852,"screenAvailWidth":393,"screenAvailHeight":852,"innerWidth":393,"innerHeight":659,"devicePixelRatio":3,"language":"ru-RU","languages":["ru-RU"],"webdriver":false,"hardwareConcurrency":4,"notificationsPermission":"denied"}`
|
||||
)
|
||||
|
||||
// For строит канонический профиль для (family, platform). Неизвестный family -> Chrome.
|
||||
func For(k Kind, p Platform) Profile {
|
||||
if p != Mobile {
|
||||
p = Desktop
|
||||
}
|
||||
switch k {
|
||||
case Safari:
|
||||
return Profile{
|
||||
UserAgent: "Mozilla/5.0 (Macintosh; Intel Mac OS X 10_15_7) AppleWebKit/605.1.15 (KHTML, like Gecko) Version/16.0 Safari/605.1.15",
|
||||
AcceptLanguage: "ru-RU,ru;q=0.9",
|
||||
}
|
||||
return safariProfile(p)
|
||||
case Firefox:
|
||||
return firefoxProfile(p)
|
||||
default:
|
||||
return chromeProfile(p)
|
||||
}
|
||||
}
|
||||
|
||||
func chromeProfile(p Platform) Profile {
|
||||
if p == Mobile {
|
||||
return Profile{
|
||||
UserAgent: "Mozilla/5.0 (Windows NT 10.0; Win64; x64; rv:148.0) Gecko/20100101 Firefox/148.0",
|
||||
AcceptLanguage: "ru-RU,ru;q=0.9",
|
||||
Family: Chrome,
|
||||
Platform: Mobile,
|
||||
UserAgent: "Mozilla/5.0 (Linux; Android 10; K) AppleWebKit/537.36 (KHTML, like Gecko) Chrome/146.0.0.0 Mobile Safari/537.36",
|
||||
SecChUa: `"Google Chrome";v="146", "Chromium";v="146", "Not)A;Brand";v="24"`,
|
||||
SecChUaMobile: "?1",
|
||||
SecChUaPlatform: `"Android"`,
|
||||
AcceptLanguage: "ru-RU,ru;q=0.9",
|
||||
DeviceJSON: deviceChromeMobile,
|
||||
}
|
||||
}
|
||||
return Profile{
|
||||
Family: Chrome,
|
||||
Platform: Desktop,
|
||||
UserAgent: "Mozilla/5.0 (Windows NT 10.0; Win64; x64) AppleWebKit/537.36 (KHTML, like Gecko) Chrome/146.0.0.0 Safari/537.36",
|
||||
SecChUa: `"Google Chrome";v="146", "Chromium";v="146", "Not)A;Brand";v="24"`,
|
||||
SecChUaMobile: "?0",
|
||||
SecChUaPlatform: `"Windows"`,
|
||||
AcceptLanguage: "ru-RU,ru;q=0.9",
|
||||
DeviceJSON: deviceChromeDesktop,
|
||||
}
|
||||
}
|
||||
|
||||
func Family(p Profile) Kind {
|
||||
ua := strings.ToLower(p.UserAgent)
|
||||
switch {
|
||||
case strings.Contains(ua, "firefox/"):
|
||||
return Firefox
|
||||
case strings.Contains(ua, "version/") && strings.Contains(ua, "safari/") && !strings.Contains(ua, "chrome/") && !strings.Contains(ua, "chromium/"):
|
||||
return Safari
|
||||
case strings.Contains(ua, "chrome/") || strings.Contains(ua, "chromium/"):
|
||||
return Chrome
|
||||
func firefoxProfile(p Platform) Profile {
|
||||
if p == Mobile {
|
||||
return Profile{
|
||||
Family: Firefox,
|
||||
Platform: Mobile,
|
||||
UserAgent: "Mozilla/5.0 (Android 14; Mobile; rv:148.0) Gecko/148.0 Firefox/148.0",
|
||||
AcceptLanguage: "ru-RU,ru;q=0.9",
|
||||
DeviceJSON: deviceFirefoxMobile,
|
||||
}
|
||||
}
|
||||
return Profile{
|
||||
Family: Firefox,
|
||||
Platform: Desktop,
|
||||
UserAgent: "Mozilla/5.0 (Windows NT 10.0; Win64; x64; rv:148.0) Gecko/20100101 Firefox/148.0",
|
||||
AcceptLanguage: "ru-RU,ru;q=0.9",
|
||||
DeviceJSON: deviceFirefoxDesktop,
|
||||
}
|
||||
}
|
||||
|
||||
func safariProfile(p Platform) Profile {
|
||||
if p == Mobile {
|
||||
return Profile{
|
||||
Family: Safari,
|
||||
Platform: Mobile,
|
||||
UserAgent: "Mozilla/5.0 (iPhone; CPU iPhone OS 17_0 like Mac OS X) AppleWebKit/605.1.15 (KHTML, like Gecko) Version/17.0 Mobile/15E148 Safari/604.1",
|
||||
AcceptLanguage: "ru-RU,ru;q=0.9",
|
||||
DeviceJSON: deviceSafariMobile,
|
||||
}
|
||||
}
|
||||
return Profile{
|
||||
Family: Safari,
|
||||
Platform: Desktop,
|
||||
UserAgent: "Mozilla/5.0 (Macintosh; Intel Mac OS X 10_15_7) AppleWebKit/605.1.15 (KHTML, like Gecko) Version/16.0 Safari/605.1.15",
|
||||
AcceptLanguage: "ru-RU,ru;q=0.9",
|
||||
DeviceJSON: deviceSafariDesktop,
|
||||
}
|
||||
}
|
||||
|
||||
func Family(p Profile) Kind { return p.Family }
|
||||
|
||||
func IsMobile(p Profile) bool { return p.Platform == Mobile }
|
||||
|
||||
// ClientProfile - TLS/HTTP2-отпечаток персоны (JA3 + ALPN + h2 settings).
|
||||
// Chrome/Firefox используют один TLS-стек на всех платформах, поэтому platform на
|
||||
// них не влияет; Safari desktop и iOS различаются в ClientHello.
|
||||
func (p Profile) ClientProfile() profiles.ClientProfile {
|
||||
switch p.Family {
|
||||
case Safari:
|
||||
if p.Platform == Mobile {
|
||||
return profiles.Safari_IOS_17_0
|
||||
}
|
||||
return profiles.Safari_16_0
|
||||
case Firefox:
|
||||
return profiles.Firefox_148
|
||||
default:
|
||||
return ""
|
||||
return profiles.Chrome_146
|
||||
}
|
||||
}
|
||||
|
||||
func IsMobile(p Profile) bool {
|
||||
ua := strings.ToLower(p.UserAgent)
|
||||
return strings.Contains(ua, " mobile ") ||
|
||||
strings.Contains(ua, " mobile/") ||
|
||||
strings.Contains(ua, "android") ||
|
||||
strings.Contains(strings.ToLower(p.SecChUaMobile), "?1")
|
||||
}
|
||||
|
||||
type Saved struct {
|
||||
Profile
|
||||
DeviceJSON string
|
||||
BrowserFp string
|
||||
}
|
||||
|
||||
const profileFile = "vk_profile.json"
|
||||
|
||||
// profilePath возвращает путь к сохранённому профилю.
|
||||
func profilePath() string {
|
||||
if p := strings.TrimSpace(os.Getenv("VK_PROFILE_PATH")); p != "" {
|
||||
return p
|
||||
}
|
||||
return profileFile
|
||||
}
|
||||
|
||||
func Load() (*Saved, error) {
|
||||
data, err := os.ReadFile(profilePath())
|
||||
if err != nil {
|
||||
return nil, err
|
||||
}
|
||||
var sp Saved
|
||||
if err := json.Unmarshal(data, &sp); err != nil {
|
||||
return nil, err
|
||||
}
|
||||
return &sp, nil
|
||||
}
|
||||
|
||||
func Save(sp Saved) error {
|
||||
data, err := json.MarshalIndent(sp, "", " ")
|
||||
if err != nil {
|
||||
return err
|
||||
}
|
||||
return os.WriteFile(profilePath(), data, 0600)
|
||||
}
|
||||
|
||||
func ApplyFhttp(req *fhttp.Request, profile Profile) {
|
||||
req.Header.Set("User-Agent", profile.UserAgent)
|
||||
if profile.SecChUa != "" {
|
||||
|
||||
@@ -1,11 +1,11 @@
|
||||
package browserprofile
|
||||
|
||||
import (
|
||||
"os"
|
||||
"path/filepath"
|
||||
"strings"
|
||||
"testing"
|
||||
|
||||
fhttp "github.com/bogdanfinn/fhttp"
|
||||
"github.com/bogdanfinn/tls-client/profiles"
|
||||
)
|
||||
|
||||
func TestKindFromString(t *testing.T) {
|
||||
@@ -26,29 +26,25 @@ func TestKindFromString(t *testing.T) {
|
||||
}
|
||||
}
|
||||
|
||||
func TestProfilePathHonorsEnv(t *testing.T) {
|
||||
path := filepath.Join(t.TempDir(), "vk_profile_chrome_42.json")
|
||||
t.Setenv("VK_PROFILE_PATH", path)
|
||||
|
||||
want := Saved{Profile: ForKind(Chrome), DeviceJSON: "{}", BrowserFp: "abc123"}
|
||||
if err := Save(want); err != nil {
|
||||
t.Fatal(err)
|
||||
func TestPlatformFromString(t *testing.T) {
|
||||
cases := []struct {
|
||||
in string
|
||||
want Platform
|
||||
}{
|
||||
{"mobile", Mobile},
|
||||
{"desktop", Desktop},
|
||||
{"", Desktop},
|
||||
{"unknown", Desktop},
|
||||
}
|
||||
if _, err := os.Stat(path); err != nil {
|
||||
t.Fatalf("profile not written to VK_PROFILE_PATH %s: %v", path, err)
|
||||
}
|
||||
|
||||
got, err := Load()
|
||||
if err != nil {
|
||||
t.Fatal(err)
|
||||
}
|
||||
if got.BrowserFp != want.BrowserFp || got.UserAgent != want.UserAgent {
|
||||
t.Fatalf("loaded = %+v, want fp=%s ua=%s", got, want.BrowserFp, want.UserAgent)
|
||||
for _, tc := range cases {
|
||||
if got := PlatformFromString(tc.in); got != tc.want {
|
||||
t.Fatalf("PlatformFromString(%q) = %q, want %q", tc.in, got, tc.want)
|
||||
}
|
||||
}
|
||||
}
|
||||
|
||||
func TestForKindChrome146(t *testing.T) {
|
||||
p := ForKind(Chrome)
|
||||
func TestForChromeDesktop146(t *testing.T) {
|
||||
p := For(Chrome, Desktop)
|
||||
if p.UserAgent != "Mozilla/5.0 (Windows NT 10.0; Win64; x64) AppleWebKit/537.36 (KHTML, like Gecko) Chrome/146.0.0.0 Safari/537.36" {
|
||||
t.Fatalf("unexpected chrome UA: %q", p.UserAgent)
|
||||
}
|
||||
@@ -63,35 +59,67 @@ func TestApplyFhttpOmitsClientHintsForFirefoxAndSafari(t *testing.T) {
|
||||
if err != nil {
|
||||
t.Fatal(err)
|
||||
}
|
||||
ApplyFhttp(req, ForKind(kind))
|
||||
ApplyFhttp(req, For(kind, Desktop))
|
||||
if req.Header.Get("sec-ch-ua") != "" {
|
||||
t.Fatalf("%s sec-ch-ua = %q, want empty", kind, req.Header.Get("sec-ch-ua"))
|
||||
}
|
||||
if req.Header.Get("DNT") != "" {
|
||||
t.Fatalf("%s DNT = %q, want empty", kind, req.Header.Get("DNT"))
|
||||
}
|
||||
}
|
||||
}
|
||||
|
||||
func TestFamily(t *testing.T) {
|
||||
func TestFamilyAndPlatformSet(t *testing.T) {
|
||||
for _, kind := range []Kind{Chrome, Firefox, Safari} {
|
||||
if got := Family(ForKind(kind)); got != kind {
|
||||
t.Fatalf("Family(%s profile) = %q, want %q", kind, got, kind)
|
||||
for _, plat := range []Platform{Desktop, Mobile} {
|
||||
p := For(kind, plat)
|
||||
if Family(p) != kind {
|
||||
t.Fatalf("Family(For(%s,%s)) = %q, want %q", kind, plat, Family(p), kind)
|
||||
}
|
||||
if IsMobile(p) != (plat == Mobile) {
|
||||
t.Fatalf("IsMobile(For(%s,%s)) = %v", kind, plat, IsMobile(p))
|
||||
}
|
||||
}
|
||||
}
|
||||
if got := Family(Profile{UserAgent: "curl/8.0"}); got != "" {
|
||||
t.Fatalf("Family(unknown) = %q, want empty", got)
|
||||
}
|
||||
}
|
||||
|
||||
func TestIsMobile(t *testing.T) {
|
||||
if IsMobile(ForKind(Chrome)) {
|
||||
t.Fatal("desktop chrome detected as mobile")
|
||||
// Персона обязана быть самосогласованной: мобильная платформа -> мобильный UA,
|
||||
// мобильный sec-ch-ua (для chromium) и непустой device для captcha.
|
||||
func TestPersonaSelfConsistent(t *testing.T) {
|
||||
for _, kind := range []Kind{Chrome, Firefox, Safari} {
|
||||
p := For(kind, Mobile)
|
||||
ua := strings.ToLower(p.UserAgent)
|
||||
if !strings.Contains(ua, "mobile") && !strings.Contains(ua, "iphone") && !strings.Contains(ua, "android") {
|
||||
t.Fatalf("%s mobile UA not mobile: %q", kind, p.UserAgent)
|
||||
}
|
||||
if p.DeviceJSON == "" {
|
||||
t.Fatalf("%s mobile persona has empty DeviceJSON", kind)
|
||||
}
|
||||
if kind == Chrome && p.SecChUaMobile != "?1" {
|
||||
t.Fatalf("chrome mobile sec-ch-ua-mobile = %q, want ?1", p.SecChUaMobile)
|
||||
}
|
||||
}
|
||||
if !IsMobile(Profile{UserAgent: "Mozilla/5.0 (Linux; Android 14; Pixel 8) AppleWebKit/537.36 (KHTML, like Gecko) Chrome/149.0.0.0 Mobile Safari/537.36"}) {
|
||||
t.Fatal("android chrome was not detected as mobile")
|
||||
}
|
||||
if !IsMobile(Profile{UserAgent: ForKind(Chrome).UserAgent, SecChUaMobile: "?1"}) {
|
||||
t.Fatal("sec-ch-ua-mobile ?1 was not detected as mobile")
|
||||
if For(Chrome, Desktop).SecChUaMobile != "?0" {
|
||||
t.Fatalf("chrome desktop sec-ch-ua-mobile != ?0")
|
||||
}
|
||||
}
|
||||
|
||||
// TLS-отпечаток - часть персоны: Safari desktop/iOS различаются, Chrome/Firefox
|
||||
// одинаковы на всех платформах (один TLS-стек).
|
||||
func TestClientProfilePlatformAware(t *testing.T) {
|
||||
cases := []struct {
|
||||
family Kind
|
||||
plat Platform
|
||||
want profiles.ClientProfile
|
||||
}{
|
||||
{Safari, Desktop, profiles.Safari_16_0},
|
||||
{Safari, Mobile, profiles.Safari_IOS_17_0},
|
||||
{Chrome, Desktop, profiles.Chrome_146},
|
||||
{Chrome, Mobile, profiles.Chrome_146},
|
||||
{Firefox, Desktop, profiles.Firefox_148},
|
||||
{Firefox, Mobile, profiles.Firefox_148},
|
||||
}
|
||||
for _, tc := range cases {
|
||||
got := For(tc.family, tc.plat).ClientProfile()
|
||||
if got.GetClientHelloStr() != tc.want.GetClientHelloStr() {
|
||||
t.Fatalf("For(%s,%s).ClientProfile() = %s, want %s", tc.family, tc.plat, got.GetClientHelloStr(), tc.want.GetClientHelloStr())
|
||||
}
|
||||
}
|
||||
}
|
||||
|
||||
@@ -28,35 +28,32 @@ import (
|
||||
"github.com/samosvalishe/free-turn-proxy/internal/randx"
|
||||
)
|
||||
|
||||
// Log - пакетный логгер.
|
||||
var Log logx.Logger = logx.Nop()
|
||||
|
||||
// SetLogger ставит логгер пакета.
|
||||
func SetLogger(l logx.Logger) { Log = logx.OrNop(l) }
|
||||
|
||||
const (
|
||||
captchaAPIVersion = "5.131"
|
||||
captchaScriptVersion = "1.1.1370"
|
||||
captchaAPIOrigin = "https://id.vk.ru"
|
||||
captchaDomain = "vk.ru"
|
||||
captchaDeviceInfo = `{"screenWidth":1920,"screenHeight":1080,"screenAvailWidth":1920,"screenAvailHeight":1032,"innerWidth":1147,"innerHeight":945,"devicePixelRatio":1,"language":"ru-RU","languages":["ru-RU"],"webdriver":false,"hardwareConcurrency":8,"deviceMemory":16,"connectionEffectiveType":"4g","notificationsPermission":"denied"}`
|
||||
captchaConnectionSamples = 4
|
||||
)
|
||||
|
||||
var (
|
||||
reCaptchaPowInput = regexp.MustCompile(`const\s+powInput\s*=\s*"([^"]+)"`)
|
||||
reCaptchaDifficulty = regexp.MustCompile(`const\s+difficulty\s*=\s*(\d+)`)
|
||||
reCaptchaWindowInit = regexp.MustCompile(`(?s)window\.init\s*=\s*(\{.*?})\s*;`)
|
||||
reCaptchaScriptSrc = regexp.MustCompile(`src="(https://[^"]+not_robot_captcha[^"]+)"`)
|
||||
reCaptchaDebugInfo = regexp.MustCompile(`debug_info:(?:[^"]*\|\|)?"([a-fA-F0-9]{64})"`)
|
||||
reCaptchaVersion = regexp.MustCompile(`vkid/([0-9.]*)/not_robot_captcha\.js`)
|
||||
|
||||
errCaptchaRateLimit = errors.New("captcha session rate limit reached")
|
||||
errCaptchaBot = errors.New("captcha bot challenge")
|
||||
|
||||
captchaMaxAttempts = 2
|
||||
|
||||
captchaDebugCache sync.Map // scriptURL -> string
|
||||
// debugInfoCache кэширует 64-hex debug_info по URL JS-бандла (константа виджета,
|
||||
// одна на всех).
|
||||
debugInfoCache sync.Map
|
||||
|
||||
captchaHeaderOrder = []string{
|
||||
"host",
|
||||
"content-length",
|
||||
@@ -78,15 +75,6 @@ var (
|
||||
captchaPHeaderOrder = []string{":method", ":path", ":authority", ":scheme"}
|
||||
)
|
||||
|
||||
type captchaInit struct {
|
||||
Data captchaInitData `json:"data"`
|
||||
}
|
||||
|
||||
type captchaInitData struct {
|
||||
ShowCaptchaType string `json:"show_captcha_type"`
|
||||
CaptchaSettings []captchaInitSetting `json:"captcha_settings"`
|
||||
}
|
||||
|
||||
type captchaInitSetting struct {
|
||||
Type string `json:"type"`
|
||||
Settings string `json:"settings"`
|
||||
@@ -97,7 +85,6 @@ type captchaPage struct {
|
||||
PowInput string
|
||||
PowDifficulty int
|
||||
ScriptURL string
|
||||
Init *captchaInit
|
||||
}
|
||||
|
||||
type captchaCheck struct {
|
||||
@@ -115,12 +102,11 @@ func (e *captchaShowTypeError) Error() string {
|
||||
}
|
||||
|
||||
type captchaSession struct {
|
||||
ctx context.Context
|
||||
client tlsclient.HttpClient
|
||||
profile browserprofile.Profile
|
||||
savedProfile *browserprofile.Saved
|
||||
domain string
|
||||
log logx.Logger
|
||||
ctx context.Context
|
||||
client tlsclient.HttpClient
|
||||
profile browserprofile.Profile
|
||||
domain string
|
||||
log logx.Logger
|
||||
}
|
||||
|
||||
func (s *captchaSession) logger() logx.Logger {
|
||||
@@ -137,7 +123,6 @@ func Solve(
|
||||
streamID int,
|
||||
client tlsclient.HttpClient,
|
||||
profile browserprofile.Profile,
|
||||
savedProfile *browserprofile.Saved,
|
||||
log logx.Logger,
|
||||
) (string, error) {
|
||||
if captchaErr == nil || captchaErr.SessionToken == "" {
|
||||
@@ -146,7 +131,7 @@ func Solve(
|
||||
l := logx.OrNop(log)
|
||||
l.Infof("[STREAM %d] [Captcha] Solving VK Smart Captcha automatically...", streamID)
|
||||
|
||||
s := &captchaSession{ctx: ctx, client: client, profile: profile, savedProfile: savedProfile, domain: captchaDomain, log: l}
|
||||
s := &captchaSession{ctx: ctx, client: client, profile: profile, domain: captchaDomain, log: l}
|
||||
|
||||
for attempt := 1; attempt <= captchaMaxAttempts; attempt++ {
|
||||
token, solveErr := s.solveOnce(captchaErr)
|
||||
@@ -182,64 +167,39 @@ func (s *captchaSession) solveOnce(captchaErr *Error) (string, error) {
|
||||
|
||||
page, err := parseCaptchaPage(html)
|
||||
if err != nil {
|
||||
s.dumpChunks("html", html)
|
||||
return "", err
|
||||
}
|
||||
s.logCaptchaPage(page)
|
||||
if page.PowInput == "" {
|
||||
return "", errors.New("failed to find PoW settings")
|
||||
}
|
||||
|
||||
sliderContent := captchaContentRef{}
|
||||
if page.Init != nil {
|
||||
for _, setting := range page.Init.Data.CaptchaSettings {
|
||||
if setting.Type == "slider" {
|
||||
sliderContent = setting.contentRef()
|
||||
}
|
||||
}
|
||||
}
|
||||
if page.Init != nil && page.Init.Data.ShowCaptchaType == "slider" && sliderContent.Value == "" {
|
||||
return "", errors.New("failed to find slider captcha settings key")
|
||||
}
|
||||
|
||||
s.logger().Debugf("[Captcha] solving pow difficulty=%d", page.PowDifficulty)
|
||||
hash := solveCaptchaPoW(s.ctx, page.PowInput, page.PowDifficulty)
|
||||
if hash == "" {
|
||||
return "", errors.New("captcha pow failed")
|
||||
}
|
||||
s.logger().Debugf("[Captcha] pow solved hash_len=%d", len(hash))
|
||||
|
||||
debugInfo := s.resolveDebugInfo(page.ScriptURL)
|
||||
|
||||
browserFP, err := captchaBrowserFP()
|
||||
if err != nil {
|
||||
return "", err
|
||||
}
|
||||
|
||||
base := s.captchaBaseValues(captchaErr.SessionToken)
|
||||
if _, settingsErr := s.captchaRequest("captchaNotRobot.settings", base); settingsErr != nil {
|
||||
return "", fmt.Errorf("captcha settings failed: %w", settingsErr)
|
||||
}
|
||||
|
||||
browserFP, err := captchaBrowserFP()
|
||||
initResp, err := s.captchaRequest("captchaNotRobot.initSession", [][2]string{
|
||||
{"session_token", captchaErr.SessionToken},
|
||||
{"domain", s.domain},
|
||||
{"lang", "0"},
|
||||
})
|
||||
if err != nil {
|
||||
return "", err
|
||||
return "", fmt.Errorf("captcha initSession failed: %w", err)
|
||||
}
|
||||
browserFPSource := "generated"
|
||||
if s.savedProfile != nil && strings.TrimSpace(s.savedProfile.BrowserFp) != "" {
|
||||
browserFP = s.savedProfile.BrowserFp
|
||||
browserFPSource = "saved"
|
||||
}
|
||||
s.logger().Debugf("[Captcha] browser_fp source=%s len=%d", browserFPSource, len(browserFP))
|
||||
showType, sliderContent := parseCaptchaInitSession(initResp)
|
||||
s.logger().Debugf("[Captcha] initSession show_type=%q slider_len=%d", showType, len(sliderContent.Value))
|
||||
|
||||
if m := reCaptchaVersion.FindStringSubmatch(page.ScriptURL); len(m) > 1 {
|
||||
if m[1] != captchaScriptVersion {
|
||||
s.logger().Debugf("[Captcha] script version drift: known=%s latest=%s", captchaScriptVersion, m[1])
|
||||
}
|
||||
}
|
||||
|
||||
debugInfo, err := s.fetchDebugInfo(page.ScriptURL)
|
||||
if err != nil {
|
||||
return "", fmt.Errorf("failed to fetch debug info: %w (script_version=%s)", err, captchaScriptVersion)
|
||||
}
|
||||
|
||||
showType := ""
|
||||
if page.Init != nil {
|
||||
showType = page.Init.Data.ShowCaptchaType
|
||||
}
|
||||
s.logger().Debugf("[Captcha] solving show_type=%s", showType)
|
||||
var token string
|
||||
switch showType {
|
||||
case "slider":
|
||||
@@ -259,7 +219,36 @@ func (s *captchaSession) solveOnce(captchaErr *Error) (string, error) {
|
||||
return token, nil
|
||||
}
|
||||
|
||||
// captchaContentRef несёт значение настроек слайдера.
|
||||
func parseCaptchaInitSession(raw map[string]any) (string, captchaContentRef) {
|
||||
resp, ok := raw["response"].(map[string]any)
|
||||
if !ok {
|
||||
return "", captchaContentRef{}
|
||||
}
|
||||
showType := captchaStringifyAny(resp["show_captcha_type"])
|
||||
content := captchaContentRef{}
|
||||
if data, err := json.Marshal(resp["content_settings"]); err == nil {
|
||||
var settings []captchaInitSetting
|
||||
if json.Unmarshal(data, &settings) == nil {
|
||||
for _, setting := range settings {
|
||||
if setting.Type == "slider" {
|
||||
content = setting.contentRef()
|
||||
}
|
||||
}
|
||||
}
|
||||
}
|
||||
return showType, content
|
||||
}
|
||||
|
||||
func newCaptchaUUID() string {
|
||||
b := make([]byte, 16)
|
||||
if _, err := rand.Read(b); err != nil {
|
||||
return ""
|
||||
}
|
||||
b[6] = (b[6] & 0x0f) | 0x40
|
||||
b[8] = (b[8] & 0x3f) | 0x80
|
||||
return fmt.Sprintf("%x-%x-%x-%x-%x", b[0:4], b[4:6], b[6:8], b[8:10], b[10:16])
|
||||
}
|
||||
|
||||
type captchaContentRef struct {
|
||||
Source string
|
||||
Value string
|
||||
@@ -317,12 +306,25 @@ func (s *captchaSession) fetchCaptchaHTML(redirectURI string) (string, error) {
|
||||
return string(body), nil
|
||||
}
|
||||
|
||||
func (s *captchaSession) fetchDebugInfo(scriptURL string) (string, error) {
|
||||
if cached, ok := captchaDebugCache.Load(scriptURL); ok {
|
||||
if cachedDebugInfo, ok := cached.(string); ok {
|
||||
return cachedDebugInfo, nil
|
||||
func (s *captchaSession) resolveDebugInfo(scriptURL string) string {
|
||||
if scriptURL != "" {
|
||||
v, err := s.fetchDebugInfoJS(scriptURL)
|
||||
if err == nil {
|
||||
s.logger().Debugf("[Captcha] debug_info from JS len=%d", len(v))
|
||||
return v
|
||||
}
|
||||
s.logger().Warnf("[Captcha] debug_info JS fetch failed: %v; using UUID fallback", err)
|
||||
} else {
|
||||
s.logger().Warnf("[Captcha] captcha script URL not in HTML; using UUID fallback")
|
||||
}
|
||||
return newCaptchaUUID()
|
||||
}
|
||||
|
||||
func (s *captchaSession) fetchDebugInfoJS(scriptURL string) (string, error) {
|
||||
if cached, ok := debugInfoCache.Load(scriptURL); ok {
|
||||
if v, ok := cached.(string); ok {
|
||||
return v, nil
|
||||
}
|
||||
captchaDebugCache.Delete(scriptURL)
|
||||
}
|
||||
body, err := s.doRaw(fhttp.MethodGet, scriptURL, nil, map[string]string{
|
||||
"Accept": "text/javascript,*/*",
|
||||
@@ -333,47 +335,45 @@ func (s *captchaSession) fetchDebugInfo(scriptURL string) (string, error) {
|
||||
}
|
||||
m := reCaptchaDebugInfo.FindSubmatch(body)
|
||||
if len(m) < 2 {
|
||||
return "", errors.New("debug_info match not found")
|
||||
return "", errors.New("debug_info constant not found in JS")
|
||||
}
|
||||
v := string(m[1])
|
||||
captchaDebugCache.Store(scriptURL, v)
|
||||
s.logger().Debugf("[Captcha] debug_info fetched url=%s", scriptURL)
|
||||
debugInfoCache.Store(scriptURL, v)
|
||||
return v, nil
|
||||
}
|
||||
|
||||
func (s *captchaSession) dumpChunks(label, body string) {
|
||||
const chunk = 1800
|
||||
total := (len(body) + chunk - 1) / chunk
|
||||
l := s.logger()
|
||||
l.Debugf("[Captcha][DUMP] %s bytes=%d chunks=%d", label, len(body), total)
|
||||
for i := range total {
|
||||
start := i * chunk
|
||||
end := min(start+chunk, len(body))
|
||||
l.Debugf("[Captcha][DUMP %s %d/%d] %s", label, i+1, total, body[start:end])
|
||||
}
|
||||
}
|
||||
|
||||
func parseCaptchaPage(html string) (*captchaPage, error) {
|
||||
page := &captchaPage{}
|
||||
|
||||
match := reCaptchaWindowInit.FindStringSubmatch(html)
|
||||
if len(match) < 2 {
|
||||
return nil, errors.New("captcha init json not found")
|
||||
}
|
||||
var init captchaInit
|
||||
if err := json.Unmarshal([]byte(match[1]), &init); err != nil {
|
||||
return nil, fmt.Errorf("captcha init json parse: %w", err)
|
||||
}
|
||||
page.Init = &init
|
||||
|
||||
match = reCaptchaScriptSrc.FindStringSubmatch(html)
|
||||
if len(match) < 2 {
|
||||
return nil, errors.New("captcha script url not found")
|
||||
}
|
||||
page.ScriptURL = match[1]
|
||||
|
||||
if m := reCaptchaPowInput.FindStringSubmatch(html); len(m) >= 2 {
|
||||
page.PowInput = m[1]
|
||||
}
|
||||
if page.PowInput == "" {
|
||||
return page, nil
|
||||
if m := reCaptchaScriptSrc.FindStringSubmatch(html); len(m) >= 2 {
|
||||
page.ScriptURL = m[1]
|
||||
}
|
||||
|
||||
match = reCaptchaDifficulty.FindStringSubmatch(html)
|
||||
if len(match) < 2 {
|
||||
m := reCaptchaPowInput.FindStringSubmatch(html)
|
||||
if len(m) < 2 {
|
||||
return nil, errors.New("captcha powInput not found")
|
||||
}
|
||||
page.PowInput = m[1]
|
||||
|
||||
dm := reCaptchaDifficulty.FindStringSubmatch(html)
|
||||
if len(dm) < 2 {
|
||||
return nil, errors.New("captcha difficulty const not found")
|
||||
}
|
||||
difficulty, err := strconv.Atoi(match[1])
|
||||
difficulty, err := strconv.Atoi(dm[1])
|
||||
if err != nil || difficulty <= 0 {
|
||||
return nil, fmt.Errorf("invalid captcha difficulty %q", match[1])
|
||||
return nil, fmt.Errorf("invalid captcha difficulty %q", dm[1])
|
||||
}
|
||||
page.PowDifficulty = difficulty
|
||||
return page, nil
|
||||
@@ -471,13 +471,8 @@ func (s *captchaSession) solveCheckboxCaptcha(
|
||||
hash string,
|
||||
debugInfo string,
|
||||
) (string, error) {
|
||||
deviceJSON := captchaDeviceInfo
|
||||
deviceSource := "default"
|
||||
if s.savedProfile != nil && strings.TrimSpace(s.savedProfile.DeviceJSON) != "" {
|
||||
deviceJSON = s.savedProfile.DeviceJSON
|
||||
deviceSource = "saved"
|
||||
}
|
||||
s.logger().Debugf("[Captcha] checkbox componentDone device_source=%s device_bytes=%d", deviceSource, len(deviceJSON))
|
||||
deviceJSON := s.profile.DeviceJSON
|
||||
s.logger().Debugf("[Captcha] checkbox componentDone device_bytes=%d", len(deviceJSON))
|
||||
if _, err := s.captchaRequest("captchaNotRobot.componentDone", [][2]string{
|
||||
{"session_token", sessionToken},
|
||||
{"domain", s.domain},
|
||||
@@ -536,26 +531,12 @@ func solveCaptchaPoW(ctx context.Context, input string, difficulty int) string {
|
||||
sum := sha256.Sum256(buf)
|
||||
hashHex := hex.EncodeToString(sum[:])
|
||||
if strings.HasPrefix(hashHex, target) {
|
||||
return encodeCaptchaPoW(hashHex, nonce)
|
||||
return hashHex
|
||||
}
|
||||
}
|
||||
return ""
|
||||
}
|
||||
|
||||
func encodeCaptchaPoW(hash string, nonce int) string {
|
||||
payload, err := json.Marshal(struct {
|
||||
Hash string `json:"hash"`
|
||||
Nonce int `json:"nonce"`
|
||||
}{
|
||||
Hash: hash,
|
||||
Nonce: nonce,
|
||||
})
|
||||
if err != nil {
|
||||
return ""
|
||||
}
|
||||
return "v2." + base64.RawURLEncoding.EncodeToString(payload)
|
||||
}
|
||||
|
||||
func (s *captchaSession) doRaw(
|
||||
method string,
|
||||
endpoint string,
|
||||
@@ -602,31 +583,6 @@ func (s *captchaSession) doRaw(
|
||||
return data, readErr
|
||||
}
|
||||
|
||||
func (s *captchaSession) logCaptchaPage(page *captchaPage) {
|
||||
showType := ""
|
||||
settingsSummary := "none"
|
||||
if page.Init != nil {
|
||||
showType = page.Init.Data.ShowCaptchaType
|
||||
parts := make([]string, 0, len(page.Init.Data.CaptchaSettings))
|
||||
for _, setting := range page.Init.Data.CaptchaSettings {
|
||||
ref := setting.contentRef()
|
||||
valueLen := 0
|
||||
if ref.Value != "" {
|
||||
valueLen = len(ref.Value)
|
||||
}
|
||||
parts = append(parts, fmt.Sprintf("%s:%s:%d", setting.Type, ref.Source, valueLen))
|
||||
}
|
||||
if len(parts) > 0 {
|
||||
settingsSummary = strings.Join(parts, ",")
|
||||
}
|
||||
}
|
||||
scriptVersion := ""
|
||||
if m := reCaptchaVersion.FindStringSubmatch(page.ScriptURL); len(m) > 1 {
|
||||
scriptVersion = m[1]
|
||||
}
|
||||
s.logger().Debugf("[Captcha] page parsed show_type=%q settings=%s pow_difficulty=%d script_version=%q script_url=%s", showType, settingsSummary, page.PowDifficulty, scriptVersion, captchaSafeURL(page.ScriptURL))
|
||||
}
|
||||
|
||||
func captchaAPIResponseSummary(raw map[string]any) string {
|
||||
if errData, ok := raw["error"].(map[string]any); ok {
|
||||
return fmt.Sprintf("error code=%s msg=%q keys=%s", captchaStringifyAny(errData["error_code"]), captchaStringifyAny(errData["error_msg"]), captchaMapKeys(errData))
|
||||
|
||||
@@ -1,7 +1,7 @@
|
||||
package captcha
|
||||
|
||||
import (
|
||||
"encoding/base64"
|
||||
"context"
|
||||
"encoding/json"
|
||||
"strings"
|
||||
"testing"
|
||||
@@ -34,46 +34,73 @@ func TestCaptchaInitSettingContentRefLegacySettings(t *testing.T) {
|
||||
}
|
||||
}
|
||||
|
||||
func TestParseCaptchaPageSettingsKey(t *testing.T) {
|
||||
html := `<html><head><script src="https://static.vk.ru/vkid/1.1.1359/not_robot_captcha.js"></script></head><body>
|
||||
<script>
|
||||
window.init = {"data":{"show_captcha_type":"slider","captcha_settings":[{"type":"slider","settings_key":"abc123"}]}};
|
||||
const powInput = "input";
|
||||
func TestParseCaptchaPageSPA(t *testing.T) {
|
||||
html := `<html><head><script>
|
||||
const powInput = "Pihj7tyAHFxdwm4t";
|
||||
const difficulty = 2;
|
||||
</script>
|
||||
</body></html>`
|
||||
<script src="https://id.vk.ru/static/vkid/1.1.1374/not_robot_captcha.js"></script>
|
||||
</head><body><div id="spa_root"></div></body></html>`
|
||||
|
||||
page, err := parseCaptchaPage(html)
|
||||
if err != nil {
|
||||
t.Fatal(err)
|
||||
}
|
||||
if page.Init == nil || len(page.Init.Data.CaptchaSettings) != 1 {
|
||||
t.Fatalf("captcha settings missing: %+v", page.Init)
|
||||
if page.PowInput != "Pihj7tyAHFxdwm4t" || page.PowDifficulty != 2 {
|
||||
t.Fatalf("pow parse = %q/%d", page.PowInput, page.PowDifficulty)
|
||||
}
|
||||
got := page.Init.Data.CaptchaSettings[0].contentRef()
|
||||
if got.Source != "settings_key" || got.Value != "abc123" {
|
||||
t.Fatalf("contentRef = %+v, want settings_key/abc123", got)
|
||||
if page.ScriptURL != "https://id.vk.ru/static/vkid/1.1.1374/not_robot_captcha.js" {
|
||||
t.Fatalf("script url = %q", page.ScriptURL)
|
||||
}
|
||||
}
|
||||
|
||||
func TestEncodeCaptchaPoW(t *testing.T) {
|
||||
got := encodeCaptchaPoW("00abcdef", 147)
|
||||
if !strings.HasPrefix(got, "v2.") {
|
||||
t.Fatalf("pow = %q, want v2 prefix", got)
|
||||
func TestParseCaptchaPageMissingPoW(t *testing.T) {
|
||||
if _, err := parseCaptchaPage(`<html><body><div id="spa_root"></div></body></html>`); err == nil {
|
||||
t.Fatal("expected error when powInput/difficulty absent")
|
||||
}
|
||||
payload, err := base64.RawURLEncoding.DecodeString(strings.TrimPrefix(got, "v2."))
|
||||
if err != nil {
|
||||
t.Fatal(err)
|
||||
}
|
||||
|
||||
func TestSolveCaptchaPoWRawHex(t *testing.T) {
|
||||
got := solveCaptchaPoW(context.Background(), "input", 1)
|
||||
if len(got) != 64 {
|
||||
t.Fatalf("pow = %q, want 64-hex", got)
|
||||
}
|
||||
var decoded struct {
|
||||
Hash string `json:"hash"`
|
||||
Nonce int `json:"nonce"`
|
||||
if !strings.HasPrefix(got, "0") {
|
||||
t.Fatalf("pow = %q, want leading zero for difficulty 1", got)
|
||||
}
|
||||
if err := json.Unmarshal(payload, &decoded); err != nil {
|
||||
t.Fatal(err)
|
||||
if again := solveCaptchaPoW(context.Background(), "input", 1); again != got {
|
||||
t.Fatalf("pow not deterministic: %q vs %q", got, again)
|
||||
}
|
||||
if decoded.Hash != "00abcdef" || decoded.Nonce != 147 {
|
||||
t.Fatalf("decoded = %+v, want hash/nonce", decoded)
|
||||
}
|
||||
|
||||
func TestParseCaptchaInitSession(t *testing.T) {
|
||||
raw := map[string]any{"response": map[string]any{
|
||||
"show_captcha_type": "slider",
|
||||
"captcha_id": "cid",
|
||||
"content_settings": []any{
|
||||
map[string]any{"type": "slider", "settings_key": "sliderkey"},
|
||||
map[string]any{"type": "sound", "settings_key": "soundkey"},
|
||||
},
|
||||
}}
|
||||
showType, content := parseCaptchaInitSession(raw)
|
||||
if showType != "slider" {
|
||||
t.Fatalf("show_type = %q, want slider", showType)
|
||||
}
|
||||
if content.Value != "sliderkey" || content.Source != "settings_key" {
|
||||
t.Fatalf("content = %+v, want sliderkey/settings_key", content)
|
||||
}
|
||||
}
|
||||
|
||||
func TestParseCaptchaInitSessionCheckbox(t *testing.T) {
|
||||
raw := map[string]any{"response": map[string]any{
|
||||
"show_captcha_type": "checkbox",
|
||||
"content_settings": []any{
|
||||
map[string]any{"type": "slider", "settings_key": "k"},
|
||||
},
|
||||
}}
|
||||
showType, _ := parseCaptchaInitSession(raw)
|
||||
if showType != "checkbox" {
|
||||
t.Fatalf("show_type = %q, want checkbox", showType)
|
||||
}
|
||||
}
|
||||
|
||||
|
||||
@@ -11,7 +11,6 @@ type Error struct {
|
||||
ErrorCode int
|
||||
ErrorMsg string
|
||||
CaptchaSid string
|
||||
CaptchaImg string
|
||||
RedirectURI string
|
||||
IsSoundCaptchaAvailable bool
|
||||
SessionToken string
|
||||
@@ -42,8 +41,6 @@ func ParseError(errData map[string]any) *Error {
|
||||
}
|
||||
}
|
||||
|
||||
captchaImg, _ := errData["captcha_img"].(string)
|
||||
|
||||
errorMsg, ok := errData["error_msg"].(string)
|
||||
if !ok {
|
||||
Log.Warnf("[Captcha] missing error_msg in error data")
|
||||
@@ -88,7 +85,6 @@ func ParseError(errData map[string]any) *Error {
|
||||
ErrorCode: code,
|
||||
ErrorMsg: errorMsg,
|
||||
CaptchaSid: captchaSid,
|
||||
CaptchaImg: captchaImg,
|
||||
RedirectURI: redirectURI,
|
||||
IsSoundCaptchaAvailable: isSound,
|
||||
SessionToken: sessionToken,
|
||||
|
||||
@@ -0,0 +1,154 @@
|
||||
(() => {
|
||||
'use strict';
|
||||
|
||||
const { local: LOCAL, upstream: UPSTREAM } = window.__ftpCaptcha ?? {};
|
||||
const PROXY = '/generic_proxy?proxy_url=';
|
||||
const RESULT = '/local-captcha-result';
|
||||
const CHECK = 'captchaNotRobot.check';
|
||||
|
||||
function rewriteUrl(url) {
|
||||
if (!url || typeof url !== 'string') return url;
|
||||
if (url.startsWith(LOCAL)) return url;
|
||||
if (url.startsWith(UPSTREAM)) return LOCAL + url.slice(UPSTREAM.length);
|
||||
if (url.startsWith('//')) return PROXY + encodeURIComponent(location.protocol + url);
|
||||
if (url.startsWith('http://') || url.startsWith('https://')) return PROXY + encodeURIComponent(url);
|
||||
return url;
|
||||
}
|
||||
|
||||
function rewriteAttr(el, attr) {
|
||||
const value = el.getAttribute?.(attr);
|
||||
if (!value) return;
|
||||
const rewritten = rewriteUrl(value);
|
||||
if (rewritten !== value) el.setAttribute(attr, rewritten);
|
||||
}
|
||||
|
||||
function rewriteTree(root) {
|
||||
if (!root.querySelectorAll) return;
|
||||
for (const attr of ['href', 'src', 'action']) {
|
||||
root.querySelectorAll(`[${attr}]`).forEach((el) => rewriteAttr(el, attr));
|
||||
}
|
||||
}
|
||||
|
||||
const extractToken = (data) => data?.response?.success_token;
|
||||
|
||||
function sendToken(token) {
|
||||
if (!token) return;
|
||||
const body = `token=${encodeURIComponent(token)}`;
|
||||
|
||||
// sendBeacon переживает уход со страницы (mobile Safari)
|
||||
if (navigator.sendBeacon?.(RESULT, new Blob([body], { type: 'application/x-www-form-urlencoded' }))) {
|
||||
showDone();
|
||||
return;
|
||||
}
|
||||
|
||||
fetch(RESULT, {
|
||||
method: 'POST',
|
||||
headers: { 'Content-Type': 'application/x-www-form-urlencoded' },
|
||||
body,
|
||||
}).then(showDone).catch(() => {
|
||||
const form = document.createElement('form');
|
||||
form.method = 'POST';
|
||||
form.action = RESULT;
|
||||
const input = document.createElement('input');
|
||||
input.type = 'hidden';
|
||||
input.name = 'token';
|
||||
input.value = token;
|
||||
form.append(input);
|
||||
document.body.append(form);
|
||||
form.submit();
|
||||
});
|
||||
}
|
||||
|
||||
function showPending() {
|
||||
document.body.style.background = '#000';
|
||||
const banner = document.createElement('div');
|
||||
banner.textContent = 'free turn proxy - captcha';
|
||||
banner.style.cssText = 'position:fixed;top:0;left:0;right:0;z-index:99999;padding:12px;text-align:center;font:13.5px ui-monospace,monospace;color:#e1e1e1;background:#000';
|
||||
document.body.append(banner);
|
||||
}
|
||||
|
||||
function showDone() {
|
||||
document.body.style.background = '#000';
|
||||
document.body.innerHTML =
|
||||
'<div style="min-height:100vh;display:flex;flex-direction:column;align-items:center;justify-content:center;gap:12px;font-family:ui-monospace,monospace;text-align:center">' +
|
||||
'<div style="font-size:16.5px;font-weight:700;color:#e1e1e1">free turn proxy</div>' +
|
||||
'<div style="font-size:13.5px;color:#818181">gg</div></div>';
|
||||
setTimeout(() => window.close(), 1000);
|
||||
}
|
||||
|
||||
const xhrOpen = XMLHttpRequest.prototype.open;
|
||||
XMLHttpRequest.prototype.open = function (...args) {
|
||||
if (typeof args[1] === 'string') {
|
||||
this._origUrl = args[1];
|
||||
args[1] = rewriteUrl(args[1]);
|
||||
}
|
||||
return xhrOpen.apply(this, args);
|
||||
};
|
||||
|
||||
const xhrSend = XMLHttpRequest.prototype.send;
|
||||
XMLHttpRequest.prototype.send = function (...args) {
|
||||
if (this._origUrl?.includes(CHECK)) {
|
||||
this.addEventListener('load', () => {
|
||||
try { sendToken(extractToken(JSON.parse(this.responseText))); } catch {}
|
||||
});
|
||||
}
|
||||
return xhrSend.apply(this, args);
|
||||
};
|
||||
|
||||
const origFetch = window.fetch;
|
||||
window.fetch = function (...args) {
|
||||
const urlStr = typeof args[0] === 'object' ? args[0]?.url : args[0];
|
||||
if (typeof args[0] === 'string') args[0] = rewriteUrl(args[0]);
|
||||
|
||||
const promise = origFetch.apply(this, args);
|
||||
if (typeof urlStr === 'string' && urlStr.includes(CHECK)) {
|
||||
promise
|
||||
.then((res) => res.clone().json())
|
||||
.then((data) => sendToken(extractToken(data)))
|
||||
.catch(() => {});
|
||||
}
|
||||
return promise;
|
||||
};
|
||||
|
||||
document.addEventListener('submit', (event) => {
|
||||
if (event.target?.action) event.target.action = rewriteUrl(event.target.action);
|
||||
}, true);
|
||||
|
||||
document.addEventListener('click', (event) => {
|
||||
const link = event.target?.closest?.('a[href]');
|
||||
if (link?.href) link.href = rewriteUrl(link.href);
|
||||
}, true);
|
||||
|
||||
const formSubmit = HTMLFormElement.prototype.submit;
|
||||
HTMLFormElement.prototype.submit = function (...args) {
|
||||
if (this.action) this.action = rewriteUrl(this.action);
|
||||
return formSubmit.apply(this, args);
|
||||
};
|
||||
|
||||
const windowOpen = window.open;
|
||||
window.open = function (...args) {
|
||||
if (typeof args[0] === 'string') args[0] = rewriteUrl(args[0]);
|
||||
return windowOpen.apply(this, args);
|
||||
};
|
||||
|
||||
rewriteTree(document);
|
||||
new MutationObserver((mutations) => {
|
||||
for (const { type, target, attributeName, addedNodes } of mutations) {
|
||||
if (type === 'attributes') {
|
||||
rewriteAttr(target, attributeName);
|
||||
continue;
|
||||
}
|
||||
for (const node of addedNodes) {
|
||||
if (node.nodeType === 1) rewriteTree(node);
|
||||
}
|
||||
}
|
||||
}).observe(document.documentElement, {
|
||||
subtree: true,
|
||||
childList: true,
|
||||
attributes: true,
|
||||
attributeFilter: ['href', 'src', 'action'],
|
||||
});
|
||||
|
||||
if (document.body) showPending();
|
||||
else document.addEventListener('DOMContentLoaded', showPending);
|
||||
})();
|
||||
@@ -1,18 +1,13 @@
|
||||
// Package manual реализует ручное решение CAPTCHA - fallback, когда автосолвер
|
||||
// (internal/provider/vk/internal/captcha) не справился или пользователь дал -manual-captcha.
|
||||
// Поднимает локальный HTTP-сервер 127.0.0.1:8765, проксирующий страницу VK
|
||||
// CAPTCHA (с переписыванием абсолютных URL и gzip), открывает её в браузере и
|
||||
// ждёт токен/ключ после решения пользователем.
|
||||
package manual
|
||||
|
||||
import (
|
||||
"bytes"
|
||||
"compress/gzip"
|
||||
"context"
|
||||
_ "embed"
|
||||
"encoding/json"
|
||||
"errors"
|
||||
"fmt"
|
||||
"html"
|
||||
"io"
|
||||
"net"
|
||||
"net/http"
|
||||
@@ -26,22 +21,27 @@ import (
|
||||
|
||||
"github.com/samosvalishe/free-turn-proxy/internal/client/ish"
|
||||
"github.com/samosvalishe/free-turn-proxy/internal/logx"
|
||||
"github.com/samosvalishe/free-turn-proxy/internal/provider/vk/internal/browserprofile"
|
||||
)
|
||||
|
||||
// Debug включает подробное логирование request/response проксируемого
|
||||
// браузерного трафика. Ставится из main после разбора cfg.
|
||||
// Debug включает логирование проксируемого браузерного трафика.
|
||||
var Debug bool
|
||||
|
||||
// Log - пакетный логгер; по умолчанию no-op. main устанавливает его через
|
||||
// SetLogger, чтобы вывод подчинялся -debug.
|
||||
var Log logx.Logger = logx.Nop()
|
||||
|
||||
// SetLogger ставит логгер пакета.
|
||||
func SetLogger(l logx.Logger) { Log = logx.OrNop(l) }
|
||||
|
||||
const captchaListenPort = "8765"
|
||||
|
||||
//go:embed inject.js
|
||||
var injectJS string
|
||||
|
||||
// injectScriptTag: конфиг отдельной строкой (json.Marshal экранирует, включая "<"),
|
||||
// сам inject.js статичный, без плейсхолдеров.
|
||||
func injectScriptTag(localOrigin, upstreamOrigin string) string {
|
||||
cfg, _ := json.Marshal(map[string]string{"local": localOrigin, "upstream": upstreamOrigin})
|
||||
return "\n<script>window.__ftpCaptcha=" + string(cfg) + ";</script>\n<script>\n" + injectJS + "</script>\n"
|
||||
}
|
||||
|
||||
type browserCommand struct {
|
||||
name string
|
||||
args []string
|
||||
@@ -296,199 +296,7 @@ func rewriteCaptchaHTML(html string, targetURL *neturl.URL) string {
|
||||
// сразу при парсинге HTML - раньше любых инжектированных JS-перехватов.
|
||||
html = rewriteHTMLAttrsServerSide(html, targetURL)
|
||||
|
||||
script := fmt.Sprintf(`
|
||||
<script>
|
||||
(function() {
|
||||
var localOrigin = %q;
|
||||
var upstreamOrigin = %q;
|
||||
|
||||
function rewriteUrl(urlStr) {
|
||||
if (!urlStr || typeof urlStr !== 'string') return urlStr;
|
||||
if (urlStr.indexOf(localOrigin) === 0) return urlStr;
|
||||
if (urlStr.indexOf(upstreamOrigin) === 0) return localOrigin + urlStr.slice(upstreamOrigin.length);
|
||||
if (urlStr.indexOf('//') === 0) {
|
||||
return '/generic_proxy?proxy_url=' + encodeURIComponent(window.location.protocol + urlStr);
|
||||
}
|
||||
if (urlStr.indexOf('http://') === 0 || urlStr.indexOf('https://') === 0) {
|
||||
return '/generic_proxy?proxy_url=' + encodeURIComponent(urlStr);
|
||||
}
|
||||
return urlStr;
|
||||
}
|
||||
|
||||
function rewriteElementAttr(el, attr) {
|
||||
if (!el || !el.getAttribute) return;
|
||||
var value = el.getAttribute(attr);
|
||||
if (!value) return;
|
||||
var rewritten = rewriteUrl(value);
|
||||
if (rewritten !== value) {
|
||||
el.setAttribute(attr, rewritten);
|
||||
}
|
||||
}
|
||||
|
||||
function rewriteDocument(root) {
|
||||
if (!root || !root.querySelectorAll) return;
|
||||
root.querySelectorAll('[href]').forEach(function(el) { rewriteElementAttr(el, 'href'); });
|
||||
root.querySelectorAll('[src]').forEach(function(el) { rewriteElementAttr(el, 'src'); });
|
||||
root.querySelectorAll('form[action]').forEach(function(el) { rewriteElementAttr(el, 'action'); });
|
||||
}
|
||||
|
||||
function handleSuccessToken(token) {
|
||||
if (!token) return;
|
||||
console.log('Captcha solved, sending token to proxy...');
|
||||
var body = 'token=' + encodeURIComponent(token);
|
||||
|
||||
// sendBeacon is the most reliable on mobile Safari:
|
||||
// it's fire-and-forget and works even if the page navigates away.
|
||||
if (navigator && navigator.sendBeacon) {
|
||||
var blob = new Blob([body], {type: 'application/x-www-form-urlencoded'});
|
||||
var sent = navigator.sendBeacon('/local-captcha-result', blob);
|
||||
if (sent) {
|
||||
console.log('Token sent via sendBeacon');
|
||||
showDone();
|
||||
return;
|
||||
}
|
||||
}
|
||||
|
||||
// Fallback: fetch
|
||||
fetch('/local-captcha-result', {
|
||||
method: 'POST',
|
||||
headers: {'Content-Type': 'application/x-www-form-urlencoded'},
|
||||
body: body
|
||||
}).then(function(r) {
|
||||
console.log('Proxy acknowledged token');
|
||||
showDone();
|
||||
}).catch(function(e) {
|
||||
console.error('Fetch failed, trying form submit...', e);
|
||||
// Last resort: form POST (navigates the page)
|
||||
var form = document.createElement('form');
|
||||
form.method = 'POST';
|
||||
form.action = '/local-captcha-result';
|
||||
var input = document.createElement('input');
|
||||
input.type = 'hidden';
|
||||
input.name = 'token';
|
||||
input.value = token;
|
||||
form.appendChild(input);
|
||||
document.body.appendChild(form);
|
||||
form.submit();
|
||||
});
|
||||
}
|
||||
|
||||
function showDone() {
|
||||
document.body.innerHTML = '<div style="text-align:center;margin-top:20vh;font-family:sans-serif">' +
|
||||
'<h2 style="color:#4caf50">✔ Done!</h2>' +
|
||||
'<p>Captcha solved successfully. You can close this tab now.</p>' +
|
||||
'</div>';
|
||||
// On iOS, window.close() often doesn't work, so we just let the user know they are done.
|
||||
setTimeout(function() { window.close(); }, 1000);
|
||||
}
|
||||
|
||||
var origOpen = XMLHttpRequest.prototype.open;
|
||||
XMLHttpRequest.prototype.open = function() {
|
||||
if (arguments[1] && typeof arguments[1] === 'string') {
|
||||
this._origUrl = arguments[1];
|
||||
arguments[1] = rewriteUrl(arguments[1]);
|
||||
}
|
||||
return origOpen.apply(this, arguments);
|
||||
};
|
||||
|
||||
var origSend = XMLHttpRequest.prototype.send;
|
||||
XMLHttpRequest.prototype.send = function() {
|
||||
var xhr = this;
|
||||
if (this._origUrl && this._origUrl.indexOf('captchaNotRobot.check') !== -1) {
|
||||
xhr.addEventListener('load', function() {
|
||||
try {
|
||||
var data = JSON.parse(xhr.responseText);
|
||||
if (data.response && data.response.success_token) {
|
||||
handleSuccessToken(data.response.success_token);
|
||||
}
|
||||
} catch (e) {}
|
||||
});
|
||||
}
|
||||
return origSend.apply(this, arguments);
|
||||
};
|
||||
|
||||
var origFetch = window.fetch;
|
||||
if (origFetch) {
|
||||
window.fetch = function() {
|
||||
var url = arguments[0];
|
||||
var isObj = (typeof url === 'object' && url && url.url);
|
||||
var urlStr = isObj ? url.url : url;
|
||||
var origUrlStr = urlStr;
|
||||
|
||||
if (typeof urlStr === 'string') {
|
||||
urlStr = rewriteUrl(urlStr);
|
||||
arguments[0] = urlStr;
|
||||
}
|
||||
|
||||
var p = origFetch.apply(this, arguments);
|
||||
if (typeof origUrlStr === 'string' && origUrlStr.indexOf('captchaNotRobot.check') !== -1) {
|
||||
p.then(function(response) {
|
||||
return response.clone().json();
|
||||
}).then(function(data) {
|
||||
if (data.response && data.response.success_token) {
|
||||
handleSuccessToken(data.response.success_token);
|
||||
}
|
||||
}).catch(function() {});
|
||||
}
|
||||
return p;
|
||||
};
|
||||
}
|
||||
|
||||
document.addEventListener('submit', function(event) {
|
||||
if (event.target && event.target.action) {
|
||||
event.target.action = rewriteUrl(event.target.action);
|
||||
}
|
||||
}, true);
|
||||
|
||||
document.addEventListener('click', function(event) {
|
||||
var target = event.target && event.target.closest ? event.target.closest('a[href]') : null;
|
||||
if (target && target.href) {
|
||||
target.href = rewriteUrl(target.href);
|
||||
}
|
||||
}, true);
|
||||
|
||||
var origFormSubmit = HTMLFormElement.prototype.submit;
|
||||
HTMLFormElement.prototype.submit = function() {
|
||||
if (this.action) {
|
||||
this.action = rewriteUrl(this.action);
|
||||
}
|
||||
return origFormSubmit.apply(this, arguments);
|
||||
};
|
||||
|
||||
var origWindowOpen = window.open;
|
||||
if (origWindowOpen) {
|
||||
window.open = function(url) {
|
||||
if (typeof url === 'string') {
|
||||
arguments[0] = rewriteUrl(url);
|
||||
}
|
||||
return origWindowOpen.apply(this, arguments);
|
||||
};
|
||||
}
|
||||
|
||||
rewriteDocument(document);
|
||||
if (document.documentElement && window.MutationObserver) {
|
||||
new MutationObserver(function(mutations) {
|
||||
mutations.forEach(function(mutation) {
|
||||
if (mutation.type === 'attributes' && mutation.target) {
|
||||
rewriteElementAttr(mutation.target, mutation.attributeName);
|
||||
return;
|
||||
}
|
||||
mutation.addedNodes.forEach(function(node) {
|
||||
if (node.nodeType === 1) {
|
||||
rewriteDocument(node);
|
||||
}
|
||||
});
|
||||
});
|
||||
}).observe(document.documentElement, {
|
||||
subtree: true,
|
||||
childList: true,
|
||||
attributes: true,
|
||||
attributeFilter: ['href', 'src', 'action']
|
||||
});
|
||||
}
|
||||
})();
|
||||
</script>
|
||||
`, localOrigin, upstreamOrigin)
|
||||
script := injectScriptTag(localOrigin, upstreamOrigin)
|
||||
|
||||
// Шаг 3: инжектируем клиентский скрипт как можно раньше - после <head>,
|
||||
// чтобы XHR/fetch-перехваты были активны до любого inline <script> в <head>.
|
||||
@@ -592,39 +400,6 @@ func notifyKey(keyCh chan<- string, key string) {
|
||||
}
|
||||
}
|
||||
|
||||
// SolveViaHTTP отдаёт минимальную HTML-страницу для решения картинки CAPTCHA,
|
||||
// открывает её в браузере и блокируется до прихода ключа.
|
||||
func SolveViaHTTP(ctx context.Context, captchaImg string) (string, error) {
|
||||
keyCh := make(chan string, 1)
|
||||
mux := http.NewServeMux()
|
||||
|
||||
mux.HandleFunc("/", func(w http.ResponseWriter, _ *http.Request) {
|
||||
w.Header().Set("Content-Type", "text/html; charset=utf-8")
|
||||
_, _ = fmt.Fprintf(w, `<!DOCTYPE html>
|
||||
<html><head>
|
||||
<meta name="viewport" content="width=device-width,initial-scale=1">
|
||||
<style>body{font-family:sans-serif;text-align:center;padding:20px}
|
||||
img{max-width:100%%;margin:16px 0}
|
||||
input{font-size:24px;padding:12px;width:80%%;box-sizing:border-box}
|
||||
button{font-size:24px;padding:12px 32px;margin-top:12px;cursor:pointer}</style>
|
||||
</head><body>
|
||||
<h2>Solve the Captcha</h2>
|
||||
<img src="%s" alt="captcha"/>
|
||||
<form onsubmit="fetch('/solve?key='+encodeURIComponent(document.getElementById('k').value)).then(()=>{document.body.innerHTML='<h2>Done!</h2>';setTimeout(function(){window.close();}, 300);});return false;">
|
||||
<br><input id="k" type="text" autofocus placeholder="Text from image"/>
|
||||
<br><button type="submit">Submit</button>
|
||||
</form></body></html>`, captchaImg)
|
||||
})
|
||||
|
||||
mux.HandleFunc("/solve", func(w http.ResponseWriter, r *http.Request) {
|
||||
notifyKey(keyCh, r.URL.Query().Get("key"))
|
||||
w.Header().Set("Content-Type", "text/html; charset=utf-8")
|
||||
_, _ = fmt.Fprint(w, `<!DOCTYPE html><html><body><h2>Done!</h2></body></html>`)
|
||||
})
|
||||
|
||||
return runCaptchaServerAndWait(ctx, mux, localCaptchaOrigin(), keyCh, "captcha HTTP server error", openBrowser)
|
||||
}
|
||||
|
||||
type loggingTransport struct {
|
||||
rt http.RoundTripper
|
||||
}
|
||||
@@ -646,35 +421,6 @@ func (t *loggingTransport) RoundTrip(req *http.Request) (*http.Response, error)
|
||||
Log.Debugf("[Captcha Proxy] header (%s): %s = %s", req.URL.Path, k, strings.Join(v, ", "))
|
||||
}
|
||||
}
|
||||
|
||||
if strings.Contains(req.URL.Path, "captchaNotRobot.componentDone") || strings.Contains(req.URL.Path, "captchaNotRobot.check") {
|
||||
parsedBody, err := neturl.ParseQuery(string(b))
|
||||
if err != nil {
|
||||
Log.Warnf("[Captcha Proxy] failed to parse request body: %v", err)
|
||||
}
|
||||
device := parsedBody.Get("device")
|
||||
browserFp := parsedBody.Get("browser_fp")
|
||||
|
||||
// сохраняем только если есть device. componentDone обычно его содержит.
|
||||
if device != "" && browserFp != "" {
|
||||
sp := browserprofile.Saved{
|
||||
Profile: browserprofile.Profile{
|
||||
UserAgent: req.Header.Get("User-Agent"),
|
||||
SecChUa: req.Header.Get("Sec-Ch-Ua"),
|
||||
SecChUaMobile: req.Header.Get("Sec-Ch-Ua-Mobile"),
|
||||
SecChUaPlatform: req.Header.Get("Sec-Ch-Ua-Platform"),
|
||||
AcceptLanguage: req.Header.Get("Accept-Language"),
|
||||
},
|
||||
DeviceJSON: device,
|
||||
BrowserFp: browserFp,
|
||||
}
|
||||
if err := browserprofile.Save(sp); err != nil {
|
||||
Log.Warnf("[Captcha Proxy] failed to save browser profile: %v", err)
|
||||
} else {
|
||||
Log.Infof("[Captcha Proxy] saved real browser profile")
|
||||
}
|
||||
}
|
||||
}
|
||||
}
|
||||
return t.rt.RoundTrip(req)
|
||||
}
|
||||
@@ -711,10 +457,7 @@ func solveViaProxy(ctx context.Context, redirectURI string, dialer net.Dialer, p
|
||||
},
|
||||
ErrorHandler: func(w http.ResponseWriter, r *http.Request, err error) {
|
||||
Log.Errorf("[Captcha Proxy] %s %s: %v", r.Method, r.URL.String(), err)
|
||||
w.Header().Set("Content-Type", "text/html; charset=utf-8")
|
||||
w.WriteHeader(http.StatusBadGateway)
|
||||
_, _ = fmt.Fprintf(w, `<!DOCTYPE html><html><body style="font-family:sans-serif;padding:20px"><h2>Captcha proxy error</h2><p>%s %s</p><p>%s</p></body></html>`,
|
||||
html.EscapeString(r.Method), html.EscapeString(r.URL.String()), html.EscapeString(err.Error()))
|
||||
http.Error(w, "ошибка прокси капчи, детали в консоли клиента", http.StatusBadGateway)
|
||||
},
|
||||
ModifyResponse: func(res *http.Response) error {
|
||||
rewriteProxyCookies(res.Header)
|
||||
|
||||
@@ -80,13 +80,8 @@ func (s *captchaSession) solveSliderCaptcha(
|
||||
}
|
||||
s.logger().Debugf("[Captcha] slider guesses ranked: total=%d limit=%d", len(guesses), limit)
|
||||
|
||||
deviceJSON := captchaDeviceInfo
|
||||
deviceSource := "default"
|
||||
if s.savedProfile != nil && strings.TrimSpace(s.savedProfile.DeviceJSON) != "" {
|
||||
deviceJSON = s.savedProfile.DeviceJSON
|
||||
deviceSource = "saved"
|
||||
}
|
||||
s.logger().Debugf("[Captcha] slider componentDone device_source=%s device_bytes=%d", deviceSource, len(deviceJSON))
|
||||
deviceJSON := s.profile.DeviceJSON
|
||||
s.logger().Debugf("[Captcha] slider componentDone device_bytes=%d", len(deviceJSON))
|
||||
if _, err := s.captchaRequest("captchaNotRobot.componentDone", [][2]string{
|
||||
{"session_token", sessionToken},
|
||||
{"domain", s.domain},
|
||||
|
||||
@@ -3,7 +3,6 @@ package vkauth
|
||||
import (
|
||||
"context"
|
||||
"fmt"
|
||||
"strings"
|
||||
|
||||
"github.com/samosvalishe/free-turn-proxy/internal/provider/vk/internal/browserprofile"
|
||||
"github.com/samosvalishe/free-turn-proxy/internal/provider/vk/internal/captcha"
|
||||
@@ -11,7 +10,7 @@ import (
|
||||
tlsclient "github.com/bogdanfinn/tls-client"
|
||||
)
|
||||
|
||||
func (c *Client) defaultAutoSolve(
|
||||
func (*Client) defaultAutoSolve(
|
||||
ctx context.Context,
|
||||
captchaErr *captcha.Error,
|
||||
streamID int,
|
||||
@@ -19,7 +18,7 @@ func (c *Client) defaultAutoSolve(
|
||||
profile browserprofile.Profile,
|
||||
) (string, error) {
|
||||
log := captcha.Log
|
||||
log.Infof("[STREAM %d] [Captcha] Solving captcha...", streamID)
|
||||
log.Infof("[STREAM %d] [Captcha] Solving captcha (family=%s platform=%s)...", streamID, profile.Family, profile.Platform)
|
||||
|
||||
if captchaErr.SessionToken == "" {
|
||||
return "", fmt.Errorf("no session_token in redirect_uri for auto-solve")
|
||||
@@ -28,45 +27,10 @@ func (c *Client) defaultAutoSolve(
|
||||
return "", fmt.Errorf("no redirect_uri for auto-solve")
|
||||
}
|
||||
|
||||
var savedProfile *browserprofile.Saved
|
||||
switch sp, err := browserprofile.Load(); {
|
||||
case err == nil && savedProfileUsable(*sp):
|
||||
savedFamily := browserprofile.Family(sp.Profile)
|
||||
log.Infof("[STREAM %d] [Captcha] Using captured browser profile (authority) family=%s mobile=%t ua=%q device=%t browser_fp=%t",
|
||||
streamID, savedFamily, browserprofile.IsMobile(sp.Profile), sp.UserAgent, sp.DeviceJSON != "", sp.BrowserFp != "")
|
||||
savedProfile = sp
|
||||
profile = sp.Profile
|
||||
if savedFamily != "" && normalizeFamily(savedFamily) != normalizeFamily(c.browser) {
|
||||
if rebuilt, rebuildErr := c.newTLSClientForKind(savedFamily, tlsclient.NewCookieJar()); rebuildErr == nil {
|
||||
client = rebuilt
|
||||
log.Infof("[STREAM %d] [Captcha] Rebuilt TLS client to match captured family=%s", streamID, savedFamily)
|
||||
} else {
|
||||
log.Warnf("[STREAM %d] [Captcha] Failed to rebuild TLS for captured family=%s: %v; keeping -browser TLS", streamID, savedFamily, rebuildErr)
|
||||
}
|
||||
}
|
||||
case err == nil:
|
||||
log.Warnf("[STREAM %d] [Captcha] Captured profile unusable (empty UA); using -browser fallback", streamID)
|
||||
default:
|
||||
log.Debugf("[STREAM %d] [Captcha] No captured browser profile: %v", streamID, err)
|
||||
}
|
||||
|
||||
successToken, err := captcha.Solve(ctx, captchaErr, streamID, client, profile, savedProfile, log)
|
||||
successToken, err := captcha.Solve(ctx, captchaErr, streamID, client, profile, log)
|
||||
if err != nil {
|
||||
return "", err
|
||||
}
|
||||
log.Infof("[STREAM %d] [Captcha] solver succeeded", streamID)
|
||||
return successToken, nil
|
||||
}
|
||||
|
||||
func savedProfileUsable(saved browserprofile.Saved) bool {
|
||||
return strings.TrimSpace(saved.UserAgent) != ""
|
||||
}
|
||||
|
||||
func normalizeFamily(k browserprofile.Kind) browserprofile.Kind {
|
||||
switch k {
|
||||
case browserprofile.Firefox, browserprofile.Safari:
|
||||
return k
|
||||
default:
|
||||
return browserprofile.Chrome
|
||||
}
|
||||
}
|
||||
|
||||
@@ -6,8 +6,6 @@ import (
|
||||
"sync/atomic"
|
||||
)
|
||||
|
||||
// StreamCredentialsCache хранит TURN-реквизиты для группы потоков
|
||||
// и счётчик ошибок для решений об инвалидации.
|
||||
type StreamCredentialsCache struct {
|
||||
creds TurnCredentials
|
||||
mutex sync.RWMutex
|
||||
@@ -15,7 +13,6 @@ type StreamCredentialsCache struct {
|
||||
lastErrorTime atomic.Int64
|
||||
}
|
||||
|
||||
// Store отображает cache-id ((streamID-1) / streamsPerCache) -> StreamCredentialsCache.
|
||||
type Store struct {
|
||||
mu sync.RWMutex
|
||||
caches map[int]*StreamCredentialsCache
|
||||
@@ -64,7 +61,6 @@ func (s *Store) Get(streamID int) *StreamCredentialsCache {
|
||||
return cache
|
||||
}
|
||||
|
||||
// Invalidate сбрасывает реквизиты кэша потока и обнуляет счётчик ошибок.
|
||||
func (c *StreamCredentialsCache) Invalidate() {
|
||||
c.mutex.Lock()
|
||||
c.creds = TurnCredentials{}
|
||||
@@ -74,8 +70,6 @@ func (c *StreamCredentialsCache) Invalidate() {
|
||||
c.lastErrorTime.Store(0)
|
||||
}
|
||||
|
||||
// IsAuthError проверяет ошибку по эвристике TURN-клиента:
|
||||
// auth/401/stale-nonce - признак инвалидации кэша.
|
||||
func IsAuthError(err error) bool {
|
||||
if err == nil {
|
||||
return false
|
||||
|
||||
@@ -23,7 +23,6 @@ type Config struct {
|
||||
// Credentials для перебора по порядку. nil/empty -> DefaultCredentials.
|
||||
Credentials []VKCredentials
|
||||
|
||||
// Dialer для HTTP-транспорта запросов к VK API.
|
||||
Dialer net.Dialer
|
||||
|
||||
// ManualOnly форсирует ручной путь captcha с первой попытки.
|
||||
@@ -46,18 +45,19 @@ type Config struct {
|
||||
// Нулевое значение -> Chrome (исторический дефолт для прямых вызовов в тестах).
|
||||
Browser browserprofile.Kind
|
||||
|
||||
// Platform - класс устройства персоны (desktop|mobile). Нулевое -> desktop.
|
||||
Platform browserprofile.Platform
|
||||
|
||||
// Log - уровневый логгер. nil -> no-op.
|
||||
Log logx.Logger
|
||||
}
|
||||
|
||||
// Client - фасад VK-аутентификации и кэша реквизитов. Владеет кэшем группы
|
||||
// потоков, глобальным throttle запросов, таймером блокировки captcha и счётчиком
|
||||
// ошибок аутентификации для инвалидации устаревших TURN-реквизитов.
|
||||
type Client struct {
|
||||
credentials []VKCredentials
|
||||
dialer net.Dialer
|
||||
manualOnly bool
|
||||
browser browserprofile.Kind
|
||||
platform browserprofile.Platform
|
||||
streamsFn func() int32
|
||||
autoSolver AutoSolveFunc
|
||||
manualSolve ManualSolveFunc
|
||||
@@ -86,6 +86,7 @@ func New(cfg Config) *Client {
|
||||
dialer: cfg.Dialer,
|
||||
manualOnly: cfg.ManualOnly,
|
||||
browser: cfg.Browser,
|
||||
platform: cfg.Platform,
|
||||
streamsFn: cfg.StreamsAlive,
|
||||
autoSolver: cfg.AutoSolver,
|
||||
manualSolve: cfg.ManualSolver,
|
||||
@@ -108,10 +109,8 @@ func New(cfg Config) *Client {
|
||||
return c
|
||||
}
|
||||
|
||||
// GetCredentials возвращает (username, password, server-addrs) для TURN-allocate,
|
||||
// обращаясь к VK (с throttle + кэшем) только при необходимости. Адреса отдаются
|
||||
// в порядке предпочтения для streamID (предпочтительный первым) - pipeline
|
||||
// пробует их по очереди при allocate.
|
||||
// GetCredentials -> (username, password, server-addrs); addrs ротированы под
|
||||
// streamID (предпочтительный первым, см. orderAddrs), fetch к VK только при промахе кэша.
|
||||
func (c *Client) GetCredentials(ctx context.Context, link string, streamID int) (string, string, []string, error) {
|
||||
cache := c.store.Get(streamID)
|
||||
cacheID := c.store.CacheID(streamID)
|
||||
@@ -165,9 +164,7 @@ func orderAddrs(addrs []string, streamID int) []string {
|
||||
return out
|
||||
}
|
||||
|
||||
// HandleAuthError увеличивает счётчик ошибок аутентификации кэша потока и
|
||||
// инвалидирует кэш при достижении порога внутри скользящего окна.
|
||||
// Возвращает true при инвалидации.
|
||||
// HandleAuthError инвалидирует кэш при MaxCacheErrors в окне ErrorWindow; true = инвалидирован.
|
||||
func (c *Client) HandleAuthError(streamID int) bool {
|
||||
cache := c.store.Get(streamID)
|
||||
cacheID := c.store.CacheID(streamID)
|
||||
@@ -190,35 +187,29 @@ func (c *Client) HandleAuthError(streamID int) bool {
|
||||
return false
|
||||
}
|
||||
|
||||
// ResetErrors обнуляет счётчик ошибок аутентификации (вызывать при успешном allocate).
|
||||
// ResetErrors вызывать при успешном allocate.
|
||||
func (c *Client) ResetErrors(streamID int) {
|
||||
c.store.Get(streamID).errorCount.Store(0)
|
||||
}
|
||||
|
||||
// LockoutUntilUnix возвращает unix-секунду дедлайна глобальной блокировки captcha
|
||||
// или 0, если блокировки нет.
|
||||
func (c *Client) LockoutUntilUnix() int64 {
|
||||
return c.lockout.Load()
|
||||
}
|
||||
|
||||
// BackoffUntilUnix реализует provider.Provider - алиас LockoutUntilUnix.
|
||||
// vkauth-lockout глобальный (без per-stream), streamID-параметра в самом
|
||||
// методе нет; интерфейс provider.Provider определяет no-arg сигнатуру.
|
||||
// BackoffUntilUnix - алиас LockoutUntilUnix: lockout глобальный, а provider.Provider
|
||||
// требует no-arg сигнатуру (без streamID).
|
||||
func (c *Client) BackoffUntilUnix() int64 { return c.LockoutUntilUnix() }
|
||||
|
||||
// Name реализует provider.Provider.
|
||||
func (*Client) Name() string { return "vk" }
|
||||
|
||||
// IsAuthError оборачивает пакетный IsAuthError как метод для работы через интерфейс.
|
||||
func (*Client) IsAuthError(err error) bool { return IsAuthError(err) }
|
||||
|
||||
// engageLockout устанавливает глобальную блокировку captcha на d с момента вызова.
|
||||
func (c *Client) engageLockout(d time.Duration) {
|
||||
c.lockout.Store(time.Now().Add(d).Unix())
|
||||
}
|
||||
|
||||
// fetchSerialized соблюдает интервал 3s+jitter между запросами, затем
|
||||
// выполняет перебор всех credentials.
|
||||
// fetchSerialized сериализует fetch и держит min-интервал между запросами (анти
|
||||
// rate-limit VK).
|
||||
func (c *Client) fetchSerialized(ctx context.Context, link string, streamID int) (string, string, []string, error) {
|
||||
c.fetchMu.Lock()
|
||||
defer c.fetchMu.Unlock()
|
||||
@@ -238,7 +229,6 @@ func (c *Client) fetchSerialized(ctx context.Context, link string, streamID int)
|
||||
return c.fetch(ctx, link, streamID)
|
||||
}
|
||||
|
||||
// fetch перебирает c.credentials, возвращая первый успех или терминальную ошибку.
|
||||
func (c *Client) fetch(ctx context.Context, link string, streamID int) (string, string, []string, error) {
|
||||
if time.Now().Unix() < c.lockout.Load() {
|
||||
return "", "", nil, fmt.Errorf("%w: %w", ErrCaptchaWaitRequired, ErrLockoutActive)
|
||||
@@ -257,7 +247,9 @@ func (c *Client) fetch(ctx context.Context, link string, streamID int) (string,
|
||||
lastErr = err
|
||||
c.log.Warnf("[STREAM %d] [VK Auth] Failed with client_id=%s: %v", streamID, creds.ClientID, err)
|
||||
|
||||
if errors.Is(err, ErrCaptchaWaitRequired) || errors.Is(err, ErrFatalCaptchaNoStreams) {
|
||||
if errors.Is(err, ErrCaptchaWaitRequired) || errors.Is(err, ErrFatalCaptchaNoStreams) ||
|
||||
errors.Is(err, ErrInvalidJoinLink) || errors.Is(err, ErrAnonymousBlocked) ||
|
||||
errors.Is(err, ErrCallFull) {
|
||||
return "", "", nil, err
|
||||
}
|
||||
es := err.Error()
|
||||
|
||||
@@ -10,7 +10,6 @@ import (
|
||||
|
||||
fhttp "github.com/bogdanfinn/fhttp"
|
||||
tlsclient "github.com/bogdanfinn/tls-client"
|
||||
"github.com/bogdanfinn/tls-client/profiles"
|
||||
"golang.org/x/net/proxy"
|
||||
)
|
||||
|
||||
@@ -49,25 +48,10 @@ func (d *splitDialer) DialContext(ctx context.Context, network, addr string) (ne
|
||||
}, nil
|
||||
}
|
||||
|
||||
// clientProfileForKind мапит семейство браузера в TLS/HTTP2-профиль.
|
||||
func clientProfileForKind(kind browserprofile.Kind) profiles.ClientProfile {
|
||||
switch kind {
|
||||
case browserprofile.Safari:
|
||||
return profiles.Safari_16_0
|
||||
case browserprofile.Firefox:
|
||||
return profiles.Firefox_148
|
||||
}
|
||||
return profiles.Chrome_146
|
||||
}
|
||||
|
||||
func (c *Client) newTLSClient(jar tlsclient.CookieJar) (tlsclient.HttpClient, error) {
|
||||
return c.newTLSClientForKind(c.browser, jar)
|
||||
}
|
||||
|
||||
func (c *Client) newTLSClientForKind(kind browserprofile.Kind, jar tlsclient.CookieJar) (tlsclient.HttpClient, error) {
|
||||
func (c *Client) newTLSClient(profile browserprofile.Profile, jar tlsclient.CookieJar) (tlsclient.HttpClient, error) {
|
||||
return tlsclient.NewHttpClient(tlsclient.NewNoopLogger(),
|
||||
tlsclient.WithTimeoutSeconds(20),
|
||||
tlsclient.WithClientProfile(clientProfileForKind(kind)),
|
||||
tlsclient.WithClientProfile(profile.ClientProfile()),
|
||||
tlsclient.WithCookieJar(jar),
|
||||
tlsclient.WithProxyDialerFactory(func(_ string, timeout time.Duration, localAddr *net.TCPAddr, _ fhttp.Header, _ tlsclient.Logger) (proxy.ContextDialer, error) {
|
||||
base := c.dialer
|
||||
|
||||
@@ -10,7 +10,6 @@ import (
|
||||
tlsclient "github.com/bogdanfinn/tls-client"
|
||||
)
|
||||
|
||||
// CaptchaSolveMode - выбор между автоматическим решением и ручным браузерным fallback.
|
||||
type CaptchaSolveMode int
|
||||
|
||||
const (
|
||||
@@ -18,8 +17,6 @@ const (
|
||||
CaptchaSolveModeManual
|
||||
)
|
||||
|
||||
// CaptchaSolveModeForAttempt выбирает решалку для конкретной попытки retry.
|
||||
// Возвращает (mode, true) если режим доступен, (_, false) если исчерпан.
|
||||
func CaptchaSolveModeForAttempt(attempt int, manualOnly bool) (CaptchaSolveMode, bool) {
|
||||
if manualOnly {
|
||||
return CaptchaSolveModeManual, attempt == 0
|
||||
@@ -44,8 +41,6 @@ func CaptchaSolveModeLabel(mode CaptchaSolveMode) string {
|
||||
}
|
||||
}
|
||||
|
||||
// AutoSolveFunc возвращает success_token для captcha через in-page widget flow.
|
||||
// Реализации обязаны соблюдать отмену ctx.
|
||||
type AutoSolveFunc func(
|
||||
ctx context.Context,
|
||||
captchaErr *captcha.Error,
|
||||
@@ -54,11 +49,8 @@ type AutoSolveFunc func(
|
||||
profile browserprofile.Profile,
|
||||
) (token string, err error)
|
||||
|
||||
// ManualSolveFunc открывает локальный браузерный fallback. Возвращает либо
|
||||
// success_token (token != ""), либо captcha_key - в зависимости от пути
|
||||
// ошибки VK.
|
||||
type ManualSolveFunc func(
|
||||
ctx context.Context,
|
||||
captchaErr *captcha.Error,
|
||||
dialer net.Dialer,
|
||||
) (token, key string, err error)
|
||||
) (token string, err error)
|
||||
|
||||
@@ -2,8 +2,6 @@ package vkauth
|
||||
|
||||
import (
|
||||
"testing"
|
||||
|
||||
"github.com/samosvalishe/free-turn-proxy/internal/provider/vk/internal/browserprofile"
|
||||
)
|
||||
|
||||
func TestCaptchaSolveModeForAttempt(t *testing.T) {
|
||||
@@ -40,38 +38,3 @@ func TestCaptchaSolveModeForAttempt(t *testing.T) {
|
||||
}
|
||||
})
|
||||
}
|
||||
|
||||
func TestSavedProfileUsable(t *testing.T) {
|
||||
t.Parallel()
|
||||
|
||||
if savedProfileUsable(browserprofile.Saved{}) {
|
||||
t.Fatal("empty profile must be unusable (no UA to impersonate)")
|
||||
}
|
||||
if savedProfileUsable(browserprofile.Saved{Profile: browserprofile.Profile{UserAgent: " "}}) {
|
||||
t.Fatal("whitespace UA must be unusable")
|
||||
}
|
||||
mobile := browserprofile.Saved{Profile: browserprofile.Profile{
|
||||
UserAgent: "Mozilla/5.0 (Linux; Android 14; Pixel 8) AppleWebKit/537.36 (KHTML, like Gecko) Chrome/146.0.0.0 Mobile Safari/537.36",
|
||||
SecChUaMobile: "?1",
|
||||
}}
|
||||
if !savedProfileUsable(mobile) {
|
||||
t.Fatal("captured mobile profile must be usable")
|
||||
}
|
||||
}
|
||||
|
||||
func TestNormalizeFamily(t *testing.T) {
|
||||
t.Parallel()
|
||||
|
||||
cases := map[browserprofile.Kind]browserprofile.Kind{
|
||||
browserprofile.Firefox: browserprofile.Firefox,
|
||||
browserprofile.Safari: browserprofile.Safari,
|
||||
browserprofile.Chrome: browserprofile.Chrome,
|
||||
"": browserprofile.Chrome,
|
||||
"weird": browserprofile.Chrome,
|
||||
}
|
||||
for in, want := range cases {
|
||||
if got := normalizeFamily(in); got != want {
|
||||
t.Fatalf("normalizeFamily(%q) = %q, want %q", in, got, want)
|
||||
}
|
||||
}
|
||||
}
|
||||
|
||||
@@ -15,9 +15,9 @@ import (
|
||||
// и возвращает тройку TURN-allocate. Ошибки captcha запускают настроенную цепочку
|
||||
// auto/manual solver.
|
||||
func (c *Client) getTokenChain(ctx context.Context, link string, streamID int, creds VKCredentials, jar tlsclient.CookieJar) (string, string, []string, error) {
|
||||
profile := browserprofile.ForKind(c.browser)
|
||||
profile := browserprofile.For(c.browser, c.platform)
|
||||
|
||||
httpClient, err := c.newTLSClient(jar)
|
||||
httpClient, err := c.newTLSClient(profile, jar)
|
||||
if err != nil {
|
||||
return "", "", nil, fmt.Errorf("failed to initialize tls_client: %w", err)
|
||||
}
|
||||
|
||||
@@ -5,6 +5,7 @@ import (
|
||||
"errors"
|
||||
"fmt"
|
||||
neturl "net/url"
|
||||
"strings"
|
||||
"time"
|
||||
|
||||
"github.com/samosvalishe/free-turn-proxy/internal/provider/vk/internal/browserprofile"
|
||||
@@ -43,6 +44,10 @@ func (c *Client) fetchCallToken(
|
||||
data = retryData
|
||||
continue
|
||||
}
|
||||
if termErr := classifyLinkError(errObj); termErr != nil {
|
||||
c.log.Errorf("[STREAM %d] [VK Auth] terminal link error: %v", streamID, termErr)
|
||||
return "", termErr
|
||||
}
|
||||
return "", fmt.Errorf("VK API error: %v", errObj)
|
||||
}
|
||||
|
||||
@@ -58,6 +63,48 @@ func (c *Client) fetchCallToken(
|
||||
}
|
||||
}
|
||||
|
||||
// classifyLinkError распознаёт ТЕРМИНАЛЬНЫЕ ответы VK в join-флоу и возвращает
|
||||
// соответствующий sentinel (или nil, если ошибку можно ретраить дальше по
|
||||
// client_id). Терминал = ни client_id, ни captcha не помогут, поэтому fast-fail
|
||||
// вместо бесконечного цикла "решить captcha -> ошибка -> следующий client_id".
|
||||
//
|
||||
// Порядок важен: сначала явные коды (терминальные и транзиентные), и только для
|
||||
// неизвестного кода - матч по тексту error_msg. Так текстовый матч не может
|
||||
// перекрыть транзиентный код (5 auth-failed, 6/9/29 rate/flood, 14 captcha) и
|
||||
// убить рабочее подключение из-за подстроки в сообщении.
|
||||
func classifyLinkError(errObj map[string]any) error {
|
||||
code := 0
|
||||
if f, ok := errObj["error_code"].(float64); ok {
|
||||
code = int(f)
|
||||
}
|
||||
|
||||
// Явные терминальные коды: 9008 Join link is not valid, 9000 Call not found.
|
||||
if code == 9000 || code == 9008 {
|
||||
return ErrInvalidJoinLink
|
||||
}
|
||||
// Явные транзиентные коды: гасить нельзя, текст ниже к ним не применяем.
|
||||
switch code {
|
||||
case 5, 6, 9, 14, 29:
|
||||
return nil
|
||||
}
|
||||
|
||||
// Код неизвестен/плавает - осторожный матч по тексту.
|
||||
msg := ""
|
||||
if s, ok := errObj["error_msg"].(string); ok {
|
||||
msg = strings.ToLower(s)
|
||||
}
|
||||
switch {
|
||||
case strings.Contains(msg, "not valid") || strings.Contains(msg, "not found"):
|
||||
return ErrInvalidJoinLink
|
||||
// Анонимный вход запрещён. Матчим по "anonym" (не "authoriz" - коллизия с auth-failed).
|
||||
case strings.Contains(msg, "anonym"):
|
||||
return ErrAnonymousBlocked
|
||||
case strings.Contains(msg, "full"):
|
||||
return ErrCallFull
|
||||
}
|
||||
return nil
|
||||
}
|
||||
|
||||
// solveCaptcha выполняет одну попытку решения captcha и возвращает тело POST
|
||||
// для следующего retry или ошибку при исчерпании всех режимов.
|
||||
func (c *Client) solveCaptcha(
|
||||
@@ -80,7 +127,6 @@ func (c *Client) solveCaptcha(
|
||||
}
|
||||
|
||||
var successToken string
|
||||
var captchaKey string
|
||||
var solveErr error
|
||||
|
||||
switch solveMode {
|
||||
@@ -111,21 +157,19 @@ func (c *Client) solveCaptcha(
|
||||
|
||||
type manualRes struct {
|
||||
token string
|
||||
key string
|
||||
err error
|
||||
}
|
||||
resCh := make(chan manualRes, 1)
|
||||
go func() {
|
||||
t, k, e := c.manualSolve(manualCtx, captchaErr, c.dialer)
|
||||
resCh <- manualRes{t, k, e}
|
||||
t, e := c.manualSolve(manualCtx, captchaErr, c.dialer)
|
||||
resCh <- manualRes{t, e}
|
||||
}()
|
||||
|
||||
select {
|
||||
case res := <-resCh:
|
||||
successToken = res.token
|
||||
captchaKey = res.key
|
||||
solveErr = res.err
|
||||
if successToken != "" || captchaKey != "" {
|
||||
if successToken != "" {
|
||||
if solveErr != nil {
|
||||
c.log.Debugf("[STREAM %d] [Captcha] Token received (ignoring cleanup error: %v)", streamID, solveErr)
|
||||
solveErr = nil
|
||||
@@ -151,7 +195,7 @@ func (c *Client) solveCaptcha(
|
||||
if hasNextSolveMode {
|
||||
c.log.Infof("[STREAM %d] [Captcha] Falling back to %s",
|
||||
streamID, CaptchaSolveModeLabel(nextSolveMode))
|
||||
return buildCaptchaRetryData(link, escapedName, token1, captchaErr, "", captchaKey), nil
|
||||
return buildCaptchaRetryData(link, escapedName, token1, captchaErr, ""), nil
|
||||
}
|
||||
c.engageLockout(60 * time.Second)
|
||||
if c.streamsFn() == 0 {
|
||||
@@ -164,23 +208,16 @@ func (c *Client) solveCaptcha(
|
||||
if captchaErr.CaptchaAttempt == "0" || captchaErr.CaptchaAttempt == "" {
|
||||
captchaErr.CaptchaAttempt = "1"
|
||||
}
|
||||
return buildCaptchaRetryData(link, escapedName, token1, captchaErr, successToken, captchaKey), nil
|
||||
return buildCaptchaRetryData(link, escapedName, token1, captchaErr, successToken), nil
|
||||
}
|
||||
|
||||
// buildCaptchaRetryData формирует тело POST для следующей попытки captcha.
|
||||
func buildCaptchaRetryData(link, escapedName, token1 string, captchaErr *captcha.Error, successToken, captchaKey string) string {
|
||||
func buildCaptchaRetryData(link, escapedName, token1 string, captchaErr *captcha.Error, successToken string) string {
|
||||
if captchaErr.CaptchaSid == "" {
|
||||
return fmt.Sprintf(
|
||||
"vk_join_link=https://vk.ru/call/join/%s&name=%s&success_token=%s&access_token=%s",
|
||||
link, escapedName, neturl.QueryEscape(successToken), token1,
|
||||
)
|
||||
}
|
||||
if captchaKey != "" {
|
||||
return fmt.Sprintf(
|
||||
"vk_join_link=https://vk.ru/call/join/%s&name=%s&captcha_key=%s&captcha_sid=%s&access_token=%s",
|
||||
link, escapedName, neturl.QueryEscape(captchaKey), captchaErr.CaptchaSid, token1,
|
||||
)
|
||||
}
|
||||
return fmt.Sprintf(
|
||||
"vk_join_link=https://vk.ru/call/join/%s&name=%s&captcha_key=&captcha_sid=%s&is_sound_captcha=0&success_token=%s&captcha_ts=%s&captcha_attempt=%s&access_token=%s",
|
||||
link, escapedName, captchaErr.CaptchaSid, neturl.QueryEscape(successToken),
|
||||
|
||||
@@ -14,8 +14,6 @@ import (
|
||||
tlsclient "github.com/bogdanfinn/tls-client"
|
||||
)
|
||||
|
||||
// doRequest отправляет POST form-запрос по url через tls-клиент с браузерным
|
||||
// профилем и десериализует JSON-тело ответа.
|
||||
func (c *Client) doRequest(ctx context.Context, httpClient tlsclient.HttpClient, profile browserprofile.Profile, data, url string) (map[string]any, error) {
|
||||
parsedURL, err := neturl.Parse(url)
|
||||
if err != nil {
|
||||
|
||||
@@ -7,13 +7,11 @@ import (
|
||||
"github.com/samosvalishe/free-turn-proxy/internal/provider"
|
||||
)
|
||||
|
||||
// VKCredentials - пара app_id/app_secret для получения анонимных токенов.
|
||||
type VKCredentials struct {
|
||||
ClientID string
|
||||
ClientSecret string
|
||||
}
|
||||
|
||||
// TurnCredentials - разрешённые TURN-реквизиты для группы потоков.
|
||||
type TurnCredentials struct {
|
||||
Username string
|
||||
Password string
|
||||
@@ -22,13 +20,9 @@ type TurnCredentials struct {
|
||||
Link string
|
||||
}
|
||||
|
||||
// DefaultCredentials - публичные app_id/secret официальных VK-клиентов. Это НЕ
|
||||
// приватные креды пользователя - VK раздаёт их в JS-бандле страницы калла.
|
||||
// Клиент перебирает по порядку при ошибках авторизации. В списке только app_id
|
||||
// с доступом к calls.getAnonymousToken (проверено живым звонком); приложения
|
||||
// без calls-scope ("Unknown method passed") исключены.
|
||||
// Публичные app_id/secret штатных VK-клиентов (зашиты в сами приложения), не наши приватные креды.
|
||||
//
|
||||
//nolint:gosec // public VK SDK app credentials, not user secrets
|
||||
//nolint:gosec // G101: публичные VK app secrets
|
||||
var DefaultCredentials = []VKCredentials{
|
||||
{ClientID: "6287487", ClientSecret: "QbYic1K3lEV5kTGiqlq2"}, // VK_WEB_APP_ID
|
||||
{ClientID: "7879029", ClientSecret: "aR5NKGmm03GYrCiNKsaw"}, // VK_MVK_APP_ID
|
||||
@@ -37,8 +31,6 @@ var DefaultCredentials = []VKCredentials{
|
||||
{ClientID: "3140623", ClientSecret: "VeWdmVclDCtn6ihuP1nt"}, // VK_IPHONE_APP
|
||||
}
|
||||
|
||||
// APIVersion - версия VK API во всех calls.* запросах. Держать единой и близкой
|
||||
// к версии живого web-клиента звонка (рассинхрон = fingerprint-аномалия).
|
||||
const APIVersion = "5.282"
|
||||
|
||||
const (
|
||||
@@ -50,13 +42,11 @@ const (
|
||||
DefaultStreamsPerCache = 10
|
||||
)
|
||||
|
||||
// Sentinel-ошибки auth-потока. Строковые формы стабильны (используются в логах).
|
||||
//
|
||||
// ErrCaptchaWaitRequired и ErrFatalCaptchaNoStreams также матчатся через
|
||||
// provider.ErrBackoffActive / provider.ErrFatalNoStreams - pipeline проверяет
|
||||
// generic-sentinels, vkauth-внутренний код может проверять и старые.
|
||||
var (
|
||||
ErrCaptchaWaitRequired = errors.Join(provider.ErrBackoffActive, errors.New("CAPTCHA_WAIT_REQUIRED"))
|
||||
ErrFatalCaptchaNoStreams = errors.Join(provider.ErrFatalNoStreams, errors.New("FATAL_CAPTCHA_FAILED_NO_STREAMS"))
|
||||
ErrLockoutActive = errors.New("global lockout active")
|
||||
ErrInvalidJoinLink = errors.Join(provider.ErrFatalNoStreams, errors.New("INVALID_JOIN_LINK"))
|
||||
ErrAnonymousBlocked = errors.Join(provider.ErrFatalNoStreams, errors.New("ANON_BLOCKED"))
|
||||
ErrCallFull = errors.Join(provider.ErrFatalNoStreams, errors.New("CALL_FULL"))
|
||||
)
|
||||
|
||||
@@ -14,9 +14,9 @@ var proxyManualMu sync.Mutex
|
||||
|
||||
// ProxyManualSolver показывает UI после запуска локального captcha-прокси.
|
||||
func ProxyManualSolver(show func(url string), hide func()) ManualSolverFunc {
|
||||
return func(ctx context.Context, e *captcha.Error, dialer net.Dialer) (string, string, error) {
|
||||
return func(ctx context.Context, e *captcha.Error, dialer net.Dialer) (string, error) {
|
||||
if e.RedirectURI == "" {
|
||||
return "", "", fmt.Errorf("manual captcha: no redirect_uri")
|
||||
return "", fmt.Errorf("manual captcha: no redirect_uri")
|
||||
}
|
||||
|
||||
proxyManualMu.Lock()
|
||||
@@ -25,7 +25,6 @@ func ProxyManualSolver(show func(url string), hide func()) ManualSolverFunc {
|
||||
defer hide()
|
||||
}
|
||||
|
||||
token, err := manualcaptcha.SolveViaProxyWithPresenter(ctx, e.RedirectURI, dialer, show)
|
||||
return token, "", err
|
||||
return manualcaptcha.SolveViaProxyWithPresenter(ctx, e.RedirectURI, dialer, show)
|
||||
}
|
||||
}
|
||||
|
||||
+11
-32
@@ -1,10 +1,3 @@
|
||||
// Package vk - провайдер TURN-реквизитов через VK Calls API.
|
||||
//
|
||||
// Фасад над internal/provider/vk/internal/vkauth: добавляет фиксированный link (адрес
|
||||
// VK callroom) и адаптирует сигнатуру GetCredentials к provider.Provider.
|
||||
//
|
||||
// vk.Provider удовлетворяет provider.Provider и используется через generic
|
||||
// pipeline (proxy/udprelay, proxy/tcpfwd) без VK-specific импортов.
|
||||
package vk
|
||||
|
||||
import (
|
||||
@@ -20,22 +13,22 @@ import (
|
||||
"github.com/samosvalishe/free-turn-proxy/internal/provider/vk/internal/vkauth"
|
||||
)
|
||||
|
||||
// Config - параметры VK-провайдера.
|
||||
type Config struct {
|
||||
// Link - VK callroom join-код (нормализованный, без префикса URL).
|
||||
// Обязателен.
|
||||
// Link - VK callroom join-код (нормализованный, без префикса URL). Обязателен.
|
||||
Link string
|
||||
|
||||
// Dialer для HTTP-транспорта VK API.
|
||||
Dialer net.Dialer
|
||||
|
||||
// ManualOnly форсирует ручной путь captcha с первой попытки.
|
||||
ManualOnly bool
|
||||
|
||||
// Browser - браузерный профиль control-plane: "chrome" | "firefox" | "safari".
|
||||
// Пустое -> firefox (дефолт продукта).
|
||||
// Пустое -> firefox
|
||||
Browser string
|
||||
|
||||
// Platform - класс устройства персоны: "desktop" | "mobile". Пустое -> desktop.
|
||||
Platform string
|
||||
|
||||
// StreamsPerCache - делитель streamID -> cacheID. <=0 -> дефолт (10).
|
||||
StreamsPerCache int
|
||||
|
||||
@@ -57,14 +50,12 @@ type Config struct {
|
||||
// решать ручную captcha (поток падает на ErrFatalNoStreams при auto-fail).
|
||||
type ManualSolverFunc = vkauth.ManualSolveFunc
|
||||
|
||||
// Provider реализует provider.Provider через vkauth.Client + сохранённый link.
|
||||
type Provider struct {
|
||||
link string
|
||||
auth *vkauth.Client
|
||||
}
|
||||
|
||||
// New создаёт VK-провайдер. solver - функция ручного решения captcha
|
||||
// (опциональная); если nil - manual captcha путь отключён.
|
||||
// New: solver nil -> ручной путь captcha отключён (поток падает на auto-fail).
|
||||
func New(cfg Config, solver ManualSolverFunc) (*Provider, error) {
|
||||
if cfg.Link == "" {
|
||||
return nil, fmt.Errorf("vk: empty Link")
|
||||
@@ -79,6 +70,7 @@ func New(cfg Config, solver ManualSolverFunc) (*Provider, error) {
|
||||
Dialer: cfg.Dialer,
|
||||
ManualOnly: cfg.ManualOnly,
|
||||
Browser: browserprofile.KindFromString(cfg.Browser),
|
||||
Platform: browserprofile.PlatformFromString(cfg.Platform),
|
||||
StreamsPerCache: cfg.StreamsPerCache,
|
||||
StreamsAlive: cfg.StreamsAlive,
|
||||
ManualSolver: solver,
|
||||
@@ -87,7 +79,6 @@ func New(cfg Config, solver ManualSolverFunc) (*Provider, error) {
|
||||
return &Provider{link: cfg.Link, auth: auth}, nil
|
||||
}
|
||||
|
||||
// GetCredentials реализует provider.Provider.
|
||||
func (p *Provider) GetCredentials(ctx context.Context, streamID int) (provider.Credentials, error) {
|
||||
user, pass, addrs, err := p.auth.GetCredentials(ctx, p.link, streamID)
|
||||
if err != nil {
|
||||
@@ -96,31 +87,19 @@ func (p *Provider) GetCredentials(ctx context.Context, streamID int) (provider.C
|
||||
return provider.Credentials{User: user, Pass: pass, ServerAddrs: addrs}, nil
|
||||
}
|
||||
|
||||
// IsAuthError реализует provider.Provider.
|
||||
func (p *Provider) IsAuthError(err error) bool { return p.auth.IsAuthError(err) }
|
||||
|
||||
// HandleAuthError реализует provider.Provider.
|
||||
func (p *Provider) HandleAuthError(streamID int) bool { return p.auth.HandleAuthError(streamID) }
|
||||
|
||||
// ResetErrors реализует provider.Provider.
|
||||
func (p *Provider) ResetErrors(streamID int) { p.auth.ResetErrors(streamID) }
|
||||
|
||||
// BackoffUntilUnix реализует provider.Provider.
|
||||
func (p *Provider) BackoffUntilUnix() int64 { return p.auth.BackoffUntilUnix() }
|
||||
|
||||
// Name реализует provider.Provider.
|
||||
func (*Provider) Name() string { return "vk" }
|
||||
|
||||
// DefaultManualSolver - стандартный manual-captcha solver, использует
|
||||
// internal/provider/vk/internal/captcha/manual (HTTP-сервер 127.0.0.1:8765 + браузер).
|
||||
func DefaultManualSolver(ctx context.Context, e *captcha.Error, d net.Dialer) (string, string, error) {
|
||||
if e.RedirectURI != "" {
|
||||
t, err := manualcaptcha.SolveViaProxy(ctx, e.RedirectURI, d)
|
||||
return t, "", err
|
||||
func DefaultManualSolver(ctx context.Context, e *captcha.Error, d net.Dialer) (string, error) {
|
||||
if e.RedirectURI == "" {
|
||||
return "", fmt.Errorf("no redirect_uri")
|
||||
}
|
||||
if e.CaptchaImg != "" {
|
||||
k, err := manualcaptcha.SolveViaHTTP(ctx, e.CaptchaImg)
|
||||
return "", k, err
|
||||
}
|
||||
return "", "", fmt.Errorf("no redirect_uri or captcha_img")
|
||||
return manualcaptcha.SolveViaProxy(ctx, e.RedirectURI, d)
|
||||
}
|
||||
|
||||
@@ -17,6 +17,7 @@ import (
|
||||
"github.com/pion/logging"
|
||||
"github.com/pion/turn/v5"
|
||||
"github.com/samosvalishe/free-turn-proxy/internal/netconn"
|
||||
"github.com/samosvalishe/free-turn-proxy/internal/netctl"
|
||||
"github.com/samosvalishe/free-turn-proxy/internal/randx"
|
||||
)
|
||||
|
||||
@@ -83,10 +84,15 @@ func Open(ctx context.Context, cfg Config, peer *net.UDPAddr, user, pass, rawAdd
|
||||
closeConn func() error
|
||||
)
|
||||
if cfg.TransportUDP {
|
||||
c, derr := net.DialUDP("udp", nil, turnServerUDPAddr) //nolint:noctx
|
||||
raw, derr := (&net.Dialer{Control: netctl.Apply}).Dial("udp", turnServerUDPAddr.String())
|
||||
if derr != nil {
|
||||
return nil, fmt.Errorf("dial TURN (udp): %w", derr)
|
||||
}
|
||||
c, ok := raw.(*net.UDPConn)
|
||||
if !ok {
|
||||
_ = raw.Close()
|
||||
return nil, fmt.Errorf("turndial: expected *net.UDPConn, got %T", raw)
|
||||
}
|
||||
turnConn = &netconn.ConnectedUDPConn{UDPConn: c}
|
||||
closeConn = c.Close
|
||||
} else {
|
||||
|
||||
@@ -0,0 +1,30 @@
|
||||
package mobile
|
||||
|
||||
import (
|
||||
"syscall"
|
||||
|
||||
"github.com/samosvalishe/free-turn-proxy/internal/netctl"
|
||||
)
|
||||
|
||||
// Protector is implemented by the host to keep the client's own sockets out of
|
||||
// a VPN tunnel it is feeding. On Android that is VpnService.protect(fd); on
|
||||
// other tun-based hosts the equivalent. Without it the client's TURN / VK API /
|
||||
// DNS traffic is routed back into the tunnel and the connection deadlocks.
|
||||
type Protector interface {
|
||||
// Protect is invoked once for every outbound socket the client opens, with
|
||||
// the socket's raw file descriptor, before it connects.
|
||||
Protect(fd int) bool
|
||||
}
|
||||
|
||||
// SetProtect installs the host socket protector. Pass nil to clear it (the
|
||||
// default is a no-op, so desktop builds are unaffected). May be called before
|
||||
// or after Start; it is read at dial time.
|
||||
func SetProtect(p Protector) {
|
||||
if p == nil {
|
||||
netctl.SetControl(nil)
|
||||
return
|
||||
}
|
||||
netctl.SetControl(func(_, _ string, c syscall.RawConn) error {
|
||||
return c.Control(func(fd uintptr) { p.Protect(int(fd)) })
|
||||
})
|
||||
}
|
||||
Reference in New Issue
Block a user