deployphp / deployer

deps/vendor/react/stream/src/DuplexResourceStream.php

Indentation +1 added lines, -1 removed lines

@@ -47,7 +47,7 @@
     public function __construct($stream, $loop = null, $readChunkSize = null, $buffer = null)
     {
         if (!\is_resource($stream) || \get_resource_type($stream) !== "stream") {
-             throw new InvalidArgumentException('First parameter must be a valid stream resource');
+                throw new InvalidArgumentException('First parameter must be a valid stream resource');
         }
 
         // ensure resource is opened for reading and wrting (fopen mode must contain "+")

Spacing +4 added lines, -4 removed lines

@@ -87,18 +87,18 @@ 
 
         $this->stream = $stream;
         $this->loop = $loop ?: Loop::get();
-        $this->bufferSize = ($readChunkSize === null) ? 65536 : (int)$readChunkSize;
+        $this->bufferSize = ($readChunkSize === null) ? 65536 : (int) $readChunkSize;
         $this->buffer = $buffer;
 
         $that = $this;
 
-        $this->buffer->on('error', function ($error) use ($that) {
+        $this->buffer->on('error', function($error) use ($that) {
             $that->emit('error', array($error));
         });
 
         $this->buffer->on('close', array($this, 'close'));
 
-        $this->buffer->on('drain', function () use ($that) {
+        $this->buffer->on('drain', function() use ($that) {
             $that->emit('drain');
         });
 
@@ -185,7 +185,7 @@ 
     public function handleData($stream)
     {
         $error = null;
-        \set_error_handler(function ($errno, $errstr, $errfile, $errline) use (&$error) {
+        \set_error_handler(function($errno, $errstr, $errfile, $errline) use (&$error) {
             $error = new \ErrorException(
                 $errstr,
                 0,

deps/vendor/react/dns/src/Resolver/Resolver.php

Spacing +4 added lines, -4 removed lines

@@ -21,7 +21,7 @@ 
 
     public function resolve($domain)
     {
-        return $this->resolveAll($domain, Message::TYPE_A)->then(function (array $ips) {
+        return $this->resolveAll($domain, Message::TYPE_A)->then(function(array $ips) {
             return $ips[array_rand($ips)];
         });
     }
@@ -33,7 +33,7 @@ 
 
         return $this->executor->query(
             $query
-        )->then(function (Message $response) use ($query, $that) {
+        )->then(function(Message $response) use ($query, $that) {
             return $that->extractValues($query, $response);
         });
     }
@@ -133,14 +133,14 @@ 
     private function filterByField(array $answers, $field, $value)
     {
         $value = strtolower($value);
-        return array_filter($answers, function ($answer) use ($field, $value) {
+        return array_filter($answers, function($answer) use ($field, $value) {
             return $value === strtolower($answer->$field);
         });
     }
 
     private function mapRecordData(array $records)
     {
-        return array_map(function ($record) {
+        return array_map(function($record) {
             return $record->data;
         }, $records);
     }

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'));