Thruster\Component\Socket\Connection

Complexity

Total Complexity

11

Size/Duplication

Total Lines	37
Duplicated Lines	0 %

Coupling/Cohesion

Components	2
Dependencies	1

Test Coverage

Coverage

100%

4 Methods

Rating	Name	Duplication	Size	Complexity
A	getRemoteAddress()	0	4	1
A	parseAddress()	0	4	1
B	handleData()	0	11	7
A	handleClose()	0	9	2

<?php

namespace Thruster\Component\Socket;

use Thruster\Component\Stream\Stream;

/**
 * Class Connection
 *
 * @package Thruster\Component\Socket
 * @author  Aurimas Niekis <aurimas@niekis.lt>
 */
class Connection extends Stream implements ConnectionInterface
{
    /**
     * @param resource $stream
     */
    public function handleData($stream)
    {
        $data = stream_socket_recvfrom($stream, $this->bufferSize);
        if ('' !== $data && false !== $data) {
            $this->emit('data', array($data, $this));
        }

        if ('' === $data || false === $data || !is_resource($stream) || feof($stream)) {
            $this->end();
        }
    }

    public function handleClose()
    {
        if (is_resource($this->stream)) {
            stream_socket_shutdown($this->stream, STREAM_SHUT_RDWR);
            stream_set_blocking($this->stream, false);

            fclose($this->stream);
        }
    }

    public function getRemoteAddress() : string
    {
        return $this->parseAddress(stream_socket_get_name($this->stream, true));
    }

    public function parseAddress(string $address) : string
    {
        return trim(substr($address, 0, strrpos($address, ':')), '[]');
    }
}