/src/logging-log4cxx/src/main/cpp/jsonlayout.cpp
Line | Count | Source |
1 | | /* |
2 | | * Licensed to the Apache Software Foundation (ASF) under one or more |
3 | | * contributor license agreements. See the NOTICE file distributed with |
4 | | * this work for additional information regarding copyright ownership. |
5 | | * The ASF licenses this file to You under the Apache License, Version 2.0 |
6 | | * (the "License"); you may not use this file except in compliance with |
7 | | * the License. You may obtain a copy of the License at |
8 | | * |
9 | | * http://www.apache.org/licenses/LICENSE-2.0 |
10 | | * |
11 | | * Unless required by applicable law or agreed to in writing, software |
12 | | * distributed under the License is distributed on an "AS IS" BASIS, |
13 | | * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. |
14 | | * See the License for the specific language governing permissions and |
15 | | * limitations under the License. |
16 | | */ |
17 | | |
18 | | #include <log4cxx/logstring.h> |
19 | | #include <log4cxx/jsonlayout.h> |
20 | | #include <log4cxx/spi/loggingevent.h> |
21 | | #include <log4cxx/level.h> |
22 | | #include <log4cxx/helpers/optionconverter.h> |
23 | | #include <log4cxx/helpers/cacheddateformat.h> |
24 | | #include <log4cxx/helpers/simpledateformat.h> |
25 | | #include <log4cxx/helpers/stringhelper.h> |
26 | | #include <log4cxx/helpers/transcoder.h> |
27 | | #include <log4cxx/private/layout_priv.h> |
28 | | |
29 | | #include <string.h> |
30 | | |
31 | | using namespace LOG4CXX_NS; |
32 | | using namespace LOG4CXX_NS::helpers; |
33 | | using namespace LOG4CXX_NS::spi; |
34 | | |
35 | | IMPLEMENT_LOG4CXX_OBJECT(JSONLayout) |
36 | | |
37 | | struct JSONLayout::JSONLayoutPrivate |
38 | | { |
39 | | JSONLayoutPrivate() : |
40 | 0 | locationInfo(false), |
41 | 0 | prettyPrint(false), |
42 | 0 | ppIndentL1(LOG4CXX_STR(" ")), |
43 | 0 | ppIndentL2(LOG4CXX_STR(" ")), |
44 | 0 | expectedPatternLength(100), |
45 | 0 | threadInfo(false) {} |
46 | | |
47 | | // Print no location info by default |
48 | | bool locationInfo; //= false |
49 | | bool prettyPrint; //= false |
50 | | |
51 | | pattern::CachedDateFormat dateFormat |
52 | | { std::make_shared<helpers::SimpleDateFormat>(LOG4CXX_STR("yyyy-MM-dd HH:mm:ss,SSS")) |
53 | | , pattern::CachedDateFormat::getMaximumCacheValidity(LOG4CXX_STR("yyyy-MM-dd HH:mm:ss,SSS")) |
54 | | }; |
55 | | |
56 | | LogString ppIndentL1; |
57 | | LogString ppIndentL2; |
58 | | |
59 | | // Expected length of a formatted event excluding the message text |
60 | | size_t expectedPatternLength; |
61 | | |
62 | | // Thread info is not included by default |
63 | | bool threadInfo; //= false |
64 | | }; |
65 | | |
66 | | JSONLayout::JSONLayout() : |
67 | 0 | m_priv(std::make_unique<JSONLayoutPrivate>()) |
68 | 0 | { |
69 | 0 | } Unexecuted instantiation: log4cxx::JSONLayout::JSONLayout() Unexecuted instantiation: log4cxx::JSONLayout::JSONLayout() |
70 | | |
71 | 0 | JSONLayout::~JSONLayout(){} |
72 | | |
73 | | void JSONLayout::setLocationInfo(bool locationInfoFlag) |
74 | 0 | { |
75 | 0 | m_priv->locationInfo = locationInfoFlag; |
76 | 0 | } |
77 | | |
78 | | bool JSONLayout::getLocationInfo() const |
79 | 0 | { |
80 | 0 | return m_priv->locationInfo; |
81 | 0 | } |
82 | | |
83 | | void JSONLayout::setPrettyPrint(bool prettyPrintFlag) |
84 | 0 | { |
85 | 0 | m_priv->prettyPrint = prettyPrintFlag; |
86 | 0 | } |
87 | | |
88 | | bool JSONLayout::getPrettyPrint() const |
89 | 0 | { |
90 | 0 | return m_priv->prettyPrint; |
91 | 0 | } |
92 | | |
93 | | void JSONLayout::setThreadInfo(bool newValue) |
94 | 0 | { |
95 | 0 | m_priv->threadInfo = newValue; |
96 | 0 | } |
97 | | |
98 | | bool JSONLayout::getThreadInfo() const |
99 | 0 | { |
100 | 0 | return m_priv->threadInfo; |
101 | 0 | } |
102 | | |
103 | | LogString JSONLayout::getContentType() const |
104 | 0 | { |
105 | 0 | return LOG4CXX_STR("application/json"); |
106 | 0 | } |
107 | | |
108 | | void JSONLayout::activateOptions( LOG4CXX_ACTIVATE_OPTIONS_FORMAL_PARAMETERS ) |
109 | 0 | { |
110 | 0 | m_priv->expectedPatternLength = priv::doubledLayoutSize(getFormattedEventCharacterCount()); |
111 | 0 | } |
112 | | |
113 | | void JSONLayout::setOption(const LogString& option, const LogString& value) |
114 | 0 | { |
115 | 0 | if (StringHelper::equalsIgnoreCase(option, |
116 | 0 | LOG4CXX_STR("LOCATIONINFO"), LOG4CXX_STR("locationinfo"))) |
117 | 0 | { |
118 | 0 | setLocationInfo(OptionConverter::toBoolean(value, false)); |
119 | 0 | } |
120 | 0 | else if (StringHelper::equalsIgnoreCase(option, |
121 | 0 | LOG4CXX_STR("THREADINFO"), LOG4CXX_STR("threadinfo"))) |
122 | 0 | { |
123 | 0 | setThreadInfo(OptionConverter::toBoolean(value, false)); |
124 | 0 | } |
125 | 0 | else if (StringHelper::equalsIgnoreCase(option, |
126 | 0 | LOG4CXX_STR("PRETTYPRINT"), LOG4CXX_STR("prettyprint"))) |
127 | 0 | { |
128 | 0 | setPrettyPrint(OptionConverter::toBoolean(value, false)); |
129 | 0 | } |
130 | 0 | } |
131 | | |
132 | | void JSONLayout::format( LOG4CXX_FORMAT_LAYOUT_FORMAL_PARAMETERS ) const |
133 | 0 | { |
134 | 0 | auto& lsMsg = event->getRenderedMessage(); |
135 | 0 | priv::reserveFormattedEvent(output, m_priv->expectedPatternLength, lsMsg.size()); |
136 | 0 | output.append(LOG4CXX_STR("{")); |
137 | 0 | output.append(m_priv->prettyPrint ? LOG4CXX_EOL : LOG4CXX_STR(" ")); |
138 | |
|
139 | 0 | if (m_priv->prettyPrint) |
140 | 0 | { |
141 | 0 | output.append(m_priv->ppIndentL1); |
142 | 0 | } |
143 | |
|
144 | 0 | output.append(LOG4CXX_STR("\"timestamp\": \"")); |
145 | 0 | m_priv->dateFormat.format(output, event->getTimeStamp()); |
146 | 0 | output.append(LOG4CXX_STR("\",")); |
147 | 0 | output.append(m_priv->prettyPrint ? LOG4CXX_EOL : LOG4CXX_STR(" ")); |
148 | |
|
149 | 0 | if (m_priv->threadInfo) |
150 | 0 | { |
151 | 0 | if (m_priv->prettyPrint) |
152 | 0 | { |
153 | 0 | output.append(m_priv->ppIndentL1); |
154 | 0 | } |
155 | 0 | appendQuotedEscapedString(output, LOG4CXX_STR("thread")); |
156 | 0 | output.append(LOG4CXX_STR(": ")); |
157 | 0 | appendQuotedEscapedString(output, event->getThreadName()); |
158 | 0 | output.append(LOG4CXX_STR(",")); |
159 | 0 | output.append(m_priv->prettyPrint ? LOG4CXX_EOL : LOG4CXX_STR(" ")); |
160 | 0 | } |
161 | |
|
162 | 0 | if (m_priv->prettyPrint) |
163 | 0 | { |
164 | 0 | output.append(m_priv->ppIndentL1); |
165 | 0 | } |
166 | |
|
167 | 0 | output.append(LOG4CXX_STR("\"level\": ")); |
168 | 0 | LogString level; |
169 | 0 | event->getLevel()->toString(level); |
170 | 0 | appendQuotedEscapedString(output, level); |
171 | 0 | output.append(LOG4CXX_STR(",")); |
172 | 0 | output.append(m_priv->prettyPrint ? LOG4CXX_EOL : LOG4CXX_STR(" ")); |
173 | |
|
174 | 0 | if (m_priv->prettyPrint) |
175 | 0 | { |
176 | 0 | output.append(m_priv->ppIndentL1); |
177 | 0 | } |
178 | |
|
179 | 0 | output.append(LOG4CXX_STR("\"logger\": ")); |
180 | 0 | appendQuotedEscapedString(output, event->getLoggerName()); |
181 | 0 | output.append(LOG4CXX_STR(",")); |
182 | 0 | output.append(m_priv->prettyPrint ? LOG4CXX_EOL : LOG4CXX_STR(" ")); |
183 | |
|
184 | 0 | if (m_priv->prettyPrint) |
185 | 0 | { |
186 | 0 | output.append(m_priv->ppIndentL1); |
187 | 0 | } |
188 | |
|
189 | 0 | output.append(LOG4CXX_STR("\"message\": ")); |
190 | 0 | appendQuotedEscapedString(output, lsMsg); |
191 | |
|
192 | 0 | appendSerializedMDC(output, event); |
193 | 0 | appendSerializedNDC(output, event); |
194 | |
|
195 | 0 | if (m_priv->locationInfo) |
196 | 0 | { |
197 | 0 | output.append(LOG4CXX_STR(",")); |
198 | 0 | output.append(m_priv->prettyPrint ? LOG4CXX_EOL : LOG4CXX_STR(" ")); |
199 | 0 | appendSerializedLocationInfo(output, event); |
200 | 0 | } |
201 | |
|
202 | 0 | output.append(m_priv->prettyPrint ? LOG4CXX_EOL : LOG4CXX_STR(" ")); |
203 | 0 | output.append(LOG4CXX_STR("}")); |
204 | 0 | output.append(LOG4CXX_EOL); |
205 | 0 | } |
206 | | |
207 | | void JSONLayout::appendQuotedEscapedString(LogString& buf, |
208 | | const LogString& input) const |
209 | 0 | { |
210 | 0 | appendItem(input, buf); |
211 | 0 | } |
212 | | |
213 | | void JSONLayout::appendItem(const LogString& input, LogString& buf) |
214 | 0 | { |
215 | 0 | auto toHexDigit = [](int ch) -> int |
216 | 0 | { |
217 | 0 | return (10 <= ch ? (0x61 - 10) : 0x30) + ch; |
218 | 0 | }; |
219 | | /* add leading quote */ |
220 | 0 | buf.push_back(0x22); |
221 | |
|
222 | 0 | auto start = input.begin(); |
223 | 0 | for (auto nextCodePoint = start; input.end() != nextCodePoint; ) |
224 | 0 | { |
225 | 0 | auto lastCodePoint = nextCodePoint; |
226 | 0 | auto ch = Transcoder::getCodePoint(input, nextCodePoint); |
227 | 0 | if (0x22 == ch || 0x5c == ch) // double quote or backslash? |
228 | 0 | ; |
229 | 0 | else if (0x20 <= ch && 0xFFFD != ch) // not a control character or the replacement character? |
230 | 0 | continue; |
231 | | |
232 | 0 | if (start != lastCodePoint) |
233 | 0 | buf.append(start, lastCodePoint); |
234 | 0 | start = nextCodePoint; |
235 | 0 | switch (ch) |
236 | 0 | { |
237 | 0 | case 0x08: |
238 | | /* \b backspace */ |
239 | 0 | buf.push_back(0x5c); |
240 | 0 | buf.push_back('b'); |
241 | 0 | break; |
242 | | |
243 | 0 | case 0x09: |
244 | | /* \t tab */ |
245 | 0 | buf.push_back(0x5c); |
246 | 0 | buf.push_back('t'); |
247 | 0 | break; |
248 | | |
249 | 0 | case 0x0a: |
250 | | /* \n newline */ |
251 | 0 | buf.push_back(0x5c); |
252 | 0 | buf.push_back('n'); |
253 | 0 | break; |
254 | | |
255 | 0 | case 0x0c: |
256 | | /* \f form feed */ |
257 | 0 | buf.push_back(0x5c); |
258 | 0 | buf.push_back('f'); |
259 | 0 | break; |
260 | | |
261 | 0 | case 0x0d: |
262 | | /* \r carriage return */ |
263 | 0 | buf.push_back(0x5c); |
264 | 0 | buf.push_back('r'); |
265 | 0 | break; |
266 | | |
267 | 0 | case 0x22: |
268 | | /* \" double quote */ |
269 | 0 | buf.push_back(0x5c); |
270 | 0 | buf.push_back(0x22); |
271 | 0 | break; |
272 | | |
273 | 0 | case 0x5c: |
274 | | /* \\ backslash */ |
275 | 0 | buf.push_back(0x5c); |
276 | 0 | buf.push_back(0x5c); |
277 | 0 | break; |
278 | | |
279 | 0 | default: |
280 | 0 | buf.push_back(0x5c); |
281 | 0 | buf.push_back(0x75); // 'u' |
282 | 0 | buf.push_back(toHexDigit((ch & 0xF000) >> 12)); |
283 | 0 | buf.push_back(toHexDigit((ch & 0xF00) >> 8)); |
284 | 0 | buf.push_back(toHexDigit((ch & 0xF0) >> 4)); |
285 | 0 | buf.push_back(toHexDigit(ch & 0xF)); |
286 | 0 | break; |
287 | 0 | } |
288 | 0 | } |
289 | 0 | buf.append(start, input.end()); |
290 | | |
291 | | /* add trailing quote */ |
292 | 0 | buf.push_back(0x22); |
293 | 0 | } |
294 | | |
295 | | void JSONLayout::appendSerializedMDC(LogString& buf, |
296 | | const LoggingEventPtr& event) const |
297 | 0 | { |
298 | 0 | LoggingEvent::KeySet keys = event->getMDCKeySet(); |
299 | |
|
300 | 0 | if (keys.empty()) |
301 | 0 | { |
302 | 0 | return; |
303 | 0 | } |
304 | | |
305 | 0 | buf.append(LOG4CXX_STR(",")); |
306 | 0 | buf.append(m_priv->prettyPrint ? LOG4CXX_EOL : LOG4CXX_STR(" ")); |
307 | |
|
308 | 0 | if (m_priv->prettyPrint) |
309 | 0 | { |
310 | 0 | buf.append(m_priv->ppIndentL1); |
311 | 0 | } |
312 | |
|
313 | 0 | appendQuotedEscapedString(buf, LOG4CXX_STR("context_map")); |
314 | 0 | buf.append(LOG4CXX_STR(": {")); |
315 | 0 | buf.append(m_priv->prettyPrint ? LOG4CXX_EOL : LOG4CXX_STR(" ")); |
316 | |
|
317 | 0 | for (LoggingEvent::KeySet::iterator it = keys.begin(); |
318 | 0 | it != keys.end(); ++it) |
319 | 0 | { |
320 | 0 | if (m_priv->prettyPrint) |
321 | 0 | { |
322 | 0 | buf.append(m_priv->ppIndentL2); |
323 | 0 | } |
324 | |
|
325 | 0 | appendQuotedEscapedString(buf, *it); |
326 | 0 | buf.append(LOG4CXX_STR(": ")); |
327 | 0 | LogString value; |
328 | 0 | event->getMDC(*it, value); |
329 | 0 | appendQuotedEscapedString(buf, value); |
330 | | |
331 | | /* if this isn't the last k:v pair, we need a comma */ |
332 | 0 | if (it + 1 != keys.end()) |
333 | 0 | { |
334 | 0 | buf.append(LOG4CXX_STR(",")); |
335 | 0 | buf.append(m_priv->prettyPrint ? LOG4CXX_EOL : LOG4CXX_STR(" ")); |
336 | 0 | } |
337 | 0 | else |
338 | 0 | { |
339 | 0 | buf.append(m_priv->prettyPrint ? LOG4CXX_EOL : LOG4CXX_STR(" ")); |
340 | 0 | } |
341 | 0 | } |
342 | |
|
343 | 0 | if (m_priv->prettyPrint) |
344 | 0 | { |
345 | 0 | buf.append(m_priv->ppIndentL1); |
346 | 0 | } |
347 | |
|
348 | 0 | buf.append(LOG4CXX_STR("}")); |
349 | 0 | } |
350 | | |
351 | | void JSONLayout::appendSerializedNDC(LogString& buf, |
352 | | const LoggingEventPtr& event) const |
353 | 0 | { |
354 | 0 | LogString ndcVal; |
355 | |
|
356 | 0 | if (!event->getNDC(ndcVal)) |
357 | 0 | { |
358 | 0 | return; |
359 | 0 | } |
360 | | |
361 | 0 | buf.append(LOG4CXX_STR(",")); |
362 | 0 | buf.append(m_priv->prettyPrint ? LOG4CXX_EOL : LOG4CXX_STR(" ")); |
363 | |
|
364 | 0 | if (m_priv->prettyPrint) |
365 | 0 | { |
366 | 0 | buf.append(m_priv->ppIndentL1); |
367 | 0 | } |
368 | |
|
369 | 0 | appendQuotedEscapedString(buf, LOG4CXX_STR("context_stack")); |
370 | 0 | buf.append(LOG4CXX_STR(": [")); |
371 | 0 | buf.append(m_priv->prettyPrint ? LOG4CXX_EOL : LOG4CXX_STR(" ")); |
372 | |
|
373 | 0 | if (m_priv->prettyPrint) |
374 | 0 | { |
375 | 0 | buf.append(m_priv->ppIndentL2); |
376 | 0 | } |
377 | |
|
378 | 0 | appendQuotedEscapedString(buf, ndcVal); |
379 | 0 | buf.append(m_priv->prettyPrint ? LOG4CXX_EOL : LOG4CXX_STR(" ")); |
380 | |
|
381 | 0 | if (m_priv->prettyPrint) |
382 | 0 | { |
383 | 0 | buf.append(m_priv->ppIndentL1); |
384 | 0 | } |
385 | |
|
386 | 0 | buf.append(LOG4CXX_STR("]")); |
387 | 0 | } |
388 | | |
389 | | void JSONLayout::appendSerializedLocationInfo(LogString& buf, const LoggingEventPtr& event) const |
390 | 0 | { |
391 | 0 | if (m_priv->prettyPrint) |
392 | 0 | { |
393 | 0 | buf.append(m_priv->ppIndentL1); |
394 | 0 | } |
395 | |
|
396 | 0 | appendQuotedEscapedString(buf, LOG4CXX_STR("location_info")); |
397 | 0 | buf.append(LOG4CXX_STR(": {")); |
398 | 0 | buf.append(m_priv->prettyPrint ? LOG4CXX_EOL : LOG4CXX_STR(" ")); |
399 | 0 | const LocationInfo& locInfo = event->getLocationInformation(); |
400 | |
|
401 | 0 | if (m_priv->prettyPrint) |
402 | 0 | { |
403 | 0 | buf.append(m_priv->ppIndentL2); |
404 | 0 | } |
405 | |
|
406 | 0 | appendQuotedEscapedString(buf, LOG4CXX_STR("file")); |
407 | 0 | buf.append(LOG4CXX_STR(": ")); |
408 | 0 | LOG4CXX_DECODE_CHAR(fileName, locInfo.getFileName()); |
409 | 0 | appendQuotedEscapedString(buf, fileName); |
410 | 0 | buf.append(LOG4CXX_STR(",")); |
411 | 0 | buf.append(m_priv->prettyPrint ? LOG4CXX_EOL : LOG4CXX_STR(" ")); |
412 | |
|
413 | 0 | if (m_priv->prettyPrint) |
414 | 0 | { |
415 | 0 | buf.append(m_priv->ppIndentL2); |
416 | 0 | } |
417 | |
|
418 | 0 | appendQuotedEscapedString(buf, LOG4CXX_STR("line")); |
419 | 0 | buf.append(LOG4CXX_STR(": ")); |
420 | 0 | LogString lineNumber; |
421 | 0 | StringHelper::toString(locInfo.getLineNumber(), lineNumber); |
422 | 0 | appendQuotedEscapedString(buf, lineNumber); |
423 | 0 | buf.append(LOG4CXX_STR(",")); |
424 | 0 | buf.append(m_priv->prettyPrint ? LOG4CXX_EOL : LOG4CXX_STR(" ")); |
425 | |
|
426 | 0 | if (m_priv->prettyPrint) |
427 | 0 | { |
428 | 0 | buf.append(m_priv->ppIndentL2); |
429 | 0 | } |
430 | |
|
431 | 0 | appendQuotedEscapedString(buf, LOG4CXX_STR("class")); |
432 | 0 | buf.append(LOG4CXX_STR(": ")); |
433 | 0 | LOG4CXX_DECODE_CHAR(className, locInfo.getClassName()); |
434 | 0 | appendQuotedEscapedString(buf, className); |
435 | 0 | buf.append(LOG4CXX_STR(",")); |
436 | 0 | buf.append(m_priv->prettyPrint ? LOG4CXX_EOL : LOG4CXX_STR(" ")); |
437 | |
|
438 | 0 | if (m_priv->prettyPrint) |
439 | 0 | { |
440 | 0 | buf.append(m_priv->ppIndentL2); |
441 | 0 | } |
442 | |
|
443 | 0 | appendQuotedEscapedString(buf, LOG4CXX_STR("method")); |
444 | 0 | buf.append(LOG4CXX_STR(": ")); |
445 | 0 | LOG4CXX_DECODE_CHAR(methodName, locInfo.getMethodName()); |
446 | 0 | appendQuotedEscapedString(buf, methodName); |
447 | 0 | buf.append(m_priv->prettyPrint ? LOG4CXX_EOL : LOG4CXX_STR(" ")); |
448 | |
|
449 | 0 | if (m_priv->prettyPrint) |
450 | 0 | { |
451 | 0 | buf.append(m_priv->ppIndentL1); |
452 | 0 | } |
453 | |
|
454 | 0 | buf.append(LOG4CXX_STR("}")); |
455 | 0 | } |
456 | | |
457 | | #if LOG4CXX_ABI_VERSION <= 15 |
458 | | void JSONLayout::appendSerializedLocationInfo(LogString& buf, |
459 | | const LoggingEventPtr& event, Pool& p) const |
460 | 0 | { |
461 | 0 | appendSerializedLocationInfo(buf, event); |
462 | 0 | } |
463 | | #endif |