MySQLReplication\Socket\Socket

Complexity

Total Complexity

15

Size/Duplication

Total Lines	74
Duplicated Lines	0 %

Importance

Changes	1
Bugs	0	Features	1

8 Methods

Rating	Name	Duplication	Size	Complexity
A	getSocketErrorCode()	0	3	1
A	__destruct()	0	3	1
A	readFromSocket()	0	16	3
A	writeToSocket()	0	6	2
A	isConnected()	0	3	2
A	getSocketErrorMessage()	0	3	1
A	close()	0	7	2
A	connectToStream()	0	14	3

<?php
declare(strict_types=1);

namespace MySQLReplication\Socket;

class Socket implements SocketInterface
{
    private $socket;

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

    public function close(): void
    {
        if ($this->isConnected()) {
            socket_shutdown($this->socket);
            socket_close($this->socket);
        }
        $this->socket = null;
    }

    public function isConnected(): bool
    {
        return is_resource($this->socket) || $this->socket instanceof \Socket;
    }

    public function connectToStream(string $host, int $port): void
    {
        $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());
        }
    }

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

    private function getSocketErrorCode(): int
    {
        return socket_last_error();
    }

    public function readFromSocket(int $length): string
    {
        $received = socket_recv($this->socket, $buf, $length, MSG_WAITALL);
        if ($length === $received) {
            return $buf;
        }

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

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

    public function writeToSocket(string $data): void
    {
        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
            );
        }
    }
}