From 99ee4d8bbc8509f955846d870ea5c5daecae5e50 Mon Sep 17 00:00:00 2001
From: zarazaex69 <zarazaex@tuta.io>
Date: Thu, 7 May 2026 13:03:19 +0300
Subject: [PATCH] fix:fix suppress  noisy LiveKit/pion logs in non-debug mode

---
 cmd/olcrtc/main.go                 | 1 +
 cmd/olcrtc/main_test.go            | 7 +++++++
 internal/provider/wbstream/peer.go | 9 ++++++++-
 3 files changed, 16 insertions(+), 1 deletion(-)

diff --git a/cmd/olcrtc/main.go b/cmd/olcrtc/main.go
index 8fbde5a..1bff663 100644
--- a/cmd/olcrtc/main.go
+++ b/cmd/olcrtc/main.go
@@ -178,6 +178,7 @@ func configureLogging(debug bool) {
 		return
 	}
 	// Suppress noisy LiveKit/pion logs unless debug is enabled.
+	_ = os.Setenv("PION_LOG_DISABLE", "all")
 	lksdk.SetLogger(protoLogger.GetDiscardLogger())
 }
 
diff --git a/cmd/olcrtc/main_test.go b/cmd/olcrtc/main_test.go
index 5873293..9ae01d2 100644
--- a/cmd/olcrtc/main_test.go
+++ b/cmd/olcrtc/main_test.go
@@ -183,17 +183,24 @@ func TestRunWithArgsSuccessfulSessionReturn(t *testing.T) {
 }
 
 func TestConfigureLogging(t *testing.T) {
+	t.Setenv("PION_LOG_DISABLE", "")
 	logger.SetVerbose(false)
 	configureLogging(true)
 	if !logger.IsVerbose() {
 		t.Fatal("configureLogging(true) did not enable verbose logging")
 	}
+	if got := os.Getenv("PION_LOG_DISABLE"); got != "" {
+		t.Fatalf("configureLogging(true) PION_LOG_DISABLE = %q, want empty", got)
+	}
 
 	logger.SetVerbose(false)
 	configureLogging(false)
 	if logger.IsVerbose() {
 		t.Fatal("configureLogging(false) enabled verbose logging")
 	}
+	if got := os.Getenv("PION_LOG_DISABLE"); got != "all" {
+		t.Fatalf("configureLogging(false) PION_LOG_DISABLE = %q, want all", got)
+	}
 }
 
 func TestResolveDataDir(t *testing.T) {
diff --git a/internal/provider/wbstream/peer.go b/internal/provider/wbstream/peer.go
index c0353c4..03f5f91 100644
--- a/internal/provider/wbstream/peer.go
+++ b/internal/provider/wbstream/peer.go
@@ -9,6 +9,7 @@ import (
 	"sync"
 	"sync/atomic"
 
+	protoLogger "github.com/livekit/protocol/logger"
 	lksdk "github.com/livekit/server-sdk-go/v2"
 	"github.com/pion/webrtc/v4"
 )
@@ -92,7 +93,13 @@ func (p *Peer) Connect(ctx context.Context) error {
 		},
 	}
 
-	room, err := lksdk.ConnectToRoomWithToken(wsURL, token, roomCB, lksdk.WithAutoSubscribe(true))
+	room, err := lksdk.ConnectToRoomWithToken(
+		wsURL,
+		token,
+		roomCB,
+		lksdk.WithAutoSubscribe(true),
+		lksdk.WithLogger(protoLogger.GetDiscardLogger()),
+	)
 	if err != nil {
 		return fmt.Errorf("connect to room: %w", err)
 	}