LoggerDecoratedIO::open() - Code Metrics - Inspection of "Move buffering from IO to Wire" - skolodyazhnyy/butter-amqplib - Measure and Improve Code Quality continuously with Scrutinizer

Completed

Push — master ( b2e4f3...d16f6a )

by Sergey

created 2016-09-16 14:41 UTC

LoggerDecoratedIO::open() A

↳ Parent: LoggerDecoratedIO

Complexity

Conditions	1
Paths	1

Size

Total Lines	11
Code Lines	7

Duplication

Lines	0
Ratio	0 %

Code Coverage

Tests	8
CRAP Score	1

Importance

Changes

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

<?php

namespace ButterAMQP\Debug;

use ButterAMQP\IOInterface;
use Psr\Log\LoggerInterface;

class LoggerDecoratedIO implements IOInterface
{
    /**
     * @var IOInterface
     */
    private $io;

    /**
     * @var LoggerInterface
     */
    private $logger;

    /**
     * @param IOInterface     $io
     * @param LoggerInterface $logger
     */
    public function __construct(IOInterface $io, LoggerInterface $logger)
    {
        $this->io = $io;
        $this->logger = $logger;
    }

    /**
     * {@inheritdoc}
     */
    public function open($protocol, $host, $port, array $parameters = [])
    {
        $this->logger->debug(sprintf('Connecting to "%s://%s:%d"...', $protocol, $host, $port), [
            'protocol' => $protocol,
            'host' => $host,
            'port' => $port,
            'parameters' => $parameters,
        ]);

        return $this->io->open($protocol, $host, $port, $parameters);
    }

    /**
     * {@inheritdoc}
     */
    public function close()
    {
        $this->logger->debug('Closing connection');

        return $this->io->close();
    }

    /**
     * {@inheritdoc}
     */
    public function read($length, $blocking = true)
    {
        $data = $this->io->read($length, $blocking);

        $this->logger->debug(new ReadableBinaryData('Reading', $data));

        return $data;
    }

    /**
     * {@inheritdoc}
     */
    public function write($data, $length = null)
    {
        $this->logger->debug(new ReadableBinaryData('Writing', $data));

        return $this->io->write($data, $length);
    }
}


1		<?php
2
3		namespace ButterAMQP\Debug;
4
5		use ButterAMQP\IOInterface;
6		use Psr\Log\LoggerInterface;
7
8		class LoggerDecoratedIO implements IOInterface
9		{
10		/**
11		* @var IOInterface
12		*/
13		private $io;
14
15		/**
16		* @var LoggerInterface
17		*/
18		private $logger;
19
20		/**
21		* @param IOInterface $io
22		* @param LoggerInterface $logger
23		*/
24	4	public function __construct(IOInterface $io, LoggerInterface $logger)
25		{
26	4	$this->io = $io;
27	4	$this->logger = $logger;
28	4	}
29
30		/**
31		* {@inheritdoc}
32		*/
33	1	public function open($protocol, $host, $port, array $parameters = [])
34		{
35	1	$this->logger->debug(sprintf('Connecting to "%s://%s:%d"...', $protocol, $host, $port), [
36	1	'protocol' => $protocol,
37	1	'host' => $host,
38	1	'port' => $port,
39	1	'parameters' => $parameters,
40	1	]);
41
42	1	return $this->io->open($protocol, $host, $port, $parameters);
43		}
44
45		/**
46		* {@inheritdoc}
47		*/
48	1	public function close()
49		{
50	1	$this->logger->debug('Closing connection');
51
52	1	return $this->io->close();
53		}
54
55		/**
56		* {@inheritdoc}
57		*/
58	1	public function read($length, $blocking = true)
59		{
60	1	$data = $this->io->read($length, $blocking);
61
62	1	$this->logger->debug(new ReadableBinaryData('Reading', $data));
63
64	1	return $data;
65		}
66
67		/**
68		* {@inheritdoc}
69		*/
70	1	public function write($data, $length = null)
71		{
72	1	$this->logger->debug(new ReadableBinaryData('Writing', $data));
73
74	1	return $this->io->write($data, $length);
75		}
76		}
77

skolodyazhnyy / butter-amqplib

Push — master ( b2e4f3...d16f6a )

LoggerDecoratedIO::open() A

Complexity

Size

Duplication

Code Coverage

Importance

Duplication Side-by-Side

Filter issues like