rotatelogger_test.go 3.6 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144
  1. package logx
  2. import (
  3. "os"
  4. "path/filepath"
  5. "syscall"
  6. "testing"
  7. "time"
  8. "github.com/stretchr/testify/assert"
  9. "github.com/zeromicro/go-zero/core/fs"
  10. )
  11. func TestDailyRotateRuleMarkRotated(t *testing.T) {
  12. var rule DailyRotateRule
  13. rule.MarkRotated()
  14. assert.Equal(t, getNowDate(), rule.rotatedTime)
  15. }
  16. func TestDailyRotateRuleOutdatedFiles(t *testing.T) {
  17. var rule DailyRotateRule
  18. assert.Empty(t, rule.OutdatedFiles())
  19. rule.days = 1
  20. assert.Empty(t, rule.OutdatedFiles())
  21. rule.gzip = true
  22. assert.Empty(t, rule.OutdatedFiles())
  23. }
  24. func TestDailyRotateRuleShallRotate(t *testing.T) {
  25. var rule DailyRotateRule
  26. rule.rotatedTime = time.Now().Add(time.Hour * 24).Format(dateFormat)
  27. assert.True(t, rule.ShallRotate())
  28. }
  29. func TestRotateLoggerClose(t *testing.T) {
  30. filename, err := fs.TempFilenameWithText("foo")
  31. assert.Nil(t, err)
  32. if len(filename) > 0 {
  33. defer os.Remove(filename)
  34. }
  35. logger, err := NewLogger(filename, new(DailyRotateRule), false)
  36. assert.Nil(t, err)
  37. assert.Nil(t, logger.Close())
  38. }
  39. func TestRotateLoggerGetBackupFilename(t *testing.T) {
  40. filename, err := fs.TempFilenameWithText("foo")
  41. assert.Nil(t, err)
  42. if len(filename) > 0 {
  43. defer os.Remove(filename)
  44. }
  45. logger, err := NewLogger(filename, new(DailyRotateRule), false)
  46. assert.Nil(t, err)
  47. assert.True(t, len(logger.getBackupFilename()) > 0)
  48. logger.backup = ""
  49. assert.True(t, len(logger.getBackupFilename()) > 0)
  50. }
  51. func TestRotateLoggerMayCompressFile(t *testing.T) {
  52. old := os.Stdout
  53. os.Stdout = os.NewFile(0, os.DevNull)
  54. defer func() {
  55. os.Stdout = old
  56. }()
  57. filename, err := fs.TempFilenameWithText("foo")
  58. assert.Nil(t, err)
  59. if len(filename) > 0 {
  60. defer os.Remove(filename)
  61. }
  62. logger, err := NewLogger(filename, new(DailyRotateRule), false)
  63. assert.Nil(t, err)
  64. logger.maybeCompressFile(filename)
  65. _, err = os.Stat(filename)
  66. assert.Nil(t, err)
  67. }
  68. func TestRotateLoggerMayCompressFileTrue(t *testing.T) {
  69. old := os.Stdout
  70. os.Stdout = os.NewFile(0, os.DevNull)
  71. defer func() {
  72. os.Stdout = old
  73. }()
  74. filename, err := fs.TempFilenameWithText("foo")
  75. assert.Nil(t, err)
  76. logger, err := NewLogger(filename, new(DailyRotateRule), true)
  77. assert.Nil(t, err)
  78. if len(filename) > 0 {
  79. defer os.Remove(filepath.Base(logger.getBackupFilename()) + ".gz")
  80. }
  81. logger.maybeCompressFile(filename)
  82. _, err = os.Stat(filename)
  83. assert.NotNil(t, err)
  84. }
  85. func TestRotateLoggerRotate(t *testing.T) {
  86. filename, err := fs.TempFilenameWithText("foo")
  87. assert.Nil(t, err)
  88. logger, err := NewLogger(filename, new(DailyRotateRule), true)
  89. assert.Nil(t, err)
  90. if len(filename) > 0 {
  91. defer func() {
  92. os.Remove(logger.getBackupFilename())
  93. os.Remove(filepath.Base(logger.getBackupFilename()) + ".gz")
  94. }()
  95. }
  96. err = logger.rotate()
  97. switch v := err.(type) {
  98. case *os.LinkError:
  99. // avoid rename error on docker container
  100. assert.Equal(t, syscall.EXDEV, v.Err)
  101. case *os.PathError:
  102. // ignore remove error for tests,
  103. // files are cleaned in GitHub actions.
  104. assert.Equal(t, "remove", v.Op)
  105. default:
  106. assert.Nil(t, err)
  107. }
  108. }
  109. func TestRotateLoggerWrite(t *testing.T) {
  110. filename, err := fs.TempFilenameWithText("foo")
  111. assert.Nil(t, err)
  112. rule := new(DailyRotateRule)
  113. logger, err := NewLogger(filename, rule, true)
  114. assert.Nil(t, err)
  115. if len(filename) > 0 {
  116. defer func() {
  117. os.Remove(logger.getBackupFilename())
  118. os.Remove(filepath.Base(logger.getBackupFilename()) + ".gz")
  119. }()
  120. }
  121. // the following write calls cannot be changed to Write, because of DATA RACE.
  122. logger.write([]byte(`foo`))
  123. rule.rotatedTime = time.Now().Add(-time.Hour * 24).Format(dateFormat)
  124. logger.write([]byte(`bar`))
  125. logger.Close()
  126. logger.write([]byte(`baz`))
  127. }
  128. func TestLogWriterClose(t *testing.T) {
  129. assert.Nil(t, newLogWriter(nil).Close())
  130. }