logger.go 2.6 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118
  1. package logger
  2. import (
  3. "fmt"
  4. "os"
  5. "time"
  6. "github.com/op/go-logging"
  7. )
  8. var logger *logging.Logger
  9. var logBuffer []struct {
  10. time string
  11. level logging.Level
  12. log string
  13. }
  14. func init() {
  15. InitLogger(logging.INFO)
  16. }
  17. func InitLogger(level logging.Level) {
  18. newLogger := logging.MustGetLogger("x-ui")
  19. var err error
  20. var backend logging.Backend
  21. var format logging.Formatter
  22. ppid := os.Getppid()
  23. if ppid == 1 {
  24. backend, err = logging.NewSyslogBackend("")
  25. format = logging.MustStringFormatter(
  26. `%{level} - %{message}`,
  27. )
  28. }
  29. if err != nil || ppid != 1 {
  30. backend = logging.NewLogBackend(os.Stderr, "", 0)
  31. format = logging.MustStringFormatter(
  32. `%{time:2006/01/02 15:04:05} %{level} - %{message}`,
  33. )
  34. }
  35. backendFormatter := logging.NewBackendFormatter(backend, format)
  36. backendLeveled := logging.AddModuleLevel(backendFormatter)
  37. backendLeveled.SetLevel(level, "x-ui")
  38. newLogger.SetBackend(backendLeveled)
  39. logger = newLogger
  40. }
  41. func Debug(args ...interface{}) {
  42. logger.Debug(args...)
  43. addToBuffer("DEBUG", fmt.Sprint(args...))
  44. }
  45. func Debugf(format string, args ...interface{}) {
  46. logger.Debugf(format, args...)
  47. addToBuffer("DEBUG", fmt.Sprintf(format, args...))
  48. }
  49. func Info(args ...interface{}) {
  50. logger.Info(args...)
  51. addToBuffer("INFO", fmt.Sprint(args...))
  52. }
  53. func Infof(format string, args ...interface{}) {
  54. logger.Infof(format, args...)
  55. addToBuffer("INFO", fmt.Sprintf(format, args...))
  56. }
  57. func Warning(args ...interface{}) {
  58. logger.Warning(args...)
  59. addToBuffer("WARNING", fmt.Sprint(args...))
  60. }
  61. func Warningf(format string, args ...interface{}) {
  62. logger.Warningf(format, args...)
  63. addToBuffer("WARNING", fmt.Sprintf(format, args...))
  64. }
  65. func Error(args ...interface{}) {
  66. logger.Error(args...)
  67. addToBuffer("ERROR", fmt.Sprint(args...))
  68. }
  69. func Errorf(format string, args ...interface{}) {
  70. logger.Errorf(format, args...)
  71. addToBuffer("ERROR", fmt.Sprintf(format, args...))
  72. }
  73. func addToBuffer(level string, newLog string) {
  74. t := time.Now()
  75. if len(logBuffer) >= 10240 {
  76. logBuffer = logBuffer[1:]
  77. }
  78. logLevel, _ := logging.LogLevel(level)
  79. logBuffer = append(logBuffer, struct {
  80. time string
  81. level logging.Level
  82. log string
  83. }{
  84. time: t.Format("2006/01/02 15:04:05"),
  85. level: logLevel,
  86. log: newLog,
  87. })
  88. }
  89. func GetLogs(c int, level string) []string {
  90. var output []string
  91. logLevel, _ := logging.LogLevel(level)
  92. for i := len(logBuffer) - 1; i >= 0 && len(output) <= c; i-- {
  93. if logBuffer[i].level <= logLevel {
  94. output = append(output, fmt.Sprintf("%s %s - %s", logBuffer[i].time, logBuffer[i].level, logBuffer[i].log))
  95. }
  96. }
  97. return output
  98. }