[Http] Refactor header parsing from WS to HTTP

This commit is contained in:
Chris Boden 2013-04-14 18:34:28 -04:00
parent 7b2b6897e5
commit 423b5cc355
4 changed files with 11 additions and 18 deletions

View File

@ -1,5 +1,5 @@
<?php <?php
namespace Ratchet\WebSocket\Guzzle\Http\Message; namespace Ratchet\Http\Guzzle\Http\Message;
use Guzzle\Http\Message\RequestFactory as GuzzleRequestFactory; use Guzzle\Http\Message\RequestFactory as GuzzleRequestFactory;
use Guzzle\Http\EntityBody; use Guzzle\Http\EntityBody;

View File

@ -1,8 +1,8 @@
<?php <?php
namespace Ratchet\WebSocket; namespace Ratchet\Http;
use Ratchet\MessageInterface; use Ratchet\MessageInterface;
use Ratchet\ConnectionInterface; use Ratchet\ConnectionInterface;
use Ratchet\WebSocket\Guzzle\Http\Message\RequestFactory; use Ratchet\Http\Guzzle\Http\Message\RequestFactory;
/** /**
* This class receives streaming data from a client request * This class receives streaming data from a client request

View File

@ -3,9 +3,6 @@ namespace Ratchet\Http;
use Ratchet\MessageComponentInterface; use Ratchet\MessageComponentInterface;
use Ratchet\ConnectionInterface; use Ratchet\ConnectionInterface;
// @todo This class will move to this namespace
use Ratchet\WebSocket\HttpRequestParser;
use Symfony\Component\Routing\RouteCollection; use Symfony\Component\Routing\RouteCollection;
class HttpServer implements MessageComponentInterface { class HttpServer implements MessageComponentInterface {
@ -15,6 +12,11 @@ class HttpServer implements MessageComponentInterface {
*/ */
protected $_decorating; protected $_decorating;
/**
* Buffers incoming HTTP requests returning a Guzzle Request when coalesced
* @var HttpRequestParser
* @note May not expose this in the future, may do through facade methods
*/
protected $_reqParser; protected $_reqParser;
/** /**

View File

@ -2,12 +2,11 @@
namespace Ratchet\WebSocket; namespace Ratchet\WebSocket;
use Ratchet\MessageComponentInterface; use Ratchet\MessageComponentInterface;
use Ratchet\ConnectionInterface; use Ratchet\ConnectionInterface;
use Ratchet\Http\HttpServerInterface;
use Guzzle\Http\Message\RequestInterface;
use Guzzle\Http\Message\Response;
use Ratchet\WebSocket\Version; use Ratchet\WebSocket\Version;
use Ratchet\WebSocket\Encoding\ToggleableValidator; use Ratchet\WebSocket\Encoding\ToggleableValidator;
use Guzzle\Http\Message\Response;
use Guzzle\Http\Message\RequestInterface;
use Ratchet\Http\HttpServerInterface;
/** /**
* The adapter to handle WebSocket requests/responses * The adapter to handle WebSocket requests/responses
@ -16,13 +15,6 @@ use Ratchet\Http\HttpServerInterface;
* @link http://dev.w3.org/html5/websockets/ * @link http://dev.w3.org/html5/websockets/
*/ */
class WsServer implements HttpServerInterface { class WsServer implements HttpServerInterface {
/**
* Buffers incoming HTTP requests returning a Guzzle Request when coalesced
* @var HttpRequestParser
* @note May not expose this in the future, may do through facade methods
*/
public $reqParser;
/** /**
* Manage the various WebSocket versions to support * Manage the various WebSocket versions to support
* @var VersionManager * @var VersionManager
@ -65,7 +57,6 @@ class WsServer implements HttpServerInterface {
* If you want to enable sub-protocols have your component implement WsServerInterface as well * If you want to enable sub-protocols have your component implement WsServerInterface as well
*/ */
public function __construct(MessageComponentInterface $component) { public function __construct(MessageComponentInterface $component) {
$this->reqParser = new HttpRequestParser;
$this->versioner = new VersionManager; $this->versioner = new VersionManager;
$this->validator = new ToggleableValidator; $this->validator = new ToggleableValidator;