Function TestBatchHandlerAttrsFormat

tools/logger/batch_handler_test.go:255–335

(t *testing.T)

}

func TestBatchHandlerAttrsFormat(t *testing.T) {
	ctx := context.Background()

	beforeLogs := []*Log{}

	h0 := NewBatchHandler(BatchOptions{
		BeforeAddFunc: func(_ context.Context, log *Log) bool {
			beforeLogs = append(beforeLogs, log)
			return true
		},
		WriteFunc: func(_ context.Context, logs []*Log) error {
			return nil
		},
	})

	h1 := h0.WithAttrs([]slog.Attr{slog.Int("a", 1), slog.String("b", "123")})

	h2 := h1.WithGroup("sub").WithAttrs([]slog.Attr{
		slog.Int("c", 3),
		slog.Any("d", map[string]any{"d.1": 1}),
		slog.Any("e", errors.New("example error")),
	})

	record := slog.NewRecord(time.Now(), slog.LevelInfo, "hello", 0)
	record.AddAttrs(slog.String("name", "test"))

	h0.Handle(ctx, record)
	h1.Handle(ctx, record)
	h2.Handle(ctx, record)

	// errors serialization checks
	errorsRecord := slog.NewRecord(time.Now(), slog.LevelError, "details", 0)
	errorsRecord.Add("validation.Errors", validation.Errors{
		"a": validation.NewError("validation_code", "validation_message"),
		"b": errors.New("plain"),
	})
	errorsRecord.Add("wrapped_validation.Errors", fmt.Errorf("wrapped: %w", validation.Errors{
		"a": validation.NewError("validation_code", "validation_message"),
		"b": errors.New("plain"),
	}))
	errorsRecord.Add("map[string]any", map[string]any{
		"a": validation.NewError("validation_code", "validation_message"),
		"b": errors.New("plain"),
		"c": "test_any",
		"d": map[string]any{
			"nestedA": validation.NewError("nested_code", "nested_message"),
			"nestedB": errors.New("nested_plain"),
		},
	})
	errorsRecord.Add("map[string]error", map[string]error{
		"a": validation.NewError("validation_code", "validation_message"),
		"b": errors.New("plain"),
	})
	errorsRecord.Add("map[string]validation.Error", map[string]validation.Error{
		"a": validation.NewError("validation_code", "validation_message"),
		"b": nil,
	})
	errorsRecord.Add("plain_error", errors.New("plain"))