From 6823adbb9cd160079d088d73432d45039274d3bc Mon Sep 17 00:00:00 2001
From: sergystepanov <sergystepanov@gmail.com>
Date: Mon, 6 Jul 2026 15:48:25 +0300
Subject: [PATCH] Guard debug log calls with level checks

---
 pkg/com/com.go                                 | 12 +++++++++---
 pkg/worker/caged/libretro/nanoarch/nanoarch.go | 16 ++++++++++++----
 2 files changed, 21 insertions(+), 7 deletions(-)

diff --git a/pkg/com/com.go b/pkg/com/com.go
index 31207876..e69071f5 100644
--- a/pkg/com/com.go
+++ b/pkg/com/com.go
@@ -56,7 +56,9 @@ func NewConnection[T ~uint8, P Packet[T], X any, P2 Packet2[X]](conn *Connection
 func (c *SocketClient[T, P, _, _]) ProcessPackets(fn func(in P) error) chan struct{} {
 	c.rpc = NewRPC[T, P]()
 	c.rpc.Handler = func(p P) {
-		c.log.Debug().Str(logger.DirectionField, logger.MarkIn).Msgf("%v", p.GetType())
+		if c.log.GetLevel() <= logger.DebugLevel {
+			c.log.Debug().Str(logger.DirectionField, logger.MarkIn).Msgf("%v", p.GetType())
+		}
 		if err := fn(p); err != nil { // 3rd handler
 			c.log.Error().Err(err).Send()
 		}
@@ -92,7 +94,9 @@ func (c *SocketClient[_, P, X, P2]) Route(in P, out P2) {
 
 // Send makes a blocking call.
 func (c *SocketClient[T, P, X, P2]) Send(t T, data any) ([]byte, error) {
-	c.log.Debug().Str(logger.DirectionField, logger.MarkOut).Msgf("ᵇ%v", t)
+	if c.log.GetLevel() <= logger.DebugLevel {
+		c.log.Debug().Str(logger.DirectionField, logger.MarkOut).Msgf("ᵇ%v", t)
+	}
 	rq := P2(new(X))
 	rq.SetType(uint8(t))
 	rq.SetPayload(data)
@@ -101,7 +105,9 @@ func (c *SocketClient[T, P, X, P2]) Send(t T, data any) ([]byte, error) {
 
 // Notify just sends a message and goes further.
 func (c *SocketClient[T, P, X, P2]) Notify(t T, data any) {
-	c.log.Debug().Str(logger.DirectionField, logger.MarkOut).Msgf("%v", t)
+	if c.log.GetLevel() <= logger.DebugLevel {
+		c.log.Debug().Str(logger.DirectionField, logger.MarkOut).Msgf("%v", t)
+	}
 	rq := P2(new(X))
 	rq.SetType(uint8(t))
 	rq.SetPayload(data)
diff --git a/pkg/worker/caged/libretro/nanoarch/nanoarch.go b/pkg/worker/caged/libretro/nanoarch/nanoarch.go
index 17f10fc6..1319cbd6 100644
--- a/pkg/worker/caged/libretro/nanoarch/nanoarch.go
+++ b/pkg/worker/caged/libretro/nanoarch/nanoarch.go
@@ -721,13 +721,21 @@ func coreLog(level C.enum_retro_log_level, msg *C.char) {
 	switch level {
 	// with debug level cores have too much logs
 	case C.RETRO_LOG_DEBUG:
-		Nan0.log.Debug().MsgFunc(func() string { return m(msg) })
+		if Nan0.log.GetLevel() <= logger.DebugLevel {
+			Nan0.log.Debug().MsgFunc(func() string { return m(msg) })
+		}
 	case C.RETRO_LOG_INFO:
-		Nan0.log.Info().MsgFunc(func() string { return m(msg) })
+		if Nan0.log.GetLevel() <= logger.InfoLevel {
+			Nan0.log.Info().MsgFunc(func() string { return m(msg) })
+		}
 	case C.RETRO_LOG_WARN:
-		Nan0.log.Warn().MsgFunc(func() string { return m(msg) })
+		if Nan0.log.GetLevel() <= logger.WarnLevel {
+			Nan0.log.Warn().MsgFunc(func() string { return m(msg) })
+		}
 	case C.RETRO_LOG_ERROR:
-		Nan0.log.Error().MsgFunc(func() string { return m(msg) })
+		if Nan0.log.GetLevel() <= logger.ErrorLevel {
+			Nan0.log.Error().MsgFunc(func() string { return m(msg) })
+		}
 	default:
 		Nan0.log.Log().MsgFunc(func() string { return m(msg) })
 		// RETRO_LOG_DUMMY = INT_MAX