mirror of
https://github.com/taigrr/log-socket
synced 2026-03-20 16:02:28 -07:00
Compare commits
3 Commits
cd/logger-
...
cd/slog-ha
| Author | SHA1 | Date | |
|---|---|---|---|
| cac3d127ee | |||
| 90471833d0 | |||
| 703f80c5f6 |
13
.github/workflows/ci.yaml
vendored
13
.github/workflows/ci.yaml
vendored
@@ -1,20 +1,23 @@
|
|||||||
name: Go package
|
name: Go package
|
||||||
|
|
||||||
on: [push, pull_request]
|
on: [push]
|
||||||
|
|
||||||
jobs:
|
jobs:
|
||||||
test:
|
test:
|
||||||
runs-on: ubuntu-latest
|
runs-on: ubuntu-latest
|
||||||
steps:
|
steps:
|
||||||
- uses: actions/checkout@v4
|
- uses: actions/checkout@v3
|
||||||
|
|
||||||
- name: Set up Go
|
- name: Set up Go
|
||||||
uses: actions/setup-go@v5
|
uses: actions/setup-go@v4
|
||||||
with:
|
with:
|
||||||
go-version: "1.26"
|
go-version: "1.25"
|
||||||
|
|
||||||
|
- name: Install dependencies
|
||||||
|
run: go get .
|
||||||
|
|
||||||
- name: Build
|
- name: Build
|
||||||
run: go build -v ./...
|
run: go build -v ./...
|
||||||
|
|
||||||
- name: Test
|
- name: Test
|
||||||
run: go test -race -v ./...
|
run: go test -v ./...
|
||||||
|
|||||||
23
CRUSH.md
23
CRUSH.md
@@ -239,7 +239,7 @@ Still embeds viewer.html, but HTML now includes:
|
|||||||
|
|
||||||
## Go Version & Dependencies
|
## Go Version & Dependencies
|
||||||
|
|
||||||
- **Go version**: 1.26.1 (specified in go.mod)
|
- **Go version**: 1.24.4 (specified in go.mod)
|
||||||
- **Only external dependency**: `github.com/gorilla/websocket v1.5.3`
|
- **Only external dependency**: `github.com/gorilla/websocket v1.5.3`
|
||||||
|
|
||||||
## Naming Conventions & Style
|
## Naming Conventions & Style
|
||||||
@@ -314,17 +314,27 @@ UI provides "Reconnect" button for this purpose.
|
|||||||
### 6. Stderr Client Uses All Namespaces
|
### 6. Stderr Client Uses All Namespaces
|
||||||
The built-in stderr client (created in `init()`) listens to all namespaces:
|
The built-in stderr client (created in `init()`) listens to all namespaces:
|
||||||
```go
|
```go
|
||||||
stderrClient = CreateClient() // No args = all namespaces
|
stderrClient = CreateClient(DefaultNamespace)
|
||||||
```
|
```
|
||||||
|
|
||||||
It prints logs matching its level and namespace filter in `logStdErr()`:
|
But only prints logs matching its own namespace in `logStdErr()`:
|
||||||
```go
|
```go
|
||||||
if e.level >= c.LogLevel && c.matchesNamespace(e.Namespace) {
|
if e.level >= c.LogLevel && c.matchesNamespace(e.Namespace) {
|
||||||
fmt.Fprintf(os.Stderr, "%s\t%s\t[%s]\t%s\t%s\n", ...)
|
fmt.Fprintf(os.Stderr, "%s\t%s\t[%s]\t%s\t%s\n", ...)
|
||||||
}
|
}
|
||||||
```
|
```
|
||||||
|
|
||||||
Since `CreateClient()` is called with no arguments, the Namespaces slice is empty, which means it matches all namespaces.
|
**Wait, that's a bug!** The stderr client is created with `DefaultNamespace` but should be created with no namespaces to see all logs. Let me check this.
|
||||||
|
|
||||||
|
Actually looking at the code:
|
||||||
|
```go
|
||||||
|
stderrClient = CreateClient(DefaultNamespace)
|
||||||
|
```
|
||||||
|
|
||||||
|
This means stderr client only sees "default" namespace logs. This might be intentional, but seems like a bug. Should probably be:
|
||||||
|
```go
|
||||||
|
stderrClient = CreateClient() // No args = all namespaces
|
||||||
|
```
|
||||||
|
|
||||||
### 7. Grid Layout Updated
|
### 7. Grid Layout Updated
|
||||||
The log viewer grid changed from 4 to 5 columns:
|
The log viewer grid changed from 4 to 5 columns:
|
||||||
@@ -364,9 +374,8 @@ All existing tests pass with namespace support added.
|
|||||||
## CI/CD
|
## CI/CD
|
||||||
|
|
||||||
GitHub Actions workflow (`.github/workflows/ci.yaml`):
|
GitHub Actions workflow (`.github/workflows/ci.yaml`):
|
||||||
- Uses Go 1.26, actions/checkout@v4, actions/setup-go@v5
|
- Still uses Go 1.21 (should update to 1.24.4 to match go.mod)
|
||||||
- Runs tests with `-race` flag
|
- No changes needed for v2 functionality
|
||||||
- Triggers on push and pull_request
|
|
||||||
|
|
||||||
## Common Tasks
|
## Common Tasks
|
||||||
|
|
||||||
|
|||||||
2
go.mod
2
go.mod
@@ -1,5 +1,5 @@
|
|||||||
module github.com/taigrr/log-socket/v2
|
module github.com/taigrr/log-socket/v2
|
||||||
|
|
||||||
go 1.26.1
|
go 1.26.0
|
||||||
|
|
||||||
require github.com/gorilla/websocket v1.5.3
|
require github.com/gorilla/websocket v1.5.3
|
||||||
|
|||||||
508
log/log_test.go
508
log/log_test.go
@@ -4,21 +4,8 @@ import (
|
|||||||
"strconv"
|
"strconv"
|
||||||
"sync"
|
"sync"
|
||||||
"testing"
|
"testing"
|
||||||
"time"
|
|
||||||
)
|
)
|
||||||
|
|
||||||
// getEntry reads from a client with a timeout to avoid hanging tests.
|
|
||||||
func getEntry(c *Client, timeout time.Duration) (Entry, bool) {
|
|
||||||
ch := make(chan Entry, 1)
|
|
||||||
go func() { ch <- c.Get() }()
|
|
||||||
select {
|
|
||||||
case e := <-ch:
|
|
||||||
return e, true
|
|
||||||
case <-time.After(timeout):
|
|
||||||
return Entry{}, false
|
|
||||||
}
|
|
||||||
}
|
|
||||||
|
|
||||||
// Test CreateClient() and Client.Destroy()
|
// Test CreateClient() and Client.Destroy()
|
||||||
func TestCreateDestroy(t *testing.T) {
|
func TestCreateDestroy(t *testing.T) {
|
||||||
// Ensure only stderr exists at the beginning
|
// Ensure only stderr exists at the beginning
|
||||||
@@ -77,477 +64,70 @@ func TestOrder(t *testing.T) {
|
|||||||
t.Error("Trace input doesn't match output")
|
t.Error("Trace input doesn't match output")
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
c.Destroy()
|
|
||||||
}
|
}
|
||||||
|
|
||||||
|
// Debug prints out logs on debug level
|
||||||
func TestDebug(t *testing.T) {
|
func TestDebug(t *testing.T) {
|
||||||
c := CreateClient(DefaultNamespace)
|
Debug("Test of Debug")
|
||||||
c.SetLogLevel(LDebug)
|
// if logLevel >= LDebug {
|
||||||
|
// entry := logger.WithFields(logrus.Fields{})
|
||||||
Debug("debug message")
|
// entry.Data["file"] = fileInfo(2)
|
||||||
e, ok := getEntry(c, time.Second)
|
// entry.Debug(args...)
|
||||||
if !ok {
|
// }
|
||||||
t.Fatal("timed out waiting for debug entry")
|
|
||||||
}
|
|
||||||
if e.Level != "DEBUG" {
|
|
||||||
t.Errorf("level = %q, want DEBUG", e.Level)
|
|
||||||
}
|
|
||||||
if e.Output != "debug message" {
|
|
||||||
t.Errorf("output = %q, want %q", e.Output, "debug message")
|
|
||||||
}
|
|
||||||
if e.Namespace != DefaultNamespace {
|
|
||||||
t.Errorf("namespace = %q, want %q", e.Namespace, DefaultNamespace)
|
|
||||||
}
|
|
||||||
c.Destroy()
|
|
||||||
}
|
|
||||||
|
|
||||||
func TestDebugf(t *testing.T) {
|
|
||||||
c := CreateClient(DefaultNamespace)
|
|
||||||
c.SetLogLevel(LDebug)
|
|
||||||
|
|
||||||
Debugf("hello %s %d", "world", 42)
|
|
||||||
e, ok := getEntry(c, time.Second)
|
|
||||||
if !ok {
|
|
||||||
t.Fatal("timed out")
|
|
||||||
}
|
|
||||||
if e.Output != "hello world 42" {
|
|
||||||
t.Errorf("output = %q, want %q", e.Output, "hello world 42")
|
|
||||||
}
|
|
||||||
c.Destroy()
|
|
||||||
}
|
}
|
||||||
|
|
||||||
|
// Info prints out logs on info level
|
||||||
func TestInfo(t *testing.T) {
|
func TestInfo(t *testing.T) {
|
||||||
c := CreateClient(DefaultNamespace)
|
// if logLevel >= LInfo {
|
||||||
c.SetLogLevel(LInfo)
|
// entry := logger.WithFields(logrus.Fields{})
|
||||||
|
// entry.Data["file"] = fileInfo(2)
|
||||||
Info("info message")
|
// entry.Info(args...)
|
||||||
e, ok := getEntry(c, time.Second)
|
// }
|
||||||
if !ok {
|
|
||||||
t.Fatal("timed out waiting for info entry")
|
|
||||||
}
|
|
||||||
if e.Level != "INFO" {
|
|
||||||
t.Errorf("level = %q, want INFO", e.Level)
|
|
||||||
}
|
|
||||||
if e.Output != "info message" {
|
|
||||||
t.Errorf("output = %q, want %q", e.Output, "info message")
|
|
||||||
}
|
|
||||||
c.Destroy()
|
|
||||||
}
|
|
||||||
|
|
||||||
func TestInfof(t *testing.T) {
|
|
||||||
c := CreateClient(DefaultNamespace)
|
|
||||||
c.SetLogLevel(LInfo)
|
|
||||||
|
|
||||||
Infof("count: %d", 99)
|
|
||||||
e, ok := getEntry(c, time.Second)
|
|
||||||
if !ok {
|
|
||||||
t.Fatal("timed out")
|
|
||||||
}
|
|
||||||
if e.Output != "count: 99" {
|
|
||||||
t.Errorf("output = %q, want %q", e.Output, "count: 99")
|
|
||||||
}
|
|
||||||
c.Destroy()
|
|
||||||
}
|
}
|
||||||
|
|
||||||
|
// Print prints out logs on info level
|
||||||
func TestPrint(t *testing.T) {
|
func TestPrint(t *testing.T) {
|
||||||
c := CreateClient(DefaultNamespace)
|
// if logLevel >= LInfo {
|
||||||
c.SetLogLevel(LInfo)
|
// entry := logger.WithFields(logrus.Fields{})
|
||||||
|
// entry.Data["file"] = fileInfo(2)
|
||||||
Print("print message")
|
// entry.Info(args...)
|
||||||
e, ok := getEntry(c, time.Second)
|
// }
|
||||||
if !ok {
|
|
||||||
t.Fatal("timed out")
|
|
||||||
}
|
|
||||||
// Print is an alias for Info
|
|
||||||
if e.Level != "INFO" {
|
|
||||||
t.Errorf("level = %q, want INFO", e.Level)
|
|
||||||
}
|
|
||||||
if e.Output != "print message" {
|
|
||||||
t.Errorf("output = %q, want %q", e.Output, "print message")
|
|
||||||
}
|
|
||||||
c.Destroy()
|
|
||||||
}
|
|
||||||
|
|
||||||
func TestPrintf(t *testing.T) {
|
|
||||||
c := CreateClient(DefaultNamespace)
|
|
||||||
c.SetLogLevel(LInfo)
|
|
||||||
|
|
||||||
Printf("formatted %s", "print")
|
|
||||||
e, ok := getEntry(c, time.Second)
|
|
||||||
if !ok {
|
|
||||||
t.Fatal("timed out")
|
|
||||||
}
|
|
||||||
if e.Output != "formatted print" {
|
|
||||||
t.Errorf("output = %q, want %q", e.Output, "formatted print")
|
|
||||||
}
|
|
||||||
c.Destroy()
|
|
||||||
}
|
|
||||||
|
|
||||||
func TestNotice(t *testing.T) {
|
|
||||||
c := CreateClient(DefaultNamespace)
|
|
||||||
c.SetLogLevel(LNotice)
|
|
||||||
|
|
||||||
Notice("notice message")
|
|
||||||
e, ok := getEntry(c, time.Second)
|
|
||||||
if !ok {
|
|
||||||
t.Fatal("timed out")
|
|
||||||
}
|
|
||||||
if e.Level != "NOTICE" {
|
|
||||||
t.Errorf("level = %q, want NOTICE", e.Level)
|
|
||||||
}
|
|
||||||
c.Destroy()
|
|
||||||
}
|
}
|
||||||
|
|
||||||
|
// Warn prints out logs on warn level
|
||||||
func TestWarn(t *testing.T) {
|
func TestWarn(t *testing.T) {
|
||||||
c := CreateClient(DefaultNamespace)
|
// if logLevel >= LWarn {
|
||||||
c.SetLogLevel(LWarn)
|
// entry := logger.WithFields(logrus.Fields{})
|
||||||
|
// entry.Data["file"] = fileInfo(2)
|
||||||
Warn("warning message")
|
// entry.Warn(args...)
|
||||||
e, ok := getEntry(c, time.Second)
|
// }
|
||||||
if !ok {
|
|
||||||
t.Fatal("timed out waiting for warn entry")
|
|
||||||
}
|
|
||||||
if e.Level != "WARN" {
|
|
||||||
t.Errorf("level = %q, want WARN", e.Level)
|
|
||||||
}
|
|
||||||
if e.Output != "warning message" {
|
|
||||||
t.Errorf("output = %q, want %q", e.Output, "warning message")
|
|
||||||
}
|
|
||||||
c.Destroy()
|
|
||||||
}
|
|
||||||
|
|
||||||
func TestWarnf(t *testing.T) {
|
|
||||||
c := CreateClient(DefaultNamespace)
|
|
||||||
c.SetLogLevel(LWarn)
|
|
||||||
|
|
||||||
Warnf("warn %d", 1)
|
|
||||||
e, ok := getEntry(c, time.Second)
|
|
||||||
if !ok {
|
|
||||||
t.Fatal("timed out")
|
|
||||||
}
|
|
||||||
if e.Output != "warn 1" {
|
|
||||||
t.Errorf("output = %q, want %q", e.Output, "warn 1")
|
|
||||||
}
|
|
||||||
c.Destroy()
|
|
||||||
}
|
}
|
||||||
|
|
||||||
|
// Error prints out logs on error level
|
||||||
func TestError(t *testing.T) {
|
func TestError(t *testing.T) {
|
||||||
c := CreateClient(DefaultNamespace)
|
// if logLevel >= LError {
|
||||||
c.SetLogLevel(LError)
|
// entry := logger.WithFields(logrus.Fields{})
|
||||||
|
// entry.Data["file"] = fileInfo(2)
|
||||||
Error("error message")
|
// entry.Error(args...)
|
||||||
e, ok := getEntry(c, time.Second)
|
// }
|
||||||
if !ok {
|
|
||||||
t.Fatal("timed out waiting for error entry")
|
|
||||||
}
|
|
||||||
if e.Level != "ERROR" {
|
|
||||||
t.Errorf("level = %q, want ERROR", e.Level)
|
|
||||||
}
|
|
||||||
if e.Output != "error message" {
|
|
||||||
t.Errorf("output = %q, want %q", e.Output, "error message")
|
|
||||||
}
|
|
||||||
c.Destroy()
|
|
||||||
}
|
}
|
||||||
|
|
||||||
func TestErrorf(t *testing.T) {
|
// Fatal prints out logs on fatal level
|
||||||
c := CreateClient(DefaultNamespace)
|
func TestFatal(t *testing.T) {
|
||||||
c.SetLogLevel(LError)
|
// if logLevel >= LFatal {
|
||||||
|
// entry := logger.WithFields(logrus.Fields{})
|
||||||
Errorf("err: %s", "something broke")
|
// entry.Data["file"] = fileInfo(2)
|
||||||
e, ok := getEntry(c, time.Second)
|
// entry.Fatal(args...)
|
||||||
if !ok {
|
// }
|
||||||
t.Fatal("timed out")
|
|
||||||
}
|
|
||||||
if e.Output != "err: something broke" {
|
|
||||||
t.Errorf("output = %q, want %q", e.Output, "err: something broke")
|
|
||||||
}
|
|
||||||
c.Destroy()
|
|
||||||
}
|
}
|
||||||
|
|
||||||
|
// Panic prints out logs on panic level
|
||||||
func TestPanic(t *testing.T) {
|
func TestPanic(t *testing.T) {
|
||||||
c := CreateClient(DefaultNamespace)
|
// if logLevel >= LPanic {
|
||||||
c.SetLogLevel(LPanic)
|
// entry := logger.WithFields(logrus.Fields{})
|
||||||
|
// entry.Data["file"] = fileInfo(2)
|
||||||
defer func() {
|
// entry.Panic(args...)
|
||||||
r := recover()
|
// }
|
||||||
if r == nil {
|
|
||||||
t.Error("expected panic, got nil")
|
|
||||||
}
|
|
||||||
c.Destroy()
|
|
||||||
}()
|
|
||||||
|
|
||||||
Panic("panic message")
|
|
||||||
}
|
|
||||||
|
|
||||||
func TestPanicf(t *testing.T) {
|
|
||||||
c := CreateClient(DefaultNamespace)
|
|
||||||
c.SetLogLevel(LPanic)
|
|
||||||
|
|
||||||
defer func() {
|
|
||||||
r := recover()
|
|
||||||
if r == nil {
|
|
||||||
t.Error("expected panic, got nil")
|
|
||||||
}
|
|
||||||
c.Destroy()
|
|
||||||
}()
|
|
||||||
|
|
||||||
Panicf("panic %d", 42)
|
|
||||||
}
|
|
||||||
|
|
||||||
func TestPanicln(t *testing.T) {
|
|
||||||
c := CreateClient(DefaultNamespace)
|
|
||||||
c.SetLogLevel(LPanic)
|
|
||||||
|
|
||||||
defer func() {
|
|
||||||
r := recover()
|
|
||||||
if r == nil {
|
|
||||||
t.Error("expected panic, got nil")
|
|
||||||
}
|
|
||||||
c.Destroy()
|
|
||||||
}()
|
|
||||||
|
|
||||||
Panicln("panic line")
|
|
||||||
}
|
|
||||||
|
|
||||||
// TestLogLevelFiltering verifies that the client's log level is stored correctly.
|
|
||||||
// Note: level filtering only applies to stderr output, not to client channels.
|
|
||||||
// All entries matching the namespace are delivered to the client channel regardless of level.
|
|
||||||
func TestLogLevelFiltering(t *testing.T) {
|
|
||||||
c := CreateClient(DefaultNamespace)
|
|
||||||
c.SetLogLevel(LWarn)
|
|
||||||
|
|
||||||
if c.GetLogLevel() != LWarn {
|
|
||||||
t.Errorf("expected log level LWarn, got %d", c.GetLogLevel())
|
|
||||||
}
|
|
||||||
|
|
||||||
// Both entries arrive at the client channel (level filtering is stderr-only)
|
|
||||||
Info("info message")
|
|
||||||
Warn("warn message")
|
|
||||||
|
|
||||||
e1, ok := getEntry(c, time.Second)
|
|
||||||
if !ok {
|
|
||||||
t.Fatal("timed out waiting for first entry")
|
|
||||||
}
|
|
||||||
if e1.Output != "info message" {
|
|
||||||
t.Errorf("expected 'info message', got %q", e1.Output)
|
|
||||||
}
|
|
||||||
|
|
||||||
e2, ok := getEntry(c, time.Second)
|
|
||||||
if !ok {
|
|
||||||
t.Fatal("timed out waiting for second entry")
|
|
||||||
}
|
|
||||||
if e2.Output != "warn message" {
|
|
||||||
t.Errorf("expected 'warn message', got %q", e2.Output)
|
|
||||||
}
|
|
||||||
c.Destroy()
|
|
||||||
}
|
|
||||||
|
|
||||||
// TestNamespaceFiltering verifies clients only receive matching namespaces.
|
|
||||||
func TestNamespaceFiltering(t *testing.T) {
|
|
||||||
c := CreateClient("api")
|
|
||||||
c.SetLogLevel(LTrace)
|
|
||||||
|
|
||||||
apiLogger := NewLogger("api")
|
|
||||||
dbLogger := NewLogger("database")
|
|
||||||
|
|
||||||
// Log to database namespace — should not arrive at "api" client
|
|
||||||
dbLogger.Info("db message")
|
|
||||||
|
|
||||||
// Log to api namespace — should arrive
|
|
||||||
apiLogger.Info("api message")
|
|
||||||
|
|
||||||
e, ok := getEntry(c, time.Second)
|
|
||||||
if !ok {
|
|
||||||
t.Fatal("timed out waiting for api entry")
|
|
||||||
}
|
|
||||||
if e.Output != "api message" {
|
|
||||||
t.Errorf("expected 'api message', got %q", e.Output)
|
|
||||||
}
|
|
||||||
if e.Namespace != "api" {
|
|
||||||
t.Errorf("namespace = %q, want 'api'", e.Namespace)
|
|
||||||
}
|
|
||||||
c.Destroy()
|
|
||||||
}
|
|
||||||
|
|
||||||
// TestMultiNamespaceClient verifies a client subscribed to multiple namespaces.
|
|
||||||
func TestMultiNamespaceClient(t *testing.T) {
|
|
||||||
c := CreateClient("api", "auth")
|
|
||||||
c.SetLogLevel(LTrace)
|
|
||||||
|
|
||||||
apiLogger := NewLogger("api")
|
|
||||||
authLogger := NewLogger("auth")
|
|
||||||
dbLogger := NewLogger("database")
|
|
||||||
|
|
||||||
dbLogger.Info("db message") // filtered out
|
|
||||||
apiLogger.Info("api message") // should arrive
|
|
||||||
authLogger.Info("auth message") // should arrive
|
|
||||||
|
|
||||||
e1, ok := getEntry(c, time.Second)
|
|
||||||
if !ok {
|
|
||||||
t.Fatal("timed out waiting for first entry")
|
|
||||||
}
|
|
||||||
if e1.Output != "api message" {
|
|
||||||
t.Errorf("first entry = %q, want 'api message'", e1.Output)
|
|
||||||
}
|
|
||||||
|
|
||||||
e2, ok := getEntry(c, time.Second)
|
|
||||||
if !ok {
|
|
||||||
t.Fatal("timed out waiting for second entry")
|
|
||||||
}
|
|
||||||
if e2.Output != "auth message" {
|
|
||||||
t.Errorf("second entry = %q, want 'auth message'", e2.Output)
|
|
||||||
}
|
|
||||||
c.Destroy()
|
|
||||||
}
|
|
||||||
|
|
||||||
// TestGetNamespaces verifies the namespace registry.
|
|
||||||
func TestGetNamespaces(t *testing.T) {
|
|
||||||
l := NewLogger("test-ns-registry")
|
|
||||||
l.Info("register this namespace")
|
|
||||||
|
|
||||||
nss := GetNamespaces()
|
|
||||||
found := false
|
|
||||||
for _, ns := range nss {
|
|
||||||
if ns == "test-ns-registry" {
|
|
||||||
found = true
|
|
||||||
break
|
|
||||||
}
|
|
||||||
}
|
|
||||||
if !found {
|
|
||||||
t.Errorf("expected 'test-ns-registry' in GetNamespaces(), got %v", nss)
|
|
||||||
}
|
|
||||||
}
|
|
||||||
|
|
||||||
// TestLoggerDebugln verifies the Debugln method on Logger.
|
|
||||||
func TestLoggerDebugln(t *testing.T) {
|
|
||||||
c := CreateClient("debugln-test")
|
|
||||||
c.SetLogLevel(LDebug)
|
|
||||||
|
|
||||||
l := NewLogger("debugln-test")
|
|
||||||
l.Debugln("debugln message")
|
|
||||||
|
|
||||||
e, ok := getEntry(c, time.Second)
|
|
||||||
if !ok {
|
|
||||||
t.Fatal("timed out")
|
|
||||||
}
|
|
||||||
if e.Level != "DEBUG" {
|
|
||||||
t.Errorf("level = %q, want DEBUG", e.Level)
|
|
||||||
}
|
|
||||||
// Sprintln appends a newline
|
|
||||||
if e.Output != "debugln message\n" {
|
|
||||||
t.Errorf("output = %q, want %q", e.Output, "debugln message\n")
|
|
||||||
}
|
|
||||||
c.Destroy()
|
|
||||||
}
|
|
||||||
|
|
||||||
// TestNewLoggerEmptyNamespace verifies empty namespace defaults to DefaultNamespace.
|
|
||||||
func TestNewLoggerEmptyNamespace(t *testing.T) {
|
|
||||||
l := NewLogger("")
|
|
||||||
if l.Namespace != DefaultNamespace {
|
|
||||||
t.Errorf("namespace = %q, want %q", l.Namespace, DefaultNamespace)
|
|
||||||
}
|
|
||||||
}
|
|
||||||
|
|
||||||
// TestFileInfo verifies fileInfo returns a non-empty file:line string.
|
|
||||||
func TestFileInfo(t *testing.T) {
|
|
||||||
fi := fileInfo(1)
|
|
||||||
if fi == "" || fi == "<???>:1" {
|
|
||||||
t.Errorf("fileInfo returned unexpected value: %q", fi)
|
|
||||||
}
|
|
||||||
}
|
|
||||||
|
|
||||||
// TestColorize verifies color wrapping.
|
|
||||||
func TestColorize(t *testing.T) {
|
|
||||||
SetColorEnabled(true)
|
|
||||||
result := colorize("hello", colorRed)
|
|
||||||
expected := colorRed + "hello" + colorReset
|
|
||||||
if result != expected {
|
|
||||||
t.Errorf("colorize with color enabled: got %q, want %q", result, expected)
|
|
||||||
}
|
|
||||||
|
|
||||||
SetColorEnabled(false)
|
|
||||||
result = colorize("hello", colorRed)
|
|
||||||
if result != "hello" {
|
|
||||||
t.Errorf("colorize with color disabled: got %q, want %q", result, "hello")
|
|
||||||
}
|
|
||||||
|
|
||||||
// Restore default
|
|
||||||
SetColorEnabled(true)
|
|
||||||
}
|
|
||||||
|
|
||||||
// TestParseLevelString verifies level string parsing.
|
|
||||||
func TestParseLevelString(t *testing.T) {
|
|
||||||
tests := []struct {
|
|
||||||
input string
|
|
||||||
want Level
|
|
||||||
}{
|
|
||||||
{"TRACE", LTrace},
|
|
||||||
{"DEBUG", LDebug},
|
|
||||||
{"INFO", LInfo},
|
|
||||||
{"NOTICE", LNotice},
|
|
||||||
{"WARN", LWarn},
|
|
||||||
{"ERROR", LError},
|
|
||||||
{"PANIC", LPanic},
|
|
||||||
{"FATAL", LFatal},
|
|
||||||
{"UNKNOWN", LInfo}, // default
|
|
||||||
{"", LInfo}, // default
|
|
||||||
}
|
|
||||||
for _, tt := range tests {
|
|
||||||
got := parseLevelString(tt.input)
|
|
||||||
if got != tt.want {
|
|
||||||
t.Errorf("parseLevelString(%q) = %d, want %d", tt.input, got, tt.want)
|
|
||||||
}
|
|
||||||
}
|
|
||||||
}
|
|
||||||
|
|
||||||
// TestBroadcast verifies the public Broadcast function.
|
|
||||||
func TestBroadcast(t *testing.T) {
|
|
||||||
c := CreateClient("broadcast-ns")
|
|
||||||
c.SetLogLevel(LTrace)
|
|
||||||
|
|
||||||
e := Entry{
|
|
||||||
Timestamp: time.Now(),
|
|
||||||
Output: "broadcast test",
|
|
||||||
File: "test.go:1",
|
|
||||||
Level: "WARN",
|
|
||||||
Namespace: "broadcast-ns",
|
|
||||||
}
|
|
||||||
Broadcast(e)
|
|
||||||
|
|
||||||
got, ok := getEntry(c, time.Second)
|
|
||||||
if !ok {
|
|
||||||
t.Fatal("timed out")
|
|
||||||
}
|
|
||||||
if got.Output != "broadcast test" {
|
|
||||||
t.Errorf("output = %q, want %q", got.Output, "broadcast test")
|
|
||||||
}
|
|
||||||
if got.Level != "WARN" {
|
|
||||||
t.Errorf("level = %q, want WARN", got.Level)
|
|
||||||
}
|
|
||||||
c.Destroy()
|
|
||||||
}
|
|
||||||
|
|
||||||
// TestMatchesNamespace verifies the namespace matching helper.
|
|
||||||
func TestMatchesNamespace(t *testing.T) {
|
|
||||||
// Client with no namespace filter matches everything
|
|
||||||
c := CreateClient()
|
|
||||||
if !c.matchesNamespace("anything") {
|
|
||||||
t.Error("empty Namespaces should match all")
|
|
||||||
}
|
|
||||||
c.Destroy()
|
|
||||||
|
|
||||||
// Client with specific namespaces
|
|
||||||
c2 := CreateClient("api", "auth")
|
|
||||||
if !c2.matchesNamespace("api") {
|
|
||||||
t.Error("should match 'api'")
|
|
||||||
}
|
|
||||||
if !c2.matchesNamespace("auth") {
|
|
||||||
t.Error("should match 'auth'")
|
|
||||||
}
|
|
||||||
if c2.matchesNamespace("database") {
|
|
||||||
t.Error("should not match 'database'")
|
|
||||||
}
|
|
||||||
c2.Destroy()
|
|
||||||
}
|
}
|
||||||
|
|
||||||
func TestFlush(t *testing.T) {
|
func TestFlush(t *testing.T) {
|
||||||
|
|||||||
@@ -92,20 +92,6 @@ func (l Logger) Debugf(format string, args ...any) {
|
|||||||
createLog(e)
|
createLog(e)
|
||||||
}
|
}
|
||||||
|
|
||||||
// Debugln prints out logs on debug level with a newline
|
|
||||||
func (l Logger) Debugln(args ...any) {
|
|
||||||
output := fmt.Sprintln(args...)
|
|
||||||
e := Entry{
|
|
||||||
Timestamp: time.Now(),
|
|
||||||
Output: output,
|
|
||||||
File: fileInfo(2 + l.FileInfoDepth),
|
|
||||||
Level: "DEBUG",
|
|
||||||
level: LDebug,
|
|
||||||
Namespace: l.Namespace,
|
|
||||||
}
|
|
||||||
createLog(e)
|
|
||||||
}
|
|
||||||
|
|
||||||
// Info prints out logs on info level
|
// Info prints out logs on info level
|
||||||
func (l Logger) Info(args ...any) {
|
func (l Logger) Info(args ...any) {
|
||||||
output := fmt.Sprint(args...)
|
output := fmt.Sprint(args...)
|
||||||
|
|||||||
@@ -1,518 +0,0 @@
|
|||||||
package log
|
|
||||||
|
|
||||||
import (
|
|
||||||
"testing"
|
|
||||||
"time"
|
|
||||||
)
|
|
||||||
|
|
||||||
func TestLoggerTrace(t *testing.T) {
|
|
||||||
c := CreateClient("logger-trace")
|
|
||||||
c.SetLogLevel(LTrace)
|
|
||||||
|
|
||||||
l := NewLogger("logger-trace")
|
|
||||||
l.Trace("trace message")
|
|
||||||
|
|
||||||
e, ok := getEntry(c, time.Second)
|
|
||||||
if !ok {
|
|
||||||
t.Fatal("timed out")
|
|
||||||
}
|
|
||||||
if e.Level != "TRACE" {
|
|
||||||
t.Errorf("level = %q, want TRACE", e.Level)
|
|
||||||
}
|
|
||||||
if e.Output != "trace message" {
|
|
||||||
t.Errorf("output = %q, want %q", e.Output, "trace message")
|
|
||||||
}
|
|
||||||
if e.Namespace != "logger-trace" {
|
|
||||||
t.Errorf("namespace = %q, want %q", e.Namespace, "logger-trace")
|
|
||||||
}
|
|
||||||
c.Destroy()
|
|
||||||
}
|
|
||||||
|
|
||||||
func TestLoggerTracef(t *testing.T) {
|
|
||||||
c := CreateClient("logger-tracef")
|
|
||||||
c.SetLogLevel(LTrace)
|
|
||||||
|
|
||||||
l := NewLogger("logger-tracef")
|
|
||||||
l.Tracef("trace %s %d", "msg", 1)
|
|
||||||
|
|
||||||
e, ok := getEntry(c, time.Second)
|
|
||||||
if !ok {
|
|
||||||
t.Fatal("timed out")
|
|
||||||
}
|
|
||||||
if e.Level != "TRACE" {
|
|
||||||
t.Errorf("level = %q, want TRACE", e.Level)
|
|
||||||
}
|
|
||||||
if e.Output != "trace msg 1" {
|
|
||||||
t.Errorf("output = %q, want %q", e.Output, "trace msg 1")
|
|
||||||
}
|
|
||||||
c.Destroy()
|
|
||||||
}
|
|
||||||
|
|
||||||
func TestLoggerTraceln(t *testing.T) {
|
|
||||||
c := CreateClient("logger-traceln")
|
|
||||||
c.SetLogLevel(LTrace)
|
|
||||||
|
|
||||||
l := NewLogger("logger-traceln")
|
|
||||||
l.Traceln("trace line")
|
|
||||||
|
|
||||||
e, ok := getEntry(c, time.Second)
|
|
||||||
if !ok {
|
|
||||||
t.Fatal("timed out")
|
|
||||||
}
|
|
||||||
if e.Level != "TRACE" {
|
|
||||||
t.Errorf("level = %q, want TRACE", e.Level)
|
|
||||||
}
|
|
||||||
if e.Output != "trace line\n" {
|
|
||||||
t.Errorf("output = %q, want %q", e.Output, "trace line\n")
|
|
||||||
}
|
|
||||||
c.Destroy()
|
|
||||||
}
|
|
||||||
|
|
||||||
func TestLoggerDebug(t *testing.T) {
|
|
||||||
c := CreateClient("logger-debug")
|
|
||||||
c.SetLogLevel(LDebug)
|
|
||||||
|
|
||||||
l := NewLogger("logger-debug")
|
|
||||||
l.Debug("debug message")
|
|
||||||
|
|
||||||
e, ok := getEntry(c, time.Second)
|
|
||||||
if !ok {
|
|
||||||
t.Fatal("timed out")
|
|
||||||
}
|
|
||||||
if e.Level != "DEBUG" {
|
|
||||||
t.Errorf("level = %q, want DEBUG", e.Level)
|
|
||||||
}
|
|
||||||
if e.Output != "debug message" {
|
|
||||||
t.Errorf("output = %q, want %q", e.Output, "debug message")
|
|
||||||
}
|
|
||||||
c.Destroy()
|
|
||||||
}
|
|
||||||
|
|
||||||
func TestLoggerDebugf(t *testing.T) {
|
|
||||||
c := CreateClient("logger-debugf")
|
|
||||||
c.SetLogLevel(LDebug)
|
|
||||||
|
|
||||||
l := NewLogger("logger-debugf")
|
|
||||||
l.Debugf("debug %d", 42)
|
|
||||||
|
|
||||||
e, ok := getEntry(c, time.Second)
|
|
||||||
if !ok {
|
|
||||||
t.Fatal("timed out")
|
|
||||||
}
|
|
||||||
if e.Output != "debug 42" {
|
|
||||||
t.Errorf("output = %q, want %q", e.Output, "debug 42")
|
|
||||||
}
|
|
||||||
c.Destroy()
|
|
||||||
}
|
|
||||||
|
|
||||||
func TestLoggerInfo(t *testing.T) {
|
|
||||||
c := CreateClient("logger-info")
|
|
||||||
c.SetLogLevel(LInfo)
|
|
||||||
|
|
||||||
l := NewLogger("logger-info")
|
|
||||||
l.Info("info message")
|
|
||||||
|
|
||||||
e, ok := getEntry(c, time.Second)
|
|
||||||
if !ok {
|
|
||||||
t.Fatal("timed out")
|
|
||||||
}
|
|
||||||
if e.Level != "INFO" {
|
|
||||||
t.Errorf("level = %q, want INFO", e.Level)
|
|
||||||
}
|
|
||||||
if e.Output != "info message" {
|
|
||||||
t.Errorf("output = %q, want %q", e.Output, "info message")
|
|
||||||
}
|
|
||||||
c.Destroy()
|
|
||||||
}
|
|
||||||
|
|
||||||
func TestLoggerInfof(t *testing.T) {
|
|
||||||
c := CreateClient("logger-infof")
|
|
||||||
c.SetLogLevel(LInfo)
|
|
||||||
|
|
||||||
l := NewLogger("logger-infof")
|
|
||||||
l.Infof("count: %d", 99)
|
|
||||||
|
|
||||||
e, ok := getEntry(c, time.Second)
|
|
||||||
if !ok {
|
|
||||||
t.Fatal("timed out")
|
|
||||||
}
|
|
||||||
if e.Output != "count: 99" {
|
|
||||||
t.Errorf("output = %q, want %q", e.Output, "count: 99")
|
|
||||||
}
|
|
||||||
c.Destroy()
|
|
||||||
}
|
|
||||||
|
|
||||||
func TestLoggerInfoln(t *testing.T) {
|
|
||||||
c := CreateClient("logger-infoln")
|
|
||||||
c.SetLogLevel(LInfo)
|
|
||||||
|
|
||||||
l := NewLogger("logger-infoln")
|
|
||||||
l.Infoln("info line")
|
|
||||||
|
|
||||||
e, ok := getEntry(c, time.Second)
|
|
||||||
if !ok {
|
|
||||||
t.Fatal("timed out")
|
|
||||||
}
|
|
||||||
if e.Output != "info line\n" {
|
|
||||||
t.Errorf("output = %q, want %q", e.Output, "info line\n")
|
|
||||||
}
|
|
||||||
c.Destroy()
|
|
||||||
}
|
|
||||||
|
|
||||||
func TestLoggerNotice(t *testing.T) {
|
|
||||||
c := CreateClient("logger-notice")
|
|
||||||
c.SetLogLevel(LNotice)
|
|
||||||
|
|
||||||
l := NewLogger("logger-notice")
|
|
||||||
l.Notice("notice message")
|
|
||||||
|
|
||||||
e, ok := getEntry(c, time.Second)
|
|
||||||
if !ok {
|
|
||||||
t.Fatal("timed out")
|
|
||||||
}
|
|
||||||
if e.Level != "NOTICE" {
|
|
||||||
t.Errorf("level = %q, want NOTICE", e.Level)
|
|
||||||
}
|
|
||||||
if e.Output != "notice message" {
|
|
||||||
t.Errorf("output = %q, want %q", e.Output, "notice message")
|
|
||||||
}
|
|
||||||
c.Destroy()
|
|
||||||
}
|
|
||||||
|
|
||||||
func TestLoggerNoticef(t *testing.T) {
|
|
||||||
c := CreateClient("logger-noticef")
|
|
||||||
c.SetLogLevel(LNotice)
|
|
||||||
|
|
||||||
l := NewLogger("logger-noticef")
|
|
||||||
l.Noticef("notice %s", "formatted")
|
|
||||||
|
|
||||||
e, ok := getEntry(c, time.Second)
|
|
||||||
if !ok {
|
|
||||||
t.Fatal("timed out")
|
|
||||||
}
|
|
||||||
if e.Output != "notice formatted" {
|
|
||||||
t.Errorf("output = %q, want %q", e.Output, "notice formatted")
|
|
||||||
}
|
|
||||||
c.Destroy()
|
|
||||||
}
|
|
||||||
|
|
||||||
func TestLoggerNoticeln(t *testing.T) {
|
|
||||||
c := CreateClient("logger-noticeln")
|
|
||||||
c.SetLogLevel(LNotice)
|
|
||||||
|
|
||||||
l := NewLogger("logger-noticeln")
|
|
||||||
l.Noticeln("notice line")
|
|
||||||
|
|
||||||
e, ok := getEntry(c, time.Second)
|
|
||||||
if !ok {
|
|
||||||
t.Fatal("timed out")
|
|
||||||
}
|
|
||||||
if e.Output != "notice line\n" {
|
|
||||||
t.Errorf("output = %q, want %q", e.Output, "notice line\n")
|
|
||||||
}
|
|
||||||
c.Destroy()
|
|
||||||
}
|
|
||||||
|
|
||||||
func TestLoggerWarn(t *testing.T) {
|
|
||||||
c := CreateClient("logger-warn")
|
|
||||||
c.SetLogLevel(LWarn)
|
|
||||||
|
|
||||||
l := NewLogger("logger-warn")
|
|
||||||
l.Warn("warn message")
|
|
||||||
|
|
||||||
e, ok := getEntry(c, time.Second)
|
|
||||||
if !ok {
|
|
||||||
t.Fatal("timed out")
|
|
||||||
}
|
|
||||||
if e.Level != "WARN" {
|
|
||||||
t.Errorf("level = %q, want WARN", e.Level)
|
|
||||||
}
|
|
||||||
if e.Output != "warn message" {
|
|
||||||
t.Errorf("output = %q, want %q", e.Output, "warn message")
|
|
||||||
}
|
|
||||||
c.Destroy()
|
|
||||||
}
|
|
||||||
|
|
||||||
func TestLoggerWarnf(t *testing.T) {
|
|
||||||
c := CreateClient("logger-warnf")
|
|
||||||
c.SetLogLevel(LWarn)
|
|
||||||
|
|
||||||
l := NewLogger("logger-warnf")
|
|
||||||
l.Warnf("warn %d", 1)
|
|
||||||
|
|
||||||
e, ok := getEntry(c, time.Second)
|
|
||||||
if !ok {
|
|
||||||
t.Fatal("timed out")
|
|
||||||
}
|
|
||||||
if e.Output != "warn 1" {
|
|
||||||
t.Errorf("output = %q, want %q", e.Output, "warn 1")
|
|
||||||
}
|
|
||||||
c.Destroy()
|
|
||||||
}
|
|
||||||
|
|
||||||
func TestLoggerWarnln(t *testing.T) {
|
|
||||||
c := CreateClient("logger-warnln")
|
|
||||||
c.SetLogLevel(LWarn)
|
|
||||||
|
|
||||||
l := NewLogger("logger-warnln")
|
|
||||||
l.Warnln("warn line")
|
|
||||||
|
|
||||||
e, ok := getEntry(c, time.Second)
|
|
||||||
if !ok {
|
|
||||||
t.Fatal("timed out")
|
|
||||||
}
|
|
||||||
if e.Output != "warn line\n" {
|
|
||||||
t.Errorf("output = %q, want %q", e.Output, "warn line\n")
|
|
||||||
}
|
|
||||||
c.Destroy()
|
|
||||||
}
|
|
||||||
|
|
||||||
func TestLoggerError(t *testing.T) {
|
|
||||||
c := CreateClient("logger-error")
|
|
||||||
c.SetLogLevel(LError)
|
|
||||||
|
|
||||||
l := NewLogger("logger-error")
|
|
||||||
l.Error("error message")
|
|
||||||
|
|
||||||
e, ok := getEntry(c, time.Second)
|
|
||||||
if !ok {
|
|
||||||
t.Fatal("timed out")
|
|
||||||
}
|
|
||||||
if e.Level != "ERROR" {
|
|
||||||
t.Errorf("level = %q, want ERROR", e.Level)
|
|
||||||
}
|
|
||||||
if e.Output != "error message" {
|
|
||||||
t.Errorf("output = %q, want %q", e.Output, "error message")
|
|
||||||
}
|
|
||||||
c.Destroy()
|
|
||||||
}
|
|
||||||
|
|
||||||
func TestLoggerErrorf(t *testing.T) {
|
|
||||||
c := CreateClient("logger-errorf")
|
|
||||||
c.SetLogLevel(LError)
|
|
||||||
|
|
||||||
l := NewLogger("logger-errorf")
|
|
||||||
l.Errorf("err: %s", "something broke")
|
|
||||||
|
|
||||||
e, ok := getEntry(c, time.Second)
|
|
||||||
if !ok {
|
|
||||||
t.Fatal("timed out")
|
|
||||||
}
|
|
||||||
if e.Output != "err: something broke" {
|
|
||||||
t.Errorf("output = %q, want %q", e.Output, "err: something broke")
|
|
||||||
}
|
|
||||||
c.Destroy()
|
|
||||||
}
|
|
||||||
|
|
||||||
func TestLoggerErrorln(t *testing.T) {
|
|
||||||
c := CreateClient("logger-errorln")
|
|
||||||
c.SetLogLevel(LError)
|
|
||||||
|
|
||||||
l := NewLogger("logger-errorln")
|
|
||||||
l.Errorln("error line")
|
|
||||||
|
|
||||||
e, ok := getEntry(c, time.Second)
|
|
||||||
if !ok {
|
|
||||||
t.Fatal("timed out")
|
|
||||||
}
|
|
||||||
if e.Output != "error line\n" {
|
|
||||||
t.Errorf("output = %q, want %q", e.Output, "error line\n")
|
|
||||||
}
|
|
||||||
c.Destroy()
|
|
||||||
}
|
|
||||||
|
|
||||||
func TestLoggerPanic(t *testing.T) {
|
|
||||||
c := CreateClient("logger-panic")
|
|
||||||
c.SetLogLevel(LPanic)
|
|
||||||
|
|
||||||
l := NewLogger("logger-panic")
|
|
||||||
|
|
||||||
defer func() {
|
|
||||||
r := recover()
|
|
||||||
if r == nil {
|
|
||||||
t.Error("expected panic, got nil")
|
|
||||||
}
|
|
||||||
// Verify the entry was broadcast
|
|
||||||
e, ok := getEntry(c, time.Second)
|
|
||||||
if !ok {
|
|
||||||
t.Fatal("timed out waiting for panic entry")
|
|
||||||
}
|
|
||||||
if e.Level != "PANIC" {
|
|
||||||
t.Errorf("level = %q, want PANIC", e.Level)
|
|
||||||
}
|
|
||||||
if e.Namespace != "logger-panic" {
|
|
||||||
t.Errorf("namespace = %q, want %q", e.Namespace, "logger-panic")
|
|
||||||
}
|
|
||||||
c.Destroy()
|
|
||||||
}()
|
|
||||||
|
|
||||||
l.Panic("panic message")
|
|
||||||
}
|
|
||||||
|
|
||||||
func TestLoggerPanicf(t *testing.T) {
|
|
||||||
c := CreateClient("logger-panicf")
|
|
||||||
c.SetLogLevel(LPanic)
|
|
||||||
|
|
||||||
l := NewLogger("logger-panicf")
|
|
||||||
|
|
||||||
defer func() {
|
|
||||||
r := recover()
|
|
||||||
if r == nil {
|
|
||||||
t.Error("expected panic, got nil")
|
|
||||||
}
|
|
||||||
e, ok := getEntry(c, time.Second)
|
|
||||||
if !ok {
|
|
||||||
t.Fatal("timed out")
|
|
||||||
}
|
|
||||||
if e.Output != "panic 42" {
|
|
||||||
t.Errorf("output = %q, want %q", e.Output, "panic 42")
|
|
||||||
}
|
|
||||||
c.Destroy()
|
|
||||||
}()
|
|
||||||
|
|
||||||
l.Panicf("panic %d", 42)
|
|
||||||
}
|
|
||||||
|
|
||||||
func TestLoggerPanicln(t *testing.T) {
|
|
||||||
c := CreateClient("logger-panicln")
|
|
||||||
c.SetLogLevel(LPanic)
|
|
||||||
|
|
||||||
l := NewLogger("logger-panicln")
|
|
||||||
|
|
||||||
defer func() {
|
|
||||||
r := recover()
|
|
||||||
if r == nil {
|
|
||||||
t.Error("expected panic, got nil")
|
|
||||||
}
|
|
||||||
e, ok := getEntry(c, time.Second)
|
|
||||||
if !ok {
|
|
||||||
t.Fatal("timed out")
|
|
||||||
}
|
|
||||||
if e.Output != "panic line\n" {
|
|
||||||
t.Errorf("output = %q, want %q", e.Output, "panic line\n")
|
|
||||||
}
|
|
||||||
c.Destroy()
|
|
||||||
}()
|
|
||||||
|
|
||||||
l.Panicln("panic line")
|
|
||||||
}
|
|
||||||
|
|
||||||
func TestLoggerPrint(t *testing.T) {
|
|
||||||
c := CreateClient("logger-print")
|
|
||||||
c.SetLogLevel(LInfo)
|
|
||||||
|
|
||||||
l := NewLogger("logger-print")
|
|
||||||
l.Print("print message")
|
|
||||||
|
|
||||||
e, ok := getEntry(c, time.Second)
|
|
||||||
if !ok {
|
|
||||||
t.Fatal("timed out")
|
|
||||||
}
|
|
||||||
// Print delegates to Info
|
|
||||||
if e.Level != "INFO" {
|
|
||||||
t.Errorf("level = %q, want INFO", e.Level)
|
|
||||||
}
|
|
||||||
if e.Output != "print message" {
|
|
||||||
t.Errorf("output = %q, want %q", e.Output, "print message")
|
|
||||||
}
|
|
||||||
c.Destroy()
|
|
||||||
}
|
|
||||||
|
|
||||||
func TestLoggerPrintf(t *testing.T) {
|
|
||||||
c := CreateClient("logger-printf")
|
|
||||||
c.SetLogLevel(LInfo)
|
|
||||||
|
|
||||||
l := NewLogger("logger-printf")
|
|
||||||
l.Printf("formatted %s", "print")
|
|
||||||
|
|
||||||
e, ok := getEntry(c, time.Second)
|
|
||||||
if !ok {
|
|
||||||
t.Fatal("timed out")
|
|
||||||
}
|
|
||||||
if e.Output != "formatted print" {
|
|
||||||
t.Errorf("output = %q, want %q", e.Output, "formatted print")
|
|
||||||
}
|
|
||||||
c.Destroy()
|
|
||||||
}
|
|
||||||
|
|
||||||
func TestLoggerPrintln(t *testing.T) {
|
|
||||||
c := CreateClient("logger-println")
|
|
||||||
c.SetLogLevel(LInfo)
|
|
||||||
|
|
||||||
l := NewLogger("logger-println")
|
|
||||||
l.Println("println message")
|
|
||||||
|
|
||||||
e, ok := getEntry(c, time.Second)
|
|
||||||
if !ok {
|
|
||||||
t.Fatal("timed out")
|
|
||||||
}
|
|
||||||
if e.Output != "println message\n" {
|
|
||||||
t.Errorf("output = %q, want %q", e.Output, "println message\n")
|
|
||||||
}
|
|
||||||
c.Destroy()
|
|
||||||
}
|
|
||||||
|
|
||||||
func TestLoggerSetInfoDepth(t *testing.T) {
|
|
||||||
l := NewLogger("depth-test")
|
|
||||||
l.SetInfoDepth(3)
|
|
||||||
if l.FileInfoDepth != 3 {
|
|
||||||
t.Errorf("FileInfoDepth = %d, want 3", l.FileInfoDepth)
|
|
||||||
}
|
|
||||||
}
|
|
||||||
|
|
||||||
func TestDefaultLogger(t *testing.T) {
|
|
||||||
l := Default()
|
|
||||||
if l.Namespace != DefaultNamespace {
|
|
||||||
t.Errorf("namespace = %q, want %q", l.Namespace, DefaultNamespace)
|
|
||||||
}
|
|
||||||
if l.FileInfoDepth != 0 {
|
|
||||||
t.Errorf("FileInfoDepth = %d, want 0", l.FileInfoDepth)
|
|
||||||
}
|
|
||||||
|
|
||||||
// Verify Default() logger can emit entries
|
|
||||||
c := CreateClient(DefaultNamespace)
|
|
||||||
c.SetLogLevel(LInfo)
|
|
||||||
|
|
||||||
l.Info("default logger message")
|
|
||||||
|
|
||||||
e, ok := getEntry(c, time.Second)
|
|
||||||
if !ok {
|
|
||||||
t.Fatal("timed out")
|
|
||||||
}
|
|
||||||
if e.Output != "default logger message" {
|
|
||||||
t.Errorf("output = %q, want %q", e.Output, "default logger message")
|
|
||||||
}
|
|
||||||
c.Destroy()
|
|
||||||
}
|
|
||||||
|
|
||||||
func TestLoggerPanicWithError(t *testing.T) {
|
|
||||||
// When the first arg is an error, Panic should re-panic with that error
|
|
||||||
c := CreateClient("logger-panic-err")
|
|
||||||
c.SetLogLevel(LPanic)
|
|
||||||
|
|
||||||
l := NewLogger("logger-panic-err")
|
|
||||||
testErr := errTest("test error")
|
|
||||||
|
|
||||||
defer func() {
|
|
||||||
r := recover()
|
|
||||||
if r == nil {
|
|
||||||
t.Error("expected panic, got nil")
|
|
||||||
}
|
|
||||||
if err, ok := r.(errTest); ok {
|
|
||||||
if string(err) != "test error" {
|
|
||||||
t.Errorf("panic value = %q, want %q", string(err), "test error")
|
|
||||||
}
|
|
||||||
} else {
|
|
||||||
// The first arg was an error, so Panic should re-panic with it
|
|
||||||
t.Logf("panic type = %T, value = %v (implementation re-panics with original error)", r, r)
|
|
||||||
}
|
|
||||||
c.Destroy()
|
|
||||||
}()
|
|
||||||
|
|
||||||
l.Panic(testErr)
|
|
||||||
}
|
|
||||||
|
|
||||||
// errTest is a simple error type for testing.
|
|
||||||
type errTest string
|
|
||||||
|
|
||||||
func (e errTest) Error() string { return string(e) }
|
|
||||||
Reference in New Issue
Block a user