jsonlogbytes.go 2.2 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111
  1. package jsonlog
  2. import (
  3. "bytes"
  4. "unicode/utf8"
  5. )
  6. // JSONLogBytes is based on JSONLog.
  7. // It allows marshalling JSONLog from Log as []byte
  8. // and an already marshalled Created timestamp.
  9. type JSONLogBytes struct {
  10. Log []byte `json:"log,omitempty"`
  11. Stream string `json:"stream,omitempty"`
  12. Created string `json:"time"`
  13. }
  14. // MarshalJSONBuf is based on the same method from JSONLog
  15. // It has been modified to take into account the necessary changes.
  16. func (mj *JSONLogBytes) MarshalJSONBuf(buf *bytes.Buffer) error {
  17. var first = true
  18. buf.WriteString(`{`)
  19. if len(mj.Log) != 0 {
  20. first = false
  21. buf.WriteString(`"log":`)
  22. ffjson_WriteJsonBytesAsString(buf, mj.Log)
  23. }
  24. if len(mj.Stream) != 0 {
  25. if first == true {
  26. first = false
  27. } else {
  28. buf.WriteString(`,`)
  29. }
  30. buf.WriteString(`"stream":`)
  31. ffjson_WriteJsonString(buf, mj.Stream)
  32. }
  33. if first == true {
  34. first = false
  35. } else {
  36. buf.WriteString(`,`)
  37. }
  38. buf.WriteString(`"time":`)
  39. buf.WriteString(mj.Created)
  40. buf.WriteString(`}`)
  41. return nil
  42. }
  43. // This is based on ffjson_WriteJsonString. It has been changed
  44. // to accept a string passed as a slice of bytes.
  45. func ffjson_WriteJsonBytesAsString(buf *bytes.Buffer, s []byte) {
  46. const hex = "0123456789abcdef"
  47. buf.WriteByte('"')
  48. start := 0
  49. for i := 0; i < len(s); {
  50. if b := s[i]; b < utf8.RuneSelf {
  51. if 0x20 <= b && b != '\\' && b != '"' && b != '<' && b != '>' && b != '&' {
  52. i++
  53. continue
  54. }
  55. if start < i {
  56. buf.Write(s[start:i])
  57. }
  58. switch b {
  59. case '\\', '"':
  60. buf.WriteByte('\\')
  61. buf.WriteByte(b)
  62. case '\n':
  63. buf.WriteByte('\\')
  64. buf.WriteByte('n')
  65. case '\r':
  66. buf.WriteByte('\\')
  67. buf.WriteByte('r')
  68. default:
  69. buf.WriteString(`\u00`)
  70. buf.WriteByte(hex[b>>4])
  71. buf.WriteByte(hex[b&0xF])
  72. }
  73. i++
  74. start = i
  75. continue
  76. }
  77. c, size := utf8.DecodeRune(s[i:])
  78. if c == utf8.RuneError && size == 1 {
  79. if start < i {
  80. buf.Write(s[start:i])
  81. }
  82. buf.WriteString(`\ufffd`)
  83. i += size
  84. start = i
  85. continue
  86. }
  87. if c == '\u2028' || c == '\u2029' {
  88. if start < i {
  89. buf.Write(s[start:i])
  90. }
  91. buf.WriteString(`\u202`)
  92. buf.WriteByte(hex[c&0xF])
  93. i += size
  94. start = i
  95. continue
  96. }
  97. i += size
  98. }
  99. if start < len(s) {
  100. buf.Write(s[start:])
  101. }
  102. buf.WriteByte('"')
  103. }