deployphp / deployer

deps/vendor/react/socket/src/UnixServer.php

Spacing +3 added lines, -3 removed lines

@@ -69,13 +69,13 @@ 
 
         $errno = 0;
         $errstr = '';
-        \set_error_handler(function ($_, $error) use (&$errno, &$errstr) {
+        \set_error_handler(function($_, $error) use (&$errno, &$errstr) {
             // PHP does not seem to report errno/errstr for Unix domain sockets (UDS) right now.
             // This only applies to UDS server sockets, see also https://3v4l.org/NAhpr.
             // Parse PHP warning message containing unknown error, HHVM reports proper info at least.
             if (\preg_match('/\(([^\)]+)\)|\[(\d+)\]: (.*)/', $error, $match)) {
                 $errstr = isset($match[3]) ? $match['3'] : $match[1];
-                $errno = isset($match[2]) ? (int)$match[2] : 0;
+                $errno = isset($match[2]) ? (int) $match[2] : 0;
             }
         });
 
@@ -126,7 +126,7 @@ 
         }
 
         $that = $this;
-        $this->loop->addReadStream($this->master, function ($master) use ($that) {
+        $this->loop->addReadStream($this->master, function($master) use ($that) {
             try {
                 $newSocket = SocketServer::accept($master);
             } catch (\RuntimeException $e) {

deps/vendor/react/socket/src/Connector.php

Spacing +3 added lines, -3 removed lines

@@ -57,7 +57,7 @@ 
     {
         // swap arguments for legacy constructor signature
         if (($context instanceof LoopInterface || $context === null) && (\func_num_args() <= 1 || \is_array($loop))) {
-            $swap = $loop === null ? array(): $loop;
+            $swap = $loop === null ? array() : $loop;
             $loop = $context;
             $context = $swap;
         }
@@ -78,7 +78,7 @@ 
         );
 
         if ($context['timeout'] === true) {
-            $context['timeout'] = (float)\ini_get("default_socket_timeout");
+            $context['timeout'] = (float) \ini_get("default_socket_timeout");
         }
 
         if ($context['tcp'] instanceof ConnectorInterface) {
@@ -164,7 +164,7 @@ 
     {
         $scheme = 'tcp';
         if (\strpos($uri, '://') !== false) {
-            $scheme = (string)\substr($uri, 0, \strpos($uri, '://'));
+            $scheme = (string) \substr($uri, 0, \strpos($uri, '://'));
         }
 
         if (!isset($this->connectors[$scheme])) {

deps/vendor/react/socket/src/Server.php

Spacing +2 added lines, -2 removed lines

@@ -88,10 +88,10 @@
         $this->server = $server;
 
         $that = $this;
-        $server->on('connection', function (ConnectionInterface $conn) use ($that) {
+        $server->on('connection', function(ConnectionInterface $conn) use ($that) {
             $that->emit('connection', array($conn));
         });
-        $server->on('error', function (Exception $error) use ($that) {
+        $server->on('error', function(Exception $error) use ($that) {
             $that->emit('error', array($error));
         });
     }

deps/vendor/react/socket/src/HappyEyeBallsConnectionBuilder.php

Spacing +13 added lines, -13 removed lines

@@ -66,9 +66,9 @@ 
     public function connect()
     {
         $that = $this;
-        return new Promise\Promise(function ($resolve, $reject) use ($that) {
-            $lookupResolve = function ($type) use ($that, $resolve, $reject) {
-                return function (array $ips) use ($that, $type, $resolve, $reject) {
+        return new Promise\Promise(function($resolve, $reject) use ($that) {
+            $lookupResolve = function($type) use ($that, $resolve, $reject) {
+                return function(array $ips) use ($that, $type, $resolve, $reject) {
                     unset($that->resolverPromises[$type]);
                     $that->resolved[$type] = true;
 
@@ -82,29 +82,29 @@ 
             };
 
             $that->resolverPromises[Message::TYPE_AAAA] = $that->resolve(Message::TYPE_AAAA, $reject)->then($lookupResolve(Message::TYPE_AAAA));
-            $that->resolverPromises[Message::TYPE_A] = $that->resolve(Message::TYPE_A, $reject)->then(function (array $ips) use ($that) {
+            $that->resolverPromises[Message::TYPE_A] = $that->resolve(Message::TYPE_A, $reject)->then(function(array $ips) use ($that) {
                 // happy path: IPv6 has resolved already (or could not resolve), continue with IPv4 addresses
                 if ($that->resolved[Message::TYPE_AAAA] === true || !$ips) {
                     return $ips;
                 }
 
                 // Otherwise delay processing IPv4 lookup until short timer passes or IPv6 resolves in the meantime
-                $deferred = new Promise\Deferred(function () use (&$ips) {
+                $deferred = new Promise\Deferred(function() use (&$ips) {
                     // discard all IPv4 addresses if cancelled
                     $ips = array();
                 });
-                $timer = $that->loop->addTimer($that::RESOLUTION_DELAY, function () use ($deferred, $ips) {
+                $timer = $that->loop->addTimer($that::RESOLUTION_DELAY, function() use ($deferred, $ips) {
                     $deferred->resolve($ips);
                 });
 
-                $that->resolverPromises[Message::TYPE_AAAA]->then(function () use ($that, $timer, $deferred, &$ips) {
+                $that->resolverPromises[Message::TYPE_AAAA]->then(function() use ($that, $timer, $deferred, &$ips) {
                     $that->loop->cancelTimer($timer);
                     $deferred->resolve($ips);
                 });
 
                 return $deferred->promise();
             })->then($lookupResolve(Message::TYPE_A));
-        }, function ($_, $reject) use ($that) {
+        }, function($_, $reject) use ($that) {
             $reject(new \RuntimeException(
                 'Connection to ' . $that->uri . ' cancelled' . (!$that->connectionPromises ? ' during DNS lookup' : '') . ' (ECONNABORTED)',
                 \defined('SOCKET_ECONNABORTED') ? \SOCKET_ECONNABORTED : 103
@@ -126,7 +126,7 @@ 
     public function resolve($type, $reject)
     {
         $that = $this;
-        return $that->resolver->resolveAll($that->host, $type)->then(null, function (\Exception $e) use ($type, $reject, $that) {
+        return $that->resolver->resolveAll($that->host, $type)->then(null, function(\Exception $e) use ($type, $reject, $that) {
             unset($that->resolverPromises[$type]);
             $that->resolved[$type] = true;
 
@@ -170,13 +170,13 @@ 
         $index = \key($this->connectionPromises);
 
         $that = $this;
-        $that->connectionPromises[$index]->then(function ($connection) use ($that, $index, $resolve) {
+        $that->connectionPromises[$index]->then(function($connection) use ($that, $index, $resolve) {
             unset($that->connectionPromises[$index]);
 
             $that->cleanUp();
 
             $resolve($connection);
-        }, function (\Exception $e) use ($that, $index, $ip, $resolve, $reject) {
+        }, function(\Exception $e) use ($that, $index, $ip, $resolve, $reject) {
             unset($that->connectionPromises[$index]);
 
             $that->failureCount++;
@@ -218,7 +218,7 @@ 
         // Allow next connection attempt in 100ms: https://tools.ietf.org/html/rfc8305#section-5
         // Only start timer when more IPs are queued or when DNS query is still pending (might add more IPs)
         if ($this->nextAttemptTimer === null && (\count($this->connectQueue) > 0 || $this->resolved[Message::TYPE_A] === false || $this->resolved[Message::TYPE_AAAA] === false)) {
-            $this->nextAttemptTimer = $this->loop->addTimer(self::CONNECTION_ATTEMPT_DELAY, function () use ($that, $resolve, $reject) {
+            $this->nextAttemptTimer = $this->loop->addTimer(self::CONNECTION_ATTEMPT_DELAY, function() use ($that, $resolve, $reject) {
                 $that->nextAttemptTimer = null;
 
                 if ($that->connectQueue) {
@@ -329,6 +329,6 @@ 
             $message = ': ' . $message;
         }
 
-        return 'Connection to ' . $this->uri . ' failed'  . $message;
+        return 'Connection to ' . $this->uri . ' failed' . $message;
     }
 }

deps/vendor/react/socket/src/Connection.php

Spacing +2 added lines, -2 removed lines

@@ -160,12 +160,12 @@
             // remove trailing colon from address for HHVM < 3.19: https://3v4l.org/5C1lo
             // note that technically ":" is a valid address, so keep this in place otherwise
             if (\substr($address, -1) === ':' && \defined('HHVM_VERSION_ID') && \HHVM_VERSION_ID < 31900) {
-                $address = (string)\substr($address, 0, -1); // @codeCoverageIgnore
+                $address = (string) \substr($address, 0, -1); // @codeCoverageIgnore
             }
 
             // work around unknown addresses should return null value: https://3v4l.org/5C1lo and https://bugs.php.net/bug.php?id=74556
             // PHP uses "\0" string and HHVM uses empty string (colon removed above)
-            if ($address === '' || $address[0] === "\x00" ) {
+            if ($address === '' || $address[0] === "\x00") {
                 return null; // @codeCoverageIgnore
             }
 

deps/vendor/react/socket/src/SecureServer.php

Spacing +5 added lines, -5 removed lines

@@ -142,10 +142,10 @@ 
         $this->context = $context;
 
         $that = $this;
-        $this->tcp->on('connection', function ($connection) use ($that) {
+        $this->tcp->on('connection', function($connection) use ($that) {
             $that->handleConnection($connection);
         });
-        $this->tcp->on('error', function ($error) use ($that) {
+        $this->tcp->on('error', function($error) use ($that) {
             $that->emit('error', array($error));
         });
     }
@@ -157,7 +157,7 @@ 
             return null;
         }
 
-        return \str_replace('tcp://' , 'tls://', $address);
+        return \str_replace('tcp://', 'tls://', $address);
     }
 
     public function pause()
@@ -193,10 +193,10 @@ 
         $that = $this;
 
         $this->encryption->enable($connection)->then(
-            function ($conn) use ($that) {
+            function($conn) use ($that) {
                 $that->emit('connection', array($conn));
             },
-            function ($error) use ($that, $connection, $remote) {
+            function($error) use ($that, $connection, $remote) {
                 $error = new \RuntimeException(
                     'Connection from ' . $remote . ' failed during TLS handshake: ' . $error->getMessage(),
                     $error->getCode()

deps/vendor/react/socket/src/TcpServer.php

Spacing +2 added lines, -2 removed lines

@@ -137,7 +137,7 @@ 
         $this->loop = $loop ?: Loop::get();
 
         // a single port has been given => assume localhost
-        if ((string)(int)$uri === (string)$uri) {
+        if ((string) (int) $uri === (string) $uri) {
             $uri = '127.0.0.1:' . $uri;
         }
 
@@ -229,7 +229,7 @@ 
         }
 
         $that = $this;
-        $this->loop->addReadStream($this->master, function ($master) use ($that) {
+        $this->loop->addReadStream($this->master, function($master) use ($that) {
             try {
                 $newSocket = SocketServer::accept($master);
             } catch (\RuntimeException $e) {

deps/vendor/react/socket/src/SecureConnector.php

Spacing +5 added lines, -5 removed lines

@@ -55,7 +55,7 @@ 
         /** @var \React\Promise\PromiseInterface<ConnectionInterface> $promise */
         $promise = $this->connector->connect(
             \str_replace('tls://', '', $uri)
-        )->then(function (ConnectionInterface $connection) use ($context, $encryption, $uri, &$promise, &$connected) {
+        )->then(function(ConnectionInterface $connection) use ($context, $encryption, $uri, &$promise, &$connected) {
             // (unencrypted) TCP/IP connection succeeded
             $connected = true;
 
@@ -70,7 +70,7 @@ 
             }
 
             // try to enable encryption
-            return $promise = $encryption->enable($connection)->then(null, function ($error) use ($connection, $uri) {
+            return $promise = $encryption->enable($connection)->then(null, function($error) use ($connection, $uri) {
                 // establishing encryption failed => close invalid connection and return error
                 $connection->close();
 
@@ -79,7 +79,7 @@ 
                     $error->getCode()
                 );
             });
-        }, function (\Exception $e) use ($uri) {
+        }, function(\Exception $e) use ($uri) {
             if ($e instanceof \RuntimeException) {
                 $message = \preg_replace('/^Connection to [^ ]+/', '', $e->getMessage());
                 $e = new \RuntimeException(
@@ -113,10 +113,10 @@ 
         });
 
         return new \React\Promise\Promise(
-            function ($resolve, $reject) use ($promise) {
+            function($resolve, $reject) use ($promise) {
                 $promise->then($resolve, $reject);
             },
-            function ($_, $reject) use (&$promise, $uri, &$connected) {
+            function($_, $reject) use (&$promise, $uri, &$connected) {
                 if ($connected) {
                     $reject(new \RuntimeException(
                         'Connection to ' . $uri . ' cancelled during TLS handshake (ECONNABORTED)',

deps/vendor/react/socket/src/StreamEncryption.php

Spacing +4 added lines, -4 removed lines

@@ -66,7 +66,7 @@ 
         // TODO: add write() event to make sure we're not sending any excessive data
 
         // cancelling this leaves this stream in an inconsistent state…
-        $deferred = new Deferred(function () {
+        $deferred = new Deferred(function() {
             throw new \RuntimeException();
         });
 
@@ -81,7 +81,7 @@ 
         }
 
         $that = $this;
-        $toggleCrypto = function () use ($socket, $deferred, $toggle, $method, $that) {
+        $toggleCrypto = function() use ($socket, $deferred, $toggle, $method, $that) {
             $that->toggleCrypto($socket, $deferred, $toggle, $method);
         };
 
@@ -93,7 +93,7 @@ 
 
         $loop = $this->loop;
 
-        return $deferred->promise()->then(function () use ($stream, $socket, $loop, $toggle) {
+        return $deferred->promise()->then(function() use ($stream, $socket, $loop, $toggle) {
             $loop->removeReadStream($socket);
 
             $stream->encryptionEnabled = $toggle;
@@ -118,7 +118,7 @@ 
     public function toggleCrypto($socket, Deferred $deferred, $toggle, $method)
     {
         $error = null;
-        \set_error_handler(function ($_, $errstr) use (&$error) {
+        \set_error_handler(function($_, $errstr) use (&$error) {
             $error = \str_replace(array("\r", "\n"), ' ', $errstr);
 
             // remove useless function name from error message