Log Coordinator's http internal errors to zap logger

Signed-off-by: Daniel Weiße <[email protected]>

coordinator/server/server.go

@@ -21,6 +21,7 @@ import (
 	"github.com/edgelesssys/marblerun/coordinator/server/handler"
 	v1 "github.com/edgelesssys/marblerun/coordinator/server/v1"
 	v2 "github.com/edgelesssys/marblerun/coordinator/server/v2"
+	mrlogging "github.com/edgelesssys/marblerun/internal/logging"
 	grpcprometheus "github.com/grpc-ecosystem/go-grpc-middleware/providers/prometheus"
 	"github.com/grpc-ecosystem/go-grpc-middleware/v2/interceptors/logging"
 	"github.com/prometheus/client_golang/prometheus"
@@ -115,6 +116,7 @@ func RunClientServer(mux http.Handler, address string, tlsConfig *tls.Config, za
 		Addr:      address,
 		Handler:   mux,
 		TLSConfig: tlsConfig,
+		ErrorLog:  mrlogging.NewWrapper(zapLogger),
 	}
 	zapLogger.Info("Starting client https server", zap.String("address", address))
 	err := server.ListenAndServeTLS("", "")

internal/logging/logging.go

@@ -0,0 +1,43 @@
+package logging
+
+import (
+	"fmt"
+	"log"
+	"os"
+
+	"github.com/edgelesssys/marblerun/coordinator/constants"
+	"github.com/edgelesssys/marblerun/util"
+	"go.uber.org/zap"
+)
+
+// New creates a new [*zap.Logger].
+func New() *zap.Logger {
+	var cfg zap.Config
+	if util.Getenv(constants.DevMode, constants.DevModeDefault) == "1" {
+		cfg = zap.NewDevelopmentConfig()
+	} else {
+		cfg = zap.NewProductionConfig()
+		cfg.DisableStacktrace = true // Disable stacktraces in production
+	}
+	log, err := cfg.Build()
+	if err != nil {
+		fmt.Fprintf(os.Stderr, "failed to create logger: %s\n", err)
+		os.Exit(1)
+	}
+	return log
+}
+
+// NewWrapper creates a new [*log.Logger] that writes to the given [*zap.Logger].
+func NewWrapper(zapLogger *zap.Logger) *log.Logger {
+	return log.New(logWrapper{zapLogger}, "", 0)
+}
+
+// loggerWrapper implements [io.Writer] by writing any data to the error level of the embedded [*zap.Logger].
+type logWrapper struct {
+	*zap.Logger
+}
+
+func (l logWrapper) Write(p []byte) (n int, err error) {
+	l.Error(string(p))
+	return len(p), nil
+}