logger.go 2.3 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112
  1. package logger
  2. import (
  3. "log"
  4. "net/http"
  5. "time"
  6. "github.com/sirupsen/logrus"
  7. )
  8. const (
  9. Disabled = iota
  10. InfoLevel
  11. WarningLevel
  12. DebugLevel
  13. )
  14. type (
  15. // struct for holding response details
  16. responseData struct {
  17. status int
  18. size int
  19. }
  20. // our http.ResponseWriter implementation
  21. loggingResponseWriter struct {
  22. http.ResponseWriter // compose original http.ResponseWriter
  23. responseData *responseData
  24. }
  25. )
  26. var loggerLevel int = InfoLevel
  27. func (r *loggingResponseWriter) Write(b []byte) (int, error) {
  28. size, err := r.ResponseWriter.Write(b) // write response using original http.ResponseWriter
  29. r.responseData.size += size // capture size
  30. return size, err
  31. }
  32. func (r *loggingResponseWriter) WriteHeader(statusCode int) {
  33. r.ResponseWriter.WriteHeader(statusCode) // write status code using original http.ResponseWriter
  34. r.responseData.status = statusCode // capture status code
  35. }
  36. func WithLogging(h http.Handler) http.Handler {
  37. loggingFn := func(rw http.ResponseWriter, req *http.Request) {
  38. start := time.Now()
  39. responseData := &responseData{
  40. status: 0,
  41. size: 0,
  42. }
  43. lrw := loggingResponseWriter{
  44. ResponseWriter: rw, // compose original http.ResponseWriter
  45. responseData: responseData,
  46. }
  47. h.ServeHTTP(&lrw, req) // inject our implementation of http.ResponseWriter
  48. duration := time.Since(start)
  49. if loggerLevel >= InfoLevel {
  50. logrus.WithFields(logrus.Fields{
  51. "URI": req.RequestURI,
  52. "Method": req.Method,
  53. "Status": responseData.status,
  54. "Duration": duration,
  55. "Size": responseData.size,
  56. }).Info("Completed.")
  57. }
  58. }
  59. return http.HandlerFunc(loggingFn)
  60. }
  61. func SetLevel(level int) {
  62. loggerLevel = level
  63. }
  64. func Info(v ...interface{}) {
  65. if loggerLevel >= InfoLevel {
  66. log.Println(v...)
  67. }
  68. }
  69. func Infof(format string, v ...interface{}) {
  70. if loggerLevel >= InfoLevel {
  71. log.Printf(format, v...)
  72. }
  73. }
  74. func Warning(v ...interface{}) {
  75. if loggerLevel >= WarningLevel {
  76. log.Println(v...)
  77. }
  78. }
  79. func Warningf(format string, v ...interface{}) {
  80. if loggerLevel >= WarningLevel {
  81. log.Printf(format, v...)
  82. }
  83. }
  84. func Debug(v ...interface{}) {
  85. if loggerLevel >= DebugLevel {
  86. log.Println(v...)
  87. }
  88. }
  89. func Debugf(format string, v ...interface{}) {
  90. if loggerLevel >= DebugLevel {
  91. log.Printf(format, v...)
  92. }
  93. }