major update
Some checks are pending
CI / PHPUnit (highest, 5.4) (push) Waiting to run
CI / PHPUnit (highest, 5.5) (push) Waiting to run
CI / PHPUnit (highest, 5.6) (push) Waiting to run
CI / PHPUnit (highest, 7.0) (push) Waiting to run
CI / PHPUnit (highest, 7.1) (push) Waiting to run
CI / PHPUnit (highest, 7.2) (push) Waiting to run
CI / PHPUnit (highest, 7.3) (push) Waiting to run
CI / PHPUnit (highest, 7.4) (push) Waiting to run
CI / PHPUnit (lowest, 5.4) (push) Waiting to run
Some checks are pending
CI / PHPUnit (highest, 5.4) (push) Waiting to run
CI / PHPUnit (highest, 5.5) (push) Waiting to run
CI / PHPUnit (highest, 5.6) (push) Waiting to run
CI / PHPUnit (highest, 7.0) (push) Waiting to run
CI / PHPUnit (highest, 7.1) (push) Waiting to run
CI / PHPUnit (highest, 7.2) (push) Waiting to run
CI / PHPUnit (highest, 7.3) (push) Waiting to run
CI / PHPUnit (highest, 7.4) (push) Waiting to run
CI / PHPUnit (lowest, 5.4) (push) Waiting to run
This commit is contained in:
parent
11a39c8e46
commit
50725bbf4c
@ -33,8 +33,8 @@ Need help? Have a question? Want to provide feedback? Write a message on the
|
|||||||
|
|
||||||
```php
|
```php
|
||||||
<?php
|
<?php
|
||||||
use Ratchet\MessageComponentInterface;
|
use mfmdevsystem\socket\MessageComponentInterface;
|
||||||
use Ratchet\ConnectionInterface;
|
use mfmdevsystem\socket\ConnectionInterface;
|
||||||
|
|
||||||
// Make sure composer dependencies have been installed
|
// Make sure composer dependencies have been installed
|
||||||
require __DIR__ . '/vendor/autoload.php';
|
require __DIR__ . '/vendor/autoload.php';
|
||||||
|
@ -27,12 +27,12 @@
|
|||||||
}
|
}
|
||||||
, "autoload": {
|
, "autoload": {
|
||||||
"psr-4": {
|
"psr-4": {
|
||||||
"Ratchet\\": "src/Ratchet"
|
"mfmdevsystem\\socket\\": "src/Socket"
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
, "require": {
|
, "require": {
|
||||||
"php": ">=8.4.0"
|
"php": ">=8.4.0"
|
||||||
, "ratchet/rfc6455": "^0.3.1"
|
, "mfmdevsystem/rfc6455": "dev-master"
|
||||||
, "react/socket": "^1.0 || ^0.8 || ^0.7 || ^0.6 || ^0.5"
|
, "react/socket": "^1.0 || ^0.8 || ^0.7 || ^0.6 || ^0.5"
|
||||||
, "react/event-loop": ">=0.4"
|
, "react/event-loop": ">=0.4"
|
||||||
, "guzzlehttp/psr7": "^1.7|^2.0"
|
, "guzzlehttp/psr7": "^1.7|^2.0"
|
||||||
|
@ -1,8 +0,0 @@
|
|||||||
<?php
|
|
||||||
namespace Ratchet\WebSocket;
|
|
||||||
use Ratchet\ConnectionInterface;
|
|
||||||
use Ratchet\RFC6455\Messaging\MessageInterface;
|
|
||||||
|
|
||||||
interface MessageCallableInterface {
|
|
||||||
public function onMessage(ConnectionInterface $conn, MessageInterface $msg);
|
|
||||||
}
|
|
@ -4,16 +4,16 @@ use React\EventLoop\LoopInterface;
|
|||||||
use React\EventLoop\Factory as LoopFactory;
|
use React\EventLoop\Factory as LoopFactory;
|
||||||
use React\Socket\Server as Reactor;
|
use React\Socket\Server as Reactor;
|
||||||
use React\Socket\SecureServer as SecureReactor;
|
use React\Socket\SecureServer as SecureReactor;
|
||||||
use Ratchet\Http\HttpServerInterface;
|
use mfmdevsystem\socket\Http\HttpServerInterface;
|
||||||
use Ratchet\Http\OriginCheck;
|
use mfmdevsystem\socket\Http\OriginCheck;
|
||||||
use Ratchet\Wamp\WampServerInterface;
|
use mfmdevsystem\socket\Wamp\WampServerInterface;
|
||||||
use Ratchet\Server\IoServer;
|
use mfmdevsystem\socket\Server\IoServer;
|
||||||
use Ratchet\Server\FlashPolicy;
|
use mfmdevsystem\socket\Server\FlashPolicy;
|
||||||
use Ratchet\Http\HttpServer;
|
use mfmdevsystem\socket\Http\HttpServer;
|
||||||
use Ratchet\Http\Router;
|
use mfmdevsystem\socket\Http\Router;
|
||||||
use Ratchet\WebSocket\MessageComponentInterface as WsMessageComponentInterface;
|
use mfmdevsystem\socket\WebSocket\MessageComponentInterface as WsMessageComponentInterface;
|
||||||
use Ratchet\WebSocket\WsServer;
|
use mfmdevsystem\socket\WebSocket\WsServer;
|
||||||
use Ratchet\Wamp\WampServer;
|
use mfmdevsystem\socket\Wamp\WampServer;
|
||||||
use Symfony\Component\Routing\RouteCollection;
|
use Symfony\Component\Routing\RouteCollection;
|
||||||
use Symfony\Component\Routing\Route;
|
use Symfony\Component\Routing\Route;
|
||||||
use Symfony\Component\Routing\RequestContext;
|
use Symfony\Component\Routing\RequestContext;
|
@ -1,6 +1,6 @@
|
|||||||
<?php
|
<?php
|
||||||
namespace Ratchet\Http;
|
namespace mfmdevsystem\socket\Http;
|
||||||
use Ratchet\ConnectionInterface;
|
use mfmdevsystem\socket\ConnectionInterface;
|
||||||
use GuzzleHttp\Psr7\Message;
|
use GuzzleHttp\Psr7\Message;
|
||||||
use GuzzleHttp\Psr7\Response;
|
use GuzzleHttp\Psr7\Response;
|
||||||
|
|
@ -1,7 +1,7 @@
|
|||||||
<?php
|
<?php
|
||||||
namespace Ratchet\Http;
|
namespace mfmdevsystem\socket\Http;
|
||||||
use Ratchet\MessageInterface;
|
use mfmdevsystem\socket\MessageInterface;
|
||||||
use Ratchet\ConnectionInterface;
|
use mfmdevsystem\socket\ConnectionInterface;
|
||||||
use GuzzleHttp\Psr7\Message;
|
use GuzzleHttp\Psr7\Message;
|
||||||
|
|
||||||
/**
|
/**
|
@ -1,7 +1,7 @@
|
|||||||
<?php
|
<?php
|
||||||
namespace Ratchet\Http;
|
namespace mfmdevsystem\socket\Http;
|
||||||
use Ratchet\MessageComponentInterface;
|
use mfmdevsystem\socket\MessageComponentInterface;
|
||||||
use Ratchet\ConnectionInterface;
|
use mfmdevsystem\socket\ConnectionInterface;
|
||||||
|
|
||||||
class HttpServer implements MessageComponentInterface {
|
class HttpServer implements MessageComponentInterface {
|
||||||
use CloseResponseTrait;
|
use CloseResponseTrait;
|
@ -1,7 +1,7 @@
|
|||||||
<?php
|
<?php
|
||||||
namespace Ratchet\Http;
|
namespace mfmdevsystem\socket\Http;
|
||||||
use Ratchet\MessageComponentInterface;
|
use mfmdevsystem\socket\MessageComponentInterface;
|
||||||
use Ratchet\ConnectionInterface;
|
use mfmdevsystem\socket\ConnectionInterface;
|
||||||
use Psr\Http\Message\RequestInterface;
|
use Psr\Http\Message\RequestInterface;
|
||||||
|
|
||||||
interface HttpServerInterface extends MessageComponentInterface {
|
interface HttpServerInterface extends MessageComponentInterface {
|
@ -1,6 +1,6 @@
|
|||||||
<?php
|
<?php
|
||||||
namespace Ratchet\Http;
|
namespace mfmdevsystem\socket\Http;
|
||||||
use Ratchet\ConnectionInterface;
|
use mfmdevsystem\socket\ConnectionInterface;
|
||||||
use Psr\Http\Message\RequestInterface;
|
use Psr\Http\Message\RequestInterface;
|
||||||
|
|
||||||
class NoOpHttpServerController implements HttpServerInterface {
|
class NoOpHttpServerController implements HttpServerInterface {
|
@ -1,7 +1,7 @@
|
|||||||
<?php
|
<?php
|
||||||
namespace Ratchet\Http;
|
namespace mfmdevsystem\socket\Http;
|
||||||
use Ratchet\ConnectionInterface;
|
use mfmdevsystem\socket\ConnectionInterface;
|
||||||
use Ratchet\MessageComponentInterface;
|
use mfmdevsystem\socket\MessageComponentInterface;
|
||||||
use Psr\Http\Message\RequestInterface;
|
use Psr\Http\Message\RequestInterface;
|
||||||
|
|
||||||
/**
|
/**
|
@ -1,6 +1,6 @@
|
|||||||
<?php
|
<?php
|
||||||
namespace Ratchet\Http;
|
namespace mfmdevsystem\socket\Http;
|
||||||
use Ratchet\ConnectionInterface;
|
use mfmdevsystem\socket\ConnectionInterface;
|
||||||
use Psr\Http\Message\RequestInterface;
|
use Psr\Http\Message\RequestInterface;
|
||||||
use Symfony\Component\Routing\Matcher\UrlMatcherInterface;
|
use Symfony\Component\Routing\Matcher\UrlMatcherInterface;
|
||||||
use Symfony\Component\Routing\Exception\MethodNotAllowedException;
|
use Symfony\Component\Routing\Exception\MethodNotAllowedException;
|
@ -1,7 +1,7 @@
|
|||||||
<?php
|
<?php
|
||||||
namespace Ratchet\Server;
|
namespace mfmdevsystem\socket\Server;
|
||||||
use Ratchet\MessageComponentInterface;
|
use mfmdevsystem\socket\MessageComponentInterface;
|
||||||
use Ratchet\ConnectionInterface;
|
use mfmdevsystem\socket\ConnectionInterface;
|
||||||
|
|
||||||
/**
|
/**
|
||||||
* A simple Ratchet application that will reply to all messages with the message it received
|
* A simple Ratchet application that will reply to all messages with the message it received
|
@ -1,7 +1,7 @@
|
|||||||
<?php
|
<?php
|
||||||
namespace Ratchet\Server;
|
namespace mfmdevsystem\socket\Server;
|
||||||
use Ratchet\MessageComponentInterface;
|
use mfmdevsystem\socket\MessageComponentInterface;
|
||||||
use Ratchet\ConnectionInterface;
|
use mfmdevsystem\socket\ConnectionInterface;
|
||||||
|
|
||||||
/**
|
/**
|
||||||
* An app to go on a server stack to pass a policy file to a Flash socket
|
* An app to go on a server stack to pass a policy file to a Flash socket
|
@ -1,6 +1,6 @@
|
|||||||
<?php
|
<?php
|
||||||
namespace Ratchet\Server;
|
namespace mfmdevsystem\socket\Server;
|
||||||
use Ratchet\ConnectionInterface;
|
use mfmdevsystem\socket\ConnectionInterface;
|
||||||
use React\Socket\ConnectionInterface as ReactConn;
|
use React\Socket\ConnectionInterface as ReactConn;
|
||||||
|
|
||||||
/**
|
/**
|
@ -1,6 +1,6 @@
|
|||||||
<?php
|
<?php
|
||||||
namespace Ratchet\Server;
|
namespace mfmdevsystem\socket\Server;
|
||||||
use Ratchet\MessageComponentInterface;
|
use mfmdevsystem\socket\MessageComponentInterface;
|
||||||
use React\EventLoop\LoopInterface;
|
use React\EventLoop\LoopInterface;
|
||||||
use React\Socket\ServerInterface;
|
use React\Socket\ServerInterface;
|
||||||
use React\EventLoop\Factory as LoopFactory;
|
use React\EventLoop\Factory as LoopFactory;
|
@ -1,7 +1,7 @@
|
|||||||
<?php
|
<?php
|
||||||
namespace Ratchet\Server;
|
namespace mfmdevsystem\socket\Server;
|
||||||
use Ratchet\MessageComponentInterface;
|
use mfmdevsystem\socket\MessageComponentInterface;
|
||||||
use Ratchet\ConnectionInterface;
|
use mfmdevsystem\socket\ConnectionInterface;
|
||||||
|
|
||||||
class IpBlackList implements MessageComponentInterface {
|
class IpBlackList implements MessageComponentInterface {
|
||||||
/**
|
/**
|
@ -1,5 +1,5 @@
|
|||||||
<?php
|
<?php
|
||||||
namespace Ratchet\Session\Serialize;
|
namespace mfmdevsystem\socket\Session\Serialize;
|
||||||
|
|
||||||
interface HandlerInterface {
|
interface HandlerInterface {
|
||||||
/**
|
/**
|
@ -1,5 +1,5 @@
|
|||||||
<?php
|
<?php
|
||||||
namespace Ratchet\Session\Serialize;
|
namespace mfmdevsystem\socket\Session\Serialize;
|
||||||
|
|
||||||
class PhpBinaryHandler implements HandlerInterface {
|
class PhpBinaryHandler implements HandlerInterface {
|
||||||
/**
|
/**
|
@ -1,5 +1,5 @@
|
|||||||
<?php
|
<?php
|
||||||
namespace Ratchet\Session\Serialize;
|
namespace mfmdevsystem\socket\Session\Serialize;
|
||||||
|
|
||||||
class PhpHandler implements HandlerInterface {
|
class PhpHandler implements HandlerInterface {
|
||||||
/**
|
/**
|
@ -1,10 +1,10 @@
|
|||||||
<?php
|
<?php
|
||||||
namespace Ratchet\Session;
|
namespace mfmdevsystem\socket\Session;
|
||||||
use Ratchet\ConnectionInterface;
|
use mfmdevsystem\socket\ConnectionInterface;
|
||||||
use Ratchet\Http\HttpServerInterface;
|
use mfmdevsystem\socket\Http\HttpServerInterface;
|
||||||
use Psr\Http\Message\RequestInterface;
|
use Psr\Http\Message\RequestInterface;
|
||||||
use Ratchet\Session\Storage\VirtualSessionStorage;
|
use mfmdevsystem\socket\Session\Storage\VirtualSessionStorage;
|
||||||
use Ratchet\Session\Serialize\HandlerInterface;
|
use mfmdevsystem\socket\Session\Serialize\HandlerInterface;
|
||||||
use Symfony\Component\HttpFoundation\Session\Session;
|
use Symfony\Component\HttpFoundation\Session\Session;
|
||||||
use Symfony\Component\HttpFoundation\Session\Storage\Handler\NullSessionHandler;
|
use Symfony\Component\HttpFoundation\Session\Storage\Handler\NullSessionHandler;
|
||||||
|
|
@ -1,5 +1,5 @@
|
|||||||
<?php
|
<?php
|
||||||
namespace Ratchet\Session\Storage\Proxy;
|
namespace mfmdevsystem\socket\Session\Storage\Proxy;
|
||||||
use Symfony\Component\HttpFoundation\Session\Storage\Proxy\SessionHandlerProxy;
|
use Symfony\Component\HttpFoundation\Session\Storage\Proxy\SessionHandlerProxy;
|
||||||
|
|
||||||
class VirtualProxy extends SessionHandlerProxy {
|
class VirtualProxy extends SessionHandlerProxy {
|
@ -1,8 +1,8 @@
|
|||||||
<?php
|
<?php
|
||||||
namespace Ratchet\Session\Storage;
|
namespace mfmdevsystem\socket\Session\Storage;
|
||||||
use Symfony\Component\HttpFoundation\Session\Storage\NativeSessionStorage;
|
use Symfony\Component\HttpFoundation\Session\Storage\NativeSessionStorage;
|
||||||
use Ratchet\Session\Storage\Proxy\VirtualProxy;
|
use mfmdevsystem\socket\Session\Storage\Proxy\VirtualProxy;
|
||||||
use Ratchet\Session\Serialize\HandlerInterface;
|
use mfmdevsystem\socket\Session\Serialize\HandlerInterface;
|
||||||
|
|
||||||
class VirtualSessionStorage extends NativeSessionStorage {
|
class VirtualSessionStorage extends NativeSessionStorage {
|
||||||
/**
|
/**
|
@ -1,5 +1,5 @@
|
|||||||
<?php
|
<?php
|
||||||
namespace Ratchet\Wamp;
|
namespace mfmdevsystem\socket\Wamp;
|
||||||
|
|
||||||
class Exception extends \Exception {
|
class Exception extends \Exception {
|
||||||
}
|
}
|
@ -1,5 +1,5 @@
|
|||||||
<?php
|
<?php
|
||||||
namespace Ratchet\Wamp;
|
namespace mfmdevsystem\socket\Wamp;
|
||||||
|
|
||||||
class JsonException extends Exception {
|
class JsonException extends Exception {
|
||||||
public function __construct() {
|
public function __construct() {
|
@ -1,8 +1,8 @@
|
|||||||
<?php
|
<?php
|
||||||
namespace Ratchet\Wamp;
|
namespace mfmdevsystem\socket\Wamp;
|
||||||
use Ratchet\MessageComponentInterface;
|
use mfmdevsystem\socket\MessageComponentInterface;
|
||||||
use Ratchet\WebSocket\WsServerInterface;
|
use mfmdevsystem\socket\WebSocket\WsServerInterface;
|
||||||
use Ratchet\ConnectionInterface;
|
use mfmdevsystem\socket\ConnectionInterface;
|
||||||
|
|
||||||
/**
|
/**
|
||||||
* WebSocket Application Messaging Protocol
|
* WebSocket Application Messaging Protocol
|
@ -1,6 +1,6 @@
|
|||||||
<?php
|
<?php
|
||||||
namespace Ratchet\Wamp;
|
namespace mfmdevsystem\socket\Wamp;
|
||||||
use Ratchet\ConnectionInterface;
|
use mfmdevsystem\socket\ConnectionInterface;
|
||||||
|
|
||||||
/**
|
/**
|
||||||
* A topic/channel containing connections that have subscribed to it
|
* A topic/channel containing connections that have subscribed to it
|
@ -1,7 +1,7 @@
|
|||||||
<?php
|
<?php
|
||||||
namespace Ratchet\Wamp;
|
namespace mfmdevsystem\socket\Wamp;
|
||||||
use Ratchet\ConnectionInterface;
|
use mfmdevsystem\socket\ConnectionInterface;
|
||||||
use Ratchet\WebSocket\WsServerInterface;
|
use mfmdevsystem\socket\WebSocket\WsServerInterface;
|
||||||
|
|
||||||
class TopicManager implements WsServerInterface, WampServerInterface {
|
class TopicManager implements WsServerInterface, WampServerInterface {
|
||||||
/**
|
/**
|
@ -1,8 +1,8 @@
|
|||||||
<?php
|
<?php
|
||||||
namespace Ratchet\Wamp;
|
namespace mfmdevsystem\socket\Wamp;
|
||||||
use Ratchet\ConnectionInterface;
|
use mfmdevsystem\socket\ConnectionInterface;
|
||||||
use Ratchet\AbstractConnectionDecorator;
|
use mfmdevsystem\socket\AbstractConnectionDecorator;
|
||||||
use Ratchet\Wamp\ServerProtocol as WAMP;
|
use mfmdevsystem\socket\Wamp\ServerProtocol as WAMP;
|
||||||
|
|
||||||
/**
|
/**
|
||||||
* A ConnectionInterface object wrapper that is passed to your WAMP application
|
* A ConnectionInterface object wrapper that is passed to your WAMP application
|
@ -1,8 +1,8 @@
|
|||||||
<?php
|
<?php
|
||||||
namespace Ratchet\Wamp;
|
namespace mfmdevsystem\socket\Wamp;
|
||||||
use Ratchet\MessageComponentInterface;
|
use mfmdevsystem\socket\MessageComponentInterface;
|
||||||
use Ratchet\WebSocket\WsServerInterface;
|
use mfmdevsystem\socket\WebSocket\WsServerInterface;
|
||||||
use Ratchet\ConnectionInterface;
|
use mfmdevsystem\socket\ConnectionInterface;
|
||||||
|
|
||||||
/**
|
/**
|
||||||
* Enable support for the official WAMP sub-protocol in your application
|
* Enable support for the official WAMP sub-protocol in your application
|
@ -1,7 +1,7 @@
|
|||||||
<?php
|
<?php
|
||||||
namespace Ratchet\Wamp;
|
namespace mfmdevsystem\socket\Wamp;
|
||||||
use Ratchet\ComponentInterface;
|
use mfmdevsystem\socket\ComponentInterface;
|
||||||
use Ratchet\ConnectionInterface;
|
use mfmdevsystem\socket\ConnectionInterface;
|
||||||
|
|
||||||
/**
|
/**
|
||||||
* An extension of Ratchet\ComponentInterface to server a WAMP application
|
* An extension of Ratchet\ComponentInterface to server a WAMP application
|
@ -1,6 +1,6 @@
|
|||||||
<?php
|
<?php
|
||||||
namespace Ratchet\WebSocket;
|
namespace mfmdevsystem\socket\WebSocket;
|
||||||
use Ratchet\RFC6455\Messaging\MessageBuffer;
|
use mfmdevsystem\RFC6455\Messaging\MessageBuffer;
|
||||||
|
|
||||||
class ConnContext {
|
class ConnContext {
|
||||||
/**
|
/**
|
||||||
@ -9,7 +9,7 @@ class ConnContext {
|
|||||||
public $connection;
|
public $connection;
|
||||||
|
|
||||||
/**
|
/**
|
||||||
* @var \Ratchet\RFC6455\Messaging\MessageBuffer;
|
* @var \mfmdevsystem\RFC6455\Messaging\MessageBuffer;
|
||||||
*/
|
*/
|
||||||
public $buffer;
|
public $buffer;
|
||||||
|
|
8
src/Socket/WebSocket/MessageCallableInterface.php
Normal file
8
src/Socket/WebSocket/MessageCallableInterface.php
Normal file
@ -0,0 +1,8 @@
|
|||||||
|
<?php
|
||||||
|
namespace mfmdevsystem\socket\WebSocket;
|
||||||
|
use mfmdevsystem\socket\ConnectionInterface;
|
||||||
|
use mfmdevsystem\RFC6455\Messaging\MessageInterface;
|
||||||
|
|
||||||
|
interface MessageCallableInterface {
|
||||||
|
public function onMessage(ConnectionInterface $conn, MessageInterface $msg);
|
||||||
|
}
|
@ -1,6 +1,6 @@
|
|||||||
<?php
|
<?php
|
||||||
namespace Ratchet\WebSocket;
|
namespace mfmdevsystem\socket\WebSocket;
|
||||||
use Ratchet\ComponentInterface;
|
use mfmdevsystem\socket\ComponentInterface;
|
||||||
|
|
||||||
interface MessageComponentInterface extends ComponentInterface, MessageCallableInterface {
|
interface MessageComponentInterface extends ComponentInterface, MessageCallableInterface {
|
||||||
}
|
}
|
@ -1,8 +1,8 @@
|
|||||||
<?php
|
<?php
|
||||||
namespace Ratchet\WebSocket;
|
namespace mfmdevsystem\socket\WebSocket;
|
||||||
use Ratchet\AbstractConnectionDecorator;
|
use mfmdevsystem\socket\AbstractConnectionDecorator;
|
||||||
use Ratchet\RFC6455\Messaging\DataInterface;
|
use mfmdevsystem\RFC6455\Messaging\DataInterface;
|
||||||
use Ratchet\RFC6455\Messaging\Frame;
|
use mfmdevsystem\RFC6455\Messaging\Frame;
|
||||||
|
|
||||||
/**
|
/**
|
||||||
* {@inheritdoc}
|
* {@inheritdoc}
|
||||||
@ -25,7 +25,7 @@ class WsConnection extends AbstractConnectionDecorator {
|
|||||||
}
|
}
|
||||||
|
|
||||||
/**
|
/**
|
||||||
* @param int|\Ratchet\RFC6455\Messaging\DataInterface
|
* @param int|\mfmdevsystem\RFC6455\Messaging\DataInterface
|
||||||
*/
|
*/
|
||||||
public function close($code = 1000) {
|
public function close($code = 1000) {
|
||||||
if ($this->WebSocket->closing) {
|
if ($this->WebSocket->closing) {
|
@ -1,18 +1,18 @@
|
|||||||
<?php
|
<?php
|
||||||
namespace Ratchet\WebSocket;
|
namespace mfmdevsystem\socket\WebSocket;
|
||||||
use Ratchet\ComponentInterface;
|
use mfmdevsystem\socket\ComponentInterface;
|
||||||
use Ratchet\ConnectionInterface;
|
use mfmdevsystem\socket\ConnectionInterface;
|
||||||
use Ratchet\MessageComponentInterface as DataComponentInterface;
|
use mfmdevsystem\socket\MessageComponentInterface as DataComponentInterface;
|
||||||
use Ratchet\Http\HttpServerInterface;
|
use mfmdevsystem\socket\Http\HttpServerInterface;
|
||||||
use Ratchet\Http\CloseResponseTrait;
|
use mfmdevsystem\socket\Http\CloseResponseTrait;
|
||||||
use Psr\Http\Message\RequestInterface;
|
use Psr\Http\Message\RequestInterface;
|
||||||
use Ratchet\RFC6455\Messaging\MessageInterface;
|
use mfmdevsystem\RFC6455\Messaging\MessageInterface;
|
||||||
use Ratchet\RFC6455\Messaging\FrameInterface;
|
use mfmdevsystem\RFC6455\Messaging\FrameInterface;
|
||||||
use Ratchet\RFC6455\Messaging\Frame;
|
use mfmdevsystem\RFC6455\Messaging\Frame;
|
||||||
use Ratchet\RFC6455\Messaging\MessageBuffer;
|
use mfmdevsystem\RFC6455\Messaging\MessageBuffer;
|
||||||
use Ratchet\RFC6455\Messaging\CloseFrameChecker;
|
use mfmdevsystem\RFC6455\Messaging\CloseFrameChecker;
|
||||||
use Ratchet\RFC6455\Handshake\ServerNegotiator;
|
use mfmdevsystem\RFC6455\Handshake\ServerNegotiator;
|
||||||
use Ratchet\RFC6455\Handshake\RequestVerifier;
|
use mfmdevsystem\RFC6455\Handshake\RequestVerifier;
|
||||||
use React\EventLoop\LoopInterface;
|
use React\EventLoop\LoopInterface;
|
||||||
use GuzzleHttp\Psr7\Message;
|
use GuzzleHttp\Psr7\Message;
|
||||||
|
|
||||||
@ -37,12 +37,12 @@ class WsServer implements HttpServerInterface {
|
|||||||
protected $connections;
|
protected $connections;
|
||||||
|
|
||||||
/**
|
/**
|
||||||
* @var \Ratchet\RFC6455\Messaging\CloseFrameChecker
|
* @var \mfmdevsystem\RFC6455\Messaging\CloseFrameChecker
|
||||||
*/
|
*/
|
||||||
private $closeFrameChecker;
|
private $closeFrameChecker;
|
||||||
|
|
||||||
/**
|
/**
|
||||||
* @var \Ratchet\RFC6455\Handshake\ServerNegotiator
|
* @var \mfmdevsystem\RFC6455\Handshake\ServerNegotiator
|
||||||
*/
|
*/
|
||||||
private $handshakeNegotiator;
|
private $handshakeNegotiator;
|
||||||
|
|
@ -1,5 +1,5 @@
|
|||||||
<?php
|
<?php
|
||||||
namespace Ratchet\WebSocket;
|
namespace mfmdevsystem\socket\WebSocket;
|
||||||
|
|
||||||
/**
|
/**
|
||||||
* WebSocket Server Interface
|
* WebSocket Server Interface
|
@ -1,10 +1,10 @@
|
|||||||
<?php
|
<?php
|
||||||
use Ratchet\ConnectionInterface;
|
use mfmdevsystem\socket\ConnectionInterface;
|
||||||
|
|
||||||
require dirname(dirname(dirname(__DIR__))) . '/vendor/autoload.php';
|
require dirname(dirname(dirname(__DIR__))) . '/vendor/autoload.php';
|
||||||
|
|
||||||
class BinaryEcho implements \Ratchet\WebSocket\MessageComponentInterface {
|
class BinaryEcho implements \Ratchet\WebSocket\MessageComponentInterface {
|
||||||
public function onMessage(ConnectionInterface $from, \Ratchet\RFC6455\Messaging\MessageInterface $msg) {
|
public function onMessage(ConnectionInterface $from, \mfmdevsystem\RFC6455\Messaging\MessageInterface $msg) {
|
||||||
$from->send($msg);
|
$from->send($msg);
|
||||||
}
|
}
|
||||||
|
|
||||||
|
@ -1,8 +1,8 @@
|
|||||||
<?php
|
<?php
|
||||||
namespace Ratchet\Mock;
|
namespace mfmdevsystem\socket\Mock;
|
||||||
use Ratchet\MessageComponentInterface;
|
use mfmdevsystem\socket\MessageComponentInterface;
|
||||||
use Ratchet\WebSocket\WsServerInterface;
|
use mfmdevsystem\socket\WebSocket\WsServerInterface;
|
||||||
use Ratchet\ConnectionInterface;
|
use mfmdevsystem\socket\ConnectionInterface;
|
||||||
|
|
||||||
class Component implements MessageComponentInterface, WsServerInterface {
|
class Component implements MessageComponentInterface, WsServerInterface {
|
||||||
public $last = array();
|
public $last = array();
|
||||||
|
@ -1,6 +1,6 @@
|
|||||||
<?php
|
<?php
|
||||||
namespace Ratchet\Mock;
|
namespace mfmdevsystem\socket\Mock;
|
||||||
use Ratchet\ConnectionInterface;
|
use mfmdevsystem\socket\ConnectionInterface;
|
||||||
|
|
||||||
class Connection implements ConnectionInterface {
|
class Connection implements ConnectionInterface {
|
||||||
public $last = array(
|
public $last = array(
|
||||||
|
@ -1,6 +1,6 @@
|
|||||||
<?php
|
<?php
|
||||||
namespace Ratchet\Mock;
|
namespace mfmdevsystem\socket\Mock;
|
||||||
use Ratchet\AbstractConnectionDecorator;
|
use mfmdevsystem\socket\AbstractConnectionDecorator;
|
||||||
|
|
||||||
class ConnectionDecorator extends AbstractConnectionDecorator {
|
class ConnectionDecorator extends AbstractConnectionDecorator {
|
||||||
public $last = array(
|
public $last = array(
|
||||||
|
@ -1,8 +1,8 @@
|
|||||||
<?php
|
<?php
|
||||||
namespace Ratchet\Mock;
|
namespace mfmdevsystem\socket\Mock;
|
||||||
use Ratchet\Wamp\WampServerInterface;
|
use mfmdevsystem\socket\Wamp\WampServerInterface;
|
||||||
use Ratchet\WebSocket\WsServerInterface;
|
use mfmdevsystem\socket\WebSocket\WsServerInterface;
|
||||||
use Ratchet\ConnectionInterface;
|
use mfmdevsystem\socket\ConnectionInterface;
|
||||||
|
|
||||||
class WampComponent implements WampServerInterface, WsServerInterface {
|
class WampComponent implements WampServerInterface, WsServerInterface {
|
||||||
public $last = array();
|
public $last = array();
|
||||||
|
@ -1,9 +1,9 @@
|
|||||||
<?php
|
<?php
|
||||||
namespace Ratchet;
|
namespace Ratchet;
|
||||||
use Ratchet\ConnectionInterface;
|
use mfmdevsystem\socket\ConnectionInterface;
|
||||||
use Ratchet\MessageComponentInterface;
|
use mfmdevsystem\socket\MessageComponentInterface;
|
||||||
use Ratchet\WebSocket\WsServerInterface;
|
use mfmdevsystem\socket\WebSocket\WsServerInterface;
|
||||||
use Ratchet\Wamp\WampServerInterface;
|
use mfmdevsystem\socket\Wamp\WampServerInterface;
|
||||||
|
|
||||||
class NullComponent implements MessageComponentInterface, WsServerInterface, WampServerInterface {
|
class NullComponent implements MessageComponentInterface, WsServerInterface, WampServerInterface {
|
||||||
public function onOpen(ConnectionInterface $conn) {}
|
public function onOpen(ConnectionInterface $conn) {}
|
||||||
|
@ -1,7 +1,7 @@
|
|||||||
<?php
|
<?php
|
||||||
namespace Ratchet\Wamp\Stub;
|
namespace mfmdevsystem\socket\Wamp\Stub;
|
||||||
use Ratchet\WebSocket\WsServerInterface;
|
use mfmdevsystem\socket\WebSocket\WsServerInterface;
|
||||||
use Ratchet\Wamp\WampServerInterface;
|
use mfmdevsystem\socket\Wamp\WampServerInterface;
|
||||||
|
|
||||||
interface WsWampServerInterface extends WsServerInterface, WampServerInterface {
|
interface WsWampServerInterface extends WsServerInterface, WampServerInterface {
|
||||||
}
|
}
|
||||||
|
@ -1,7 +1,7 @@
|
|||||||
<?php
|
<?php
|
||||||
namespace Ratchet\WebSocket\Stub;
|
namespace mfmdevsystem\socket\WebSocket\Stub;
|
||||||
use Ratchet\MessageComponentInterface;
|
use mfmdevsystem\socket\MessageComponentInterface;
|
||||||
use Ratchet\WebSocket\WsServerInterface;
|
use mfmdevsystem\socket\WebSocket\WsServerInterface;
|
||||||
|
|
||||||
interface WsMessageComponentInterface extends MessageComponentInterface, WsServerInterface {
|
interface WsMessageComponentInterface extends MessageComponentInterface, WsServerInterface {
|
||||||
}
|
}
|
||||||
|
@ -1,6 +1,6 @@
|
|||||||
<?php
|
<?php
|
||||||
namespace Ratchet;
|
namespace Ratchet;
|
||||||
use Ratchet\Mock\ConnectionDecorator;
|
use mfmdevsystem\socket\Mock\ConnectionDecorator;
|
||||||
|
|
||||||
/**
|
/**
|
||||||
* @covers Ratchet\AbstractConnectionDecorator
|
* @covers Ratchet\AbstractConnectionDecorator
|
||||||
|
@ -1,5 +1,5 @@
|
|||||||
<?php
|
<?php
|
||||||
namespace Ratchet\Http;
|
namespace mfmdevsystem\socket\Http;
|
||||||
|
|
||||||
/**
|
/**
|
||||||
* @covers Ratchet\Http\HttpRequestParser
|
* @covers Ratchet\Http\HttpRequestParser
|
||||||
|
@ -1,6 +1,6 @@
|
|||||||
<?php
|
<?php
|
||||||
namespace Ratchet\Http;
|
namespace mfmdevsystem\socket\Http;
|
||||||
use Ratchet\AbstractMessageComponentTestCase;
|
use mfmdevsystem\socket\AbstractMessageComponentTestCase;
|
||||||
|
|
||||||
/**
|
/**
|
||||||
* @covers Ratchet\Http\HttpServer
|
* @covers Ratchet\Http\HttpServer
|
||||||
|
@ -1,6 +1,6 @@
|
|||||||
<?php
|
<?php
|
||||||
namespace Ratchet\Http;
|
namespace mfmdevsystem\socket\Http;
|
||||||
use Ratchet\AbstractMessageComponentTestCase;
|
use mfmdevsystem\socket\AbstractMessageComponentTestCase;
|
||||||
|
|
||||||
/**
|
/**
|
||||||
* @covers Ratchet\Http\OriginCheck
|
* @covers Ratchet\Http\OriginCheck
|
||||||
|
@ -1,6 +1,6 @@
|
|||||||
<?php
|
<?php
|
||||||
namespace Ratchet\Http;
|
namespace mfmdevsystem\socket\Http;
|
||||||
use Ratchet\WebSocket\WsServerInterface;
|
use mfmdevsystem\socket\WebSocket\WsServerInterface;
|
||||||
use Symfony\Component\Routing\Exception\ResourceNotFoundException;
|
use Symfony\Component\Routing\Exception\ResourceNotFoundException;
|
||||||
use Symfony\Component\Routing\Matcher\UrlMatcherInterface;
|
use Symfony\Component\Routing\Matcher\UrlMatcherInterface;
|
||||||
use Symfony\Component\Routing\RequestContext;
|
use Symfony\Component\Routing\RequestContext;
|
||||||
|
@ -1,6 +1,6 @@
|
|||||||
<?php
|
<?php
|
||||||
namespace Ratchet\Server;
|
namespace mfmdevsystem\socket\Server;
|
||||||
use Ratchet\Server\EchoServer;
|
use mfmdevsystem\socket\Server\EchoServer;
|
||||||
|
|
||||||
class EchoServerTest extends \PHPUnit_Framework_TestCase {
|
class EchoServerTest extends \PHPUnit_Framework_TestCase {
|
||||||
protected $_conn;
|
protected $_conn;
|
||||||
|
@ -1,6 +1,6 @@
|
|||||||
<?php
|
<?php
|
||||||
namespace Ratchet\Application\Server;
|
namespace mfmdevsystem\socket\Application\Server;
|
||||||
use Ratchet\Server\FlashPolicy;
|
use mfmdevsystem\socket\Server\FlashPolicy;
|
||||||
|
|
||||||
/**
|
/**
|
||||||
* @covers Ratchet\Server\FlashPolicy
|
* @covers Ratchet\Server\FlashPolicy
|
||||||
|
@ -1,6 +1,6 @@
|
|||||||
<?php
|
<?php
|
||||||
namespace Ratchet\Application\Server;
|
namespace mfmdevsystem\socket\Application\Server;
|
||||||
use Ratchet\Server\IoConnection;
|
use mfmdevsystem\socket\Server\IoConnection;
|
||||||
|
|
||||||
/**
|
/**
|
||||||
* @covers Ratchet\Server\IoConnection
|
* @covers Ratchet\Server\IoConnection
|
||||||
|
@ -1,6 +1,6 @@
|
|||||||
<?php
|
<?php
|
||||||
namespace Ratchet\Server;
|
namespace mfmdevsystem\socket\Server;
|
||||||
use Ratchet\Server\IoServer;
|
use mfmdevsystem\socket\Server\IoServer;
|
||||||
use React\EventLoop\StreamSelectLoop;
|
use React\EventLoop\StreamSelectLoop;
|
||||||
use React\EventLoop\LoopInterface;
|
use React\EventLoop\LoopInterface;
|
||||||
use React\Socket\Server;
|
use React\Socket\Server;
|
||||||
|
@ -1,6 +1,6 @@
|
|||||||
<?php
|
<?php
|
||||||
namespace Ratchet\Server;
|
namespace mfmdevsystem\socket\Server;
|
||||||
use Ratchet\Server\IpBlackList;
|
use mfmdevsystem\socket\Server\IpBlackList;
|
||||||
|
|
||||||
/**
|
/**
|
||||||
* @covers Ratchet\Server\IpBlackList
|
* @covers Ratchet\Server\IpBlackList
|
||||||
|
@ -1,6 +1,6 @@
|
|||||||
<?php
|
<?php
|
||||||
namespace Ratchet\Session\Serialize;
|
namespace mfmdevsystem\socket\Session\Serialize;
|
||||||
use Ratchet\Session\Serialize\PhpHandler;
|
use mfmdevsystem\socket\Session\Serialize\PhpHandler;
|
||||||
|
|
||||||
/**
|
/**
|
||||||
* @covers Ratchet\Session\Serialize\PhpHandler
|
* @covers Ratchet\Session\Serialize\PhpHandler
|
||||||
|
@ -1,6 +1,6 @@
|
|||||||
<?php
|
<?php
|
||||||
namespace Ratchet\Session;
|
namespace mfmdevsystem\socket\Session;
|
||||||
use Ratchet\AbstractMessageComponentTestCase;
|
use mfmdevsystem\socket\AbstractMessageComponentTestCase;
|
||||||
use Symfony\Component\HttpFoundation\Session\Storage\Handler\PdoSessionHandler;
|
use Symfony\Component\HttpFoundation\Session\Storage\Handler\PdoSessionHandler;
|
||||||
use Symfony\Component\HttpFoundation\Session\Storage\Handler\NullSessionHandler;
|
use Symfony\Component\HttpFoundation\Session\Storage\Handler\NullSessionHandler;
|
||||||
|
|
||||||
|
@ -1,6 +1,6 @@
|
|||||||
<?php
|
<?php
|
||||||
namespace Ratchet\Session\Storage;
|
namespace mfmdevsystem\socket\Session\Storage;
|
||||||
use Ratchet\Session\Serialize\PhpHandler;
|
use mfmdevsystem\socket\Session\Serialize\PhpHandler;
|
||||||
use Symfony\Component\HttpFoundation\Session\Attribute\AttributeBag;
|
use Symfony\Component\HttpFoundation\Session\Attribute\AttributeBag;
|
||||||
use Symfony\Component\HttpFoundation\Session\Flash\FlashBag;
|
use Symfony\Component\HttpFoundation\Session\Flash\FlashBag;
|
||||||
use Symfony\Component\HttpFoundation\Session\Storage\Handler\PdoSessionHandler;
|
use Symfony\Component\HttpFoundation\Session\Storage\Handler\PdoSessionHandler;
|
||||||
|
@ -1,7 +1,7 @@
|
|||||||
<?php
|
<?php
|
||||||
namespace Ratchet\Wamp;
|
namespace mfmdevsystem\socket\Wamp;
|
||||||
use Ratchet\Mock\Connection;
|
use mfmdevsystem\socket\Mock\Connection;
|
||||||
use Ratchet\Mock\WampComponent as TestComponent;
|
use mfmdevsystem\socket\Mock\WampComponent as TestComponent;
|
||||||
|
|
||||||
/**
|
/**
|
||||||
* @covers \Ratchet\Wamp\ServerProtocol
|
* @covers \Ratchet\Wamp\ServerProtocol
|
||||||
|
@ -1,5 +1,5 @@
|
|||||||
<?php
|
<?php
|
||||||
namespace Ratchet\Wamp;
|
namespace mfmdevsystem\socket\Wamp;
|
||||||
|
|
||||||
/**
|
/**
|
||||||
* @covers Ratchet\Wamp\TopicManager
|
* @covers Ratchet\Wamp\TopicManager
|
||||||
|
@ -1,5 +1,5 @@
|
|||||||
<?php
|
<?php
|
||||||
namespace Ratchet\Wamp;
|
namespace mfmdevsystem\socket\Wamp;
|
||||||
|
|
||||||
/**
|
/**
|
||||||
* @covers Ratchet\Wamp\Topic
|
* @covers Ratchet\Wamp\Topic
|
||||||
|
@ -1,5 +1,5 @@
|
|||||||
<?php
|
<?php
|
||||||
namespace Ratchet\Wamp;
|
namespace mfmdevsystem\socket\Wamp;
|
||||||
|
|
||||||
/**
|
/**
|
||||||
* @covers Ratchet\Wamp\WampConnection
|
* @covers Ratchet\Wamp\WampConnection
|
||||||
|
@ -1,6 +1,6 @@
|
|||||||
<?php
|
<?php
|
||||||
namespace Ratchet\Wamp;
|
namespace mfmdevsystem\socket\Wamp;
|
||||||
use Ratchet\AbstractMessageComponentTestCase;
|
use mfmdevsystem\socket\AbstractMessageComponentTestCase;
|
||||||
|
|
||||||
/**
|
/**
|
||||||
* @covers Ratchet\Wamp\WampServer
|
* @covers Ratchet\Wamp\WampServer
|
||||||
|
Loading…
Reference in New Issue
Block a user