mirror of
https://github.com/hackdiaz-dev/free-turn-proxy.git
synced 2026-10-12 09:41:53 +02:00
samosvalishe
12161aed4a
- Добавлена поддержка Safari в -browser.
Обновлена валидация флага, документация и выбор TLS/HTTP2-профиля для
chrome, firefox и safari.
- Улучшено переиспользование сохранённого браузерного профиля.
Добавлен VK_PROFILE_PATH, сохраняется Accept-Language, определяется семейство
браузера и mobile-профиль, а TLS-клиент пересобирается под захваченный UA.
- Обновлена форма запросов VK Smart Captcha.
Учитываются domain из redirect_uri, id.vk.ru origin/referer, settings_key для
slider captcha, сохранённый browser_fp и device JSON.
- Улучшено автоматическое решение captcha.
Обновлён формат PoW-ответа, добавлена mobile accelerometer телеметрия,
NetworkInformation отправляется только для Chromium-профилей, а slider solver
получил обратный скоринг и более естественные cursor traces.
- Убрано шумное throughput debug-логирование в relay-путях.
Удалён Stats.LogEvery и его вызовы в UDP/TCP relay, при этом агрегированная
TrafficStats-статистика сохранена.
- Обновлены тесты и инфраструктура сборки.
Добавлены проверки Safari, browser profile storage, captcha telemetry и
saved-profile fallback; tls-client обновлён до v1.15.1; Android bind в
Taskfile разделён для Windows и Unix-платформ
94 lines
2.2 KiB
Go
94 lines
2.2 KiB
Go
// Package stats - счётчики пропускной способности и обёртка net.Conn
|
|
// с подсчётом байт. Используется и клиентом, и сервером.
|
|
package stats
|
|
|
|
import (
|
|
"fmt"
|
|
"net"
|
|
"sync/atomic"
|
|
"time"
|
|
)
|
|
|
|
// Stats хранит счётчики tx/rx байт. При enabled=false Add* - no-op.
|
|
type Stats struct {
|
|
tx atomic.Uint64
|
|
rx atomic.Uint64
|
|
enabled bool
|
|
}
|
|
|
|
// New возвращает Stats с заданным флагом enabled.
|
|
func New(enabled bool) *Stats {
|
|
return &Stats{enabled: enabled}
|
|
}
|
|
|
|
func (s *Stats) Counters() (tx, rx uint64) {
|
|
return s.tx.Load(), s.rx.Load()
|
|
}
|
|
|
|
// AddTx учитывает n переданных байт.
|
|
func (s *Stats) AddTx(n int) {
|
|
if n <= 0 {
|
|
return
|
|
}
|
|
if !s.enabled {
|
|
return
|
|
}
|
|
s.tx.Add(uint64(n))
|
|
}
|
|
|
|
// AddRx учитывает n полученных байт.
|
|
func (s *Stats) AddRx(n int) {
|
|
if n <= 0 {
|
|
return
|
|
}
|
|
if !s.enabled {
|
|
return
|
|
}
|
|
s.rx.Add(uint64(n))
|
|
}
|
|
|
|
// FormatBitsPerSecond форматирует пропускную способность из числа байт и интервала.
|
|
func FormatBitsPerSecond(bytes uint64, interval time.Duration) string {
|
|
if interval <= 0 {
|
|
interval = time.Second
|
|
}
|
|
|
|
bps := float64(bytes*8) / interval.Seconds()
|
|
if bps >= 1_000_000 {
|
|
return fmt.Sprintf("%.2f Mbit/s", bps/1_000_000)
|
|
}
|
|
if bps >= 1_000 {
|
|
return fmt.Sprintf("%.1f kbit/s", bps/1_000)
|
|
}
|
|
return fmt.Sprintf("%.0f bit/s", bps)
|
|
}
|
|
|
|
// FormatByteCount форматирует число байт в человекочитаемый вид.
|
|
func FormatByteCount(bytes uint64) string {
|
|
if bytes >= 1024*1024 {
|
|
return fmt.Sprintf("%.2f MiB", float64(bytes)/(1024*1024))
|
|
}
|
|
if bytes >= 1024 {
|
|
return fmt.Sprintf("%.1f KiB", float64(bytes)/1024)
|
|
}
|
|
return fmt.Sprintf("%d B", bytes)
|
|
}
|
|
|
|
// CountingConn оборачивает net.Conn и аккумулирует rx/tx-счётчики в Stats.
|
|
type CountingConn struct {
|
|
net.Conn
|
|
Stats *Stats
|
|
}
|
|
|
|
func (c *CountingConn) Read(p []byte) (int, error) {
|
|
n, err := c.Conn.Read(p)
|
|
c.Stats.AddRx(n)
|
|
return n, err
|
|
}
|
|
|
|
func (c *CountingConn) Write(p []byte) (int, error) {
|
|
n, err := c.Conn.Write(p)
|
|
c.Stats.AddTx(n)
|
|
return n, err
|
|
}
|