Logger::__construct() - Code Metrics - Inspection of "suggest psr/log" - Innmind/AMQP - Measure and Improve Code Quality continuously with Scrutinizer

Completed

Push — develop ( dc3756...ffde21 )

by Baptiste

created 2017-09-12 18:46 UTC

Logger::__construct() A

↳ Parent: Logger

Complexity

Conditions	1
Paths	1

Size

Total Lines	7
Code Lines	5

Duplication

Lines	0
Ratio	0 %

Code Coverage

Tests	4
CRAP Score	1

Importance

Changes

Metric	Value
dl	0
loc	7
ccs	4
cts	4
cp	1
rs	9.4285
c	0
b	0
f	0
cc	1
eloc	5
nc	1
nop	2
crap	1

<?php
declare(strict_types = 1);

namespace Innmind\AMQP\Client\Channel\Basic\Get;

use Innmind\AMQP\{
    Client\Channel\Basic\Get,
    Model\Basic\Message,
    Exception\Reject,
    Exception\Requeue
};
use Psr\Log\LoggerInterface;

final class Logger implements Get
{
    private $get;
    private $logger;

    public function __construct(
        Get $get,
        LoggerInterface $logger
    ) {
        $this->get = $get;
        $this->logger = $logger;
    }

    /**
     * {@inheritdoc}
     */
    public function __invoke(callable $consume): void
    {
        ($this->get)(function(Message $message, ...$args) use ($consume): void {
            try {
                $this->logger->debug(
                    'AMQP message received',
                    ['body' => (string) $message->body()]
                );

                $consume($message, ...$args);
            } catch (Reject $e) {
                $this->logger->warning(
                    'AMQP message rejected',
                    ['body' => (string) $message->body()]
                );
                throw $e;
            } catch (Requeue $e) {
                $this->logger->info(
                    'AMQP message requeued',
                    ['body' => (string) $message->body()]
                );
                throw $e;
            } catch (\Throwable $e) {
                $this->logger->error(
                    'AMQP message consumption generated an exception',
                    [
                        'body' => (string) $message->body(),
                        'exception' => get_class($e),
                    ]
                );
                throw $e;
            }
        });
    }
}


1		<?php
2		declare(strict_types = 1);
3
4		namespace Innmind\AMQP\Client\Channel\Basic\Get;
5
6		use Innmind\AMQP\{
7		Client\Channel\Basic\Get,
8		Model\Basic\Message,
9		Exception\Reject,
10		Exception\Requeue
11		};
12		use Psr\Log\LoggerInterface;
13
14		final class Logger implements Get
15		{
16		private $get;
17		private $logger;
18
19	6	public function __construct(
20		Get $get,
21		LoggerInterface $logger
22		) {
23	6	$this->get = $get;
24	6	$this->logger = $logger;
25	6	}
26
27		/**
28		* {@inheritdoc}
29		*/
30		public function __invoke(callable $consume): void
31		{
32	4	($this->get)(function(Message $message, ...$args) use ($consume): void {
33		try {
34	4	$this->logger->debug(
35	4	'AMQP message received',
36	4	['body' => (string) $message->body()]
37		);
38
39	4	$consume($message, ...$args);
40	3	} catch (Reject $e) {
41	1	$this->logger->warning(
42	1	'AMQP message rejected',
43	1	['body' => (string) $message->body()]
44		);
45	1	throw $e;
46	2	} catch (Requeue $e) {
47	1	$this->logger->info(
48	1	'AMQP message requeued',
49	1	['body' => (string) $message->body()]
50		);
51	1	throw $e;
52	1	} catch (\Throwable $e) {
53	1	$this->logger->error(
54	1	'AMQP message consumption generated an exception',
55		[
56	1	'body' => (string) $message->body(),
57	1	'exception' => get_class($e),
58		]
59		);
60	1	throw $e;
61		}
62	4	});
63		}
64		}
65

Innmind / AMQP

GitHub Access Token became invalid

Push — develop ( dc3756...ffde21 )

Logger::__construct() A

Complexity

Size

Duplication

Code Coverage

Importance

Duplication Side-by-Side

Filter issues like