nf/middleware.go

58 lines
1.1 KiB
Go
Raw Permalink Normal View History

2024-01-12 19:18:33 +08:00
package nf
import (
"fmt"
"os"
"runtime/debug"
2024-01-14 19:10:05 +08:00
"time"
2024-12-26 19:40:39 +08:00
"github.com/loveuer/nf/nft/log"
2024-01-12 19:18:33 +08:00
)
func NewRecover(enableStackTrace bool) HandlerFunc {
return func(c *Ctx) error {
defer func() {
if r := recover(); r != nil {
if enableStackTrace {
os.Stderr.WriteString(fmt.Sprintf("recovered from panic: %v\n%s\n", r, debug.Stack()))
} else {
os.Stderr.WriteString(fmt.Sprintf("recovered from panic: %v\n", r))
}
2024-02-20 15:34:00 +08:00
2024-12-26 19:40:39 +08:00
// serveError(c, 500, []byte(fmt.Sprint(r)))
2024-02-20 15:34:00 +08:00
_ = c.Status(500).SendString(fmt.Sprint(r))
2024-01-12 19:18:33 +08:00
}
}()
return c.Next()
}
}
2024-01-14 19:10:05 +08:00
func NewLogger() HandlerFunc {
2024-06-07 17:39:06 +08:00
return func(c *Ctx) error {
2024-01-14 19:10:05 +08:00
var (
2024-06-07 17:39:06 +08:00
now = time.Now()
logFn func(msg string, data ...any)
ip = c.IP()
2024-01-14 19:10:05 +08:00
)
err := c.Next()
2024-06-07 17:39:06 +08:00
duration := time.Since(now)
2024-01-14 19:10:05 +08:00
msg := fmt.Sprintf("NF | %v | %15s | %3d | %s | %6s | %s", c.Context().Value(TraceKey), ip, c.StatusCode, HumanDuration(duration.Nanoseconds()), c.Method(), c.Path())
2024-01-14 19:10:05 +08:00
2024-06-07 17:39:06 +08:00
switch {
case c.StatusCode >= 500:
logFn = log.Error
case c.StatusCode >= 400:
logFn = log.Warn
default:
logFn = log.Info
}
logFn(msg)
2024-01-14 19:10:05 +08:00
return err
}
}