shanshanzhong
c582087c0f
Some checks failed
Build docker and publish / build (20.15.1) (push) Failing after 6m27s
feat: 添加版本和构建时间变量 fix: 修正短信队列类型注释错误 style: 清理未使用的代码和测试文件 docs: 更新安装文档中的下载链接 chore: 迁移数据库脚本添加日志和订阅配置
85 lines
1.3 KiB
Go
85 lines
1.3 KiB
Go
package logtest
|
|
|
|
import (
|
|
"bytes"
|
|
"encoding/json"
|
|
"io"
|
|
"testing"
|
|
|
|
"github.com/perfect-panel/server/pkg/logger"
|
|
)
|
|
|
|
type Buffer struct {
|
|
buf *bytes.Buffer
|
|
t *testing.T
|
|
}
|
|
|
|
func Discard(t *testing.T) {
|
|
prev := logger.Reset()
|
|
logger.SetWriter(logger.NewWriter(io.Discard))
|
|
|
|
t.Cleanup(func() {
|
|
logger.SetWriter(prev)
|
|
})
|
|
}
|
|
|
|
func NewCollector(t *testing.T) *Buffer {
|
|
var buf bytes.Buffer
|
|
writer := logger.NewWriter(&buf)
|
|
prev := logger.Reset()
|
|
logger.SetWriter(writer)
|
|
|
|
t.Cleanup(func() {
|
|
logger.SetWriter(prev)
|
|
})
|
|
|
|
return &Buffer{
|
|
buf: &buf,
|
|
t: t,
|
|
}
|
|
}
|
|
|
|
func (b *Buffer) Bytes() []byte {
|
|
return b.buf.Bytes()
|
|
}
|
|
|
|
func (b *Buffer) Content() string {
|
|
var m map[string]interface{}
|
|
if err := json.Unmarshal(b.buf.Bytes(), &m); err != nil {
|
|
return ""
|
|
}
|
|
|
|
content, ok := m["content"]
|
|
if !ok {
|
|
return ""
|
|
}
|
|
|
|
switch val := content.(type) {
|
|
case string:
|
|
return val
|
|
default:
|
|
// err is impossible to be not nil, unmarshaled from b.buf.Bytes()
|
|
bs, _ := json.Marshal(content)
|
|
return string(bs)
|
|
}
|
|
}
|
|
|
|
func (b *Buffer) Reset() {
|
|
b.buf.Reset()
|
|
}
|
|
|
|
func (b *Buffer) String() string {
|
|
return b.buf.String()
|
|
}
|
|
|
|
func PanicOnFatal(t *testing.T) {
|
|
ok := logger.ExitOnFatal.CompareAndSwap(true, false)
|
|
if !ok {
|
|
return
|
|
}
|
|
|
|
t.Cleanup(func() {
|
|
logger.ExitOnFatal.CompareAndSwap(false, true)
|
|
})
|
|
}
|