Move media related logging utilities from egress to protocol (#990)

Author: biglittlebigben

.changeset/chilly-years-obey.md

@@ -0,0 +1,5 @@
+---
+"@livekit/protocol": patch
+---
+
+Move media related logging utilities from egress to protocol

logger/medialogutils/cmd.go

@@ -0,0 +1,67 @@
+// Copyright 2025 LiveKit, Inc.
+//
+// Licensed under the Apache License, Version 2.0 (the "License");
+// you may not use this file except in compliance with the License.
+// You may obtain a copy of the License at
+//
+//     http://www.apache.org/licenses/LICENSE-2.0
+//
+// Unless required by applicable law or agreed to in writing, software
+// distributed under the License is distributed on an "AS IS" BASIS,
+// WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+// See the License for the specific language governing permissions and
+// limitations under the License.
+
+package medialogutils
+
+import (
+	"fmt"
+	"strings"
+
+	"github.com/livekit/protocol/logger"
+)
+
+// CmdLogger logs cmd outputs
+type CmdLogger struct {
+	name string
+}
+
+func NewCmdLogger(name string) *CmdLogger {
+	return &CmdLogger{
+		name: name,
+	}
+}
+
+func (l *CmdLogger) Write(p []byte) (int, error) {
+	logger.Infow(fmt.Sprintf("%s: %s", l.name, string(p)))
+	return len(p), nil
+}
+
+// HandlerLogger catches stray outputs from egress handlers
+type HandlerLogger struct {
+	logger logger.Logger
+}
+
+func NewHandlerLogger(keyAndValues ...any) *HandlerLogger {
+	return &HandlerLogger{
+		logger: logger.GetLogger().WithValues(keyAndValues...),
+	}
+}
+
+func (l *HandlerLogger) Write(p []byte) (n int, err error) {
+	s := string(p)
+	if strings.HasSuffix(s, "}\n") {
+		// normal handler logs
+		fmt.Print(s)
+	} else if strings.HasPrefix(s, "0:00:") {
+		// ignore cuda and template not mapped gstreamer warnings
+	} else if strings.HasPrefix(s, "turnc") {
+		// warn on turnc error
+		l.logger.Infow(s, nil)
+	} else {
+		// panics and unexpected errors
+		l.logger.Errorw(s, nil)
+	}
+
+	return len(p), nil
+}

logger/medialogutils/override.go

@@ -0,0 +1,32 @@
+// Copyright 2025 LiveKit, Inc.
+//
+// Licensed under the Apache License, Version 2.0 (the "License");
+// you may not use this file except in compliance with the License.
+// You may obtain a copy of the License at
+//
+//     http://www.apache.org/licenses/LICENSE-2.0
+//
+// Unless required by applicable law or agreed to in writing, software
+// distributed under the License is distributed on an "AS IS" BASIS,
+// WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+// See the License for the specific language governing permissions and
+// limitations under the License.
+
+package medialogutils
+
+import "github.com/livekit/protocol/logger"
+
+// OverrideLogger converts errors to warnings
+type OverrideLogger struct {
+	logger.Logger
+}
+
+func NewOverrideLogger() *OverrideLogger {
+	return &OverrideLogger{
+		Logger: logger.GetLogger(),
+	}
+}
+
+func (l *OverrideLogger) Errorw(msg string, err error, keysAndValues ...interface{}) {
+	l.Logger.Warnw(msg, err, keysAndValues...)
+}