diff --git a/internal/provider/vk/internal/vkauth/client.go b/internal/provider/vk/internal/vkauth/client.go index 786f385..ffb95b1 100644 --- a/internal/provider/vk/internal/vkauth/client.go +++ b/internal/provider/vk/internal/vkauth/client.go @@ -93,7 +93,7 @@ func New(cfg Config) *Client { c.identity = browserprofile.Identity{Seed: seed, Gen: c.gens.load(seed)} c.persona = browserprofile.For(c.platform, c.identity) if c.identity.Gen > 0 { - c.log.Infof("[VK Auth] Persona gen=%d restored | User-Agent: %s", c.identity.Gen, c.persona.UserAgent) + c.log.Debugf("[VK Auth] Persona gen=%d restored | User-Agent: %s", c.identity.Gen, c.persona.UserAgent) } return c } @@ -241,11 +241,11 @@ func (c *Client) fetch(ctx context.Context, link string, streamID int) (string, jar := personanet.NewCookieJar() for i := 0; i < len(c.credentials); { creds := c.credentials[i] - c.log.Infof("[STREAM %d] [VK Auth] Trying credentials: client_id=%s", streamID, creds.ClientID) + c.log.Debugf("[STREAM %d] [VK Auth] Trying credentials: client_id=%s", streamID, creds.ClientID) user, pass, addrs, err := c.tokenChain(ctx, link, streamID, creds, jar) if err == nil { - c.log.Infof("[STREAM %d] [VK Auth] Success with client_id=%s", streamID, creds.ClientID) + c.log.Debugf("[STREAM %d] [VK Auth] Success with client_id=%s", streamID, creds.ClientID) return user, pass, addrs, nil } lastErr = err diff --git a/internal/provider/vk/internal/vkauth/token.go b/internal/provider/vk/internal/vkauth/token.go index 2fce6b8..5735363 100644 --- a/internal/provider/vk/internal/vkauth/token.go +++ b/internal/provider/vk/internal/vkauth/token.go @@ -21,7 +21,7 @@ func (c *Client) getTokenChain(ctx context.Context, link string, streamID int, c name := namegen.Generate() escapedName := neturl.QueryEscape(name) - c.log.Infof("[STREAM %d] [VK Auth] Connecting Identity - Name: %s | User-Agent: %s", streamID, name, profile.UserAgent) + c.log.Debugf("[STREAM %d] [VK Auth] Connecting Identity - Name: %s | User-Agent: %s", streamID, name, profile.UserAgent) if pageErr := c.openJoinPage(ctx, httpClient, profile, link); pageErr != nil { c.log.Warnf("[STREAM %d] [VK Auth] join page warm-up failed: %v", streamID, pageErr) diff --git a/internal/provider/vk/internal/vkauth/token_creds.go b/internal/provider/vk/internal/vkauth/token_creds.go index 9c85263..69f4c71 100644 --- a/internal/provider/vk/internal/vkauth/token_creds.go +++ b/internal/provider/vk/internal/vkauth/token_creds.go @@ -43,9 +43,9 @@ func (c *Client) fetchTurnCreds( return "", "", nil, fmt.Errorf("missing or empty urls in turn_server") } - c.log.Infof("[STREAM %d] [VK Auth] TURN urls (%d total):", streamID, len(urlsRaw)) + c.log.Debugf("[STREAM %d] [VK Auth] TURN urls (%d total):", streamID, len(urlsRaw)) for i, u := range urlsRaw { - c.log.Infof("[STREAM %d] [VK Auth] [%d] %v", streamID, i, u) + c.log.Debugf("[STREAM %d] [VK Auth] [%d] %v", streamID, i, u) } for _, u := range urlsRaw { diff --git a/internal/proxy/udprelay/loop.go b/internal/proxy/udprelay/loop.go index de61508..70236c3 100644 --- a/internal/proxy/udprelay/loop.go +++ b/internal/proxy/udprelay/loop.go @@ -160,9 +160,9 @@ func dtlsSession(dtlsctx context.Context, dtlscancel context.CancelFunc, deps *D var dtlsConn net.Conn = dtlsRaw defer func() { _ = dtlsConn.Close() - deps.log().Infof("[STREAM %d] Closed DTLS connection", streamID) + deps.log().Debugf("[STREAM %d] Closed DTLS connection", streamID) }() - deps.log().Infof("[STREAM %d] Established DTLS connection", streamID) + deps.log().Debugf("[STREAM %d] Established DTLS connection", streamID) if err := clientsdb.WriteClientID(dtlsConn, params.ClientID); err != nil { return fmt.Errorf("failed to write client ID: %w", err)