25 'message',
'channel',
'level',
'type',
27 'url',
'ip',
'http_method',
'server',
'referrer',
29 'host',
'wiki',
'reqId',
'mwversion',
51 public function __construct(
string $applicationName, ?
string $systemName =
null,
52 string $extraKey =
'',
string $contextKey =
'ctxt_',
$version = self::V0
55 parent::__construct( $applicationName, $systemName, $extraKey, $contextKey );
58 public function format( array $record ): string {
59 $record = \Monolog\Formatter\NormalizerFormatter::
format( $record );
60 if ( $this->version === self::V1 ) {
61 $message = $this->
formatV1( $record );
62 } elseif ( $this->version === self::V0 ) {
63 $message = $this->
formatV0( $record );
68 return $this->toJson( $message ) .
"\n";
77 if ( $this->contextKey !==
'' ) {
78 return $this->formatMonologV0( $record );
81 $context = !empty( $record[
'context'] ) ? $record[
'context'] : [];
82 $record[
'context'] = [];
83 $formatted = $this->formatMonologV0( $record );
85 $formatted[
'@fields'] = $this->fixKeyConflicts( $formatted[
'@fields'], $context );
98 if ( empty( $record[
'datetime'] ) ) {
99 $record[
'datetime'] = gmdate(
'c' );
102 '@timestamp' => $record[
'datetime'],
103 '@source' => $this->systemName,
106 if ( isset( $record[
'message'] ) ) {
107 $message[
'@message'] = $record[
'message'];
109 if ( isset( $record[
'channel'] ) ) {
110 $message[
'@tags'] = [ $record[
'channel'] ];
111 $message[
'@fields'][
'channel'] = $record[
'channel'];
113 if ( isset( $record[
'level'] ) ) {
114 $message[
'@fields'][
'level'] = $record[
'level'];
116 if ( $this->applicationName ) {
117 $message[
'@type'] = $this->applicationName;
119 if ( isset( $record[
'extra'][
'server'] ) ) {
120 $message[
'@source_host'] = $record[
'extra'][
'server'];
122 if ( isset( $record[
'extra'][
'url'] ) ) {
123 $message[
'@source_path'] = $record[
'extra'][
'url'];
125 if ( !empty( $record[
'extra'] ) ) {
126 foreach ( $record[
'extra'] as $key => $val ) {
127 $message[
'@fields'][$this->extraKey . $key] = $val;
130 if ( !empty( $record[
'context'] ) ) {
131 foreach ( $record[
'context'] as $key => $val ) {
132 $message[
'@fields'][$this->contextKey . $key] = $val;
145 if ( $this->contextKey ) {
146 return $this->formatMonologV1( $record );
149 $context = !empty( $record[
'context'] ) ? $record[
'context'] : [];
150 $record[
'context'] = [];
151 $formatted = $this->formatMonologV1( $record );
153 return $this->fixKeyConflicts( $formatted, $context );
164 if ( empty( $record[
'datetime'] ) ) {
165 $record[
'datetime'] = gmdate(
'c' );
168 '@timestamp' => $record[
'datetime'],
170 'host' => $this->systemName,
172 if ( isset( $record[
'message'] ) ) {
173 $message[
'message'] = $record[
'message'];
175 if ( isset( $record[
'channel'] ) ) {
176 $message[
'type'] = $record[
'channel'];
177 $message[
'channel'] = $record[
'channel'];
179 if ( isset( $record[
'level_name'] ) ) {
180 $message[
'level'] = $record[
'level_name'];
184 if ( isset( $record[
'level'] ) ) {
185 $message[
'monolog_level'] = $record[
'level'];
187 if ( $this->applicationName ) {
188 $message[
'type'] = $this->applicationName;
190 if ( !empty( $record[
'extra'] ) ) {
191 foreach ( $record[
'extra'] as $key => $val ) {
192 $message[$this->extraKey . $key] = $val;
195 if ( !empty( $record[
'context'] ) ) {
196 foreach ( $record[
'context'] as $key => $val ) {
197 $message[$this->contextKey . $key] = $val;
212 foreach ( $context as $key => $val ) {
214 in_array( $key, $this->reservedKeys,
true ) &&
215 isset( $fields[$key] ) && $fields[$key] !== $val
217 $fields[
'logstash_formatter_key_conflict'][] = $key;
220 $fields[$key] = $val;
234 'class' => get_class( $e ),
235 'message' => $e->getMessage(),
236 'code' => $e->getCode(),
237 'file' => $e->getFile() .
':' . $e->getLine(),
238 'trace' => MWExceptionHandler::getRedactedTraceAsString( $e ),
241 $previous = $e->getPrevious();
243 $data[
'previous'] = $this->normalizeException( $previous );