9029605458

Committed 10 May 2024 08:35AM UTC coverage: 90.119% (-9.0%) from 99.111%

Build # 9029605458

Build Type

push

github

Committed by

fractalzombie

Commit Message

[MetricsPower] Added logstash processor

Run Details

12 of 35 new or added lines in 4 files covered. (34.29%)

228 of 253 relevant lines covered (90.12%)

10.47 hits per line

Source File
Press 'n' to go to next uncovered line, 'b' for previous

0.0

/Logger/Processor/LogstashProcessor.php

<?php

declare(strict_types=1);

/**
 * THE SOFTWARE IS PROVIDED "AS IS", WITHOUT WARRANTY OF ANY KIND,
 * EXPRESS OR IMPLIED, INCLUDING BUT NOT LIMITED TO THE WARRANTIES OF MERCHANTABILITY,
 * FITNESS FOR A PARTICULAR PURPOSE AND NONINFRINGEMENT.
 *
 * Copyright (c) 2024 Mykhailo Shtanko fractalzombie@gmail.com
 *
 * For the full copyright and license information, please view the LICENSE.MD
 * file that was distributed with this source code.
 */

namespace FRZB\Component\MetricsPower\Logger\Processor;

use FRZB\Component\DependencyInjection\Attribute\AsTagged;
use Monolog\LogRecord;
use Symfony\Component\DependencyInjection\Attribute\Autowire;

#[AsTagged('monolog.processor')]
class LogstashProcessor
{
    public function __construct(
        #[Autowire(env: 'MONOLOG_SOURCE')]
        private readonly string $source,
    ) {}

    public function __invoke(LogRecord $record): LogRecord
    {
        return new LogRecord(
            $record->datetime,
            $record->channel,
            $record->level,
            json_validate($record->message) ? $this->formatJson($record->message) : $record->message,
            $this->mapContext($record),
            $this->mapExtra($record),
            json_validate($record->formatted) ? $this->formatJson($record->formatted) : $record->formatted,
        );
    }

    private function formatJson(string $json): string
    {
        $decodedJson = json_decode($json, true);

        return json_encode($decodedJson, \JSON_PRETTY_PRINT | \JSON_UNESCAPED_SLASHES | \JSON_UNESCAPED_UNICODE);
    }

    private function mapExtra(LogRecord $record): array
    {
        return [
            ...$record->extra,
            'source' => $this->source,
        ];
    }

    private function mapContext(LogRecord $record): array
    {
        return [
            ...$record->context,
        ];
    }
}

1	<?php
2
3	declare(strict_types=1);
4
5	/**
6	* THE SOFTWARE IS PROVIDED "AS IS", WITHOUT WARRANTY OF ANY KIND,
7	* EXPRESS OR IMPLIED, INCLUDING BUT NOT LIMITED TO THE WARRANTIES OF MERCHANTABILITY,
8	* FITNESS FOR A PARTICULAR PURPOSE AND NONINFRINGEMENT.
9	*
10	* Copyright (c) 2024 Mykhailo Shtanko fractalzombie@gmail.com
11	*
12	* For the full copyright and license information, please view the LICENSE.MD
13	* file that was distributed with this source code.
14	*/
15
16	namespace FRZB\Component\MetricsPower\Logger\Processor;
17
18	use FRZB\Component\DependencyInjection\Attribute\AsTagged;
19	use Monolog\LogRecord;
20	use Symfony\Component\DependencyInjection\Attribute\Autowire;
21
22	#[AsTagged('monolog.processor')]
23	class LogstashProcessor
24	{
25	public function __construct(
26	#[Autowire(env: 'MONOLOG_SOURCE')]
27	private readonly string $source,
NEW 28	) {}	×
29
30	public function __invoke(LogRecord $record): LogRecord
31	{
NEW 32	return new LogRecord(	×
NEW 33	$record->datetime,	×
NEW 34	$record->channel,	×
NEW 35	$record->level,	×
NEW 36	json_validate($record->message) ? $this->formatJson($record->message) : $record->message,	×
NEW 37	$this->mapContext($record),	×
NEW 38	$this->mapExtra($record),	×
NEW 39	json_validate($record->formatted) ? $this->formatJson($record->formatted) : $record->formatted,	×
NEW 40	);	×
41	}
42
43	private function formatJson(string $json): string
44	{
NEW 45	$decodedJson = json_decode($json, true);	×
46
NEW 47	return json_encode($decodedJson, \JSON_PRETTY_PRINT \| \JSON_UNESCAPED_SLASHES \| \JSON_UNESCAPED_UNICODE);	×
48	}
49
50	private function mapExtra(LogRecord $record): array
51	{
NEW 52	return [	×
NEW 53	...$record->extra,	×
NEW 54	'source' => $this->source,	×
NEW 55	];	×
56	}
57
58	private function mapContext(LogRecord $record): array
59	{
NEW 60	return [	×
NEW 61	...$record->context,	×
NEW 62	];	×
63	}
64	}

fractalzombie / frzb-metrics-power / 9029605458

Source File Press 'n' to go to next uncovered line, 'b' for previous

Source File
Press 'n' to go to next uncovered line, 'b' for previous