D3strukt0r\VotifierClient\ServerConnection

Complexity

Total Complexity

10

Size/Duplication

Total Lines	79
Duplicated Lines	0 %

Test Coverage

Coverage

0%

Importance

Changes	3
Bugs	0	Features	0

4 Methods

Rating	Name	Duplication	Size	Complexity
A	__construct()	0	8	2
A	__destruct()	0	4	2
A	send()	0	13	3
A	receive()	0	11	3

<?php

/**
 * Votifier PHP Client
 *
 * @package   VotifierClient
 * @author    Manuele Vaccari <manuele.vaccari@gmail.com>
 * @copyright Copyright (c) 2017-2020 Manuele Vaccari <manuele.vaccari@gmail.com>
 * @license   https://github.com/D3strukt0r/votifier-client-php/blob/master/LICENSE.txt GNU General Public License v3.0
 * @link      https://github.com/D3strukt0r/votifier-client-php
 */

namespace D3strukt0r\VotifierClient;

use D3strukt0r\VotifierClient\ServerType\ServerTypeInterface;
use Exception;

/**
 * The class ServerConnection is used to create a connection to a server.
 */
class ServerConnection
{
    /**
     * @var ServerTypeInterface the server type information package
     */
    private $serverType;

    /**
     * @var resource the connection to the server
     */
    private $s;

    /**
     * Creates the ServerConnection object.
     *
     * @param ServerTypeInterface $serverType (Required) The server type information package to connect to
     *
     * @throws Exception
     */
    public function __construct(ServerTypeInterface $serverType)
    {
        $this->serverType = $serverType;
        $s = fsockopen($serverType->getHost(), $serverType->getPort(), $errorNumber, $errorString, 3);
        if (false === $s) {
            throw new Exception($errorString, $errorNumber);
        }
        $this->s = $s;
    }

    /**
     * Closes the connection when the object is destroyed.
     */
    public function __destruct()
    {
        if ($this->s) {
            fclose($this->s);
        }
    }

    /**
     * Sends a string to the server.
     *
     * @param string $string (Required) The string which should be sent to the server
     *
     * @return bool returns true if string was sent, or false if not
     */
    public function send(string $string): bool
    {
        if (!$this->s) {
            return false;
        }

        if (false === fwrite($this->s, $string)) {
            $this->__destruct();

            return false;
        }

        return true;
    }

    /**
     * Reads a string which is being received from the server.
     *
     * @param int $length (Optional) The length of the requested string
     *
     * @return string|null returns the string that was received from the server
     */
    public function receive(int $length = 64): ?string
    {
        if (!$this->s) {
            return null;
        }

        if (!$s = fread($this->s, $length)) {
            return null;
        }

        return $s;
    }
}