Redmage/pkg/log/watermill.go

40 lines
1.1 KiB
Go
Raw Permalink Normal View History

2024-04-25 13:22:08 +07:00
package log
import (
"context"
"log/slog"
"github.com/ThreeDotsLabs/watermill"
)
type WatermillLogger struct {
with []any
}
func (wa *WatermillLogger) Error(msg string, err error, fields watermill.LogFields) {
New(context.Background()).With(wa.with...).With(intoAttrs(fields)...).Err(err).Error(msg)
}
func (wa *WatermillLogger) Info(msg string, fields watermill.LogFields) {
2024-04-25 20:22:05 +07:00
New(context.Background()).With(wa.with...).With(intoAttrs(fields)...).Debug(msg)
2024-04-25 13:22:08 +07:00
}
func (wa *WatermillLogger) Debug(msg string, fields watermill.LogFields) {
New(context.Background()).With(wa.with...).With(intoAttrs(fields)...).Debug(msg)
}
func (wa *WatermillLogger) Trace(msg string, fields watermill.LogFields) {
New(context.Background()).With(wa.with...).With(intoAttrs(fields)...).Debug(msg)
}
func (wa *WatermillLogger) With(fields watermill.LogFields) watermill.LoggerAdapter {
return &WatermillLogger{with: append(wa.with, intoAttrs(fields)...)}
}
func intoAttrs(fields watermill.LogFields) (attrs []any) {
for k, v := range fields {
attrs = append(attrs, slog.Any(k, v))
}
return attrs
}