Do not emit undocumented events on foreign connection objects

clue · Nov 13, 2018 · aa478fe · aa478fe
1 parent ce16df7
commit aa478fe
Showing 1 changed file with 4 additions and 12 deletions.
diff --git a/src/Server.php b/src/Server.php
@@ -107,13 +107,8 @@ public function unsetAuth()
     public function onConnection(ConnectionInterface $connection)
     {
         $that = $this;
-        $handling = $this->handleSocks($connection)->then(function($remote) use ($connection){
-            $connection->emit('ready',array($remote));
-        }, function ($error) use ($connection, $that) {
-            if (!($error instanceof \Exception)) {
-                $error = new \Exception($error);
-            }
-            $connection->emit('error', array($error));
+        $handling = $this->handleSocks($connection)->then(null, function () use ($connection, $that) {
+            // SOCKS failed => close connection
             $that->endConnection($connection);
         });
 
@@ -280,9 +275,8 @@ public function handleSocks5(ConnectionInterface $stream, $auth=null, StreamRead
                             $remote = str_replace('://', '://' . rawurlencode($username) . ':' . rawurlencode($password) . '@', $remote);
                         }
 
-                        return $auth($username, $password, $remote)->then(function () use ($stream, $username) {
+                        return $auth($username, $password, $remote)->then(function () use ($stream) {
                             // accept
-                            $stream->emit('auth', array($username));
                             $stream->write(pack('C2', 0x01, 0x00));
                         }, function() use ($stream) {
                             // reject => send any code but 0x00
@@ -296,7 +290,7 @@ public function handleSocks5(ConnectionInterface $stream, $auth=null, StreamRead
                 $stream->write(pack('C2', 0x05, 0xFF));
                 throw new UnexpectedValueException('No acceptable authentication mechanism found');
             }
-        })->then(function ($method) use ($reader, $stream) {
+        })->then(function ($method) use ($reader) {
             return $reader->readBinary(array(
                 'version' => 'C',
                 'command' => 'C',
@@ -368,7 +362,6 @@ public function connectTarget(ConnectionInterface $stream, array $target)
             $uri .= '?source=' . rawurlencode($target[2]);
         }
 
-        $stream->emit('target', $target);
         $that = $this;
         $connecting = $this->connector->connect($uri);
 
@@ -382,7 +375,6 @@ public function connectTarget(ConnectionInterface $stream, array $target)
 
             // remote end closes connection => stop reading from local end, try to flush buffer to local and disconnect local
             $remote->on('end', function() use ($stream, $that) {
-                $stream->emit('shutdown', array('remote', null));
                 $that->endConnection($stream);
             });