MySQLReplication\Socket\Socket

Complexity

Total Complexity

13

Size/Duplication

Total Lines	101
Duplicated Lines	0 %

Coupling/Cohesion

Components	1
Dependencies	1

Test Coverage

Coverage

53.66%

Importance

Changes

0

7 Methods

Rating	Name	Duplication	Size	Complexity
A	__destruct()	0	7	2
A	isConnected()	0	4	1
A	connectToStream()	0	19	3
A	getSocketErrorMessage()	0	4	1
A	getSocketErrorCode()	0	4	1
A	readFromSocket()	0	17	3
A	writeToSocket()	0	9	2

<?php


namespace MySQLReplication\Socket;

/**
 * Class Socket
 * @package MySQLReplication\Socket
 */
class Socket implements SocketInterface
{
    /**
     * @var resource
     */
    private $socket;

    public function __destruct()
    {
        if ($this->isConnected()) {
            socket_shutdown($this->socket);
            socket_close($this->socket);
        }
    }

    /**
     * @return bool
     */
    public function isConnected()
    {
        return is_resource($this->socket);
    }

    /**
     * @param string $host
     * @param int $port
     * @throws SocketException
     */
    public function connectToStream($host, $port)
    {
        $this->socket = socket_create(AF_INET, SOCK_STREAM, SOL_TCP);
        if (!$this->socket) {
            throw new SocketException(
                SocketException::SOCKET_UNABLE_TO_CREATE_MESSAGE . $this->getSocketErrorMessage(),
                SocketException::SOCKET_UNABLE_TO_CREATE_CODE
            );
        }
        socket_set_block($this->socket);
        socket_set_option($this->socket, SOL_SOCKET, SO_KEEPALIVE, 1);

        if (!socket_connect($this->socket, $host, $port)) {
            throw new SocketException(
                $this->getSocketErrorMessage(),
                $this->getSocketErrorCode()
            );
        }
    }

    /**
     * @return string
     */
    private function getSocketErrorMessage()
    {
        return socket_strerror($this->getSocketErrorCode());
    }

    /**
     * @return int
     */
    private function getSocketErrorCode()
    {
        return socket_last_error();
    }

    /**
     * @param int $length
     * @return string
     * @throws SocketException
     */
    public function readFromSocket($length)
    {
        $received = socket_recv($this->socket, $buf, $length, MSG_WAITALL);
        if ($length === $received) {
            return $buf;
        }

        // http://php.net/manual/pl/function.socket-recv.php#47182
        if (0 === $received) {
            throw new SocketException(
                SocketException::SOCKET_DISCONNECTED_MESSAGE,
                SocketException::SOCKET_DISCONNECTED_CODE
            );
        }

        throw new SocketException(socket_strerror($this->getSocketErrorCode()), $this->getSocketErrorCode());
    }

    /**
     * @param string $data
     * @throws SocketException
     */
    public function writeToSocket($data)
    {
        if (!socket_write($this->socket, $data, strlen($data))) {
            throw new SocketException(
                SocketException::SOCKET_UNABLE_TO_WRITE_MESSAGE . $this->getSocketErrorMessage(),
                SocketException::SOCKET_UNABLE_TO_WRITE_CODE
            );
        }
    }
}