|
1 | | -const merge = require('lodash.merge'); |
2 | | -const moment = require('moment'); |
3 | | -const { logging, outputTypes } = require('./config'); |
4 | | -const levels = logging.log4js.levels; |
| 1 | +const moment = require('moment') |
| 2 | +const winston = require('winston') |
5 | 3 |
|
6 | | -const RequestTracing = require('./tracing/requestTracing'); |
| 4 | +const container = new winston.Container() |
7 | 5 |
|
8 | | -let userConfig = {}; |
| 6 | +function timestamp() { |
| 7 | + return moment().format('YYYY-MM-DDTHH:mm:ssZ') |
| 8 | +} |
9 | 9 |
|
10 | | -function isBlank (str) { |
11 | | - return !str || str.trim().length === 0; |
| 10 | +function transport(label) { |
| 11 | + return new winston.transports.Console({ |
| 12 | + level: (process.env.LOG_LEVEL || 'INFO').toLowerCase(), |
| 13 | + json: process.env.JSON_PRINT || false, |
| 14 | + timestamp: timestamp, |
| 15 | + label: label |
| 16 | + }) |
12 | 17 | } |
13 | 18 |
|
14 | 19 | class Logger { |
15 | 20 |
|
16 | | - //---------------------------------------------------- |
17 | | - // Public functions |
18 | | - //---------------------------------------------------- |
19 | | - |
20 | | - constructor() { |
21 | | - } |
22 | | - |
23 | | - trace(logEntry) { |
24 | | - logEntry = this._wrap(logEntry); |
25 | | - logEntry.level = levels.TRACE.toString(); |
26 | | - return this._log(logEntry); |
27 | | - } |
28 | | - |
29 | | - debug(logEntry) { |
30 | | - logEntry = this._wrap(logEntry); |
31 | | - logEntry.level = levels.DEBUG.toString(); |
32 | | - return this._log(logEntry); |
33 | | - } |
34 | | - |
35 | | - info(logEntry) { |
36 | | - logEntry = this._wrap(logEntry); |
37 | | - logEntry.level = levels.INFO.toString(); |
38 | | - return this._log(logEntry); |
39 | | - } |
40 | | - |
41 | | - warn(logEntry) { |
42 | | - logEntry = this._wrap(logEntry); |
43 | | - logEntry.level = levels.WARN.toString(); |
44 | | - return this._log(logEntry); |
45 | | - } |
46 | | - |
47 | | - error(logEntry) { |
48 | | - logEntry = this._wrap(logEntry); |
49 | | - logEntry.level = levels.ERROR.toString(); |
50 | | - return this._log(logEntry); |
51 | | - } |
52 | | - |
53 | | - fatal(logEntry) { |
54 | | - logEntry = this._wrap(logEntry); |
55 | | - logEntry.level = levels.FATAL.toString(); |
56 | | - return this._log(logEntry); |
57 | | - } |
58 | | - |
59 | | - //---------------------------------------------------- |
60 | | - // Public static functions |
61 | | - //---------------------------------------------------- |
62 | | - |
63 | 21 | static getLogger(name) { |
64 | | - const logger = new Logger(); |
65 | | - logger.logger = logging.log4js.getLogger(name); |
66 | | - |
67 | | - return logger; |
68 | | - } |
69 | | - |
70 | | - static config(config) { |
71 | | - userConfig = config || {}; |
| 22 | + return container.add(name, {transports: [transport(name)]}) |
72 | 23 | } |
73 | | - |
74 | | - //---------------------------------------------------- |
75 | | - // Private functions |
76 | | - //---------------------------------------------------- |
77 | | - |
78 | | - _log(logEntry) { |
79 | | - logEntry = merge({ }, logging.defaultLogEntry, logEntry); |
80 | | - this._addTracingInformation(logEntry) |
81 | | - logEntry.timestamp = moment().format(logging.timestampFormat); |
82 | | - const level = logEntry.level.toLowerCase(); |
83 | | - |
84 | | - logEntry.microservice = userConfig.microservice || 'not-configured'; |
85 | | - logEntry.team = userConfig.team || 'not-configured'; |
86 | | - logEntry.environment = userConfig.environment || 'not-configured'; |
87 | | - |
88 | | - if (logging.output === outputTypes.single) { |
89 | | - this.logger[level](JSON.stringify(logEntry)); |
90 | | - } else if (logging.output === outputTypes.multi) { |
91 | | - this.logger[level](logEntry); |
92 | | - } else { |
93 | | - this.logger[level](`${logEntry.timestamp} ${logEntry.level} ${this.logger.category}: ${logEntry.message}`) |
94 | | - } |
95 | | - |
96 | | - return logEntry; |
97 | | - }; |
98 | | - |
99 | | - _addTracingInformation (logEntry) { |
100 | | - if (isBlank(logEntry.requestId)) { |
101 | | - logEntry.requestId = RequestTracing.getCurrentRequestId() || logging.defaultLogEntry.requestId; |
102 | | - } |
103 | | - if (isBlank(logEntry.originRequestId)) { |
104 | | - logEntry.originRequestId = RequestTracing.getOriginRequestId() || logging.defaultLogEntry.originRequestId; |
105 | | - } |
106 | | - if (isBlank(logEntry.rootRequestId)) { |
107 | | - logEntry.rootRequestId = RequestTracing.getRootRequestId() || logging.defaultLogEntry.rootRequestId; |
108 | | - } |
109 | | - } |
110 | | - |
111 | | - _wrap(message) { |
112 | | - if (typeof message === 'string') { |
113 | | - return { message: message }; |
114 | | - } else if (message instanceof String) { |
115 | | - return { message: message.toString() }; |
116 | | - } else { |
117 | | - return message; |
118 | | - } |
119 | | - } |
120 | | - |
121 | 24 | } |
122 | 25 |
|
123 | | -module.exports = Logger; |
| 26 | +module.exports = Logger |
0 commit comments