PhpFlo\TraceableNetwork

Complexity

Total Complexity

4

Size/Duplication

Total Lines	38
Duplicated Lines	0 %

Coupling/Cohesion

Components	0
Dependencies	3

Test Coverage

Coverage

44.44%

Importance

Changes

0

2 Methods

Rating	Name	Duplication	Size	Complexity
A	__construct()	0	7	1
A	trace()	0	20	3

<?php
/*
 * This file is part of the phpflo/phpflo-flowtrace package.
 *
 * (c) Marc Aschmann <maschmann@gmail.com>
 *
 * For the full copyright and license information, please view the LICENSE
 * file that was distributed with this source code.
 */

namespace PhpFlo;

use PhpFlo\Common\AbstractNetworkAdapter;
use PhpFlo\Common\HookableNetworkInterface;
use PhpFlo\Common\Network;

This use statement conflicts with another class in this namespace, PhpFlo\Network.

use PhpFlo\Common\NetworkAdapterinterface;
use PhpFlo\Common\NetworkInterface;
use PhpFlo\Exception\FlowException;
use PhpFlo\Exception\InvalidDefinitionException;
use PhpFlo\Exception\InvalidTypeException;
use Psr\Log\LoggerInterface;

/**
 * Network for tracing events.
 *
 * @package PhpFlo
 * @author Marc Aschmann <maschmann@gmail.com>
 */
class TraceableNetwork extends AbstractNetworkAdapter implements NetworkAdapterinterface
{
    private $logger;

    public function __construct(NetworkInterface $network, LoggerInterface $logger)
    {
        parent::__construct($network);

        $this->logger = $logger;
        $this->network->hook('data', 'flowtrace', $this->trace());
    }

    /**
     * Wrap the creation of the callback
     *
     * @return \Closure
     */
    private function trace()
    {
        $trace = function ($data, $socket) {
            if (!is_string($data)) {
                $data = serialize($data);

$data is not used, you could remove the assignment.

            }

            $to = $socket->to();
            $message = "-> {$to['port']} {$to['process']}";

            $from = $socket->from();
            if (isset($from['process'])) {
                $message = "{$from['process']} {$from['port']} " . $message;
            }

            $this->logger->debug($message);
        };

        return $trace->bindTo($this);
    }
}