23 'message',
'channel',
'level',
'type',
25 'url',
'ip',
'http_method',
'server',
'referrer',
27 'host',
'wiki',
'reqId',
'mwversion',
49 public function __construct(
string $applicationName, ?
string $systemName =
null,
50 string $extraKey =
'',
string $contextKey =
'ctxt_',
$version = self::V0
53 parent::__construct( $applicationName, $systemName, $extraKey, $contextKey );
56 public function format( array $record ): string {
57 $record = \Monolog\Formatter\NormalizerFormatter::
format( $record );
58 if ( $this->version === self::V1 ) {
59 $message = $this->
formatV1( $record );
60 } elseif ( $this->version === self::V0 ) {
61 $message = $this->
formatV0( $record );
66 return $this->toJson( $message ) .
"\n";
75 if ( $this->contextKey !==
'' ) {
76 return $this->formatMonologV0( $record );
79 $context = !empty( $record[
'context'] ) ? $record[
'context'] : [];
80 $record[
'context'] = [];
81 $formatted = $this->formatMonologV0( $record );
83 $formatted[
'@fields'] = $this->fixKeyConflicts( $formatted[
'@fields'], $context );
96 if ( empty( $record[
'datetime'] ) ) {
97 $record[
'datetime'] = gmdate(
'c' );
100 '@timestamp' => $record[
'datetime'],
101 '@source' => $this->systemName,
104 if ( isset( $record[
'message'] ) ) {
105 $message[
'@message'] = $record[
'message'];
107 if ( isset( $record[
'channel'] ) ) {
108 $message[
'@tags'] = [ $record[
'channel'] ];
109 $message[
'@fields'][
'channel'] = $record[
'channel'];
111 if ( isset( $record[
'level'] ) ) {
112 $message[
'@fields'][
'level'] = $record[
'level'];
114 if ( $this->applicationName ) {
115 $message[
'@type'] = $this->applicationName;
117 if ( isset( $record[
'extra'][
'server'] ) ) {
118 $message[
'@source_host'] = $record[
'extra'][
'server'];
120 if ( isset( $record[
'extra'][
'url'] ) ) {
121 $message[
'@source_path'] = $record[
'extra'][
'url'];
123 if ( !empty( $record[
'extra'] ) ) {
124 foreach ( $record[
'extra'] as $key => $val ) {
125 $message[
'@fields'][$this->extraKey . $key] = $val;
128 if ( !empty( $record[
'context'] ) ) {
129 foreach ( $record[
'context'] as $key => $val ) {
130 $message[
'@fields'][$this->contextKey . $key] = $val;
143 if ( $this->contextKey ) {
144 return $this->formatMonologV1( $record );
147 $context = !empty( $record[
'context'] ) ? $record[
'context'] : [];
148 $record[
'context'] = [];
149 $formatted = $this->formatMonologV1( $record );
151 return $this->fixKeyConflicts( $formatted, $context );
162 if ( empty( $record[
'datetime'] ) ) {
163 $record[
'datetime'] = gmdate(
'c' );
166 '@timestamp' => $record[
'datetime'],
168 'host' => $this->systemName,
170 if ( isset( $record[
'message'] ) ) {
171 $message[
'message'] = $record[
'message'];
173 if ( isset( $record[
'channel'] ) ) {
174 $message[
'type'] = $record[
'channel'];
175 $message[
'channel'] = $record[
'channel'];
177 if ( isset( $record[
'level_name'] ) ) {
178 $message[
'level'] = $record[
'level_name'];
182 if ( isset( $record[
'level'] ) ) {
183 $message[
'monolog_level'] = $record[
'level'];
185 if ( $this->applicationName ) {
186 $message[
'type'] = $this->applicationName;
188 if ( !empty( $record[
'extra'] ) ) {
189 foreach ( $record[
'extra'] as $key => $val ) {
190 $message[$this->extraKey . $key] = $val;
193 if ( !empty( $record[
'context'] ) ) {
194 foreach ( $record[
'context'] as $key => $val ) {
195 $message[$this->contextKey . $key] = $val;
210 foreach ( $context as $key => $val ) {
212 in_array( $key, $this->reservedKeys,
true ) &&
213 isset( $fields[$key] ) && $fields[$key] !== $val
215 $fields[
'logstash_formatter_key_conflict'][] = $key;
218 $fields[$key] = $val;
232 'class' => get_class( $e ),
233 'message' => $e->getMessage(),
234 'code' => $e->getCode(),
235 'file' => $e->getFile() .
':' . $e->getLine(),
236 'trace' => \MWExceptionHandler::getRedactedTraceAsString( $e ),
239 $previous = $e->getPrevious();
241 $data[
'previous'] = $this->normalizeException( $previous );