deployphp / deployer

deps/vendor/react/dns/src/Protocol/Parser.php

Spacing +2 added lines, -2 removed lines

@@ -174,7 +174,7 @@ 
             $rdata = array();
             while ($consumed < $expected) {
                 $len = ord($data[$consumed]);
-                $rdata[] = (string)substr($data, $consumed + 1, $len);
+                $rdata[] = (string) substr($data, $consumed + 1, $len);
                 $consumed += $len + 1;
             }
         } elseif (Message::TYPE_MX === $type) {
@@ -291,7 +291,7 @@ 
             \implode(
                 '.',
                 \array_map(
-                    function ($label) {
+                    function($label) {
                         return \addcslashes($label, "\0..\40.\177");
                     },
                     $labels

deps/vendor/react/dns/src/Query/SelectiveTransportExecutor.php

Spacing +3 added lines, -3 removed lines

@@ -66,10 +66,10 @@ 
         $stream = $this->streamExecutor;
         $pending = $this->datagramExecutor->query($query);
 
-        return new Promise(function ($resolve, $reject) use (&$pending, $stream, $query) {
+        return new Promise(function($resolve, $reject) use (&$pending, $stream, $query) {
             $pending->then(
                 $resolve,
-                function ($e) use (&$pending, $stream, $query, $resolve, $reject) {
+                function($e) use (&$pending, $stream, $query, $resolve, $reject) {
                     if ($e->getCode() === (\defined('SOCKET_EMSGSIZE') ? \SOCKET_EMSGSIZE : 90)) {
                         $pending = $stream->query($query)->then($resolve, $reject);
                     } else {
@@ -77,7 +77,7 @@ 
                     }
                 }
             );
-        }, function () use (&$pending) {
+        }, function() use (&$pending) {
             $pending->cancel();
             $pending = null;
         });

deps/vendor/react/dns/src/Query/FallbackExecutor.php

Spacing +4 added lines, -4 removed lines

@@ -21,8 +21,8 @@ 
         $fallback = $this->fallback;
         $promise = $this->executor->query($query);
 
-        return new Promise(function ($resolve, $reject) use (&$promise, $fallback, $query, &$cancelled) {
-            $promise->then($resolve, function (\Exception $e1) use ($fallback, $query, $resolve, $reject, &$cancelled, &$promise) {
+        return new Promise(function($resolve, $reject) use (&$promise, $fallback, $query, &$cancelled) {
+            $promise->then($resolve, function(\Exception $e1) use ($fallback, $query, $resolve, $reject, &$cancelled, &$promise) {
                 // reject if primary resolution rejected due to cancellation
                 if ($cancelled) {
                     $reject($e1);
@@ -30,7 +30,7 @@ 
                 }
 
                 // start fallback query if primary query rejected
-                $promise = $fallback->query($query)->then($resolve, function (\Exception $e2) use ($e1, $reject) {
+                $promise = $fallback->query($query)->then($resolve, function(\Exception $e2) use ($e1, $reject) {
                     $append = $e2->getMessage();
                     if (($pos = strpos($append, ':')) !== false) {
                         $append = substr($append, $pos + 2);
@@ -40,7 +40,7 @@ 
                     $reject(new \RuntimeException($e1->getMessage() . '. ' . $append));
                 });
             });
-        }, function () use (&$promise, &$cancelled) {
+        }, function() use (&$promise, &$cancelled) {
             // cancel pending query (primary or fallback)
             $cancelled = true;
             $promise->cancel();

deps/vendor/react/dns/src/Query/CachingExecutor.php

Spacing +5 added lines, -5 removed lines

@@ -32,9 +32,9 @@ 
         $executor = $this->executor;
 
         $pending = $cache->get($id);
-        return new Promise(function ($resolve, $reject) use ($query, $id, $cache, $executor, &$pending, $that) {
+        return new Promise(function($resolve, $reject) use ($query, $id, $cache, $executor, &$pending, $that) {
             $pending->then(
-                function ($message) use ($query, $id, $cache, $executor, &$pending, $that) {
+                function($message) use ($query, $id, $cache, $executor, &$pending, $that) {
                     // return cached response message on cache hit
                     if ($message !== null) {
                         return $message;
@@ -42,7 +42,7 @@ 
 
                     // perform DNS lookup if not already cached
                     return $pending = $executor->query($query)->then(
-                        function (Message $message) use ($cache, $id, $that) {
+                        function(Message $message) use ($cache, $id, $that) {
                             // DNS response message received => store in cache when not truncated and return
                             if (!$message->tc) {
                                 $cache->set($id, $message, $that->ttl($message));
@@ -52,11 +52,11 @@ 
                         }
                     );
                 }
-            )->then($resolve, function ($e) use ($reject, &$pending) {
+            )->then($resolve, function($e) use ($reject, &$pending) {
                 $reject($e);
                 $pending = null;
             });
-        }, function ($_, $reject) use (&$pending, $query) {
+        }, function($_, $reject) use (&$pending, $query) {
             $reject(new \RuntimeException('DNS query for ' . $query->describe() . ' has been cancelled'));
             $pending->cancel();
             $pending = null;

deps/vendor/react/dns/src/Query/CoopExecutor.php

Spacing +8 added lines, -8 removed lines

@@ -58,11 +58,11 @@ 
             $this->pending[$key] = $promise;
             $this->counts[$key] = 1;
 
-            $pending =& $this->pending;
-            $counts =& $this->counts;
-            $promise->then(function () use ($key, &$pending, &$counts) {
+            $pending = & $this->pending;
+            $counts = & $this->counts;
+            $promise->then(function() use ($key, &$pending, &$counts) {
                 unset($pending[$key], $counts[$key]);
-            }, function () use ($key, &$pending, &$counts) {
+            }, function() use ($key, &$pending, &$counts) {
                 unset($pending[$key], $counts[$key]);
             });
         }
@@ -70,11 +70,11 @@ 
         // Return a child promise awaiting the pending query.
         // Cancelling this child promise should only cancel the pending query
         // when no other child promise is awaiting the same query.
-        $pending =& $this->pending;
-        $counts =& $this->counts;
-        return new Promise(function ($resolve, $reject) use ($promise) {
+        $pending = & $this->pending;
+        $counts = & $this->counts;
+        return new Promise(function($resolve, $reject) use ($promise) {
             $promise->then($resolve, $reject);
-        }, function () use (&$promise, $key, $query, &$pending, &$counts) {
+        }, function() use (&$promise, $key, $query, &$pending, &$counts) {
             if (--$counts[$key] < 1) {
                 unset($pending[$key], $counts[$key]);
                 $promise->cancel();

deps/vendor/react/dns/src/Query/RetryExecutor.php

Spacing +3 added lines, -3 removed lines

@@ -23,19 +23,19 @@
 
     public function tryQuery(Query $query, $retries)
     {
-        $deferred = new Deferred(function () use (&$promise) {
+        $deferred = new Deferred(function() use (&$promise) {
             if ($promise instanceof PromiseInterface && \method_exists($promise, 'cancel')) {
                 $promise->cancel();
             }
         });
 
-        $success = function ($value) use ($deferred, &$errorback) {
+        $success = function($value) use ($deferred, &$errorback) {
             $errorback = null;
             $deferred->resolve($value);
         };
 
         $executor = $this->executor;
-        $errorback = function ($e) use ($deferred, &$promise, $query, $success, &$errorback, &$retries, $executor) {
+        $errorback = function($e) use ($deferred, &$promise, $query, $success, &$errorback, &$retries, $executor) {
             if (!$e instanceof TimeoutException) {
                 $errorback = null;
                 $deferred->reject($e);

deps/vendor/react/dns/src/Query/TimeoutExecutor.php

Spacing +5 added lines, -5 removed lines

@@ -34,15 +34,15 @@ 
 
         $loop = $this->loop;
         $time = $this->timeout;
-        return new Promise(function ($resolve, $reject) use ($loop, $time, $promise, $query) {
+        return new Promise(function($resolve, $reject) use ($loop, $time, $promise, $query) {
             $timer = null;
-            $promise = $promise->then(function ($v) use (&$timer, $loop, $resolve) {
+            $promise = $promise->then(function($v) use (&$timer, $loop, $resolve) {
                 if ($timer) {
                     $loop->cancelTimer($timer);
                 }
                 $timer = false;
                 $resolve($v);
-            }, function ($v) use (&$timer, $loop, $reject) {
+            }, function($v) use (&$timer, $loop, $reject) {
                 if ($timer) {
                     $loop->cancelTimer($timer);
                 }
@@ -56,7 +56,7 @@ 
             }
 
             // start timeout timer which will cancel the pending promise
-            $timer = $loop->addTimer($time, function () use ($time, &$promise, $reject, $query) {
+            $timer = $loop->addTimer($time, function() use ($time, &$promise, $reject, $query) {
                 $reject(new TimeoutException(
                     'DNS query for ' . $query->describe() . ' timed out'
                 ));
@@ -67,7 +67,7 @@ 
                 $promise->cancel();
                 $promise = null;
             });
-        }, function () use (&$promise) {
+        }, function() use (&$promise) {
             // Cancelling this promise will cancel the pending query, thus triggering the rejection logic above.
             // Avoid garbage references in call stack by passing pending promise by reference.
             assert(\method_exists($promise, 'cancel'));

deps/vendor/react/dns/src/Query/TcpTransportExecutor.php

Spacing +6 added lines, -6 removed lines

@@ -180,7 +180,7 @@ 
             $socket = @\stream_socket_client($this->nameserver, $errno, $errstr, 0, \STREAM_CLIENT_CONNECT | \STREAM_CLIENT_ASYNC_CONNECT);
             if ($socket === false) {
                 return \React\Promise\reject(new \RuntimeException(
-                    'DNS query for ' . $query->describe() . ' failed: Unable to connect to DNS server ' . $this->nameserver . ' ('  . $errstr . ')',
+                    'DNS query for ' . $query->describe() . ' failed: Unable to connect to DNS server ' . $this->nameserver . ' (' . $errstr . ')',
                     $errno
                 ));
             }
@@ -205,9 +205,9 @@ 
             $this->loop->addWriteStream($this->socket, array($this, 'handleWritable'));
         }
 
-        $names =& $this->names;
+        $names = & $this->names;
         $that = $this;
-        $deferred = new Deferred(function () use ($that, &$names, $request) {
+        $deferred = new Deferred(function() use ($that, &$names, $request) {
             // remove from list of pending names, but remember pending query
             $name = $names[$request->id];
             unset($names[$request->id]);
@@ -252,7 +252,7 @@ 
 
         $errno = 0;
         $errstr = '';
-        \set_error_handler(function ($_, $error) use (&$errno, &$errstr) {
+        \set_error_handler(function($_, $error) use (&$errno, &$errstr) {
             // Match errstr from PHP's warning message.
             // fwrite(): Send of 327712 bytes failed with errno=32 Broken pipe
             \preg_match('/errno=(\d+) (.+)/', $error, $m);
@@ -306,7 +306,7 @@ 
             }
 
             $data = \substr($this->readBuffer, 2, $length);
-            $this->readBuffer = (string)substr($this->readBuffer, $length + 2);
+            $this->readBuffer = (string) substr($this->readBuffer, $length + 2);
 
             try {
                 $response = $this->parser->parseMessage($data);
@@ -374,7 +374,7 @@ 
     {
         if ($this->idleTimer === null && !$this->names) {
             $that = $this;
-            $this->idleTimer = $this->loop->addTimer($this->idlePeriod, function () use ($that) {
+            $this->idleTimer = $this->loop->addTimer($this->idlePeriod, function() use ($that) {
                 $that->closeError('Idle timeout');
             });
         }

deps/vendor/react/dns/src/Query/UdpTransportExecutor.php

Spacing +5 added lines, -5 removed lines

@@ -138,7 +138,7 @@ 
         $socket = @\stream_socket_client($this->nameserver, $errno, $errstr, 0);
         if ($socket === false) {
             return \React\Promise\reject(new \RuntimeException(
-                'DNS query for ' . $query->describe() . ' failed: Unable to connect to DNS server ' . $this->nameserver . ' ('  . $errstr . ')',
+                'DNS query for ' . $query->describe() . ' failed: Unable to connect to DNS server ' . $this->nameserver . ' (' . $errstr . ')',
                 $errno
             ));
         }
@@ -146,7 +146,7 @@ 
         // set socket to non-blocking and immediately try to send (fill write buffer)
         \stream_set_blocking($socket, false);
 
-        \set_error_handler(function ($_, $error) use (&$errno, &$errstr) {
+        \set_error_handler(function($_, $error) use (&$errno, &$errstr) {
             // Write may potentially fail, but most common errors are already caught by connection check above.
             // Among others, macOS is known to report here when trying to send to broadcast address.
             // This can also be reproduced by writing data exceeding `stream_set_chunk_size()` to a server refusing UDP data.
@@ -162,13 +162,13 @@ 
 
         if ($written !== \strlen($queryData)) {
             return \React\Promise\reject(new \RuntimeException(
-                'DNS query for ' . $query->describe() . ' failed: Unable to send query to DNS server ' . $this->nameserver . ' ('  . $errstr . ')',
+                'DNS query for ' . $query->describe() . ' failed: Unable to send query to DNS server ' . $this->nameserver . ' (' . $errstr . ')',
                 $errno
             ));
         }
 
         $loop = $this->loop;
-        $deferred = new Deferred(function () use ($loop, $socket, $query) {
+        $deferred = new Deferred(function() use ($loop, $socket, $query) {
             // cancellation should remove socket from loop and close socket
             $loop->removeReadStream($socket);
             \fclose($socket);
@@ -179,7 +179,7 @@ 
         $max = $this->maxPacketSize;
         $parser = $this->parser;
         $nameserver = $this->nameserver;
-        $loop->addReadStream($socket, function ($socket) use ($loop, $deferred, $query, $parser, $request, $max, $nameserver) {
+        $loop->addReadStream($socket, function($socket) use ($loop, $deferred, $query, $parser, $request, $max, $nameserver) {
             // try to read a single data packet from the DNS server
             // ignoring any errors, this is uses UDP packets and not a stream of data
             $data = @\fread($socket, $max);