core

type CallUnavailableError struct {
	Code    int
	Message string
}

type Config struct {

	// Peer — адрес VPS в виде host:port.
	Peer string
	// Password — пароль подключения. Из него же выводится WRAP-ключ
	// RTP-обфускации (см. deriveWrapKey), поэтому это полноценный секрет.
	Password string
	// Hashes — хеши звонков VK. Нормализуются и дедуплицируются в Normalize.
	Hashes []string

	// DeviceID — идентификатор устройства; сервер привязывает к нему пароль.
	DeviceID string

	// VkAuthMode — anonymous или account.
	VkAuthMode string
	// VkAnonPath — vkcalls или legacy; учитывается только при anonymous.
	VkAnonPath string
	// VkCredsFile — файл с готовыми TURN-кредами от аккаунта VK.
	VkCredsFile string
	// CaptchaMode — auto, rjs или wv.
	CaptchaMode string

	// TurnHost и TurnPort переопределяют адрес TURN, выданный VK. Пусто = не менять.
	TurnHost string
	TurnPort string
	// TurnTCP — соединяться с TURN-relay по TCP вместо UDP.
	// Помогает в сетях, где душат UDP.
	TurnTCP bool
	// NoDTLS — не поднимать DTLS поверх TURN: RTP-обфускация уже даёт
	// шифрование и аутентификацию каждого пакета. Требует сервера,
	// запущенного с -listen-direct.
	NoDTLS bool
	// ObfsMode — audio или video. Различаются payload type и объёмом набивки.
	ObfsMode string
	// Workers — число воркеров. Normalize приводит его к допустимому значению.
	Workers int
	// DNS — резолвер для доменов VK: yandex, cloudflare, google,
	// doh-yandex, doh-cloudflare, doh-google, custom:IP или doh:URL.
	DNS string

	// Listen — локальный UDP-адрес, куда datapath отдаёт трафик.
	//
	// Что именно подаёт в него трафик — userspace WireGuard с SOCKS5, штатный
	// wireguard.exe или свой адаптер — ядра не касается: оно только принимает
	// UDP и отдаёт наружу конфиг событием EventConfig. Выбор и настройки
	// datapath живут в internal/datapath (architecture.md §04).
	Listen string

	// PacketConn — готовый канал к datapath вместо UDP на Listen: свой
	// conn.Bind у wireguard-go (datapath.Pipe, plan-e3.md, блок B). Задан —
	// ядро сокета не открывает, а из Listen берёт только номер порта для
	// GETCONF: сервер возвращает его в Endpoint конфига. Run закрывает
	// PacketConn при любом возврате. nil — UDP на Listen, как раньше: так
	// работает external, wireguard.exe — чужой процесс. Из профиля не
	// читается.
	PacketConn net.PacketConn

	// DialControl ставится в поле Control всех собственных сокетов ядра:
	// TURN, DNS, DoH и HTTPS к VK (см. netguard_hook.go). Его задаёт CLI,
	// когда datapath забирает весь трафик системы, — это netguard.Guard.Control,
	// который уводит сокеты мимо туннеля (architecture.md §05). Из профиля не
	// читается. nil — сокеты идут по общей таблице маршрутов, как в Э1.
	DialControl DialControlFunc
}

type Control struct {
	// contains filtered or unexported fields
}

type Credentials struct {
	User          string
	Pass          string
	TurnURLs      []string
	CacheStreamID int
}

type DialControlFunc = func(network, address string, c syscall.RawConn) error

type Dispatcher struct {
	ReturnCh chan []byte
	// contains filtered or unexported fields
}

type Event interface {
	// contains filtered or unexported methods
}

type EventCaptchaRequired struct {
	// Session — номер потока, запросившего капчу.
	Session int
	// Mode — auto, manual или selected: чем занималось ядро до того, как сдалось.
	Mode string
	// RedirectURI — страница капчи VK, которую нужно открыть.
	RedirectURI string
	// SessionToken — токен сессии капчи; без него ответ не примут.
	SessionToken string
}

type EventConfig struct {
	WireGuard string
}

type EventHashCheck struct {
	// Index — номер хеша, начиная с единицы; Total — сколько их всего.
	Index int
	Total int
	Hash  string

	Status HashCheckStatus
	Msg    string
}

type EventHashFailed struct {
	// Hash — хеш звонка, по которому не вышло. Целиком: супервизор сопоставляет
	// его со своим списком. Печатать его нельзя — хеши лежат в хранилище
	// секретов (задача C2).
	Hash string
	// Group — номер группы воркеров, начиная с единицы.
	Group int
	// Status — чем кончилась попытка. HashCheckDead означает, что звонок закрыт
	// и с тем же хешем не поможет ни повтор, ни перезапуск; остальные статусы
	// временные.
	Status HashCheckStatus
	// Msg — пояснение для пользователя.
	Msg string
}

type EventLog struct {
	Level LogLevel
	Tag   string
	Msg   string
}

type EventPing struct {
	RTT time.Duration
	Err error
}

type EventStage struct {
	Stage   Stage
	Status  StageStatus
	Session int
	Msg     string
}

type EventStats struct {
	// ActiveWorkers — сколько воркеров сейчас держат соединение.
	ActiveWorkers int32
	// BytesUp и BytesDown — нарастающий итог с момента запуска.
	BytesUp   int64
	BytesDown int64
}

type EventVkAuthRequired struct {
	// Link — ссылка на звонок, для которого нужны креды.
	Link string
}

type HashCheckStatus string

type LogLevel string

type NullLogger struct{}

type NullLoggerFactory struct{}

type ObfsConfig struct {
	SSRC        uint32 // Synchronization Source — random per session
	PayloadType uint8  // RTP payload type (111 = OPUS dynamic)
	PaddingMax  int    // Max random padding bytes appended
}

type ObfsState struct {
	// contains filtered or unexported fields
}

type Profile struct {
	UserAgent       string `json:"user_agent"`
	SecChUa         string `json:"sec_ch_ua"`
	SecChUaMobile   string `json:"sec_ch_ua_mobile"`
	SecChUaPlatform string `json:"sec_ch_ua_platform"`
}

type SavedProfile struct {
	Profile
	DeviceJSON string `json:"device_json"`
	BrowserFp  string `json:"browser_fp"`
}

type Sink interface{ Emit(Event) }

type SinkFunc func(Event)

type Stage string

type StageStatus string

type Stats struct {
	TotalBytesUp      atomic.Int64
	TotalBytesDown    atomic.Int64
	ActiveConnections atomic.Int32
}

type StreamCredentialsCache struct {
	// contains filtered or unexported fields
}

type TurnCredentials struct {
	Username    string
	Password    string
	ServerAddrs []string
	ExpiresAt   time.Time
	Link        string
}

type TurnCreds struct {
	// Link — ссылка на звонок, для которого креды добыты; та же, что пришла
	// в EventVkAuthRequired. Под ней ядро их и запомнит.
	Link string
	// Username и Password — учётные данные TURN-relay.
	Username string
	Password string
	// URLs — адреса relay в виде turn:host:port или host:port.
	URLs []string
}

type TurnParams struct {
	Host     string
	Port     string
	Hashes   []string
	WrapKey  []byte // Password-derived WRAP key (32 bytes), nil = disabled
	ObfsMode string // "audio" or "video" — RTP masking mode
	// NoDTLS: пропустить DTLS и идти RTP-obfs AEAD напрямую поверх TURN relay.
	// Требует сервер, который умеет принимать прямые (без DTLS) сессии на
	// отдельном порту/слушателе — см. server/main.go -listen-direct.
	NoDTLS bool
	// TCPTransport: соединяться с TURN-relay по TCP вместо UDP (см.
	// dialTURNConn в session.go). На некоторых сетях (замечено на
	// Ростелекоме) UDP до TURN душится/дропается провайдером агрессивнее,
	// чем TCP на тот же relay — этот флаг обходит именно это.
	TCPTransport bool
}

type VKCredentials struct {
	ClientID     string
	ClientSecret string
}

type VkCaptchaError struct {
	ErrorCode      int
	ErrorMsg       string
	CaptchaSid     string
	CaptchaImg     string
	RedirectURI    string
	SessionToken   string
	CaptchaTs      string
	CaptchaAttempt string
}

type WorkerSlot struct {
	ID     int
	SendCh chan []byte
	PrioCh chan []byte
}