slogfiber

package module
v1.14.1 Latest Latest
Warning

This package is not in the latest version of its module.

Go to latest
Published: Apr 21, 2024 License: MIT Imports: 10 Imported by: 16

README

slog: Fiber middleware

tag Go Version GoDoc Build Status Go report Coverage Contributors License

Fiber middleware to log http requests using slog.

See also:

HTTP middlewares:

Loggers:

Log sinks:

🚀 Install

# Fiber v2 (current)
go get github.com/samber/slog-fiber

# Fiber v3 (beta)
go get github.com/samber/slog-echo@fiber-v3

Compatibility: go >= 1.21

No breaking changes will be made to exported APIs before v2.0.0.

💡 Usage

Handler options
type Config struct {
	DefaultLevel     slog.Level
	ClientErrorLevel slog.Level
	ServerErrorLevel slog.Level

	WithUserAgent      bool
	WithRequestID      bool
	WithRequestBody    bool
	WithRequestHeader  bool
	WithResponseBody   bool
	WithResponseHeader bool
	WithSpanID         bool
	WithTraceID        bool

	Filters []Filter
}

Attributes will be injected in log payload.

Other global parameters:

slogfiber.TraceIDKey = "trace-id"
slogfiber.SpanIDKey = "span-id"
slogfiber.RequestBodyMaxSize  = 64 * 1024 // 64KB
slogfiber.ResponseBodyMaxSize = 64 * 1024 // 64KB
slogfiber.HiddenRequestHeaders = map[string]struct{}{ ... }
slogfiber.HiddenResponseHeaders = map[string]struct{}{ ... }
slogfiber.RequestIDHeaderKey = "X-Request-Id"
Minimal
import (
	"github.com/gofiber/fiber/v2"
	"github.com/gofiber/fiber/v2/middleware/recover"
	slogfiber "github.com/samber/slog-fiber"
	"log/slog"
)

// Create a slog logger, which:
//   - Logs to stdout.
logger := slog.New(slog.NewTextHandler(os.Stdout, nil))

app := fiber.New()

app.Use(slogfiber.New(logger))
app.Use(recover.New())

app.Get("/", func(c *fiber.Ctx) error {
	return c.SendString("Hello, World 👋!")
})

app.Listen(":4242")

// output:
// time=2023-10-15T20:32:58.926+02:00 level=INFO msg="Incoming request" env=production request.time=2023-10-15T20:32:58.626+02:00 request.method=GET request.path=/ request.route="" request.ip=127.0.0.1:63932 request.length=0 response.time=2023-10-15T20:32:58.926+02:00 response.latency=100ms response.status=200 response.length=7 id=229c7fc8-64f5-4467-bc4a-940700503b0d
OTEL
logger := slog.New(slog.NewTextHandler(os.Stdout, nil))

config := slogfiber.Config{
	WithSpanID:  true,
	WithTraceID: true,
}

app := fiber.New()
app.Use(slogfiber.NewWithConfig(logger, config))
Custom log levels
logger := slog.New(slog.NewTextHandler(os.Stdout, nil))

config := slogfiber.Config{
	DefaultLevel:     slog.LevelInfo,
	ClientErrorLevel: slog.LevelWarn,
	ServerErrorLevel: slog.LevelError,
}

app := fiber.New()
app.Use(slogfiber.NewWithConfig(logger, config))
Verbose
logger := slog.New(slog.NewTextHandler(os.Stdout, nil))

config := slogfiber.Config{
	WithRequestBody: true,
	WithResponseBody: true,
	WithRequestHeader: true,
	WithResponseHeader: true,
}

app := fiber.New()
app.Use(slogfiber.NewWithConfig(logger, config))
Filters
logger := slog.New(slog.NewTextHandler(os.Stdout, nil))

app := fiber.New()
app.Use(
	slogfiber.NewWithFilters(
		logger,
		slogfiber.Accept(func (c *fiber.Ctx) bool {
			return xxx
		}),
		slogfiber.IgnoreStatus(401, 404),
	),
)
app.Use(recover.New())

Available filters:

  • Accept / Ignore
  • AcceptMethod / IgnoreMethod
  • AcceptStatus / IgnoreStatus
  • AcceptStatusGreaterThan / IgnoreStatusLessThan
  • AcceptStatusGreaterThanOrEqual / IgnoreStatusLessThanOrEqual
  • AcceptPath / IgnorePath
  • AcceptPathContains / IgnorePathContains
  • AcceptPathPrefix / IgnorePathPrefix
  • AcceptPathSuffix / IgnorePathSuffix
  • AcceptPathMatch / IgnorePathMatch
  • AcceptHost / IgnoreHost
  • AcceptHostContains / IgnoreHostContains
  • AcceptHostPrefix / IgnoreHostPrefix
  • AcceptHostSuffix / IgnoreHostSuffix
  • AcceptHostMatch / IgnoreHostMatch
Using custom time formatters
// Create a slog logger, which:
//   - Logs to stdout.
//   - RFC3339 with UTC time format.
logger := slog.New(
	slogformatter.NewFormatterHandler(
		slogformatter.TimezoneConverter(time.UTC),
		slogformatter.TimeFormatter(time.RFC3339, nil),
	)(
		slog.NewTextHandler(os.Stdout, nil),
	),
)

app := fiber.New()

app.Use(slogfiber.New(logger))
app.Use(recover.New())

app.Get("/", func(c *fiber.Ctx) error {
	return c.SendString("Hello, World 👋!")
})

app.Listen(":4242")

// output:
// time=2023-10-15T20:32:58.926+02:00 level=INFO msg="Incoming request" env=production request.time=2023-10-15T20:32:58Z request.method=GET request.path=/ request.route="" request.ip=127.0.0.1:63932 request.length=0 response.time=2023-10-15T20:32:58Z response.latency=100ms response.status=200 response.length=7 id=229c7fc8-64f5-4467-bc4a-940700503b0d
Using custom logger sub-group
logger := slog.New(slog.NewTextHandler(os.Stdout, nil))

app := fiber.New()

app.Use(slogfiber.New(logger.WithGroup("http")))
app.Use(recover.New())

app.Get("/", func(c *fiber.Ctx) error {
	return c.SendString("Hello, World 👋!")
})

app.Listen(":4242")

// output:
// time=2023-10-15T20:32:58.926+02:00 level=INFO msg="Incoming request" env=production http.request.time=2023-10-15T20:32:58.626+02:00 http.request.method=GET http.request.path=/ http.request.route="" http.request.ip=127.0.0.1:63932 http.request.length=0 http.response.time=2023-10-15T20:32:58.926+02:00 http.response.latency=100ms http.response.status=200 http.response.length=7 http.id=229c7fc8-64f5-4467-bc4a-940700503b0d
Add logger to a single route
logger := slog.New(slog.NewTextHandler(os.Stdout, nil))

app := fiber.New()

app.Use(recover.New())

app.Get("/", slogfiber.New(logger), func(c *fiber.Ctx) error {
	return c.SendString("Hello, World 👋!")
})

app.Listen(":4242")
Adding custom attributes
logger := slog.New(slog.NewTextHandler(os.Stdout, nil))

// Add an attribute to all log entries made through this logger.
logger = logger.With("env", "production")

app := fiber.New()

app.Use(slogfiber.New(logger))
app.Use(recover.New())

app.Get("/", func(c *fiber.Ctx) error {
	// Add an attribute to a single log entry.
	slogfiber.AddCustomAttributes(c, slog.String("foo", "bar"))
	return c.SendString("Hello, World 👋!")
})

app.Listen(":4242")

// output:
// time=2023-10-15T20:32:58.926+02:00 level=INFO msg="Incoming request" env=production request.time=2023-10-15T20:32:58.626+02:00 request.method=GET request.path=/ request.route="" request.ip=127.0.0.1:63932 request.length=0 response.time=2023-10-15T20:32:58.926+02:00 response.latency=100ms response.status=200 response.length=7 id=229c7fc8-64f5-4467-bc4a-940700503b0d foo=bar
JSON output
logger := slog.New(slog.NewJSONHandler(os.Stdout, nil)),

app := fiber.New()

app.Use(slogfiber.New(logger))
app.Use(recover.New())

app.Get("/", func(c *fiber.Ctx) error {
	return c.SendString("Hello, World 👋!")
})

app.Listen(":4242")

// output:
// {"time":"2023-10-15T20:32:58.926+02:00","level":"INFO","msg":"Incoming request","env":"production","http":{"request":{"time":"2023-10-15T20:32:58.626+02:00","method":"GET","path":"/","route":"","ip":"127.0.0.1:55296","length":0},"response":{"time":"2023-10-15T20:32:58.926+02:00","latency":100000,"status":200,"length":7},"id":"04201917-d7ba-4b20-a3bb-2fffba5f2bd9"}}

🤝 Contributing

Don't hesitate ;)

# Install some dev dependencies
make tools

# Run tests
make test
# or
make watch-test

👤 Contributors

Contributors

💫 Show your support

Give a ⭐️ if this project helped you!

GitHub Sponsors

📝 License

Copyright © 2023 Samuel Berthe.

This project is MIT licensed.

Documentation

Index

Constants

This section is empty.

Variables

View Source
var (
	TraceIDKey = "trace-id"
	SpanIDKey  = "span-id"

	RequestBodyMaxSize  = 64 * 1024 // 64KB
	ResponseBodyMaxSize = 64 * 1024 // 64KB

	HiddenRequestHeaders = map[string]struct{}{
		"authorization": {},
		"cookie":        {},
		"set-cookie":    {},
		"x-auth-token":  {},
		"x-csrf-token":  {},
		"x-xsrf-token":  {},
	}
	HiddenResponseHeaders = map[string]struct{}{
		"set-cookie": {},
	}

	// Formatted with http.CanonicalHeaderKey
	RequestIDHeaderKey = "X-Request-Id"
)

Functions

func AddCustomAttributes added in v1.5.0

func AddCustomAttributes(c *fiber.Ctx, attr slog.Attr)

func GetRequestID

func GetRequestID(c *fiber.Ctx) string

GetRequestID returns the request identifier

func New

func New(logger *slog.Logger) fiber.Handler

New returns a fiber.Handler (middleware) that logs requests using slog.

Requests with errors are logged using slog.Error(). Requests without errors are logged using slog.Info().

func NewWithConfig

func NewWithConfig(logger *slog.Logger, config Config) fiber.Handler

NewWithConfig returns a fiber.Handler (middleware) that logs requests using slog.

func NewWithFilters added in v1.5.0

func NewWithFilters(logger *slog.Logger, filters ...Filter) fiber.Handler

NewWithFilters returns a fiber.Handler (middleware) that logs requests using slog.

Requests with errors are logged using slog.Error(). Requests without errors are logged using slog.Info().

Types

type Config

type Config struct {
	DefaultLevel     slog.Level
	ClientErrorLevel slog.Level
	ServerErrorLevel slog.Level

	WithUserAgent      bool
	WithRequestID      bool
	WithRequestBody    bool
	WithRequestHeader  bool
	WithResponseBody   bool
	WithResponseHeader bool
	WithSpanID         bool
	WithTraceID        bool

	Filters []Filter
}

type Filter added in v1.2.0

type Filter func(ctx *fiber.Ctx) bool

func Accept added in v1.2.0

func Accept(filter Filter) Filter

Basic

func AcceptHost added in v1.2.0

func AcceptHost(hosts ...string) Filter

Host

func AcceptHostContains added in v1.2.0

func AcceptHostContains(parts ...string) Filter

func AcceptHostMatch added in v1.2.0

func AcceptHostMatch(regs ...regexp.Regexp) Filter

func AcceptHostPrefix added in v1.2.0

func AcceptHostPrefix(prefixs ...string) Filter

func AcceptHostSuffix added in v1.2.0

func AcceptHostSuffix(prefixs ...string) Filter

func AcceptMethod added in v1.2.0

func AcceptMethod(methods ...string) Filter

Method

func AcceptPath added in v1.2.0

func AcceptPath(urls ...string) Filter

Path

func AcceptPathContains added in v1.2.0

func AcceptPathContains(parts ...string) Filter

func AcceptPathMatch added in v1.2.0

func AcceptPathMatch(regs ...regexp.Regexp) Filter

func AcceptPathPrefix added in v1.2.0

func AcceptPathPrefix(prefixs ...string) Filter

func AcceptPathSuffix added in v1.2.0

func AcceptPathSuffix(prefixs ...string) Filter

func AcceptStatus added in v1.2.0

func AcceptStatus(statuses ...int) Filter

Status

func AcceptStatusGreaterThan added in v1.2.0

func AcceptStatusGreaterThan(status int) Filter

func AcceptStatusGreaterThanOrEqual added in v1.2.0

func AcceptStatusGreaterThanOrEqual(status int) Filter

func Ignore added in v1.2.0

func Ignore(filter Filter) Filter

func IgnoreHost added in v1.2.0

func IgnoreHost(hosts ...string) Filter

func IgnoreHostContains added in v1.2.0

func IgnoreHostContains(parts ...string) Filter

func IgnoreHostMatch added in v1.2.0

func IgnoreHostMatch(regs ...regexp.Regexp) Filter

func IgnoreHostPrefix added in v1.2.0

func IgnoreHostPrefix(prefixs ...string) Filter

func IgnoreHostSuffix added in v1.2.0

func IgnoreHostSuffix(suffixs ...string) Filter

func IgnoreMethod added in v1.2.0

func IgnoreMethod(methods ...string) Filter

func IgnorePath added in v1.2.0

func IgnorePath(urls ...string) Filter

func IgnorePathContains added in v1.2.0

func IgnorePathContains(parts ...string) Filter

func IgnorePathMatch added in v1.2.0

func IgnorePathMatch(regs ...regexp.Regexp) Filter

func IgnorePathPrefix added in v1.2.0

func IgnorePathPrefix(prefixs ...string) Filter

func IgnorePathSuffix added in v1.2.0

func IgnorePathSuffix(suffixs ...string) Filter

func IgnoreStatus added in v1.2.0

func IgnoreStatus(statuses ...int) Filter

func IgnoreStatusLessThan added in v1.2.0

func IgnoreStatusLessThan(status int) Filter

func IgnoreStatusLessThanOrEqual added in v1.2.0

func IgnoreStatusLessThanOrEqual(status int) Filter

Directories

Path Synopsis

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL