Thruster\Component\Socket\SocketPair

Complexity

Total Complexity

7

Size/Duplication

Total Lines	73
Duplicated Lines	30.14 %

Coupling/Cohesion

Components	1
Dependencies	2

Test Coverage

Coverage

0%

6 Methods

Rating	Name	Duplication	Size	Complexity
A	__construct()	0	4	1
A	create()	0	8	2
A	useLeft()	11	11	1
A	useRight()	11	11	1
A	shutdown()	0	4	1
A	getConnection()	0	4	1

<?php

namespace Thruster\Component\Socket;

use Thruster\Component\EventEmitter\EventEmitterTrait;
use Thruster\Component\EventLoop\EventLoopInterface;
use Thruster\Component\Socket\Exception\ConnectionException;

/**
 * Class SocketPair
 *
 * @package Thruster\Component\Socket
 * @author  Aurimas Niekis <aurimas@niekis.lt>
 */
class SocketPair
{
    const LEFT_SIDE = true;
    const RIGHT_SIDE = false;

    /**
     * @var EventLoopInterface
     */
    protected $loop;

    /**
     * @var Connection
     */
    protected $connection;

    /**
     * @var array
     */
    protected $sockets;

    /**
     * @var bool
     */
    protected $mode;

    public function __construct(EventLoopInterface $loop)
    {
        $this->loop = $loop;
    }

    public function create()
    {
        $this->sockets = @stream_socket_pair(STREAM_PF_UNIX, STREAM_SOCK_STREAM, STREAM_IPPROTO_IP);

        if (false === $this->sockets) {
            throw new ConnectionException('Could not create socket pair');
        }
    }

    public function useLeft() : Connection

This method seems to be duplicated in your project.

    {
        list($left, $right) = $this->sockets;

        fclose($right);

        $this->mode = self::LEFT_SIDE;
        $this->connection = new Connection($left, $this->loop);

        return $this->connection;
    }

    public function useRight() : Connection

This method seems to be duplicated in your project.

    {
        list($left, $right) = $this->sockets;

        fclose($left);

        $this->mode = self::RIGHT_SIDE;
        $this->connection = new Connection($right, $this->loop);

        return $this->connection;
    }

    public function shutdown()
    {
        $this->connection->close();
    }

    public function getConnection() : Connection
    {
        return $this->connection;
    }
}