hop

src/SocketBundle/Command/WsCommand.php

@@ -41,20 +41,20 @@ class WsCommand extends ContainerAwareCommand
     {
         $output->write("Tentative de connexion au chat\n");
         
-        /*
         // méthode 1
         $server = IoServer::factory(
             new HttpServer(
                 new WsServer(
                     new ChatHub($this->getContainer())
                 )
-            ), 8088, 'ws://0.0.0.0/socket'
+            ), 8088, '0.0.0.0'
         );
-        */
         
+        /*
         // méthode 2
         $server = new App('0.0.0.0', 8088);
         $server->route('/', new ChatHub($this->getContainer()));
+        */
 
         $server->run();
 

src/SocketBundle/Services/ChatHub.php

@@ -73,6 +73,14 @@ class ChatHub implements MessageComponentInterface
     {
         // TODO: Implement onClose() method.
         echo "Un utilisateur s'est déconnecté\n";
+        
+        foreach ($this->clients as $key => $client)
+        {
+            if ($client === $conn)
+            {
+                unset($this->clients[$key]);
+            }
+        }
     }
     
     /**
@@ -98,7 +106,7 @@ class ChatHub implements MessageComponentInterface
      */
     function onMessage(ConnectionInterface $from, $msg)
     {
-        echo "Le message ". $msg ." a été reçu\n";
+        echo "Le message '". $msg ."' a été reçu\n";
         foreach ($this->clients as $client)
         {
             $response = json_encode([