Rvdv\Nntp\Socket\Socket

Complexity

Total Complexity

14

Size/Duplication

Total Lines	99
Duplicated Lines	0 %

Coupling/Cohesion

Components	1
Dependencies	1

Test Coverage

Coverage

63.33%

Importance

Changes	1
Bugs	0	Features	0

7 Methods

Rating	Name	Duplication	Size	Complexity
A	enableCrypto()	0	8	2
A	connect()	0	20	3
A	disconnect()	0	8	2
A	eof()	0	4	1
A	gets()	0	8	2
A	read()	0	8	2
A	write()	0	8	2

<?php

/*
 * This file is part of the NNTP library.
 *
 * (c) Robin van der Vleuten <robin@webstronauts.co>
 *
 * For the full copyright and license information, please view the LICENSE
 * file that was distributed with this source code.
 */

namespace Rvdv\Nntp\Socket;

use Rvdv\Nntp\Exception\SocketException;

/**
 * @author Robin van der Vleuten <robin@webstronauts.co>
 */
class Socket implements SocketInterface
{
    /**
     * @var resource
     */
    private $stream;

    /**
     * {@inheritdoc}
     */
    public function enableCrypto($enable, $cryptoType = STREAM_CRYPTO_METHOD_TLS_CLIENT)
    {
        if (!stream_socket_enable_crypto($this->stream, $enable, $cryptoType)) {
            throw new SocketException();
        }

        return $this;
    }

    /**
     * {@inheritdoc}
     */
    public function connect($address)
    {
        if (!$this->stream = @stream_socket_client($address, $errno, $errstr, 1.0, STREAM_CLIENT_CONNECT)) {
            throw new SocketException(sprintf('Connection to %s failed: %s', $address, $errstr));
        }

        stream_set_blocking($this->stream, 1);

        // Use unbuffered read operations on the underlying stream resource.
        // Reading chunks from the stream may otherwise leave unread bytes in
        // PHP's stream buffers which some event loop implementations do not
        // trigger events on (edge triggered).
        // This does not affect the default event loop implementation (level
        // triggered), so we can ignore platforms not supporting this (HHVM).
        if (function_exists('stream_set_read_buffer')) {
            stream_set_read_buffer($this->stream, 0);
        }

        return $this;
    }

    /**
     * {@inheritdoc}
     */
    public function disconnect()
    {
        if (!fclose($this->stream)) {
            throw new SocketException();
        }

        return $this;
    }

    /**
     * {@inheritdoc}
     */
    public function eof()
    {
        return feof($this->stream);
    }

    /**
     * {@inheritdoc}
     */
    public function gets($length = null)
    {
        if (false === ($data = fgets($this->stream, $length))) {
            throw new SocketException();
        }

        return $data;
    }

    /**
     * {@inheritdoc}
     */
    public function read($length)
    {
        if (false === ($data = fread($this->stream, $length))) {
            throw new SocketException();
        }

        return $data;
    }

    /**
     * {@inheritdoc}
     */
    public function write($data)
    {
        if (false === ($bytes = fwrite($this->stream, $data))) {
            throw new SocketException();
        }

        return $bytes;
    }
}