Changed some logging in the example

Author: Devristo

examples/tcp_proxy_example.php

@@ -32,7 +32,6 @@ public function __construct(\React\EventLoop\LoopInterface $loop, $logger)
 
     public function onDisconnect(WebSocketConnectionInterface $user)
     {
-        $this->logger->notice(sprintf("User %s has been removed from proxy", $user->getId()));
         foreach ($this->getStreamsByUser($user) as $stream) {
             $stream->close();
         }
@@ -82,6 +81,7 @@ protected function requestConnect(WebSocketConnectionInterface $user, $message)
                 )));
 
                 $stream->on("data", function ($data) use ($stream, $id, $user, $logger){
+                    $logger->notice("Forwarding ".strlen($data). " bytes from stream $id to {$user->getId()}");
                     $message = array(
                         'connection' => $id,
                         'event' => 'data',

src/Devristo/Phpws/Server/UriHandler/ClientRouter.php

@@ -32,8 +32,9 @@ public function __construct(WebSocketServer $server, LoggerInterface $logger){
             $handler = $that->matchConnection($client);
 
             if($handler){
-                $logger->notice("We have added client {$client->getId()} to ".get_class($handler));
+                $logger->notice("Added client {$client->getId()} to ".get_class($handler));
                 $membership->attach($client, $handler);
+                $handler->emit("connect", array("client" => $client));
                 $handler->addConnection($client);
             }else
                 $logger->err("Cannot route {$client->getId()} with request uri {$client->getUriRequested()}");
@@ -44,7 +45,7 @@ public function __construct(WebSocketServer $server, LoggerInterface $logger){
                 $handler = $membership[$client];
                 $membership->detach($client);
 
-                $logger->notice("We have removed client {$client->getId()} from".get_class($handler));
+                $logger->notice("Removed client {$client->getId()} from".get_class($handler));
 
                 $handler->removeConnection($client);
                 $handler->emit("disconnect", array("client" => $client));

src/Devristo/Phpws/Server/UriHandler/WebSocketUriHandler.php

@@ -38,6 +38,7 @@ public function __construct($logger)
 
         $this->on("message", array($this, 'onMessage'));
         $this->on("disconnect", array($this, 'onDisconnect'));
+        $this->on("connect", array($this, 'onConnect'));
     }
 
     public function addConnection(WebSocketConnectionInterface $user)
@@ -48,7 +49,6 @@ public function addConnection(WebSocketConnectionInterface $user)
     public function removeConnection(WebSocketConnectionInterface $user)
     {
         $this->users->detach($user);
-        $this->onDisconnect($user);
     }
 
     public function setServer(WebSocketServer $server)
@@ -66,6 +66,10 @@ public function onDisconnect(WebSocketConnectionInterface $user)
 
     }
 
+    public function onConnect(WebSocketConnectionInterface $user){
+
+    }
+
     public function onMessage(WebSocketConnectionInterface $user, WebSocketMessageInterface $msg)
     {