text_formatter.go 8.5 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199200201202203204205206207208209210211212213214215216217218219220221222223224225226227228229230231232233234235236237238239240241242243244245246247248249250251252253254255256257258259260261262263264265266267268269270271272273274275276277278279280281282283284285286287288289290291292293294295296297298299300301302303304305306307308309310311312313314315316317318319320321322323324325326
  1. package logrus
  2. import (
  3. "bytes"
  4. "fmt"
  5. "os"
  6. "runtime"
  7. "sort"
  8. "strconv"
  9. "strings"
  10. "sync"
  11. "time"
  12. "unicode/utf8"
  13. )
  14. const (
  15. red = 31
  16. yellow = 33
  17. blue = 36
  18. gray = 37
  19. )
  20. var baseTimestamp time.Time
  21. func init() {
  22. baseTimestamp = time.Now()
  23. }
  24. // TextFormatter formats logs into text
  25. type TextFormatter struct {
  26. // Set to true to bypass checking for a TTY before outputting colors.
  27. ForceColors bool
  28. // Force disabling colors.
  29. DisableColors bool
  30. // Force quoting of all values
  31. ForceQuote bool
  32. // Override coloring based on CLICOLOR and CLICOLOR_FORCE. - https://bixense.com/clicolors/
  33. EnvironmentOverrideColors bool
  34. // Disable timestamp logging. useful when output is redirected to logging
  35. // system that already adds timestamps.
  36. DisableTimestamp bool
  37. // Enable logging the full timestamp when a TTY is attached instead of just
  38. // the time passed since beginning of execution.
  39. FullTimestamp bool
  40. // TimestampFormat to use for display when a full timestamp is printed
  41. TimestampFormat string
  42. // The fields are sorted by default for a consistent output. For applications
  43. // that log extremely frequently and don't use the JSON formatter this may not
  44. // be desired.
  45. DisableSorting bool
  46. // The keys sorting function, when uninitialized it uses sort.Strings.
  47. SortingFunc func([]string)
  48. // Disables the truncation of the level text to 4 characters.
  49. DisableLevelTruncation bool
  50. // PadLevelText Adds padding the level text so that all the levels output at the same length
  51. // PadLevelText is a superset of the DisableLevelTruncation option
  52. PadLevelText bool
  53. // QuoteEmptyFields will wrap empty fields in quotes if true
  54. QuoteEmptyFields bool
  55. // Whether the logger's out is to a terminal
  56. isTerminal bool
  57. // FieldMap allows users to customize the names of keys for default fields.
  58. // As an example:
  59. // formatter := &TextFormatter{
  60. // FieldMap: FieldMap{
  61. // FieldKeyTime: "@timestamp",
  62. // FieldKeyLevel: "@level",
  63. // FieldKeyMsg: "@message"}}
  64. FieldMap FieldMap
  65. // CallerPrettyfier can be set by the user to modify the content
  66. // of the function and file keys in the data when ReportCaller is
  67. // activated. If any of the returned value is the empty string the
  68. // corresponding key will be removed from fields.
  69. CallerPrettyfier func(*runtime.Frame) (function string, file string)
  70. terminalInitOnce sync.Once
  71. // The max length of the level text, generated dynamically on init
  72. levelTextMaxLength int
  73. }
  74. func (f *TextFormatter) init(entry *Entry) {
  75. if entry.Logger != nil {
  76. f.isTerminal = checkIfTerminal(entry.Logger.Out)
  77. }
  78. // Get the max length of the level text
  79. for _, level := range AllLevels {
  80. levelTextLength := utf8.RuneCount([]byte(level.String()))
  81. if levelTextLength > f.levelTextMaxLength {
  82. f.levelTextMaxLength = levelTextLength
  83. }
  84. }
  85. }
  86. func (f *TextFormatter) isColored() bool {
  87. isColored := f.ForceColors || (f.isTerminal && (runtime.GOOS != "windows"))
  88. if f.EnvironmentOverrideColors {
  89. switch force, ok := os.LookupEnv("CLICOLOR_FORCE"); {
  90. case ok && force != "0":
  91. isColored = true
  92. case ok && force == "0", os.Getenv("CLICOLOR") == "0":
  93. isColored = false
  94. }
  95. }
  96. return isColored && !f.DisableColors
  97. }
  98. // Format renders a single log entry
  99. func (f *TextFormatter) Format(entry *Entry) ([]byte, error) {
  100. data := make(Fields)
  101. for k, v := range entry.Data {
  102. data[k] = v
  103. }
  104. prefixFieldClashes(data, f.FieldMap, entry.HasCaller())
  105. keys := make([]string, 0, len(data))
  106. for k := range data {
  107. keys = append(keys, k)
  108. }
  109. var funcVal, fileVal string
  110. fixedKeys := make([]string, 0, 4+len(data))
  111. if !f.DisableTimestamp {
  112. fixedKeys = append(fixedKeys, f.FieldMap.resolve(FieldKeyTime))
  113. }
  114. fixedKeys = append(fixedKeys, f.FieldMap.resolve(FieldKeyLevel))
  115. if entry.Message != "" {
  116. fixedKeys = append(fixedKeys, f.FieldMap.resolve(FieldKeyMsg))
  117. }
  118. if entry.err != "" {
  119. fixedKeys = append(fixedKeys, f.FieldMap.resolve(FieldKeyLogrusError))
  120. }
  121. if entry.HasCaller() {
  122. if f.CallerPrettyfier != nil {
  123. funcVal, fileVal = f.CallerPrettyfier(entry.Caller)
  124. } else {
  125. funcVal = entry.Caller.Function
  126. fileVal = fmt.Sprintf("%s:%d", entry.Caller.File, entry.Caller.Line)
  127. }
  128. if funcVal != "" {
  129. fixedKeys = append(fixedKeys, f.FieldMap.resolve(FieldKeyFunc))
  130. }
  131. if fileVal != "" {
  132. fixedKeys = append(fixedKeys, f.FieldMap.resolve(FieldKeyFile))
  133. }
  134. }
  135. if !f.DisableSorting {
  136. if f.SortingFunc == nil {
  137. sort.Strings(keys)
  138. fixedKeys = append(fixedKeys, keys...)
  139. } else {
  140. if !f.isColored() {
  141. fixedKeys = append(fixedKeys, keys...)
  142. f.SortingFunc(fixedKeys)
  143. } else {
  144. f.SortingFunc(keys)
  145. }
  146. }
  147. } else {
  148. fixedKeys = append(fixedKeys, keys...)
  149. }
  150. var b *bytes.Buffer
  151. if entry.Buffer != nil {
  152. b = entry.Buffer
  153. } else {
  154. b = &bytes.Buffer{}
  155. }
  156. f.terminalInitOnce.Do(func() { f.init(entry) })
  157. timestampFormat := f.TimestampFormat
  158. if timestampFormat == "" {
  159. timestampFormat = defaultTimestampFormat
  160. }
  161. if f.isColored() {
  162. f.printColored(b, entry, keys, data, timestampFormat)
  163. } else {
  164. for _, key := range fixedKeys {
  165. var value interface{}
  166. switch {
  167. case key == f.FieldMap.resolve(FieldKeyTime):
  168. value = entry.Time.Format(timestampFormat)
  169. case key == f.FieldMap.resolve(FieldKeyLevel):
  170. value = entry.Level.String()
  171. case key == f.FieldMap.resolve(FieldKeyMsg):
  172. value = entry.Message
  173. case key == f.FieldMap.resolve(FieldKeyLogrusError):
  174. value = entry.err
  175. case key == f.FieldMap.resolve(FieldKeyFunc) && entry.HasCaller():
  176. value = funcVal
  177. case key == f.FieldMap.resolve(FieldKeyFile) && entry.HasCaller():
  178. value = fileVal
  179. default:
  180. value = data[key]
  181. }
  182. f.appendKeyValue(b, key, value)
  183. }
  184. }
  185. b.WriteByte('\n')
  186. return b.Bytes(), nil
  187. }
  188. func (f *TextFormatter) printColored(b *bytes.Buffer, entry *Entry, keys []string, data Fields, timestampFormat string) {
  189. var levelColor int
  190. switch entry.Level {
  191. case DebugLevel, TraceLevel:
  192. levelColor = gray
  193. case WarnLevel:
  194. levelColor = yellow
  195. case ErrorLevel, FatalLevel, PanicLevel:
  196. levelColor = red
  197. default:
  198. levelColor = blue
  199. }
  200. levelText := strings.ToUpper(entry.Level.String())
  201. if !f.DisableLevelTruncation && !f.PadLevelText {
  202. levelText = levelText[0:4]
  203. }
  204. if f.PadLevelText {
  205. // Generates the format string used in the next line, for example "%-6s" or "%-7s".
  206. // Based on the max level text length.
  207. formatString := "%-" + strconv.Itoa(f.levelTextMaxLength) + "s"
  208. // Formats the level text by appending spaces up to the max length, for example:
  209. // - "INFO "
  210. // - "WARNING"
  211. levelText = fmt.Sprintf(formatString, levelText)
  212. }
  213. // Remove a single newline if it already exists in the message to keep
  214. // the behavior of logrus text_formatter the same as the stdlib log package
  215. entry.Message = strings.TrimSuffix(entry.Message, "\n")
  216. caller := ""
  217. if entry.HasCaller() {
  218. funcVal := fmt.Sprintf("%s()", entry.Caller.Function)
  219. fileVal := fmt.Sprintf("%s:%d", entry.Caller.File, entry.Caller.Line)
  220. if f.CallerPrettyfier != nil {
  221. funcVal, fileVal = f.CallerPrettyfier(entry.Caller)
  222. }
  223. if fileVal == "" {
  224. caller = funcVal
  225. } else if funcVal == "" {
  226. caller = fileVal
  227. } else {
  228. caller = fileVal + " " + funcVal
  229. }
  230. }
  231. switch {
  232. case f.DisableTimestamp:
  233. fmt.Fprintf(b, "\x1b[%dm%s\x1b[0m%s %-44s ", levelColor, levelText, caller, entry.Message)
  234. case !f.FullTimestamp:
  235. fmt.Fprintf(b, "\x1b[%dm%s\x1b[0m[%04d]%s %-44s ", levelColor, levelText, int(entry.Time.Sub(baseTimestamp)/time.Second), caller, entry.Message)
  236. default:
  237. fmt.Fprintf(b, "\x1b[%dm%s\x1b[0m[%s]%s %-44s ", levelColor, levelText, entry.Time.Format(timestampFormat), caller, entry.Message)
  238. }
  239. for _, k := range keys {
  240. v := data[k]
  241. fmt.Fprintf(b, " \x1b[%dm%s\x1b[0m=", levelColor, k)
  242. f.appendValue(b, v)
  243. }
  244. }
  245. func (f *TextFormatter) needsQuoting(text string) bool {
  246. if f.ForceQuote {
  247. return true
  248. }
  249. if f.QuoteEmptyFields && len(text) == 0 {
  250. return true
  251. }
  252. for _, ch := range text {
  253. if !((ch >= 'a' && ch <= 'z') ||
  254. (ch >= 'A' && ch <= 'Z') ||
  255. (ch >= '0' && ch <= '9') ||
  256. ch == '-' || ch == '.' || ch == '_' || ch == '/' || ch == '@' || ch == '^' || ch == '+') {
  257. return true
  258. }
  259. }
  260. return false
  261. }
  262. func (f *TextFormatter) appendKeyValue(b *bytes.Buffer, key string, value interface{}) {
  263. if b.Len() > 0 {
  264. b.WriteByte(' ')
  265. }
  266. b.WriteString(key)
  267. b.WriteByte('=')
  268. f.appendValue(b, value)
  269. }
  270. func (f *TextFormatter) appendValue(b *bytes.Buffer, value interface{}) {
  271. stringVal, ok := value.(string)
  272. if !ok {
  273. stringVal = fmt.Sprint(value)
  274. }
  275. if !f.needsQuoting(stringVal) {
  276. b.WriteString(stringVal)
  277. } else {
  278. b.WriteString(fmt.Sprintf("%q", stringVal))
  279. }
  280. }