mirror of
https://codeberg.org/scip/yadu.git
synced 2025-12-16 20:21:00 +01:00
Compare commits
9 Commits
| Author | SHA1 | Date | |
|---|---|---|---|
| 5c0aadd54a | |||
| 33798bddb3 | |||
|
|
d53c1db7d0 | ||
|
|
1c65084c37 | ||
|
|
7391d990bb | ||
|
|
a993959de7 | ||
| 9547dccc7f | |||
| f733a30fab | |||
|
|
ec3f0b7fc3 |
7
Makefile
7
Makefile
@@ -6,6 +6,8 @@
|
||||
#
|
||||
# no need to modify anything below
|
||||
|
||||
VERSION = $(shell grep VERSION handler.go | head -1 | cut -d '"' -f2)
|
||||
|
||||
all: buildlocal
|
||||
|
||||
buildlocal:
|
||||
@@ -30,3 +32,8 @@ goupdate:
|
||||
|
||||
lint:
|
||||
golangci-lint run -p bugs -p unused
|
||||
|
||||
release: buildlocal test
|
||||
gh release create v$(VERSION) --generate-notes
|
||||
|
||||
|
||||
|
||||
@@ -2,6 +2,7 @@
|
||||
[](https://github.com/tlinden/yadu/actions)
|
||||
[](https://raw.githack.com/wiki/tlinden/yadu/coverage.html)
|
||||

|
||||
[](https://godoc.org/github.com/tlinden/yadu)
|
||||
|
||||
# yadu - a human readable yaml based slog.Handler
|
||||
|
||||
@@ -27,6 +28,8 @@ The log format generated by yadu looks like this:
|
||||
```go
|
||||
logger := slog.New(yadu.NewHandler(os.Stdout, nil))
|
||||
|
||||
type body string
|
||||
|
||||
type Ammo struct {
|
||||
Forweapon string
|
||||
Impact int
|
||||
@@ -118,15 +121,12 @@ handler][humane]. Also helpfull was the [guide to writing `slog` handlers][guid
|
||||
|
||||
+ [humane slog handler][humane]
|
||||
+ [A Guide to Writing `slog` Handlers][guide]
|
||||
+ [`slog`: Golang's official structured logging package][sobyte]
|
||||
+ [A Comprehensive Guide to Structured Logging in Go][betterstack]
|
||||
|
||||
[humane]: https://github.com/telemachus/humane/tree/main
|
||||
[guide]: https://github.com/golang/example/tree/master/slog-handler-guide
|
||||
[mrkaran]: https://mrkaran.dev/posts/structured-logging-in-go-with-slog/
|
||||
[betterstack]: https://betterstack.com/community/guides/logging/logging-in-go/
|
||||
|
||||
|
||||
## LICENSE
|
||||
|
||||
This module is published under the terms of the BSD 3-Clause
|
||||
|
||||
@@ -16,6 +16,12 @@ type Ammo struct {
|
||||
Range int
|
||||
}
|
||||
|
||||
func (a *Ammo) LogValue() slog.Value {
|
||||
return slog.GroupValue(
|
||||
slog.String("Forweapon", a.Forweapon),
|
||||
)
|
||||
}
|
||||
|
||||
type Enemy struct {
|
||||
Alive bool
|
||||
Health int
|
||||
@@ -24,6 +30,12 @@ type Enemy struct {
|
||||
Ammo []Ammo
|
||||
}
|
||||
|
||||
func (e *Enemy) LogValue() slog.Value {
|
||||
return slog.GroupValue(
|
||||
slog.String("name", e.Name),
|
||||
)
|
||||
}
|
||||
|
||||
func removeTime(_ []string, a slog.Attr) slog.Attr {
|
||||
if a.Key == slog.TimeKey {
|
||||
return slog.Attr{}
|
||||
@@ -35,6 +47,7 @@ func main() {
|
||||
opts := &yadu.Options{
|
||||
Level: slog.LevelDebug,
|
||||
ReplaceAttr: removeTime,
|
||||
AddSource: true,
|
||||
}
|
||||
|
||||
logger := slog.New(yadu.NewHandler(os.Stdout, opts))
|
||||
@@ -46,6 +59,7 @@ func main() {
|
||||
}
|
||||
|
||||
slog.Info("info", "enemy", e, "spawn", 199)
|
||||
slog.Info("info", "ammo", &Ammo{Forweapon: "axe", Impact: 1})
|
||||
slog.Info("connecting", "enemies", 100, "players", 2, "world", "600x800")
|
||||
slog.Debug("debug text")
|
||||
slog.Error("error")
|
||||
|
||||
104
handler.go
104
handler.go
@@ -3,9 +3,11 @@ package yadu
|
||||
import (
|
||||
"bytes"
|
||||
"context"
|
||||
"fmt"
|
||||
"io"
|
||||
"log/slog"
|
||||
"regexp"
|
||||
"runtime"
|
||||
"slices"
|
||||
"strings"
|
||||
"sync"
|
||||
@@ -15,18 +17,23 @@ import (
|
||||
"github.com/fatih/color"
|
||||
)
|
||||
|
||||
const VERSION = "0.1.1"
|
||||
|
||||
// We use RFC datestring by default
|
||||
const DefaultTimeFormat = "2006-01-02T03:04.05 MST"
|
||||
|
||||
// Default log level is INFO:
|
||||
const defaultLevel = slog.LevelInfo
|
||||
|
||||
// holds attributes added with logger.With()
|
||||
type attributes map[string]interface{}
|
||||
|
||||
type Handler struct {
|
||||
writer io.Writer
|
||||
mu *sync.Mutex
|
||||
level slog.Leveler
|
||||
groups []string
|
||||
attrs string
|
||||
attrs attributes
|
||||
timeFormat string
|
||||
replaceAttr func(groups []string, a slog.Attr) slog.Attr
|
||||
addSource bool
|
||||
@@ -49,6 +56,7 @@ type Options struct {
|
||||
ReplaceAttr func(groups []string, a slog.Attr) slog.Attr
|
||||
TimeFormat string
|
||||
AddSource bool
|
||||
NoColor bool
|
||||
}
|
||||
|
||||
func (h *Handler) Handle(ctx context.Context, r slog.Record) error {
|
||||
@@ -67,11 +75,28 @@ func (h *Handler) Handle(ctx context.Context, r slog.Record) error {
|
||||
|
||||
fields := make(map[string]interface{}, r.NumAttrs())
|
||||
r.Attrs(func(a slog.Attr) bool {
|
||||
fields[a.Key] = a.Value.Any()
|
||||
//fields[a.Key] = a.Value.Any()
|
||||
a.Value = a.Value.Resolve()
|
||||
wa := make(map[string]interface{})
|
||||
h.appendAttr(wa, a)
|
||||
fields[a.Key] = wa[a.Key]
|
||||
return true
|
||||
})
|
||||
|
||||
tree := h.attrs
|
||||
tree := ""
|
||||
source := ""
|
||||
|
||||
if h.addSource && r.PC != 0 {
|
||||
source = h.getSource(r.PC)
|
||||
}
|
||||
|
||||
if len(h.attrs) > 0 {
|
||||
bytetree, err := yaml.Marshal(h.attrs)
|
||||
if err != nil {
|
||||
return err
|
||||
}
|
||||
tree = h.Postprocess(bytetree)
|
||||
}
|
||||
|
||||
if len(fields) > 0 {
|
||||
bytetree, err := yaml.Marshal(&fields)
|
||||
@@ -79,7 +104,7 @@ func (h *Handler) Handle(ctx context.Context, r slog.Record) error {
|
||||
return err
|
||||
}
|
||||
|
||||
tree = h.Postprocess(bytetree)
|
||||
tree += h.Postprocess(bytetree)
|
||||
}
|
||||
|
||||
timeStr := ""
|
||||
@@ -105,6 +130,8 @@ func (h *Handler) Handle(ctx context.Context, r slog.Record) error {
|
||||
buf.WriteString(" ")
|
||||
buf.WriteString(msg)
|
||||
buf.WriteString(" ")
|
||||
buf.WriteString(source)
|
||||
buf.WriteString(" ")
|
||||
buf.WriteString(color.WhiteString(tree))
|
||||
buf.WriteString("\n")
|
||||
|
||||
@@ -115,6 +142,13 @@ func (h *Handler) Handle(ctx context.Context, r slog.Record) error {
|
||||
return err
|
||||
}
|
||||
|
||||
// report caller source+line as yaml string
|
||||
func (h *Handler) getSource(pc uintptr) string {
|
||||
fs := runtime.CallersFrames([]uintptr{pc})
|
||||
source, _ := fs.Next()
|
||||
return fmt.Sprintf("%s: %d", source.File, source.Line)
|
||||
}
|
||||
|
||||
func (h *Handler) Postprocess(yamlstr []byte) string {
|
||||
return "\n " + strings.TrimSpace(h.indenter.ReplaceAllString(string(yamlstr), " "))
|
||||
}
|
||||
@@ -144,6 +178,10 @@ func NewHandler(out io.Writer, opts *Options) *Handler {
|
||||
h.timeFormat = DefaultTimeFormat
|
||||
}
|
||||
|
||||
if opts.NoColor {
|
||||
color.NoColor = true
|
||||
}
|
||||
|
||||
return h
|
||||
}
|
||||
|
||||
@@ -153,24 +191,59 @@ func (h *Handler) Enabled(_ context.Context, l slog.Level) bool {
|
||||
}
|
||||
|
||||
// attributes plus attrs.
|
||||
func (h *Handler) appendAttr(wa map[string]interface{}, a slog.Attr) {
|
||||
a.Value = a.Value.Resolve()
|
||||
|
||||
if a.Value.Kind() == slog.KindGroup {
|
||||
attrs := a.Value.Group()
|
||||
name := ""
|
||||
if len(attrs) == 0 {
|
||||
return
|
||||
}
|
||||
|
||||
if a.Key != "" {
|
||||
name = a.Key
|
||||
h.groups = append(h.groups, a.Key)
|
||||
}
|
||||
|
||||
innerwa := make(map[string]interface{})
|
||||
for _, a := range attrs {
|
||||
h.appendAttr(innerwa, a)
|
||||
}
|
||||
wa[name] = innerwa
|
||||
|
||||
if a.Key != "" {
|
||||
h.groups = h.groups[:len(h.groups)-1]
|
||||
}
|
||||
|
||||
return
|
||||
}
|
||||
|
||||
if h.replaceAttr != nil {
|
||||
a = h.replaceAttr(h.groups, a)
|
||||
}
|
||||
|
||||
if !a.Equal(slog.Attr{}) {
|
||||
wa[a.Key] = a.Value.Any()
|
||||
}
|
||||
}
|
||||
|
||||
// sub logger is to be created, possibly with attrs, add them to h.attrs
|
||||
func (h *Handler) WithAttrs(attrs []slog.Attr) slog.Handler {
|
||||
if len(attrs) == 0 {
|
||||
return h
|
||||
}
|
||||
|
||||
fields := make(map[string]interface{}, len(attrs))
|
||||
for _, a := range attrs {
|
||||
fields[a.Key] = a.Value.Any()
|
||||
}
|
||||
|
||||
bytetree, err := yaml.Marshal(&fields)
|
||||
if err != nil {
|
||||
panic(err)
|
||||
}
|
||||
|
||||
h2 := h.clone()
|
||||
|
||||
h2.attrs += string(bytetree)
|
||||
wa := make(map[string]interface{})
|
||||
|
||||
for _, a := range attrs {
|
||||
h2.appendAttr(wa, a)
|
||||
}
|
||||
|
||||
h2.attrs = wa
|
||||
|
||||
return h2
|
||||
}
|
||||
|
||||
@@ -195,5 +268,6 @@ func (h *Handler) clone() *Handler {
|
||||
timeFormat: h.timeFormat,
|
||||
replaceAttr: h.replaceAttr,
|
||||
addSource: h.addSource,
|
||||
indenter: h.indenter,
|
||||
}
|
||||
}
|
||||
|
||||
116
handler_test.go
116
handler_test.go
@@ -7,6 +7,7 @@ import (
|
||||
"testing"
|
||||
"time"
|
||||
|
||||
"github.com/fatih/color"
|
||||
"github.com/tlinden/yadu"
|
||||
)
|
||||
|
||||
@@ -19,6 +20,12 @@ type Ammo struct {
|
||||
Range float32
|
||||
}
|
||||
|
||||
func (a *Ammo) LogValue() slog.Value {
|
||||
return slog.GroupValue(
|
||||
slog.String("Forweapon", "Use weapon: "+a.Forweapon),
|
||||
)
|
||||
}
|
||||
|
||||
type Enemy struct {
|
||||
Alive bool
|
||||
Health int
|
||||
@@ -28,10 +35,12 @@ type Enemy struct {
|
||||
}
|
||||
|
||||
type Tests struct {
|
||||
name string
|
||||
want string
|
||||
negate bool
|
||||
opts *yadu.Options
|
||||
name string
|
||||
want string
|
||||
negate bool
|
||||
opts yadu.Options
|
||||
with slog.Attr
|
||||
haswith bool
|
||||
}
|
||||
|
||||
const testTimeFormat = "03:04.05"
|
||||
@@ -47,6 +56,16 @@ var tests = []Tests{
|
||||
want: "ammo:",
|
||||
negate: false,
|
||||
},
|
||||
{
|
||||
name: "has-ammo-logvaluer",
|
||||
want: "Use weapon: Axe",
|
||||
negate: false,
|
||||
},
|
||||
{
|
||||
name: "has-ammo-logvaluer-does-resolve",
|
||||
want: "impact: 50", // should NOT appear
|
||||
negate: true,
|
||||
},
|
||||
{
|
||||
name: "has-alive",
|
||||
want: "alive: true",
|
||||
@@ -65,7 +84,7 @@ var tests = []Tests{
|
||||
{
|
||||
name: "has-no-time",
|
||||
want: time.Now().Format(yadu.DefaultTimeFormat),
|
||||
opts: &yadu.Options{
|
||||
opts: yadu.Options{
|
||||
ReplaceAttr: removeTime,
|
||||
},
|
||||
negate: true,
|
||||
@@ -73,19 +92,78 @@ var tests = []Tests{
|
||||
{
|
||||
name: "has-custom-time",
|
||||
want: time.Now().Format(testTimeFormat),
|
||||
opts: &yadu.Options{
|
||||
opts: yadu.Options{
|
||||
TimeFormat: testTimeFormat,
|
||||
},
|
||||
negate: false,
|
||||
},
|
||||
// FIXME: add WithGroup + WithAttr tests
|
||||
{
|
||||
name: "with-group",
|
||||
want: "pid:",
|
||||
negate: false,
|
||||
with: slog.Group("program_info",
|
||||
slog.Int("pid", 1923),
|
||||
slog.Bool("alive", true),
|
||||
),
|
||||
haswith: true,
|
||||
},
|
||||
{
|
||||
name: "has-debug",
|
||||
want: "DEBUG",
|
||||
negate: false,
|
||||
opts: yadu.Options{
|
||||
Level: slog.LevelDebug,
|
||||
},
|
||||
},
|
||||
{
|
||||
name: "has-warn",
|
||||
want: "WARN",
|
||||
negate: false,
|
||||
opts: yadu.Options{
|
||||
Level: slog.LevelWarn,
|
||||
},
|
||||
},
|
||||
{
|
||||
name: "has-error",
|
||||
want: "ERROR",
|
||||
negate: false,
|
||||
opts: yadu.Options{
|
||||
Level: slog.LevelError,
|
||||
},
|
||||
},
|
||||
{
|
||||
name: "has-source",
|
||||
want: "handler_test.go",
|
||||
negate: false,
|
||||
opts: yadu.Options{
|
||||
AddSource: true,
|
||||
},
|
||||
},
|
||||
{
|
||||
// check if output is NOT colored when disabling it
|
||||
name: "disable-color",
|
||||
want: "\x1b[0m",
|
||||
negate: true,
|
||||
opts: yadu.Options{
|
||||
NoColor: true,
|
||||
},
|
||||
},
|
||||
{
|
||||
// check if output is colored
|
||||
name: "enable-color",
|
||||
want: "\x1b[0m",
|
||||
negate: false,
|
||||
},
|
||||
}
|
||||
|
||||
func GetEnemy() *Enemy {
|
||||
return &Enemy{Alive: true, Health: 10, Name: "Bodo", Body: "body\nbody\n",
|
||||
Ammo: []Ammo{{Forweapon: "Railgun", Range: 400, Impact: 100, Cost: 100000}},
|
||||
}
|
||||
}
|
||||
|
||||
func GetAmmo() *Ammo {
|
||||
return &Ammo{Forweapon: "Axe", Range: 50, Impact: 1, Cost: 50}
|
||||
}
|
||||
|
||||
func removeTime(_ []string, a slog.Attr) slog.Attr {
|
||||
@@ -101,9 +179,29 @@ func Test(t *testing.T) {
|
||||
for _, tt := range tests {
|
||||
var buf bytes.Buffer
|
||||
|
||||
logger := slog.New(yadu.NewHandler(&buf, tt.opts))
|
||||
logger := slog.New(yadu.NewHandler(&buf, &tt.opts))
|
||||
|
||||
if !tt.with.Equal(slog.Attr{}) {
|
||||
logger = logger.With(tt.with)
|
||||
}
|
||||
|
||||
if !tt.opts.NoColor {
|
||||
color.NoColor = false
|
||||
}
|
||||
|
||||
slog.SetDefault(logger)
|
||||
|
||||
switch tt.opts.Level {
|
||||
case slog.LevelDebug:
|
||||
logger.Debug("attack", "enemy", GetEnemy(), "ammo", GetAmmo())
|
||||
case slog.LevelWarn:
|
||||
logger.Warn("attack", "enemy", GetEnemy(), "ammo", GetAmmo())
|
||||
case slog.LevelError:
|
||||
logger.Error("attack", "enemy", GetEnemy(), "ammo", GetAmmo())
|
||||
default:
|
||||
logger.Info("attack", "enemy", GetEnemy(), "ammo", GetAmmo())
|
||||
}
|
||||
|
||||
logger.Info("attack", "enemy", GetEnemy())
|
||||
got := buf.String()
|
||||
|
||||
if strings.Contains(got, tt.want) == tt.negate {
|
||||
|
||||
Reference in New Issue
Block a user