AsyncSockets\Socket\ServerSocket

Complexity

Total Complexity

14

Size/Duplication

Total Lines	90
Duplicated Lines	0 %

Coupling/Cohesion

Components	0
Dependencies	4

Test Coverage

Coverage

92.31%

Importance

Changes

0

6 Methods

Rating	Name	Duplication	Size	Complexity
A	getSocketScheme()	0	9	2
A	createSocketResource()	0	17	3
B	createIoInterface()	0	15	5
A	getServerFlagsByType()	0	11	2
A	isServer()	0	4	1
A	isClient()	0	4	1

<?php
/**
 * Async sockets
 *
 * @copyright Copyright (c) 2015-2017, Efimov Evgenij <edefimov.it@gmail.com>
 *
 * This source file is subject to the MIT license that is bundled
 * with this source code in the file LICENSE.
 */
namespace AsyncSockets\Socket;

use AsyncSockets\Exception\ConnectionException;
use AsyncSockets\Socket\Io\DatagramServerIo;
use AsyncSockets\Socket\Io\StreamedServerIo;

/**
 * Class ServerSocket
 */
class ServerSocket extends AbstractSocket
{
    /** {@inheritdoc} */
    protected function createSocketResource($address, $context)
    {
        $type     = $this->getSocketScheme($address);
        $resource = stream_socket_server(
            $address,
            $errno,
            $errstr,
            $this->getServerFlagsByType($type),
            $context
        );

        if ($errno || $resource === false) {
            throw new ConnectionException($this, $errstr, $errno);
        }

        return $resource;
    }

    /** {@inheritdoc} */
    protected function createIoInterface($type, $address)
    {
        switch ($type) {
            case self::SOCKET_TYPE_UNIX:
                return new StreamedServerIo($this);
            case self::SOCKET_TYPE_TCP:
                return new StreamedServerIo($this);
            case self::SOCKET_TYPE_UDG:
                return new DatagramServerIo($this, true);
            case self::SOCKET_TYPE_UDP:
                return new DatagramServerIo($this, false);
            default:
                throw new \LogicException("Unsupported socket resource type {$type}");
        }
    }

    /**
     * Return socket scheme
     *
     * @param string $address Address in form scheme://host:port
     *
     * @return string|null
     */
    private function getSocketScheme($address)
    {
        $pos = strpos($address, '://');
        if ($pos === false) {
            return null;
        }

        return substr($address, 0, $pos);
    }

    /**
     * Return flags for connection
     *
     * @param string $scheme Socket type being created
     *
     * @return int
     */
    private function getServerFlagsByType($scheme)
    {
        $connectionLessMap = [
            'udp' => 1,
            'udg' => 1,
        ];

        return isset($connectionLessMap[ $scheme ]) ?
            STREAM_SERVER_BIND :
            STREAM_SERVER_BIND | STREAM_SERVER_LISTEN;
    }

    /**
     * @inheritDoc
     */
    public function isServer()
    {
        return true;
    }

    /**
     * @inheritDoc
     */
    public function isClient()
    {
        return false;
    }
}