package log

import (
	"strings"
)

// nsq的专属log
// 1. 不关心caller
// 2. level需要处理

type NsqLoggerI struct{}

func (l *NsqLoggerI) Output(calldepth int, s string) error {
	level := strings.Split(s, " ")[0]
	switch level {
	case "INF":
		TeamsLog.Info(s)
	case "WRN":
		TeamsLog.Warn(s)
	case "ERR":
		TeamsLog.Error(s)
	default:
		TeamsLog.Debug(s)
	}
	return nil
}

func NsqLogger() *NsqLoggerI {
	return &NsqLoggerI{}
}