Gecko [ unitednationsplay.com ]

Name	Size	Permission	Date
CloseResponseTrait.php	659 B	-rw-r--r--	2017-12-12 09:00
HttpRequestParser.php	1.78 KB	-rw-r--r--	2017-12-12 09:00
HttpServer.php	1.9 KB	-rw-r--r--	2017-12-12 09:00
HttpServerInterface.php	581 B	-rw-r--r--	2017-12-12 09:00
NoOpHttpServerController.php	480 B	-rw-r--r--	2017-12-12 09:00
OriginCheck.php	1.83 KB	-rw-r--r--	2017-12-12 09:00
Router.php	2.97 KB	-rw-r--r--	2017-12-12 09:00

Rename

<?php
namespace Ratchet\Http;
use Ratchet\ConnectionInterface;
use Ratchet\MessageComponentInterface;
use Psr\Http\Message\RequestInterface;

/**
 * A middleware to ensure JavaScript clients connecting are from the expected domain.
 * This protects other websites from open WebSocket connections to your application.
 * Note: This can be spoofed from non-web browser clients
 */
class OriginCheck implements HttpServerInterface {
    use CloseResponseTrait;

/**
     * @var \Ratchet\MessageComponentInterface
     */
    protected $_component;

public $allowedOrigins = [];

/**
     * @param MessageComponentInterface $component Component/Application to decorate
     * @param array                     $allowed   An array of allowed domains that are allowed to connect from
     */
    public function __construct(MessageComponentInterface $component, array $allowed = []) {
        $this->_component = $component;
        $this->allowedOrigins += $allowed;
    }

/**
     * {@inheritdoc}
     */
    public function onOpen(ConnectionInterface $conn, RequestInterface $request = null) {
        $header = (string)$request->getHeader('Origin')[0];
        $origin = parse_url($header, PHP_URL_HOST) ?: $header;

if (!in_array($origin, $this->allowedOrigins)) {
            return $this->close($conn, 403);
        }

return $this->_component->onOpen($conn, $request);
    }

/**
     * {@inheritdoc}
     */
    function onMessage(ConnectionInterface $from, $msg) {
        return $this->_component->onMessage($from, $msg);
    }

/**
     * {@inheritdoc}
     */
    function onClose(ConnectionInterface $conn) {
        return $this->_component->onClose($conn);
    }

/**
     * {@inheritdoc}
     */
    function onError(ConnectionInterface $conn, \Exception $e) {
        return $this->_component->onError($conn, $e);
    }
}