dazzle-php / ssh

src/SSH/Driver/Shell/ShellResource.php

Spacing +7 added lines, -7 removed lines

@@ -274,9 +274,9 @@ 
         $this->readable = false;
         $this->writable = false;
 
-        $this->emit('close', [ $this ]);
+        $this->emit('close', [$this]);
         $this->pause();
-        $this->emit('done', [ $this ]);
+        $this->emit('done', [$this]);
     }
 
     /**
@@ -334,11 +334,11 @@ 
         }
         else if ($ret !== '')
         {
-            $this->emit('data', [ $this, $ret ]);
+            $this->emit('data', [$this, $ret]);
 
             if (strlen($ret) < $length)
             {
-                $this->emit('end', [ $this ]);
+                $this->emit('end', [$this]);
             }
         }
 
@@ -385,8 +385,8 @@ 
         }
 
         $this->writable = false; // this is single-use stream only!
-        $this->emit('drain', [ $this ]);
-        $this->emit('finish', [ $this ]);
+        $this->emit('drain', [$this]);
+        $this->emit('finish', [$this]);
 
         return true;
     }
@@ -400,7 +400,7 @@ 
      */
     protected function throwAndEmitException($ex)
     {
-        $this->emit('error', [ $this, $ex ]);
+        $this->emit('error', [$this, $ex]);
         throw $ex;
     }
 }

src/SSH/Driver/Sftp/SftpResource.php

Spacing +12 added lines, -12 removed lines

@@ -194,9 +194,9 @@ 
             $this->writeEnd();
         }
 
-        $this->emit('close', [ $this ]);
+        $this->emit('close', [$this]);
         $this->handleClose();
-        $this->emit('done', [ $this ]);
+        $this->emit('done', [$this]);
     }
 
     /**
@@ -226,7 +226,7 @@ 
 
             if ($text !== '' && !$sent)
             {
-                $this->emit('error', [ $this, new WriteException('Error occurred while writing to the stream resource.') ]);
+                $this->emit('error', [$this, new WriteException('Error occurred while writing to the stream resource.')]);
                 return;
             }
 
@@ -234,21 +234,21 @@ 
             $lenAfter = $lenBefore - $sent;
             $this->buffer->remove($sent);
 
-            $this->emit('drain', [ $this ]);
+            $this->emit('drain', [$this]);
 
             if ($lenAfter === 0 && $this->buffer->isEmpty())
             {
                 $this->writing = false;
-                $this->emit('finish', [ $this ]);
+                $this->emit('finish', [$this]);
             }
         }
         catch (Error $ex)
         {
-            $this->emit('error', [ $this, $ex ]);
+            $this->emit('error', [$this, $ex]);
         }
         catch (Exception $ex)
         {
-            $this->emit('error', [ $this, $ex ]);
+            $this->emit('error', [$this, $ex]);
         }
     }
 
@@ -271,28 +271,28 @@ 
 
             if ($ret === false)
             {
-                $this->emit('error', [ $this, new ReadException('Error occurred while reading from the stream resource.') ]);
+                $this->emit('error', [$this, new ReadException('Error occurred while reading from the stream resource.')]);
                 return;
             }
 
             if ($ret !== '')
             {
-                $this->emit('data', [ $this, $ret ]);
+                $this->emit('data', [$this, $ret]);
 
                 if (strlen($ret) < $length)
                 {
                     $this->reading = false;
-                    $this->emit('end', [ $this ]);
+                    $this->emit('end', [$this]);
                 }
             }
         }
         catch (Error $ex)
         {
-            $this->emit('error', [ $this, $ex ]);
+            $this->emit('error', [$this, $ex]);
         }
         catch (Exception $ex)
         {
-            $this->emit('error', [ $this, $ex ]);
+            $this->emit('error', [$this, $ex]);
         }
     }
 

src/SSH/Driver/Sftp.php

Spacing +6 added lines, -6 removed lines

@@ -134,13 +134,13 @@ 
 
         if (!$resource || !is_resource($resource))
         {
-            $this->emit('error', [ $this, new ExecutionException('SSH2:Sftp could not be connected.') ]);
+            $this->emit('error', [$this, new ExecutionException('SSH2:Sftp could not be connected.')]);
             return;
         }
 
         $this->resource = $resource;
 
-        $this->emit('connect', [ $this ]);
+        $this->emit('connect', [$this]);
     }
 
     /**
@@ -162,7 +162,7 @@ 
         }
 
         $this->handleDisconnect();
-        $this->emit('disconnect', [ $this ]);
+        $this->emit('disconnect', [$this]);
     }
 
     /**
@@ -204,7 +204,7 @@ 
 
             if ($this->timer === null)
             {
-                $this->timer = $this->loop->addPeriodicTimer($this->interval, [ $this, 'handleHeartbeat' ]);
+                $this->timer = $this->loop->addPeriodicTimer($this->interval, [$this, 'handleHeartbeat']);
             }
         }
     }
@@ -238,11 +238,11 @@ 
 
         $resource = new SftpResource($this, $stream);
         $resource->on('open', function(SSH2ResourceInterface $resource) {
-            $this->emit('resource:open', [ $this, $resource ]);
+            $this->emit('resource:open', [$this, $resource]);
         });
         $resource->on('close', function(SSH2ResourceInterface $resource) {
             $this->removeResource($resource->getId());
-            $this->emit('resource:close', [ $this, $resource ]);
+            $this->emit('resource:close', [$this, $resource]);
         });
 
         $this->resources[$resource->getId()] = $resource;

src/SSH/Driver/Shell.php

Spacing +9 added lines, -9 removed lines

@@ -131,13 +131,13 @@ 
 
         if (!$shell || !is_resource($shell))
         {
-            $this->emit('error', [ $this, new ExecutionException('SSH2:Shell could not be connected.') ]);
+            $this->emit('error', [$this, new ExecutionException('SSH2:Shell could not be connected.')]);
             return;
         }
 
         $this->resource = $shell;
 
-        $this->emit('connect', [ $this ]);
+        $this->emit('connect', [$this]);
     }
 
     /**
@@ -159,7 +159,7 @@ 
         }
 
         $this->handleDisconnect();
-        $this->emit('disconnect', [ $this ]);
+        $this->emit('disconnect', [$this]);
     }
 
     /**
@@ -201,7 +201,7 @@ 
 
             if ($this->timer === null)
             {
-                $this->timer = $this->loop->addPeriodicTimer($this->interval, [ $this, 'handleHeartbeat' ]);
+                $this->timer = $this->loop->addPeriodicTimer($this->interval, [$this, 'handleHeartbeat']);
             }
         }
     }
@@ -228,11 +228,11 @@ 
 
         $resource = new ShellResource($this, $this->resource);
         $resource->on('open', function(SSH2ResourceInterface $resource) {
-            $this->emit('resource:open', [ $this, $resource ]);
+            $this->emit('resource:open', [$this, $resource]);
         });
         $resource->on('close', function(SSH2ResourceInterface $resource) {
             $this->removeResource($resource->getId());
-            $this->emit('resource:close', [ $this, $resource ]);
+            $this->emit('resource:close', [$this, $resource]);
         });
 
         $this->resources[$resource->getId()] = $resource;
@@ -328,19 +328,19 @@ 
 
             foreach ($parts as &$part)
             {
-                $resource->emit('data', [ $resource, $part ]);
+                $resource->emit('data', [$resource, $part]);
             }
             unset($parts);
             unset($part);
 
             if ($status === 0)
             {
-                $resource->emit('end', [ $resource ]);
+                $resource->emit('end', [$resource]);
                 $resource->close();
             }
             else if ($status > 0)
             {
-                $resource->emit('error', [ $resource, new ReadException($status) ]);
+                $resource->emit('error', [$resource, new ReadException($status)]);
                 $resource->close();
             }
         }

src/SSH/SSH2.php

Spacing +14 added lines, -14 removed lines

@@ -107,17 +107,17 @@ 
 
         if (!$this->conn || !is_resource($this->conn))
         {
-            $this->emit('error', [ $this, new ExecutionException('SSH2 connection could not be established.') ]);
+            $this->emit('error', [$this, new ExecutionException('SSH2 connection could not be established.')]);
             return;
         }
 
         if (!$this->auth->authenticate($this->conn))
         {
-            $this->emit('error', [ $this, new ExecutionException('SSH2 connection could not be authenticated.') ]);
+            $this->emit('error', [$this, new ExecutionException('SSH2 connection could not be authenticated.')]);
             return;
         }
 
-        $this->emit('connect', [ $this ]);
+        $this->emit('connect', [$this]);
     }
 
     /**
@@ -138,15 +138,15 @@ 
 
         foreach ($this->drivers as $driver)
         {
-            $driver->removeListener('connect', [ $this, 'handleConnect' ]);
-            $driver->removeListener('disconnect', [ $this, 'handleDisconnect' ]);
-            $driver->removeListener('error', [ $this, 'handleError' ]);
+            $driver->removeListener('connect', [$this, 'handleConnect']);
+            $driver->removeListener('disconnect', [$this, 'handleDisconnect']);
+            $driver->removeListener('error', [$this, 'handleError']);
         }
 
         $this->conn = null;
         $this->drivers = [];
 
-        $this->emit('disconnect', [ $this ]);
+        $this->emit('disconnect', [$this]);
     }
 
     /**
@@ -188,9 +188,9 @@ 
                 throw new InvalidArgumentException("The driver [$name] is not supported.");
         }
 
-        $driver->on('connect', [ $this, 'handleConnect' ]);
-        $driver->on('disconnect', [ $this, 'handleDisconnect' ]);
-        $driver->on('error', [ $this, 'handleError' ]);
+        $driver->on('connect', [$this, 'handleConnect']);
+        $driver->on('disconnect', [$this, 'handleDisconnect']);
+        $driver->on('error', [$this, 'handleError']);
 
         $this->drivers[$name] = $driver;
 
@@ -203,7 +203,7 @@ 
      */
     public function handleConnect(SSH2DriverInterface $driver)
     {
-        $this->emit('connect:' . $driver->getName(), [ $driver ]);
+        $this->emit('connect:' . $driver->getName(), [$driver]);
     }
 
     /**
@@ -212,7 +212,7 @@ 
      */
     public function handleDisconnect(SSH2DriverInterface $driver)
     {
-        $this->emit('disconnect:' . $driver->getName(), [ $driver ]);
+        $this->emit('disconnect:' . $driver->getName(), [$driver]);
     }
 
     /**
@@ -222,8 +222,8 @@ 
      */
     public function handleError(SSH2DriverInterface $driver, $ex)
     {
-        $this->emit('error:' . $driver->getName(), [ $driver, $ex ]);
-        $this->emit('error', [ $this, $ex ]);
+        $this->emit('error:' . $driver->getName(), [$driver, $ex]);
+        $this->emit('error', [$this, $ex]);
     }
 
     /**