You cannot select more than 25 topics
Topics must start with a letter or number, can include dashes ('-') and can be up to 35 characters long.
67 lines
1.4 KiB
Go
67 lines
1.4 KiB
Go
7 days ago
|
// request_logger.go
|
||
|
package middleware
|
||
|
|
||
|
import (
|
||
|
"log/slog"
|
||
|
"net/http"
|
||
|
"runtime/debug"
|
||
|
"time"
|
||
|
)
|
||
|
|
||
|
// responseWriter is a minimal wrapper for http.ResponseWriter that allows the
|
||
|
// written HTTP status code to be captured for logging.
|
||
|
type responseWriter struct {
|
||
|
http.ResponseWriter
|
||
|
status int
|
||
|
wroteHeader bool
|
||
|
}
|
||
|
|
||
|
func wrapResponseWriter(w http.ResponseWriter) *responseWriter {
|
||
|
return &responseWriter{ResponseWriter: w}
|
||
|
}
|
||
|
|
||
|
func (rw *responseWriter) Status() int {
|
||
|
return rw.status
|
||
|
}
|
||
|
|
||
|
func (rw *responseWriter) WriteHeader(code int) {
|
||
|
if rw.wroteHeader {
|
||
|
return
|
||
|
}
|
||
|
|
||
|
rw.status = code
|
||
|
rw.ResponseWriter.WriteHeader(code)
|
||
|
rw.wroteHeader = true
|
||
|
|
||
|
return
|
||
|
}
|
||
|
|
||
|
// LoggingMiddleware logs the incoming HTTP request & its duration.
|
||
|
func LoggingMiddleware(logger *slog.Logger) func(http.Handler) http.Handler {
|
||
|
return func(next http.Handler) http.Handler {
|
||
|
fn := func(w http.ResponseWriter, r *http.Request) {
|
||
|
defer func() {
|
||
|
if err := recover(); err != nil {
|
||
|
w.WriteHeader(http.StatusInternalServerError)
|
||
|
logger.Error("Internal Server Error",
|
||
|
"err", err,
|
||
|
"trace", debug.Stack(),
|
||
|
)
|
||
|
}
|
||
|
}()
|
||
|
|
||
|
start := time.Now()
|
||
|
wrapped := wrapResponseWriter(w)
|
||
|
next.ServeHTTP(wrapped, r)
|
||
|
logger.Info("Request processed",
|
||
|
"status", wrapped.status,
|
||
|
"method", r.Method,
|
||
|
"path", r.URL.EscapedPath(),
|
||
|
"duration", time.Since(start),
|
||
|
)
|
||
|
}
|
||
|
|
||
|
return http.HandlerFunc(fn)
|
||
|
}
|
||
|
}
|