diff --git a/website/websocket.php b/website/websocket.php index 3876286..9dc5a28 100644 --- a/website/websocket.php +++ b/website/websocket.php @@ -1,26 +1,31 @@ clients = new \SplObjectStorage; + public function __construct() + { + $this->clients = new \SplObjectStorage(); } - public function onOpen(ConnectionInterface $conn) { + public function onOpen(ConnectionInterface $conn) + { $this->clients->attach($conn); } - public function onMessage(ConnectionInterface $from, $msg) { + public function onMessage(ConnectionInterface $from, $msg) + { foreach ($this->clients as $client) { if ($from != $client) { $client->send($msg); @@ -28,17 +33,19 @@ class MyChat implements MessageComponentInterface { } } - public function onClose(ConnectionInterface $conn) { + public function onClose(ConnectionInterface $conn) + { $this->clients->detach($conn); } - public function onError(ConnectionInterface $conn, \Exception $e) { + public function onError(ConnectionInterface $conn, \Exception $e) + { $conn->close(); } } - // Run the server application through the WebSocket protocol on port 8080 - $app = new Ratchet\App('localhost', 8080); - $app->route('/chat', new MyChat, array('*')); - $app->route('/echo', new Ratchet\Server\EchoServer, array('*')); - $app->run(); +// Run the server application through the WebSocket protocol on port 8080 +$app = new Ratchet\App('localhost', 8080); +$app->route('/chat', new MyChat(), array('*')); +$app->route('/echo', new Ratchet\Server\EchoServer(), array('*')); +$app->run();