faeez/mxmbsocket
1
0
Fork 0
Code Issues Pull Requests Actions 1 Packages Repo. Project Releases Wiki Activity

Inject RequestVerifier into ServerNegotiator

Browse Source
This commit is contained in:
Chris Boden 2016-02-15 17:19:29 -05:00
parent c15e275584
commit cc031e164b
1 changed files with 9 additions and 6 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

15
src/Ratchet/WebSocket/WsServer.php
View File

@ -5,12 +5,15 @@ use Ratchet\ConnectionInterface;
use Ratchet\Http\HttpServerInterface; use Ratchet\Http\HttpServerInterface;
use Ratchet\Http\CloseResponseTrait; use Ratchet\Http\CloseResponseTrait;
use Psr\Http\Message\RequestInterface; use Psr\Http\Message\RequestInterface;
use GuzzleHttp\Psr7 as gPsr;
use Ratchet\RFC6455\Messaging\FrameInterface;
use Ratchet\RFC6455\Messaging\MessageInterface; use Ratchet\RFC6455\Messaging\MessageInterface;
use Ratchet\RFC6455\Messaging\MessageBuffer; use Ratchet\RFC6455\Messaging\FrameInterface;
use React\EventLoop\LoopInterface;
use Ratchet\RFC6455\Messaging\Frame; use Ratchet\RFC6455\Messaging\Frame;
use Ratchet\RFC6455\Messaging\MessageBuffer;
use Ratchet\RFC6455\Messaging\CloseFrameChecker;
use Ratchet\RFC6455\Handshake\ServerNegotiator;
use Ratchet\RFC6455\Handshake\RequestVerifier;
use React\EventLoop\LoopInterface;
use GuzzleHttp\Psr7 as gPsr;
/** /**
* The adapter to handle WebSocket requests/responses * The adapter to handle WebSocket requests/responses
@ -60,8 +63,8 @@ class WsServer implements HttpServerInterface {
$this->delegate = $component; $this->delegate = $component;
$this->connections = new \SplObjectStorage; $this->connections = new \SplObjectStorage;
$this->closeFrameChecker = new \Ratchet\RFC6455\Messaging\CloseFrameChecker; $this->closeFrameChecker = new CloseFrameChecker;
$this->handshakeNegotiator = new \Ratchet\RFC6455\Handshake\ServerNegotiator; $this->handshakeNegotiator = new ServerNegotiator(new RequestVerifier);
if ($component instanceof WsServerInterface) { if ($component instanceof WsServerInterface) {
$this->handshakeNegotiator->setSupportedSubProtocols($component->getSubProtocols()); $this->handshakeNegotiator->setSupportedSubProtocols($component->getSubProtocols());