Spiral\Goridge\Relay::create()

Complexity

Conditions	8
Paths	6

Size

Total Lines

29

Duplication

Lines	0
Ratio	0 %

Importance

Changes

0

<?php
    public static function create(string $connection): RelayInterface
    {
        if (!preg_match(self::CONNECTION, strtolower($connection), $match)) {
            throw new Exceptions\RelayFactoryException('unsupported connection format');
        }

        switch ($match['protocol']) {
            case self::TCP_SOCKET:
                //fall through
            case self::UNIX_SOCKET:
                return new SocketRelay(
                    $match['arg1'],
                    isset($match['arg2']) ? (int)$match['arg2'] : null,
                    $match['protocol'] === self::TCP_SOCKET ? SocketRelay::SOCK_TCP : SocketRelay::SOCK_UNIX
                );

            case self::STREAM:
                if (!isset($match['arg2'])) {
                    throw new Exceptions\RelayFactoryException('unsupported stream connection format');
                }

                return new StreamRelay(
                    fopen("php://{$match['arg1']}", 'rb'),
                    fopen("php://{$match['arg2']}", 'wb')
                );
            default:
                throw new Exceptions\RelayFactoryException('unknown connection protocol');
        }
    }
}