128 lines
4.1 KiB
PHP
128 lines
4.1 KiB
PHP
<?php
|
|
namespace Ratchet\Server;
|
|
use Ratchet\Server\IoServer;
|
|
use React\EventLoop\StreamSelectLoop;
|
|
use React\EventLoop\LoopInterface;
|
|
use React\Socket\Server;
|
|
|
|
/**
|
|
* @covers Ratchet\Server\IoServer
|
|
*/
|
|
class IoServerTest extends \PHPUnit_Framework_TestCase {
|
|
protected $server;
|
|
|
|
protected $app;
|
|
|
|
protected $port;
|
|
|
|
protected $reactor;
|
|
|
|
protected function tickLoop(LoopInterface $loop) {
|
|
$loop->futureTick(function () use ($loop) {
|
|
$loop->stop();
|
|
});
|
|
|
|
$loop->run();
|
|
}
|
|
|
|
public function setUp() {
|
|
$this->app = $this->getMock('\\Ratchet\\MessageComponentInterface');
|
|
|
|
$loop = new StreamSelectLoop;
|
|
$this->reactor = new Server(0, $loop);
|
|
|
|
$uri = $this->reactor->getAddress();
|
|
$this->port = parse_url((strpos($uri, '://') === false ? 'tcp://' : '') . $uri, PHP_URL_PORT);
|
|
$this->server = new IoServer($this->app, $this->reactor, $loop);
|
|
}
|
|
|
|
public function testOnOpen() {
|
|
$this->app->expects($this->once())->method('onOpen')->with($this->isInstanceOf('\\Ratchet\\ConnectionInterface'));
|
|
|
|
$client = stream_socket_client("tcp://localhost:{$this->port}");
|
|
|
|
$this->tickLoop($this->server->loop);
|
|
|
|
//$this->assertTrue(is_string($this->app->last['onOpen'][0]->remoteAddress));
|
|
//$this->assertTrue(is_int($this->app->last['onOpen'][0]->resourceId));
|
|
}
|
|
|
|
public function testOnData() {
|
|
$msg = 'Hello World!';
|
|
|
|
$this->app->expects($this->once())->method('onMessage')->with(
|
|
$this->isInstanceOf('\\Ratchet\\ConnectionInterface')
|
|
, $msg
|
|
);
|
|
|
|
$client = socket_create(AF_INET, SOCK_STREAM, SOL_TCP);
|
|
socket_set_option($client, SOL_SOCKET, SO_REUSEADDR, 1);
|
|
socket_set_option($client, SOL_SOCKET, SO_SNDBUF, 4096);
|
|
socket_set_block($client);
|
|
socket_connect($client, 'localhost', $this->port);
|
|
|
|
$this->tickLoop($this->server->loop);
|
|
|
|
socket_write($client, $msg);
|
|
$this->tickLoop($this->server->loop);
|
|
|
|
socket_shutdown($client, 1);
|
|
socket_shutdown($client, 0);
|
|
socket_close($client);
|
|
|
|
$this->tickLoop($this->server->loop);
|
|
}
|
|
|
|
public function testOnClose() {
|
|
$this->app->expects($this->once())->method('onClose')->with($this->isInstanceOf('\\Ratchet\\ConnectionInterface'));
|
|
|
|
$client = socket_create(AF_INET, SOCK_STREAM, SOL_TCP);
|
|
socket_set_option($client, SOL_SOCKET, SO_REUSEADDR, 1);
|
|
socket_set_option($client, SOL_SOCKET, SO_SNDBUF, 4096);
|
|
socket_set_block($client);
|
|
socket_connect($client, 'localhost', $this->port);
|
|
|
|
$this->tickLoop($this->server->loop);
|
|
|
|
socket_shutdown($client, 1);
|
|
socket_shutdown($client, 0);
|
|
socket_close($client);
|
|
|
|
$this->tickLoop($this->server->loop);
|
|
}
|
|
|
|
public function testFactory() {
|
|
$this->assertInstanceOf('\\Ratchet\\Server\\IoServer', IoServer::factory($this->app, 0));
|
|
}
|
|
|
|
public function testNoLoopProvidedError() {
|
|
$this->setExpectedException('RuntimeException');
|
|
|
|
$io = new IoServer($this->app, $this->reactor);
|
|
$io->run();
|
|
}
|
|
|
|
public function testOnErrorPassesException() {
|
|
$conn = $this->getMock('\\React\\Socket\\ConnectionInterface');
|
|
$conn->decor = $this->getMock('\\Ratchet\\ConnectionInterface');
|
|
$err = new \Exception("Nope");
|
|
|
|
$this->app->expects($this->once())->method('onError')->with($conn->decor, $err);
|
|
|
|
$this->server->handleError($err, $conn);
|
|
}
|
|
|
|
public function onErrorCalledWhenExceptionThrown() {
|
|
$this->markTestIncomplete("Need to learn how to throw an exception from a mock");
|
|
|
|
$conn = $this->getMock('\\React\\Socket\\ConnectionInterface');
|
|
$this->server->handleConnect($conn);
|
|
|
|
$e = new \Exception;
|
|
$this->app->expects($this->once())->method('onMessage')->with($this->isInstanceOf('\\Ratchet\\ConnectionInterface'), 'f')->will($e);
|
|
$this->app->expects($this->once())->method('onError')->with($this->instanceOf('\\Ratchet\\ConnectionInterface', $e));
|
|
|
|
$this->server->handleData('f', $conn);
|
|
}
|
|
}
|