package repository

import (
	"AynaLivePlayer/pkg/logger"
	"github.com/mattn/go-colorable"
	"github.com/virtuald/go-paniclog"
	"go.uber.org/zap"
	"go.uber.org/zap/zapcore"
	"time"
)

var _logLevelMap = map[logger.LogLevel]zapcore.Level{
	logger.LogLevelDebug: zapcore.DebugLevel,
	logger.LogLevelInfo:  zapcore.InfoLevel,
	logger.LogLevelWarn:  zapcore.WarnLevel,
	logger.LogLevelError: zapcore.ErrorLevel,
}

var (
	_levelToCapitalColorString = make(map[zapcore.Level]string, len(logger.LogColorMap))
)

func init() {
	for level, color := range logger.LogColorMap {
		_levelToCapitalColorString[_logLevelMap[level]] = color.Add("[" + _logLevelMap[level].CapitalString() + "]")
	}
}

// reference tp https://blog.sandipb.net/2018/05/03/using-zap-creating-custom-encoders/
func syslogTimeEncoder(t time.Time, enc zapcore.PrimitiveArrayEncoder) {
	enc.AppendString(t.Format("Jan  2 15:04:05"))
}

func customLevelEncoder(level zapcore.Level, enc zapcore.PrimitiveArrayEncoder) {
	s, ok := _levelToCapitalColorString[level]
	if !ok {
		s = logger.LogColorRed.Add(level.CapitalString())
	}
	enc.AppendString(s)
}

func customNamedEncoder(loggerName string, enc zapcore.PrimitiveArrayEncoder) {
	enc.AppendString(logger.LogColorMagenta.Add("[" + loggerName + "]"))
}

type zapLoggerImpl struct {
	*zap.SugaredLogger
	level zap.AtomicLevel
}

type namedZapLoggerImpl struct {
	*zap.SugaredLogger
	parent *zapLoggerImpl
}

func (n *namedZapLoggerImpl) WithPrefix(prefix string) logger.ILogger {
	return n.parent.WithPrefix(prefix)
}

func (n *namedZapLoggerImpl) SetLogLevel(level logger.LogLevel) {
	n.parent.SetLogLevel(level)
}

func (z *namedZapLoggerImpl) DebugW(message string, keysAndValues ...interface{}) {
	z.Debugw(message, keysAndValues...)
}

func (z *namedZapLoggerImpl) InfoW(message string, keysAndValues ...interface{}) {
	z.Infow(message, keysAndValues...)
}

func (z *namedZapLoggerImpl) WarnW(message string, keysAndValues ...interface{}) {
	z.Warnw(message, keysAndValues...)
}

func (z *namedZapLoggerImpl) ErrorW(message string, keysAndValues ...interface{}) {
	z.Errorw(message, keysAndValues...)
}

func (z *namedZapLoggerImpl) DebugS(message string, fields logger.LogField) {
	z.Debugw(message, fields.Flatten()...)
}

func (z *namedZapLoggerImpl) InfoS(message string, fields logger.LogField) {
	z.Infow(message, fields.Flatten()...)
}

func (z *namedZapLoggerImpl) WarnS(message string, fields logger.LogField) {
	z.Warnw(message, fields.Flatten()...)
}

func (z *namedZapLoggerImpl) ErrorS(message string, fields logger.LogField) {
	z.Errorw(message, fields.Flatten()...)
}

func NewZapLogger() logger.ILogger {
	zapLog, _ := zap.NewProduction()
	sugar := zapLog.Sugar()
	return &zapLoggerImpl{SugaredLogger: sugar}
}

func NewZapColoredLogger(outPath string, redirectPanic bool) logger.ILogger {
	f, err := getLogOut(outPath, 5)
	cfg := zap.NewProductionEncoderConfig()
	level := zap.NewAtomicLevel()
	level.SetLevel(zapcore.DebugLevel)
	cfg.EncodeLevel = customLevelEncoder
	cfg.EncodeTime = syslogTimeEncoder
	cfg.EncodeName = customNamedEncoder
	cfg.ConsoleSeparator = " "
	var zapLog *zap.Logger
	if err == nil {
		zapLog = zap.New(
			zapcore.NewTee(zapcore.NewCore(
				zapcore.NewConsoleEncoder(cfg),
				zapcore.AddSync(colorable.NewColorableStdout()),
				level),
				zapcore.NewCore(
					zapcore.NewConsoleEncoder(cfg),
					zapcore.AddSync(f),
					level),
			),
		)
	} else {
		zapLog = zap.New(
			zapcore.NewCore(
				zapcore.NewConsoleEncoder(cfg),
				zapcore.AddSync(colorable.NewColorableStdout()),
				level),
		)
	}
	if redirectPanic {
		_, _ = paniclog.RedirectStderr(f)
	}
	sugar := zapLog.Sugar()
	return &zapLoggerImpl{SugaredLogger: sugar, level: level}
}

func (z *zapLoggerImpl) Dispose() error {
	_ = z.Sync()
	return nil
}

func (z *zapLoggerImpl) WithPrefix(prefix string) logger.ILogger {
	return &namedZapLoggerImpl{SugaredLogger: z.SugaredLogger.Named(prefix), parent: z}
}

func (z *zapLoggerImpl) SetLogLevel(level logger.LogLevel) {
	z.level.SetLevel(_logLevelMap[level])
	return
}

func (z *zapLoggerImpl) DebugW(message string, keysAndValues ...interface{}) {
	z.Debugw(message, keysAndValues...)
}

func (z *zapLoggerImpl) InfoW(message string, keysAndValues ...interface{}) {
	z.Infow(message, keysAndValues...)
}

func (z *zapLoggerImpl) WarnW(message string, keysAndValues ...interface{}) {
	z.Warnw(message, keysAndValues...)
}

func (z *zapLoggerImpl) ErrorW(message string, keysAndValues ...interface{}) {
	z.Errorw(message, keysAndValues...)
}

func (z *zapLoggerImpl) DebugS(message string, fields logger.LogField) {
	z.Debugw(message, fields.Flatten()...)
}

func (z *zapLoggerImpl) InfoS(message string, fields logger.LogField) {
	z.Infow(message, fields.Flatten()...)
}

func (z *zapLoggerImpl) WarnS(message string, fields logger.LogField) {
	z.Warnw(message, fields.Flatten()...)
}

func (z *zapLoggerImpl) ErrorS(message string, fields logger.LogField) {
	z.Errorw(message, fields.Flatten()...)
}