Thruster\Component\SocketClient\StreamEncryption

Complexity

Total Complexity

14

Size/Duplication

Total Lines	120
Duplicated Lines	0 %

Coupling/Cohesion

Components	1
Dependencies	5

Test Coverage

Coverage

73.91%

Importance

Changes	1
Bugs	0	Features	0

6 Methods

Rating	Name	Duplication	Size	Complexity
A	__construct()	0	17	4
A	enable()	0	4	1
A	disable()	0	4	1
B	toggle()	0	36	4
A	toggleCrypto()	0	21	3
A	handleError()	0	5	1

<?php

namespace Thruster\Component\SocketClient;

use Thruster\Component\EventLoop\EventLoopInterface;
use Thruster\Component\Promise\Deferred;
use Thruster\Component\Stream\Stream;
use UnexpectedValueException;

/**
 * Class StreamEncryption
 *
 * @package Thruster\Component\SocketClient
 * @author  Aurimas Niekis <aurimas@niekis.lt>
 */
class StreamEncryption
{
    /**
     * @var EventLoopInterface
     */
    private $loop;

    /**
     * @var int
     */
    private $method;

    /**
     * @var string
     */
    private $errStr;

    /**
     * @var int
     */
    private $errno;

    /**
     * @var bool
     */
    private $wrapSecure;

    public function __construct(EventLoopInterface $loop)
    {
        $this->method     = STREAM_CRYPTO_METHOD_TLS_CLIENT;
        $this->wrapSecure = false;

        $this->loop = $loop;

        if (defined('STREAM_CRYPTO_METHOD_TLSv1_0_CLIENT')) {
            $this->method |= STREAM_CRYPTO_METHOD_TLSv1_0_CLIENT;
        }
        if (defined('STREAM_CRYPTO_METHOD_TLSv1_1_CLIENT')) {
            $this->method |= STREAM_CRYPTO_METHOD_TLSv1_1_CLIENT;
        }
        if (defined('STREAM_CRYPTO_METHOD_TLSv1_2_CLIENT')) {
            $this->method |= STREAM_CRYPTO_METHOD_TLSv1_2_CLIENT;
        }
    }

    public function enable(Stream $stream)
    {
        return $this->toggle($stream, true);
    }

    public function disable(Stream $stream)
    {
        return $this->toggle($stream, false);
    }

    public function toggle(Stream $stream, $toggle)
    {
        if ($stream instanceof SecureStream) {
            $stream = $stream->getDecorating();
        }

        // pause actual stream instance to continue operation on raw stream socket
        $stream->pause();

        // TODO: add write() event to make sure we're not sending any excessive data

        $deferred = new Deferred();

        // get actual stream socket from stream instance
        $socket = $stream->getStream();

        $toggleCrypto = function () use ($socket, $deferred, $toggle) {
            $this->toggleCrypto($socket, $deferred, $toggle);
        };

        $this->loop->addReadStream($socket, $toggleCrypto);
        $toggleCrypto();

        return $deferred->promise()->then(function () use ($stream, $toggle) {
            if ($toggle && $this->wrapSecure) {
                return new SecureStream($stream, $this->loop);
            }

            $stream->resume();

            return $stream;
        }, function ($error) use ($stream) {
            $stream->resume();
            throw $error;
        });
    }

    public function toggleCrypto($socket, Deferred $deferred, $toggle)
    {
        //set_error_handler([$this, 'handleError']);

80% of this comment could be valid code. Did you maybe forget this after debugging?

        $result = stream_socket_enable_crypto($socket, $toggle, $this->method);
        //restore_error_handler();

        if (true === $result) {
            $this->loop->removeReadStream($socket);

            $deferred->resolve();
        } elseif (false === $result) {
            $this->loop->removeReadStream($socket);

            $deferred->reject(new UnexpectedValueException(
                sprintf('Unable to complete SSL/TLS handshake: %s', $this->errStr),
                $this->errno
            ));
        } else {

This else statement is empty and can be removed.

            // need more data, will retry
        }
    }

    public function handleError($errNo, $errStr)
    {
        $this->errstr = str_replace(["\r", "\n"], ' ', $errStr);

The property errstr does not seem to exist. Did you mean errStr?

        $this->errno  = $errNo;
    }
}