SeqCompactJsonFormatter::processMessage() - Code Metrics - Inspection of "Reduced code complexity" - msschl/monolog-seq-handler - Measure and Improve Code Quality continuously with Scrutinizer

Completed

Push — feature_AddTestsAndReduceCodeC... ( 0c72e4...012aa7 )

by Markus

created 2018-04-09 16:36 UTC

SeqCompactJsonFormatter::processMessage() A

↳ Parent: SeqCompactJsonFormatter

Complexity

Conditions	2
Paths	2

Size

Total Lines	8
Code Lines	4

Duplication

Lines	0
Ratio	0 %

Importance

Changes

Metric	Value
cc	2
eloc	4
nc	2
nop	2
dl	0
loc	8
rs	9.4285
c	0
b	0
f	0

<?php

namespace Msschl\Monolog\Formatter;

use DateTime;
use Monolog\Formatter\FormatterInterface;
use Monolog\Formatter\JsonFormatter;
use Throwable;

/**
 * This file is part of the msschl\monolog-seq-handler package.
 *
 * Copyright (c) 2018 Markus Schlotbohm
 *
 * For the full copyright and license information, please view the LICENSE.md
 * file that was distributed with this source code.
 */
class SeqCompactJsonFormatter extends SeqBaseFormatter
{

    /**
     * The extract context flag.
     * Whether to extract the context array to the root or not.
     *
     * @var bool
     */
    protected $extractContext;

    /**
     * The extract extras flag.
     * Whether to extract the extras array to the root or not.
     *
     * @var bool
     */
    protected $extractExtras;

    /**
     * Initializes a new instance of the {@see SeqCompactJsonFormatter} class.
     *
     * @param  bool $extractContext Flag that indicates whether to extract the extras array
     *                              to the root or not.
     * @param  bool $extractExtras  Flag that indicates whether to extract the context array
     *                              to the root or not.
     */
	public function __construct(bool $extractContext = true, bool $extractExtras = true)
	{
        $this->appendNewline = false;
        $this->batchMode = JsonFormatter::BATCH_MODE_NEWLINES;
        $this->extractContext = $extractContext;
        $this->extractExtras = $extractExtras;
	}

    /**
     * Returns a string with the content type for the seq-formatter.
     *
     * @return string
     */
    public function getContentType() : string {
        return 'application/vnd.serilog.clef';
    }

    /**
     * Gets whether the flag extract content is set or not.
     *
     * @return bool
     */
    public function getExtractContent() : bool
    {
        return $this->extractContext;
    }

    /**
     * Sets the flag extract content.
     *
     * @param  bool $value The flag.
     * @return self
     */
    public function setExtractContent(bool $value)
    {
        $this->extractContext = $value;

        return $this;
    }

    /**
     * Gets whether the flag extract extras is set or not.
     *
     * @return bool
     */
    public function getExtractExtras()
    {
        return $this->extractExtras;
    }

    /**
     * Sets the flag extract extras.
     *
     * @param  bool $value The flag.
     * @return self
     */
    public function setExtractExtras(bool $value)
    {
        $this->extractExtras = $value;

        return $this;
    }

    /**
     * Normalizes given $data.
     *
     * @param mixed $data The data to normalize.
     * @return mixed
     */
    protected function normalize($data)
    {
        if (is_array($data) || $data instanceof \Traversable) {
            return $this->normalizeArray($data);
        }

        if ($data instanceof \Throwable) {
            return $this->normalizeException($data);
        }

        return $data;
    }

    private function normalizeArray($array)
    {
        $normalized = array();

        $count = 1;
        foreach ($array as $key => $value) {
            if ($count++ >= 1000) {
                $normalized['...'] = 'Over 1000 items, aborting normalization';
                break;
            }

            $normalized = $this->processLogRecord($normalized, $key, $value, $count);
        }

        return $normalized;
    }

    private function processLogRecord($array, $key, $value, /** @scrutinizer ignore-unused */ $count)
    {
        switch ($key) {
            case 'message': return $this->processMessage($array, $value);
            case 'datetime': return $this->processDateTime($array, $value);
            case 'level':
                $array['@l'] = $this->logLevelMap[$value];
                $array['LogLevelCode'] = $value;
                return $array;
            case 'level_name': return $array;
            case 'extra': return $this->processExtras($array, $value);
            case 'context': return $this->processContext($array, $value);
            default:
                $array[is_int($key) ? $key : SeqCompactJsonFormatter::ConvertSnakeCaseToPascalCase($key)] = $this->normalize($value);
                return $array;
        }
    }

    private function processMessage($array, $value)
    {
        $array['@m'] = $value;
        if (!(strpos($value, '{') === false)) {
            $array['@mt'] = $value;
        }

        return $array;
    }

    private function processDateTime($array, $value)
    {
        if ($value instanceof \DateTime) {
            $value = $value->format(DateTime::ISO8601);
        }
        $array['@t'] = $value;

        return $array;
    }

    private function processExtras($array, $value)
    {
        if (is_array($value) && is_array($normalizedArray = $this->normalize($value))) {
            if ($this->extractExtras) {
                $array = array_merge($normalizedArray, $array);
            } else {
                $array['Extra'] = $normalizedArray;
            }
        }

        return $array;
    }

    private function processContext($array, $value)
    {
        if (is_array($value)) {
            $exception = $this->extractException($value);
            $normalizedArray = $this->normalize($value);

            if (is_array($normalizedArray)) {
                if ($this->extractContext) {
                    $array = array_merge($normalizedArray, $array);
                } else {
                    $array['Context'] = $normalizedArray;
                }
            }

            if ($exception !== null) {
                if ($exception instanceof \Throwable) {

                    $exception = $this->normalizeException($exception);
                }

                $array['@x'] = $exception;
            }
        }

        return $array;
    }
}

1			<?php
2
3			namespace Msschl\Monolog\Formatter;
4
5			use DateTime;
6			use Monolog\Formatter\FormatterInterface;
7			use Monolog\Formatter\JsonFormatter;
8			use Throwable;
9
10			/**
11			* This file is part of the msschl\monolog-seq-handler package.
12			*
13			* Copyright (c) 2018 Markus Schlotbohm
14			*
15			* For the full copyright and license information, please view the LICENSE.md
16			* file that was distributed with this source code.
17			*/
18			class SeqCompactJsonFormatter extends SeqBaseFormatter
19			{
20
21			/**
22			* The extract context flag.
23			* Whether to extract the context array to the root or not.
24			*
25			* @var bool
26			*/
27			protected $extractContext;
28
29			/**
30			* The extract extras flag.
31			* Whether to extract the extras array to the root or not.
32			*
33			* @var bool
34			*/
35			protected $extractExtras;
36
37			/**
38			* Initializes a new instance of the {@see SeqCompactJsonFormatter} class.
39			*
40			* @param bool $extractContext Flag that indicates whether to extract the extras array
41			* to the root or not.
42			* @param bool $extractExtras Flag that indicates whether to extract the context array
43			* to the root or not.
44			*/
45			public function __construct(bool $extractContext = true, bool $extractExtras = true)
46			{
47			$this->appendNewline = false;
48			$this->batchMode = JsonFormatter::BATCH_MODE_NEWLINES;
49			$this->extractContext = $extractContext;
50			$this->extractExtras = $extractExtras;
51			}
52
53			/**
54			* Returns a string with the content type for the seq-formatter.
55			*
56			* @return string
57			*/
58			public function getContentType() : string {
59			return 'application/vnd.serilog.clef';
60			}
61
62			/**
63			* Gets whether the flag extract content is set or not.
64			*
65			* @return bool
66			*/
67			public function getExtractContent() : bool
68			{
69			return $this->extractContext;
70			}
71
72			/**
73			* Sets the flag extract content.
74			*
75			* @param bool $value The flag.
76			* @return self
77			*/
78			public function setExtractContent(bool $value)
79			{
80			$this->extractContext = $value;
81
82			return $this;
83			}
84
85			/**
86			* Gets whether the flag extract extras is set or not.
87			*
88			* @return bool
89			*/
90			public function getExtractExtras()
91			{
92			return $this->extractExtras;
93			}
94
95			/**
96			* Sets the flag extract extras.
97			*
98			* @param bool $value The flag.
99			* @return self
100			*/
101			public function setExtractExtras(bool $value)
102			{
103			$this->extractExtras = $value;
104
105			return $this;
106			}
107
108			/**
109			* Normalizes given $data.
110			*
111			* @param mixed $data The data to normalize.
112			* @return mixed
113			*/
114			protected function normalize($data)
115			{
116			if (is_array($data) \|\| $data instanceof \Traversable) {
117			return $this->normalizeArray($data);
118			}
119
120			if ($data instanceof \Throwable) {
121			return $this->normalizeException($data);
122			}
123
124			return $data;
125			}
126
127			private function normalizeArray($array)
128			{
129			$normalized = array();
130
131			$count = 1;
132			foreach ($array as $key => $value) {
133			if ($count++ >= 1000) {
134			$normalized['...'] = 'Over 1000 items, aborting normalization';
135			break;
136			}
137
138			$normalized = $this->processLogRecord($normalized, $key, $value, $count);
139			}
140
141			return $normalized;
142			}
143
144			private function processLogRecord($array, $key, $value, /** @scrutinizer ignore-unused */ $count)
145			{
146			switch ($key) {
147			case 'message': return $this->processMessage($array, $value);
148			case 'datetime': return $this->processDateTime($array, $value);
149			case 'level':
150			$array['@l'] = $this->logLevelMap[$value];
151			$array['LogLevelCode'] = $value;
152			return $array;
153			case 'level_name': return $array;
154			case 'extra': return $this->processExtras($array, $value);
155			case 'context': return $this->processContext($array, $value);
156			default:
157			$array[is_int($key) ? $key : SeqCompactJsonFormatter::ConvertSnakeCaseToPascalCase($key)] = $this->normalize($value);
158			return $array;
159			}
160			}
161
162			private function processMessage($array, $value)
163			{
164			$array['@m'] = $value;
165			if (!(strpos($value, '{') === false)) {
166			$array['@mt'] = $value;
167			}
168
169			return $array;
170			}
171
172			private function processDateTime($array, $value)
173			{
174			if ($value instanceof \DateTime) {
175			$value = $value->format(DateTime::ISO8601);
176			}
177			$array['@t'] = $value;
178
179			return $array;
180			}
181
182			private function processExtras($array, $value)
183			{
184			if (is_array($value) && is_array($normalizedArray = $this->normalize($value))) {
185			if ($this->extractExtras) {
186			$array = array_merge($normalizedArray, $array);
187			} else {
188			$array['Extra'] = $normalizedArray;
189			}
190			}
191
192			return $array;
193			}
194
195			private function processContext($array, $value)
196			{
197			if (is_array($value)) {
198			$exception = $this->extractException($value);
199			$normalizedArray = $this->normalize($value);
200
201			if (is_array($normalizedArray)) {
202			if ($this->extractContext) {
203			$array = array_merge($normalizedArray, $array);
204			} else {
205			$array['Context'] = $normalizedArray;
206			}
207			}
208
209			if ($exception !== null) {
210			if ($exception instanceof \Throwable) {
			0 ignored issues – show introduced 2018-04-09 15:57 UTC by Report Bug Copy Issue Report `$exception` is always a sub-type of `Throwable`. Loading history...
211			$exception = $this->normalizeException($exception);
212			}
213
214			$array['@x'] = $exception;
215			}
216			}
217
218			return $array;
219			}
220			}

msschl / monolog-seq-handler

Push — feature_AddTestsAndReduceCodeC... ( 0c72e4...012aa7 )

SeqCompactJsonFormatter::processMessage() A

Complexity

Size

Duplication

Importance

Duplication Side-by-Side

Filter issues like