diff options
Diffstat (limited to 'assets/php/vendor/cboden/ratchet/src/Ratchet/App.php')
-rwxr-xr-x | assets/php/vendor/cboden/ratchet/src/Ratchet/App.php | 145 |
1 files changed, 0 insertions, 145 deletions
diff --git a/assets/php/vendor/cboden/ratchet/src/Ratchet/App.php b/assets/php/vendor/cboden/ratchet/src/Ratchet/App.php deleted file mode 100755 index f378534..0000000 --- a/assets/php/vendor/cboden/ratchet/src/Ratchet/App.php +++ /dev/null @@ -1,145 +0,0 @@ -<?php -namespace Ratchet; -use React\EventLoop\LoopInterface; -use React\EventLoop\Factory as LoopFactory; -use React\Socket\Server as Reactor; -use React\Socket\SecureServer as SecureReactor; -use Ratchet\Http\HttpServerInterface; -use Ratchet\Http\OriginCheck; -use Ratchet\Wamp\WampServerInterface; -use Ratchet\Server\IoServer; -use Ratchet\Server\FlashPolicy; -use Ratchet\Http\HttpServer; -use Ratchet\Http\Router; -use Ratchet\WebSocket\WsServer; -use Ratchet\Wamp\WampServer; -use Symfony\Component\Routing\RouteCollection; -use Symfony\Component\Routing\Route; -use Symfony\Component\Routing\RequestContext; -use Symfony\Component\Routing\Matcher\UrlMatcher; - -/** - * An opinionated facade class to quickly and easily create a WebSocket server. - * A few configuration assumptions are made and some best-practice security conventions are applied by default. - */ -class App { - /** - * @var \Symfony\Component\Routing\RouteCollection - */ - public $routes; - - /** - * @var \Ratchet\Server\IoServer - */ - public $flashServer; - - /** - * @var \Ratchet\Server\IoServer - */ - protected $_server; - - /** - * The Host passed in construct used for same origin policy - * @var string - */ - protected $httpHost; - - /*** - * The port the socket is listening - * @var int - */ - protected $port; - - /** - * @var int - */ - protected $_routeCounter = 0; - - /** - * @param string $httpHost HTTP hostname clients intend to connect to. MUST match JS `new WebSocket('ws://$httpHost');` - * @param int $port Port to listen on. If 80, assuming production, Flash on 843 otherwise expecting Flash to be proxied through 8843 - * @param string $address IP address to bind to. Default is localhost/proxy only. '0.0.0.0' for any machine. - * @param LoopInterface $loop Specific React\EventLoop to bind the application to. null will create one for you. - */ - public function __construct($httpHost = 'localhost', $port = 8080, $address = '127.0.0.1', LoopInterface $loop = null) { - if (extension_loaded('xdebug')) { - trigger_error('XDebug extension detected. Remember to disable this if performance testing or going live!', E_USER_WARNING); - } - - if (null === $loop) { - $loop = LoopFactory::create(); - } - - $this->httpHost = $httpHost; - $this->port = $port; - - $socket = new Reactor($address . ':' . $port, $loop); - - $this->routes = new RouteCollection; - $this->_server = new IoServer(new HttpServer(new Router(new UrlMatcher($this->routes, new RequestContext))), $socket, $loop); - - $policy = new FlashPolicy; - $policy->addAllowedAccess($httpHost, 80); - $policy->addAllowedAccess($httpHost, $port); - - if (80 == $port) { - $flashUri = '0.0.0.0:843'; - } else { - $flashUri = 8843; - } - $flashSock = new Reactor($flashUri, $loop); - $this->flashServer = new IoServer($policy, $flashSock); - } - - /** - * Add an endpoint/application to the server - * @param string $path The URI the client will connect to - * @param ComponentInterface $controller Your application to server for the route. If not specified, assumed to be for a WebSocket - * @param array $allowedOrigins An array of hosts allowed to connect (same host by default), ['*'] for any - * @param string $httpHost Override the $httpHost variable provided in the __construct - * @return ComponentInterface|WsServer - */ - public function route($path, ComponentInterface $controller, array $allowedOrigins = array(), $httpHost = null) { - if ($controller instanceof HttpServerInterface || $controller instanceof WsServer) { - $decorated = $controller; - } elseif ($controller instanceof WampServerInterface) { - $decorated = new WsServer(new WampServer($controller)); - $decorated->enableKeepAlive($this->_server->loop); - } elseif ($controller instanceof MessageComponentInterface) { - $decorated = new WsServer($controller); - $decorated->enableKeepAlive($this->_server->loop); - } else { - $decorated = $controller; - } - - if ($httpHost === null) { - $httpHost = $this->httpHost; - } - - $allowedOrigins = array_values($allowedOrigins); - if (0 === count($allowedOrigins)) { - $allowedOrigins[] = $httpHost; - } - if ('*' !== $allowedOrigins[0]) { - $decorated = new OriginCheck($decorated, $allowedOrigins); - } - - //allow origins in flash policy server - if(empty($this->flashServer) === false) { - foreach($allowedOrigins as $allowedOrgin) { - $this->flashServer->app->addAllowedAccess($allowedOrgin, $this->port); - } - } - - $this->routes->add('rr-' . ++$this->_routeCounter, new Route($path, array('_controller' => $decorated), array('Origin' => $this->httpHost), array(), $httpHost, array(), array('GET'))); - - return $decorated; - } - - /** - * Run the server by entering the event loop - */ - public function run() { - $this->_server->run(); - } -} |