rotatelogger_test.go 3.2 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126
  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/tal-tech/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. filename, err := fs.TempFilenameWithText("foo")
  53. assert.Nil(t, err)
  54. if len(filename) > 0 {
  55. defer os.Remove(filename)
  56. }
  57. logger, err := NewLogger(filename, new(DailyRotateRule), false)
  58. assert.Nil(t, err)
  59. logger.maybeCompressFile(filename)
  60. _, err = os.Stat(filename)
  61. assert.Nil(t, err)
  62. }
  63. func TestRotateLoggerMayCompressFileTrue(t *testing.T) {
  64. filename, err := fs.TempFilenameWithText("foo")
  65. assert.Nil(t, err)
  66. logger, err := NewLogger(filename, new(DailyRotateRule), true)
  67. assert.Nil(t, err)
  68. if len(filename) > 0 {
  69. defer func() {
  70. os.Remove(filename)
  71. os.Remove(filepath.Base(logger.getBackupFilename()) + ".gz")
  72. }()
  73. }
  74. logger.maybeCompressFile(filename)
  75. _, err = os.Stat(filename)
  76. assert.NotNil(t, err)
  77. }
  78. func TestRotateLoggerRotate(t *testing.T) {
  79. filename, err := fs.TempFilenameWithText("foo")
  80. assert.Nil(t, err)
  81. logger, err := NewLogger(filename, new(DailyRotateRule), true)
  82. assert.Nil(t, err)
  83. if len(filename) > 0 {
  84. defer func() {
  85. os.Remove(filename)
  86. os.Remove(logger.getBackupFilename())
  87. os.Remove(filepath.Base(logger.getBackupFilename()) + ".gz")
  88. }()
  89. }
  90. err = logger.rotate()
  91. switch v := err.(type) {
  92. case *os.LinkError:
  93. // avoid rename error on docker container
  94. assert.Equal(t, syscall.EXDEV, v.Err)
  95. default:
  96. assert.Nil(t, err)
  97. }
  98. }
  99. func TestRotateLoggerWrite(t *testing.T) {
  100. filename, err := fs.TempFilenameWithText("foo")
  101. assert.Nil(t, err)
  102. rule := new(DailyRotateRule)
  103. logger, err := NewLogger(filename, rule, true)
  104. assert.Nil(t, err)
  105. if len(filename) > 0 {
  106. defer func() {
  107. os.Remove(filename)
  108. os.Remove(logger.getBackupFilename())
  109. os.Remove(filepath.Base(logger.getBackupFilename()) + ".gz")
  110. }()
  111. }
  112. logger.write([]byte(`foo`))
  113. rule.rotatedTime = time.Now().Add(-time.Hour * 24).Format(dateFormat)
  114. logger.write([]byte(`bar`))
  115. }