1#@!#!123s

: / opt / psa / admin / plib / vendor / ratchet / rfc6455 / src / Handshake /
Filename : ClientNegotiator.php
back
<?php
namespace Ratchet\RFC6455\Handshake;
use Psr\Http\Message\RequestInterface;
use Psr\Http\Message\ResponseInterface;
use Psr\Http\Message\UriInterface;
use Psr\Http\Message\RequestFactoryInterface;

class ClientNegotiator {
    private ResponseVerifier $verifier;

    private RequestInterface $defaultHeader;

    private RequestFactoryInterface $requestFactory;

    public function __construct(
        RequestFactoryInterface $requestFactory,
        ?PermessageDeflateOptions $perMessageDeflateOptions = null
    ) {
        $this->verifier = new ResponseVerifier;
        $this->requestFactory = $requestFactory;

        $this->defaultHeader = $this->requestFactory
            ->createRequest('GET', '')
            ->withHeader('Connection'           , 'Upgrade')
            ->withHeader('Upgrade'              , 'websocket')
            ->withHeader('Sec-WebSocket-Version', $this->getVersion())
            ->withHeader('User-Agent'           , 'Ratchet');

        $perMessageDeflateOptions ??= PermessageDeflateOptions::createDisabled();

        // https://bugs.php.net/bug.php?id=73373
        // https://bugs.php.net/bug.php?id=74240 - need >=7.1.4 or >=7.0.18
        if ($perMessageDeflateOptions->isEnabled() && !PermessageDeflateOptions::permessageDeflateSupported()) {
            trigger_error('permessage-deflate is being disabled because it is not supported by your PHP version.', E_USER_NOTICE);
            $perMessageDeflateOptions = PermessageDeflateOptions::createDisabled();
        }
        if ($perMessageDeflateOptions->isEnabled() && !function_exists('deflate_add')) {
            trigger_error('permessage-deflate is being disabled because you do not have the zlib extension.', E_USER_NOTICE);
            $perMessageDeflateOptions = PermessageDeflateOptions::createDisabled();
        }

        $this->defaultHeader = $perMessageDeflateOptions->addHeaderToRequest($this->defaultHeader);
    }

    public function generateRequest(UriInterface $uri): RequestInterface {
        return $this->defaultHeader->withUri($uri)
            ->withHeader('Sec-WebSocket-Key', $this->generateKey());
    }

    public function validateResponse(RequestInterface $request, ResponseInterface $response): bool {
        return $this->verifier->verifyAll($request, $response);
    }

    public function generateKey(): string {
        $chars     = 'ABCDEFGHIJKLMNOPQRSTUVWXYZabcdefghijklmnopqrstuvwzyz1234567890+/=';
        $charRange = strlen($chars) - 1;
        $key       = '';
        for ($i = 0; $i < 16; $i++) {
            $key .= $chars[mt_rand(0, $charRange)];
        }

        return base64_encode($key);
    }

    public function getVersion(): int {
        return 13;
    }
}