deployphp / deployer

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

Spacing +12 added lines, -12 removed lines

@@ -67,9 +67,9 @@ 
     {
         $timer = null;
         $that = $this;
-        return new Promise\Promise(function ($resolve, $reject) use ($that, &$timer) {
-            $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, &$timer) {
+            $lookupResolve = function($type) use ($that, $resolve, $reject) {
+                return function(array $ips) use ($that, $type, $resolve, $reject) {
                     unset($that->resolverPromises[$type]);
                     $that->resolved[$type] = true;
 
@@ -83,7 +83,7 @@ 
             };
 
             $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, &$timer) {
+            $that->resolverPromises[Message::TYPE_A] = $that->resolve(Message::TYPE_A, $reject)->then(function(array $ips) use ($that, &$timer) {
                 // happy path: IPv6 has resolved already (or could not resolve), continue with IPv4 addresses
                 if ($that->resolved[Message::TYPE_AAAA] === true || !$ips) {
                     return $ips;
@@ -91,18 +91,18 @@ 
 
                 // Otherwise delay processing IPv4 lookup until short timer passes or IPv6 resolves in the meantime
                 $deferred = new Promise\Deferred();
-                $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, &$timer) {
+        }, function($_, $reject) use ($that, &$timer) {
             $reject(new \RuntimeException(
                 'Connection to ' . $that->uri . ' cancelled' . (!$that->connectionPromises ? ' during DNS lookup' : '') . ' (ECONNABORTED)',
                 \defined('SOCKET_ECONNABORTED') ? \SOCKET_ECONNABORTED : 103
@@ -127,7 +127,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;
 
@@ -171,13 +171,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++;
@@ -219,7 +219,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) {
@@ -328,6 +328,6 @@ 
             $message = ': ' . $message;
         }
 
-        return 'Connection to ' . $this->uri . ' failed'  . $message;
+        return 'Connection to ' . $this->uri . ' failed' . $message;
     }
 }

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

Spacing +5 added lines, -5 removed lines

@@ -45,7 +45,7 @@ 
         $connected = false;
         $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;
 
@@ -60,7 +60,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();
 
@@ -69,7 +69,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(
@@ -103,10 +103,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/TimeoutConnector.php

Spacing +1 added lines, -1 removed lines

@@ -37,7 +37,7 @@
      */
     private static function handler($uri)
     {
-        return function (\Exception $e) use ($uri) {
+        return function(\Exception $e) use ($uri) {
             if ($e instanceof TimeoutException) {
                 throw new \RuntimeException(
                     'Connection to ' . $uri . ' timed out after ' . $e->getTimeout() . ' seconds (ETIMEDOUT)',

deps/vendor/react/http/src/Client/Request.php

Spacing +1 added lines, -1 removed lines

@@ -57,7 +57,7 @@
 
         $promise = $this->connect();
         $promise->then(
-            function (ConnectionInterface $stream) use ($requestData, &$streamRef, &$stateRef, &$pendingWrites, $that) {
+            function(ConnectionInterface $stream) use ($requestData, &$streamRef, &$stateRef, &$pendingWrites, $that) {
                 $streamRef = $stream;
 
                 $stream->on('drain', array($that, 'handleDrain'));

deps/vendor/react/http/src/Client/RequestData.php

Spacing +4 added lines, -4 removed lines

@@ -28,7 +28,7 @@ 
 
         $defaults = array_merge(
             array(
-                'Host'          => $this->getHost().$port,
+                'Host'          => $this->getHost() . $port,
                 'User-Agent'    => 'ReactPHP/1',
             ),
             $connectionHeaders,
@@ -73,7 +73,7 @@ 
 
         // assume "/" path by default, but allow "OPTIONS *"
         if ($path === null) {
-            $path = ($this->method === 'OPTIONS' && $queryString === null) ? '*': '/';
+            $path = ($this->method === 'OPTIONS' && $queryString === null) ? '*' : '/';
         }
         if ($queryString !== null) {
             $path .= '?' . $queryString;
@@ -94,7 +94,7 @@ 
         $data = '';
         $data .= "{$this->method} {$this->getPath()} HTTP/{$this->protocolVersion}\r\n";
         foreach ($headers as $name => $values) {
-            foreach ((array)$values as $value) {
+            foreach ((array) $values as $value) {
                 $data .= "$name: $value\r\n";
             }
         }
@@ -119,7 +119,7 @@ 
     {
         if (null !== $auth = $this->getUrlUserPass()) {
             return array(
-                'Authorization' => 'Basic ' . base64_encode($auth['user'].':'.$auth['pass']),
+                'Authorization' => 'Basic ' . base64_encode($auth['user'] . ':' . $auth['pass']),
             );
         }
 

deps/vendor/react/http/src/Io/Transaction.php

Spacing +10 added lines, -10 removed lines

@@ -67,7 +67,7 @@ 
 
     public function send(RequestInterface $request)
     {
-        $deferred = new Deferred(function () use (&$deferred) {
+        $deferred = new Deferred(function() use (&$deferred) {
             if (isset($deferred->pending)) {
                 $deferred->pending->cancel();
                 unset($deferred->pending);
@@ -77,11 +77,11 @@ 
         $deferred->numRequests = 0;
 
         // use timeout from options or default to PHP's default_socket_timeout (60)
-        $timeout = (float)($this->timeout !== null ? $this->timeout : ini_get("default_socket_timeout"));
+        $timeout = (float) ($this->timeout !== null ? $this->timeout : ini_get("default_socket_timeout"));
 
         $loop = $this->loop;
         $this->next($request, $deferred)->then(
-            function (ResponseInterface $response) use ($deferred, $loop, &$timeout) {
+            function(ResponseInterface $response) use ($deferred, $loop, &$timeout) {
                 if (isset($deferred->timeout)) {
                     $loop->cancelTimer($deferred->timeout);
                     unset($deferred->timeout);
@@ -89,7 +89,7 @@ 
                 $timeout = -1;
                 $deferred->resolve($response);
             },
-            function ($e) use ($deferred, $loop, &$timeout) {
+            function($e) use ($deferred, $loop, &$timeout) {
                 if (isset($deferred->timeout)) {
                     $loop->cancelTimer($deferred->timeout);
                     unset($deferred->timeout);
@@ -106,7 +106,7 @@ 
         $body = $request->getBody();
         if ($body instanceof ReadableStreamInterface && $body->isReadable()) {
             $that = $this;
-            $body->on('close', function () use ($that, $deferred, &$timeout) {
+            $body->on('close', function() use ($that, $deferred, &$timeout) {
                 if ($timeout >= 0) {
                     $that->applyTimeout($deferred, $timeout);
                 }
@@ -126,7 +126,7 @@ 
      */
     public function applyTimeout(Deferred $deferred, $timeout)
     {
-        $deferred->timeout = $this->loop->addTimer($timeout, function () use ($timeout, $deferred) {
+        $deferred->timeout = $this->loop->addTimer($timeout, function() use ($timeout, $deferred) {
             $deferred->reject(new \RuntimeException(
                 'Request timed out after ' . $timeout . ' seconds'
             ));
@@ -147,7 +147,7 @@ 
         $promise = $this->sender->send($request);
 
         if (!$this->streaming) {
-            $promise = $promise->then(function ($response) use ($deferred, $that) {
+            $promise = $promise->then(function($response) use ($deferred, $that) {
                 return $that->bufferResponse($response, $deferred);
             });
         }
@@ -155,7 +155,7 @@ 
         $deferred->pending = $promise;
 
         return $promise->then(
-            function (ResponseInterface $response) use ($request, $that, $deferred) {
+            function(ResponseInterface $response) use ($request, $that, $deferred) {
                 return $that->onResponse($response, $request, $deferred);
             }
         );
@@ -187,10 +187,10 @@ 
         // buffer stream and resolve with buffered body
         $maximumSize = $this->maximumSize;
         $promise = \React\Promise\Stream\buffer($stream, $maximumSize)->then(
-            function ($body) use ($response) {
+            function($body) use ($response) {
                 return $response->withBody(new BufferedBody($body));
             },
-            function ($e) use ($stream, $maximumSize) {
+            function($e) use ($stream, $maximumSize) {
                 // try to close stream if buffering fails (or is cancelled)
                 $stream->close();
 

deps/vendor/react/http/src/Io/StreamingServer.php

Spacing +9 added lines, -9 removed lines

@@ -110,7 +110,7 @@ 
         $this->parser = new RequestHeaderParser();
 
         $that = $this;
-        $this->parser->on('headers', function (ServerRequestInterface $request, ConnectionInterface $conn) use ($that) {
+        $this->parser->on('headers', function(ServerRequestInterface $request, ConnectionInterface $conn) use ($that) {
             $that->handleRequest($conn, $request);
         });
 
@@ -158,7 +158,7 @@ 
 
         // cancel pending promise once connection closes
         if ($response instanceof CancellablePromiseInterface) {
-            $conn->on('close', function () use ($response) {
+            $conn->on('close', function() use ($response) {
                 $response->cancel();
             });
         }
@@ -175,7 +175,7 @@ 
 
         $that = $this;
         $response->then(
-            function ($response) use ($that, $conn, $request) {
+            function($response) use ($that, $conn, $request) {
                 if (!$response instanceof ResponseInterface) {
                     $message = 'The response callback is expected to resolve with an object implementing Psr\Http\Message\ResponseInterface, but resolved with "%s" instead.';
                     $message = \sprintf($message, \is_object($response) ? \get_class($response) : \gettype($response));
@@ -186,7 +186,7 @@ 
                 }
                 $that->handleResponse($conn, $request, $response);
             },
-            function ($error) use ($that, $conn, $request) {
+            function($error) use ($that, $conn, $request) {
                 $message = 'The response callback is expected to resolve with an object implementing Psr\Http\Message\ResponseInterface, but rejected with "%s" instead.';
                 $message = \sprintf($message, \is_object($error) ? \get_class($error) : \gettype($error));
 
@@ -248,7 +248,7 @@ 
         // assign default "Server" header automatically
         if (!$response->hasHeader('Server')) {
             $response = $response->withHeader('Server', 'ReactPHP/1');
-        } elseif ($response->getHeaderLine('Server') === ''){
+        } elseif ($response->getHeaderLine('Server') === '') {
             $response = $response->withoutHeader('Server');
         }
 
@@ -256,7 +256,7 @@ 
         if (!$response->hasHeader('Date')) {
             // IMF-fixdate  = day-name "," SP date1 SP time-of-day SP GMT
             $response = $response->withHeader('Date', gmdate('D, d M Y H:i:s') . ' GMT');
-        } elseif ($response->getHeaderLine('Date') === ''){
+        } elseif ($response->getHeaderLine('Date') === '') {
             $response = $response->withoutHeader('Date');
         }
 
@@ -269,7 +269,7 @@ 
             // 304 Not Modified: preserve explicit Content-Length and preserve missing header if body is empty
         } elseif ($body->getSize() !== null) {
             // assign Content-Length header when using a "normal" buffered body string
-            $response = $response->withHeader('Content-Length', (string)$body->getSize());
+            $response = $response->withHeader('Content-Length', (string) $body->getSize());
         } elseif (!$response->hasHeader('Content-Length') && $version === '1.1') {
             // assign chunked transfer-encoding if no 'content-length' is given for HTTP/1.1 responses
             $chunked = true;
@@ -310,7 +310,7 @@ 
         if (($code === Response::STATUS_SWITCHING_PROTOCOLS || ($method === 'CONNECT' && $code >= 200 && $code < 300)) && $body instanceof HttpBodyStream && $body->input instanceof WritableStreamInterface) {
             if ($request->getBody()->isReadable()) {
                 // request is still streaming => wait for request close before forwarding following data from connection
-                $request->getBody()->on('close', function () use ($connection, $body) {
+                $request->getBody()->on('close', function() use ($connection, $body) {
                     if ($body->input->isWritable()) {
                         $connection->pipe($body->input);
                         $connection->resume();
@@ -372,7 +372,7 @@ 
         if ($persist) {
             $body->pipe($connection, array('end' => false));
             $parser = $this->parser;
-            $body->on('end', function () use ($connection, $parser, $body) {
+            $body->on('end', function() use ($connection, $parser, $body) {
                 $connection->removeListener('close', array($body, 'close'));
                 $parser->handle($connection);
             });

deps/vendor/react/http/src/Io/Sender.php

Spacing +8 added lines, -8 removed lines

@@ -79,7 +79,7 @@ 
 
         if ($size !== null && $size !== 0) {
             // automatically assign a "Content-Length" request header if the body size is known and non-empty
-            $request = $request->withHeader('Content-Length', (string)$size);
+            $request = $request->withHeader('Content-Length', (string) $size);
         } elseif ($size === 0 && \in_array($request->getMethod(), array('POST', 'PUT', 'PATCH'))) {
             // only assign a "Content-Length: 0" request header if the body is expected for certain methods
             $request = $request->withHeader('Content-Length', '0');
@@ -96,9 +96,9 @@ 
             $headers[$name] = implode(', ', $values);
         }
 
-        $requestStream = $this->http->request($request->getMethod(), (string)$request->getUri(), $headers, $request->getProtocolVersion());
+        $requestStream = $this->http->request($request->getMethod(), (string) $request->getUri(), $headers, $request->getProtocolVersion());
 
-        $deferred = new Deferred(function ($_, $reject) use ($requestStream) {
+        $deferred = new Deferred(function($_, $reject) use ($requestStream) {
             // close request stream if request is cancelled
             $reject(new \RuntimeException('Request cancelled'));
             $requestStream->close();
@@ -108,7 +108,7 @@ 
             $deferred->reject($error);
         });
 
-        $requestStream->on('response', function (ResponseInterface $response, ReadableStreamInterface $body) use ($deferred, $request) {
+        $requestStream->on('response', function(ResponseInterface $response, ReadableStreamInterface $body) use ($deferred, $request) {
             $length = null;
             $code = $response->getStatusCode();
             if ($request->getMethod() === 'HEAD' || ($code >= 100 && $code < 200) || $code == Response::STATUS_NO_CONTENT || $code == Response::STATUS_NOT_MODIFIED) {
@@ -134,16 +134,16 @@ 
                 $body->pipe($requestStream);
                 $requestStream->write('');
 
-                $body->on('close', $close = function () use ($deferred, $requestStream) {
+                $body->on('close', $close = function() use ($deferred, $requestStream) {
                     $deferred->reject(new \RuntimeException('Request failed because request body closed unexpectedly'));
                     $requestStream->close();
                 });
-                $body->on('error', function ($e) use ($deferred, $requestStream, $close, $body) {
+                $body->on('error', function($e) use ($deferred, $requestStream, $close, $body) {
                     $body->removeListener('close', $close);
                     $deferred->reject(new \RuntimeException('Request failed because request body reported an error', 0, $e));
                     $requestStream->close();
                 });
-                $body->on('end', function () use ($close, $body) {
+                $body->on('end', function() use ($close, $body) {
                     $body->removeListener('close', $close);
                 });
             } else {
@@ -152,7 +152,7 @@ 
             }
         } else {
             // body is fully buffered => write as one chunk
-            $requestStream->end((string)$body);
+            $requestStream->end((string) $body);
         }
 
         return $deferred->promise();

deps/vendor/react/http/src/Io/RequestHeaderParser.php

Spacing +4 added lines, -4 removed lines

@@ -29,7 +29,7 @@ 
         $buffer = '';
         $maxSize = $this->maxSize;
         $that = $this;
-        $conn->on('data', $fn = function ($data) use (&$buffer, &$fn, $conn, $maxSize, $that) {
+        $conn->on('data', $fn = function($data) use (&$buffer, &$fn, $conn, $maxSize, $that) {
             // append chunk of data to buffer and look for end of request headers
             $buffer .= $data;
             $endOfHeader = \strpos($buffer, "\r\n\r\n");
@@ -57,7 +57,7 @@ 
 
             try {
                 $request = $that->parseRequest(
-                    (string)\substr($buffer, 0, $endOfHeader + 2),
+                    (string) \substr($buffer, 0, $endOfHeader + 2),
                     $conn->getRemoteAddress(),
                     $conn->getLocalAddress()
                 );
@@ -74,7 +74,7 @@ 
             if ($request->hasHeader('Transfer-Encoding')) {
                 $contentLength = null;
             } elseif ($request->hasHeader('Content-Length')) {
-                $contentLength = (int)$request->getHeaderLine('Content-Length');
+                $contentLength = (int) $request->getHeaderLine('Content-Length');
             }
 
             if ($contentLength === 0) {
@@ -270,7 +270,7 @@ 
         } elseif ($request->hasHeader('Content-Length')) {
             $string = $request->getHeaderLine('Content-Length');
 
-            if ((string)(int)$string !== $string) {
+            if ((string) (int) $string !== $string) {
                 // Content-Length value is not an integer or not a single integer
                 throw new \InvalidArgumentException('The value of `Content-Length` is not valid', Response::STATUS_BAD_REQUEST);
             }