ButterAMQP\Debug\LoggerDecoratedIO

Complexity

Total Complexity

6

Size/Duplication

Total Lines	77
Duplicated Lines	0 %

Coupling/Cohesion

Components	1
Dependencies	3

Test Coverage

Coverage

100%

Importance

Changes

0

6 Methods

Rating	Name	Duplication	Size	Complexity
A	__construct()	0	5	1
A	open()	0	11	1
A	close()	0	6	1
A	peek()	0	4	1
A	read()	0	8	1
A	write()	0	6	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 peek($length, $blocking = true)
    {
        return $this->io->peek($length, $blocking);
    }

    /**
     * {@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);
    }
}