aboutsummaryrefslogtreecommitdiffhomepage
path: root/assets/php/vendor/cboden/ratchet/src/Ratchet/App.php
diff options
context:
space:
mode:
Diffstat (limited to 'assets/php/vendor/cboden/ratchet/src/Ratchet/App.php')
-rwxr-xr-xassets/php/vendor/cboden/ratchet/src/Ratchet/App.php145
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();
- }
-}