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]);
     }
 
     /**

example/sftp_async_write.php

Indentation +1 added lines, -1 removed lines

@@ -59,7 +59,7 @@
 $ssh2->on('connect', function(SSH2Interface $ssh2) {
     echo "# CONNECTED\n";
     $ssh2->createDriver(SSH2::DRIVER_SFTP)
-         ->connect();
+            ->connect();
 });
 
 $ssh2->on('disconnect', function(SSH2Interface $ssh2) use($loop) {

Spacing +1 added lines, -1 removed lines

@@ -30,7 +30,7 @@
 $ssh2->on('connect:sftp', function(SSH2DriverInterface $sftp) use($loop, $ssh2) {
     echo "# CONNECTED SFTP\n";
 
-    $lines = [ "DAZZLE\n", "IS\n", "AWESOME!\n" ];
+    $lines = ["DAZZLE\n", "IS\n", "AWESOME!\n"];
     $linesPointer = 0;
 
     $file = $sftp->open(__DIR__ . '/_file_write.txt', 'w+');

Braces +2 added lines, -1 removed lines

@@ -37,7 +37,8 @@
     $file->write();
     $file->on('drain', function(SSH2ResourceInterface $file) use(&$lines, &$linesPointer) {
         echo "# PART OF THE DATA HAS BEEN WRITTEN\n";
-        if ($linesPointer < count($lines)) {
+        if ($linesPointer < count($lines))
+        {
             $file->write($lines[$linesPointer++]);
         }
     });

example/ssh_async_multi_command.php

Indentation +1 added lines, -1 removed lines

@@ -67,7 +67,7 @@
 $ssh2->on('connect', function(SSH2Interface $ssh2) {
     echo "# CONNECTED\n";
     $ssh2->createDriver(SSH2::DRIVER_SHELL)
-         ->connect();
+            ->connect();
 });
 
 $ssh2->on('disconnect', function(SSH2Interface $ssh2) use($loop) {

Spacing +1 added lines, -1 removed lines

@@ -45,7 +45,7 @@
 $ssh2->on('connect:shell', function(SSH2DriverInterface $shell) use($ssh2, $loop) {
     echo "# CONNECTED SHELL\n";
 
-    $commands = [ 'ls -la', 'pwd' ];
+    $commands = ['ls -la', 'pwd'];
     $commandsRemain = count($commands);
 
     $shell->on('resource:close', function(SSH2DriverInterface $shell) use(&$commandsRemain) {

Braces +6 added lines, -3 removed lines

@@ -19,7 +19,8 @@ 
 use Dazzle\SSH\SSH2Interface;
 use Dazzle\SSH\SSH2ResourceInterface;
 
-function executeCommand(SSH2DriverInterface $shell, $shellCommand) {
+function executeCommand(SSH2DriverInterface $shell, $shellCommand)
+{
 
     $buffer = '';
     $command = $shell->open();
@@ -49,12 +50,14 @@ 
     $commandsRemain = count($commands);
 
     $shell->on('resource:close', function(SSH2DriverInterface $shell) use(&$commandsRemain) {
-        if (--$commandsRemain === 0) {
+        if (--$commandsRemain === 0)
+        {
             $shell->disconnect();
         }
     });
 
-    foreach ($commands as $command) {
+    foreach ($commands as $command)
+    {
         executeCommand($shell, $command);
     }
 });

example/ssh_async_single_command.php

Indentation +1 added lines, -1 removed lines

@@ -67,7 +67,7 @@
 $ssh2->on('connect', function(SSH2Interface $ssh2) {
     echo "# CONNECTED\n";
     $ssh2->createDriver(SSH2::DRIVER_SHELL)
-         ->connect();
+            ->connect();
 });
 
 $ssh2->on('disconnect', function(SSH2Interface $ssh2) use($loop) {

example/sftp_async_read.php

Indentation +1 added lines, -1 removed lines

@@ -59,7 +59,7 @@
 $ssh2->on('connect', function(SSH2Interface $ssh2) {
     echo "# CONNECTED\n";
     $ssh2->createDriver(SSH2::DRIVER_SFTP)
-         ->connect();
+            ->connect();
 });
 
 $ssh2->on('disconnect', function(SSH2Interface $ssh2) use($loop) {