Generics\Socket\ClientSocket

Complexity

Total Complexity

11

Size/Duplication

Total Lines	94
Duplicated Lines	14.89 %

Coupling/Cohesion

Components	1
Dependencies	3

Test Coverage

Coverage

96.67%

Importance

Changes

0

6 Methods

Rating	Name	Duplication	Size	Complexity
A	__construct()	10	10	2
A	connect()	4	11	3
A	disconnect()	0	8	2
A	isConnected()	0	4	1
A	close()	0	5	1
A	isWriteable()	0	8	2

<?php

/**
 * This file is part of the PHP Generics package.
 *
 * @package Generics
 */
namespace Generics\Socket;

/**
 * This class provides a basic client socket implementation
 *
 * @author Maik Greubel <greubel@nkey.de>
 */
class ClientSocket extends Socket
{

    /**
     * Whether the socket is connected
     *
     * @var boolean
     */
    private $conntected;

    /**
     * Create a new client socket
     *
     * @param Endpoint $endpoint
     *            The endpoint to use
     * @param resource $clientHandle
     *            optional existing client handle
     */
    public function __construct(Endpoint $endpoint, $clientHandle = null)
    {
        $this->endpoint = $endpoint;
        $this->handle = $clientHandle;
        $this->conntected = false;
        
        if (! is_resource($clientHandle)) {
            parent::__construct($endpoint);
        }
    }

    /**
     * Connect to remote endpoint
     *
     * @throws SocketException
     */
    public function connect()
    {
        if (!is_resource($this->handle)) {
            throw new SocketException("Socket is not available");
        }
        if (! @socket_connect($this->handle, $this->endpoint->getAddress(), $this->endpoint->getPort())) {

This code seems to be duplicated across your project.

            $code = socket_last_error($this->handle);
            throw new SocketException(socket_strerror($code), array(), $code);
        }
        $this->conntected = true;
    }

    /**
     * Disconnects the socket
     *
     * @throws SocketException
     */
    public function disconnect()
    {
        if (! $this->conntected) {
            throw new SocketException("Socket is not connected");
        }
        
        $this->close();
    }

    /**
     * Whether the client is connected
     *
     * @return bool
     */
    public function isConnected():bool
    {
        return $this->conntected;
    }

    /**
     *
     * @see \Generics\Socket\ClientSocket::disconnect()
     */
    public function close()
    {
        parent::close();
        $this->conntected = false;
    }

    /**
     *
     * {@inheritdoc}
     * @see \Generics\Socket\Socket::isWriteable()
     */
    public function isWriteable():bool
    {
        if (! $this->isConnected()) {
            return false;
        }
        
        return parent::isWriteable();
    }
}