Gecko [ unitednationsplay.com ]

Name	Size	Permission	Date
Connection.php	5.61 KB	-rw-r--r--	2018-10-01 09:00
ConnectionInterface.php	4.32 KB	-rw-r--r--	2018-10-01 09:00
Connector.php	4.2 KB	-rw-r--r--	2018-10-01 09:00
ConnectorInterface.php	2.01 KB	-rw-r--r--	2018-10-01 09:00
DnsConnector.php	4.41 KB	-rw-r--r--	2018-10-01 09:00
FixedUriConnector.php	1.02 KB	-rw-r--r--	2018-10-01 09:00
LimitingServer.php	6.39 KB	-rw-r--r--	2018-10-01 09:00
SecureConnector.php	2.98 KB	-rw-r--r--	2018-10-01 09:00
SecureServer.php	6.68 KB	-rw-r--r--	2018-10-01 09:00
Server.php	1.83 KB	-rw-r--r--	2018-10-01 09:00
ServerInterface.php	5.13 KB	-rw-r--r--	2018-10-01 09:00
StreamEncryption.php	5.4 KB	-rw-r--r--	2018-10-01 09:00
TcpConnector.php	4.25 KB	-rw-r--r--	2018-10-01 09:00
TcpServer.php	7.39 KB	-rw-r--r--	2018-10-01 09:00
TimeoutConnector.php	1.45 KB	-rw-r--r--	2018-10-01 09:00
UnixConnector.php	1.11 KB	-rw-r--r--	2018-10-01 09:00
UnixServer.php	4.11 KB	-rw-r--r--	2018-10-01 09:00

Rename

<?php

namespace React\Socket;

use React\Dns\Resolver\Resolver;
use React\Promise;
use React\Promise\CancellablePromiseInterface;
use InvalidArgumentException;
use RuntimeException;

final class DnsConnector implements ConnectorInterface
{
    private $connector;
    private $resolver;

public function __construct(ConnectorInterface $connector, Resolver $resolver)
    {
        $this->connector = $connector;
        $this->resolver = $resolver;
    }

public function connect($uri)
    {
        if (strpos($uri, '://') === false) {
            $parts = parse_url('tcp://' . $uri);
            unset($parts['scheme']);
        } else {
            $parts = parse_url($uri);
        }

if (!$parts || !isset($parts['host'])) {
            return Promise\reject(new InvalidArgumentException('Given URI "' . $uri . '" is invalid'));
        }

$host = trim($parts['host'], '[]');
        $connector = $this->connector;

// skip DNS lookup / URI manipulation if this URI already contains an IP
        if (false !== filter_var($host, FILTER_VALIDATE_IP)) {
            return $connector->connect($uri);
        }

$promise = $this->resolver->resolve($host);
        $resolved = null;

return new Promise\Promise(
            function ($resolve, $reject) use (&$promise, &$resolved, $uri, $connector, $host, $parts) {
                // resolve/reject with result of DNS lookup
                $promise->then(function ($ip) use (&$promise, &$resolved, $connector, $host, $parts) {
                    $resolved = $ip;
                    $uri = '';

// prepend original scheme if known
                    if (isset($parts['scheme'])) {
                        $uri .= $parts['scheme'] . '://';
                    }

if (strpos($ip, ':') !== false) {
                        // enclose IPv6 addresses in square brackets before appending port
                        $uri .= '[' . $ip . ']';
                    } else {
                        $uri .= $ip;
                    }

// append original port if known
                    if (isset($parts['port'])) {
                        $uri .= ':' . $parts['port'];
                    }

// append orignal path if known
                    if (isset($parts['path'])) {
                        $uri .= $parts['path'];
                    }

// append original query if known
                    if (isset($parts['query'])) {
                        $uri .= '?' . $parts['query'];
                    }

// append original hostname as query if resolved via DNS and if
                    // destination URI does not contain "hostname" query param already
                    $args = array();
                    parse_str(isset($parts['query']) ? $parts['query'] : '', $args);
                    if ($host !== $ip && !isset($args['hostname'])) {
                        $uri .= (isset($parts['query']) ? '&' : '?') . 'hostname=' . rawurlencode($host);
                    }

// append original fragment if known
                    if (isset($parts['fragment'])) {
                        $uri .= '#' . $parts['fragment'];
                    }

return $promise = $connector->connect($uri);
                }, function ($e) use ($uri, $reject) {
                    $reject(new RuntimeException('Connection to ' . $uri .' failed during DNS lookup: ' . $e->getMessage(), 0, $e));
                })->then($resolve, $reject);
            },
            function ($_, $reject) use (&$promise, &$resolved, $uri) {
                // cancellation should reject connection attempt
                // reject DNS resolution with custom reason, otherwise rely on connection cancellation below
                if ($resolved === null) {
                    $reject(new RuntimeException('Connection to ' . $uri . ' cancelled during DNS lookup'));
                }

// (try to) cancel pending DNS lookup / connection attempt
                if ($promise instanceof CancellablePromiseInterface) {
                    // overwrite callback arguments for PHP7+ only, so they do not show
                    // up in the Exception trace and do not cause a possible cyclic reference.
                    $_ = $reject = null;

$promise->cancel();
                    $promise = null;
                }
            }
        );
    }
}