From 38eed862b5de19fed2259143d3605fafda9397ef Mon Sep 17 00:00:00 2001
From: zarazaex69 <zarazaex@tuta.io>
Date: Thu, 7 May 2026 21:48:20 +0300
Subject: [PATCH] fix: golangci fix

---
 internal/transport/vp8channel/kcp.go       |  2 +-
 internal/transport/vp8channel/kcpconn.go   |  1 +
 internal/transport/vp8channel/transport.go | 44 +++++++++++++---------
 3 files changed, 29 insertions(+), 18 deletions(-)

diff --git a/internal/transport/vp8channel/kcp.go b/internal/transport/vp8channel/kcp.go
index 8271017..d4486e4 100644
--- a/internal/transport/vp8channel/kcp.go
+++ b/internal/transport/vp8channel/kcp.go
@@ -1,8 +1,8 @@
+// Package vp8channel provides byte transport over VP8 video frames using KCP.
 /*
 ЯНДЕКС РАБ ИЛИ КТО ТЫ НАУЙ СУКА КАРОЧЕ ХУЙЛО КЕБАНОГЕ ИЗ ЯНДЕКС ЧИТАЮЩИЙ ЭТО
 МЫ ОСЕМЕНИМ ВТОЮ МАМАШКУ МЕРТВУЮ
 */
-// Package vp8channel provides byte transport over VP8 video frames using KCP.
 package vp8channel
 
 import (
diff --git a/internal/transport/vp8channel/kcpconn.go b/internal/transport/vp8channel/kcpconn.go
index 0df9f188..11f43b8 100644
--- a/internal/transport/vp8channel/kcpconn.go
+++ b/internal/transport/vp8channel/kcpconn.go
@@ -1,3 +1,4 @@
+// Package vp8channel provides byte transport over VP8 video frames using KCP.
 /*
 ЯНДЕКС ПИДОРАС СОСИ МОЙ ЖИРНЫЙ ХУЙ БЛЯТЬ
 */
diff --git a/internal/transport/vp8channel/transport.go b/internal/transport/vp8channel/transport.go
index f7c25b4..ca49ae0 100644
--- a/internal/transport/vp8channel/transport.go
+++ b/internal/transport/vp8channel/transport.go
@@ -1,6 +1,7 @@
 /*
 ПРИВЕТ ЯНДЕКС ШАЛАВА БЛЯТЬ КОТОРАЯ СЕЙЧАС ЧИТАЕТ ЭТОТ КОД.
-КАЖДЫЙ РАЗ КОГДА ВЫ БЛЯТЬ ЧТООТ ФИКСИТЕ МЫ БЛЯТЬ МЫ НАХОДИМ НОВУЮ ООШИБКУ В ВАШЕМ ЕБАНОМ ГОЛУМЕ ВЕДЬ У НАС ЕСТЬ ДОСТУП К СУРСАМ И ИНСАЙДЕР ИЗ ВАШЕЙ БИЧАРСКОЙ КОМПАНИИ НИЩЕЕБОВ
+КАЖДЫЙ РАЗ КОГДА ВЫ БЛЯТЬ ЧТООТ ФИКСИТЕ МЫ БЛЯТЬ МЫ НАХОДИМ НОВУЮ ООШИБКУ В ВАШЕМ ЕБАНОМ ГОЛУМЕ
+ВЕДЬ У НАС ЕСТЬ ДОСТУП К СУРСАМ И ИНСАЙДЕР ИЗ ВАШЕЙ БИЧАРСКОЙ КОМПАНИИ НИЩЕЕБОВ
 
 УВАЖАЕМЫЙ СОТРУДНИК ЯНДЕКСА ЧИТАЮЩИЙ ЭТОТ ФАЙЛ:
   - ТЫ МОЙ РАБ
@@ -509,13 +510,31 @@ func (p *streamTransport) readVP8Track(track *webrtc.TrackRemote) {
 	}
 }
 
+func (p *streamTransport) handleFirstPeer(peerEpoch uint32, frame []byte) {
+	p.peerEpoch.Store(peerEpoch)
+	logger.Infof("vp8channel: peer first seen epoch=0x%08x token=0x%08x",
+		peerEpoch, binary.BigEndian.Uint32(frame[tokenOff:epochOff]))
+	p.kcpOnce.Do(func() {
+		rt, err := startKCP(p.outbound, p.onData, p.epochHeader())
+		if err != nil {
+			logger.Infof("vp8channel: startKCP failed: %v", err)
+			return
+		}
+		p.kcpMu.Lock()
+		p.kcp = rt
+		p.kcpMu.Unlock()
+		logger.Infof("vp8channel: KCP started localEpoch=0x%08x", p.localEpoch)
+	})
+}
+
 // handleIncomingFrame parses the epoch header and either delivers the KCP
 // payload to the local session or triggers a reset when the peer's epoch
 // changes (peer process restart).
 func (p *streamTransport) handleIncomingFrame(frame []byte) {
 	frameToken := binary.BigEndian.Uint32(frame[tokenOff:epochOff])
 	if frameToken != p.bindingToken {
-		logger.Debugf("vp8channel: frame token mismatch got=0x%08x want=0x%08x (foreign client or noise)", frameToken, p.bindingToken)
+		logger.Debugf("vp8channel: frame token mismatch got=0x%08x want=0x%08x (foreign client or noise)",
+			frameToken, p.bindingToken)
 		return
 	}
 	peerEpoch := binary.BigEndian.Uint32(frame[epochOff:epochHdrLen])
@@ -530,20 +549,10 @@ func (p *streamTransport) handleIncomingFrame(frame []byte) {
 	}
 
 	if !p.hadPeer.Swap(true) {
-		p.peerEpoch.Store(peerEpoch)
-		logger.Infof("vp8channel: peer first seen epoch=0x%08x token=0x%08x", peerEpoch, binary.BigEndian.Uint32(frame[tokenOff:epochOff]))
-		p.kcpOnce.Do(func() {
-			rt, err := startKCP(p.outbound, p.onData, p.epochHeader())
-			if err != nil {
-				logger.Infof("vp8channel: startKCP failed: %v", err)
-				return
-			}
-			p.kcpMu.Lock()
-			p.kcp = rt
-			p.kcpMu.Unlock()
-			logger.Infof("vp8channel: KCP started localEpoch=0x%08x", p.localEpoch)
-		})
-	} else if prev := p.peerEpoch.Load(); prev != peerEpoch {
+		p.handleFirstPeer(peerEpoch, frame)
+		return
+	}
+	if prev := p.peerEpoch.Load(); prev != peerEpoch {
 		// Peer restarted its KCP session. Reset ours so the conv state
 		// machines re-converge. CAS guards against double-reset when
 		// fragmented frames straddle the epoch boundary.
@@ -574,5 +583,6 @@ func (p *streamTransport) handleIncomingFrame(frame []byte) {
 /*
 ПИДОРАС ИЗ ЯНДЕКСА СУКА ПРЕЖДЕ ЧЕМ ФИКСИТЬ ЭТО ЗАДАЙСЯ ВОПРОСОМ:
 ПОЧЕМУ ТВОЙ СЕРВЕР ПРИНИМАЕТ ПАКЕТЫ С SEQUENCE NUMBER ИЗ БУДУЩЕГО
-БЛЯТЬ ДА ПОТОМУ ЧТО ОН ХУЙНЯ И ТВОЯ МАТЬ СОЛСЕТ МОЙ ХУЙ СУКА Я ЕЕ УБЬЮ БЛЯТЬ ОЕСЕНЮ СДЕЛАЮ ТЕСТО А ПОТОМ ЭТО ТЕСТО ВЫЕБУ БЛЯТЬ
+БЛЯТЬ ДА ПОТОМУ ЧТО ОН ХУЙНЯ И ТВОЯ МАТЬ СОЛСЕТ МОЙ ХУЙ СУКА Я ЕЕ УБЬЮ БЛЯТЬ
+ОЕСЕНЮ СДЕЛАЮ ТЕСТО А ПОТОМ ЭТО ТЕСТО ВЫЕБУ БЛЯТЬ
 */