deployphp / deployer

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

Spacing +5 added lines, -5 removed lines

@@ -40,7 +40,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");
@@ -68,7 +68,7 @@ 
 
             try {
                 $request = $that->parseRequest(
-                    (string)\substr($buffer, 0, $endOfHeader + 2),
+                    (string) \substr($buffer, 0, $endOfHeader + 2),
                     $conn
                 );
             } catch (Exception $exception) {
@@ -84,7 +84,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) {
@@ -162,8 +162,8 @@ 
 
             // remember server params for all requests from this connection, reset on connection close
             $this->connectionParams[$cid] = $serverParams;
-            $params =& $this->connectionParams;
-            $connection->on('close', function () use (&$params, $cid) {
+            $params = & $this->connectionParams;
+            $connection->on('close', function() use (&$params, $cid) {
                 assert(\is_array($params));
                 unset($params[$cid]);
             });

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

Spacing +2 added lines, -2 removed lines

@@ -42,8 +42,8 @@
             $this->now = \microtime(true);
 
             // remember clock for current loop tick only and update on next tick
-            $now =& $this->now;
-            $this->loop->futureTick(function () use (&$now) {
+            $now = & $this->now;
+            $this->loop->futureTick(function() use (&$now) {
                 assert($now !== null);
                 $now = null;
             });

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

Spacing +1 added lines, -1 removed lines

@@ -101,7 +101,7 @@
         $this->idleConnections[] = $connection;
 
         $that = $this;
-        $cleanUp = function () use ($connection, $that) {
+        $cleanUp = function() use ($connection, $that) {
             // call public method to support legacy PHP 5.3
             $that->cleanUpConnection($connection);
         };

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

Spacing +1 added lines, -1 removed lines

@@ -50,7 +50,7 @@
         }
 
         $that = $this;
-        $next = function (ServerRequestInterface $request) use ($that, $position) {
+        $next = function(ServerRequestInterface $request) use ($that, $position) {
             return $that->call($request, $position + 1);
         };
 

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

Spacing +3 added lines, -3 removed lines

@@ -16,7 +16,7 @@ 
     public static function iniSizeToBytes($size)
     {
         if (\is_numeric($size)) {
-            return (int)$size;
+            return (int) $size;
         }
 
         $suffix = \strtoupper(\substr($size, -1));
@@ -40,9 +40,9 @@ 
             return $strippedSize * 1024 * 1024 * 1024;
         }
         if ($suffix === 'T') {
-            return $strippedSize * 1024  * 1024 * 1024 * 1024;
+            return $strippedSize * 1024 * 1024 * 1024 * 1024;
         }
 
-        return (int)$size;
+        return (int) $size;
     }
 }

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

Spacing +3 added lines, -3 removed lines

@@ -24,8 +24,8 @@ 
         $this->size = $size;
 
         $that = $this;
-        $pos =& $this->position;
-        $input->on('data', function ($data) use ($that, &$pos, $size) {
+        $pos = & $this->position;
+        $input->on('data', function($data) use ($that, &$pos, $size) {
             $that->emit('data', array($data));
 
             $pos += \strlen($data);
@@ -33,7 +33,7 @@ 
                 $that->handleEnd();
             }
         });
-        $input->on('error', function ($error) use ($that) {
+        $input->on('error', function($error) use ($that) {
             $that->emit('error', array($error));
             $that->close();
         });

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

Spacing +8 added lines, -8 removed lines

@@ -83,11 +83,11 @@ 
     {
         $var = \ini_get('max_input_vars');
         if ($var !== false) {
-            $this->maxInputVars = (int)$var;
+            $this->maxInputVars = (int) $var;
         }
         $var = \ini_get('max_input_nesting_level');
         if ($var !== false) {
-            $this->maxInputNestingLevel = (int)$var;
+            $this->maxInputNestingLevel = (int) $var;
         }
 
         if ($uploadMaxFilesize === null) {
@@ -95,7 +95,7 @@ 
         }
 
         $this->uploadMaxFilesize = IniUtil::iniSizeToBytes($uploadMaxFilesize);
-        $this->maxFileUploads = $maxFileUploads === null ? (\ini_get('file_uploads') === '' ? 0 : (int)\ini_get('max_file_uploads')) : (int)$maxFileUploads;
+        $this->maxFileUploads = $maxFileUploads === null ? (\ini_get('file_uploads') === '' ? 0 : (int) \ini_get('max_file_uploads')) : (int) $maxFileUploads;
 
         $this->maxMultipartBodyParts = $this->maxInputVars + $this->maxFileUploads;
     }
@@ -103,12 +103,12 @@ 
     public function parse(ServerRequestInterface $request)
     {
         $contentType = $request->getHeaderLine('content-type');
-        if(!\preg_match('/boundary="?(.*?)"?$/', $contentType, $matches)) {
+        if (!\preg_match('/boundary="?(.*?)"?$/', $contentType, $matches)) {
             return $request;
         }
 
         $this->request = $request;
-        $this->parseBody('--' . $matches[1], (string)$request->getBody());
+        $this->parseBody('--' . $matches[1], (string) $request->getBody());
 
         $request = $this->request;
         $this->request = null;
@@ -155,8 +155,8 @@ 
             return;
         }
 
-        $headers = $this->parseHeaders((string)substr($chunk, 0, $pos));
-        $body = (string)\substr($chunk, $pos + 4);
+        $headers = $this->parseHeaders((string) substr($chunk, 0, $pos));
+        $body = (string) \substr($chunk, $pos + 4);
 
         if (!isset($headers['content-disposition'])) {
             return;
@@ -264,7 +264,7 @@ 
         ));
 
         if (\strtoupper($name) === 'MAX_FILE_SIZE') {
-            $this->maxFileSize = (int)$value;
+            $this->maxFileSize = (int) $value;
 
             if ($this->maxFileSize === 0) {
                 $this->maxFileSize = null;

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

Spacing +7 added lines, -7 removed lines

@@ -86,7 +86,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');
@@ -105,7 +105,7 @@ 
 
         $requestStream = $this->http->request($request);
 
-        $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();
@@ -115,7 +115,7 @@ 
             $deferred->reject($error);
         });
 
-        $requestStream->on('response', function (ResponseInterface $response) use ($deferred, $request) {
+        $requestStream->on('response', function(ResponseInterface $response) use ($deferred, $request) {
             $deferred->resolve($response);
         });
 
@@ -131,16 +131,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 {
@@ -149,7 +149,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/Transaction.php

Spacing +13 added lines, -13 removed lines

@@ -69,7 +69,7 @@ 
     public function send(RequestInterface $request)
     {
         $state = new ClientRequestState();
-        $deferred = new Deferred(function () use ($state) {
+        $deferred = new Deferred(function() use ($state) {
             if ($state->pending !== null) {
                 $state->pending->cancel();
                 $state->pending = null;
@@ -77,11 +77,11 @@ 
         });
 
         // 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, $state)->then(
-            function (ResponseInterface $response) use ($state, $deferred, $loop, &$timeout) {
+            function(ResponseInterface $response) use ($state, $deferred, $loop, &$timeout) {
                 if ($state->timeout !== null) {
                     $loop->cancelTimer($state->timeout);
                     $state->timeout = null;
@@ -89,7 +89,7 @@ 
                 $timeout = -1;
                 $deferred->resolve($response);
             },
-            function ($e) use ($state, $deferred, $loop, &$timeout) {
+            function($e) use ($state, $deferred, $loop, &$timeout) {
                 if ($state->timeout !== null) {
                     $loop->cancelTimer($state->timeout);
                     $state->timeout = null;
@@ -106,7 +106,7 @@ 
         $body = $request->getBody();
         if ($body instanceof ReadableStreamInterface && $body->isReadable()) {
             $that = $this;
-            $body->on('close', function () use ($that, $deferred, $state, &$timeout) {
+            $body->on('close', function() use ($that, $deferred, $state, &$timeout) {
                 if ($timeout >= 0) {
                     $that->applyTimeout($deferred, $state, $timeout);
                 }
@@ -125,7 +125,7 @@ 
      */
     public function applyTimeout(Deferred $deferred, ClientRequestState $state, $timeout)
     {
-        $state->timeout = $this->loop->addTimer($timeout, function () use ($timeout, $deferred, $state) {
+        $state->timeout = $this->loop->addTimer($timeout, function() use ($timeout, $deferred, $state) {
             $deferred->reject(new \RuntimeException(
                 'Request timed out after ' . $timeout . ' seconds'
             ));
@@ -146,7 +146,7 @@ 
         $promise = $this->sender->send($request);
 
         if (!$this->streaming) {
-            $promise = $promise->then(function ($response) use ($deferred, $state, $that) {
+            $promise = $promise->then(function($response) use ($deferred, $state, $that) {
                 return $that->bufferResponse($response, $deferred, $state);
             });
         }
@@ -154,7 +154,7 @@ 
         $state->pending = $promise;
 
         return $promise->then(
-            function (ResponseInterface $response) use ($request, $that, $deferred, $state) {
+            function(ResponseInterface $response) use ($request, $that, $deferred, $state) {
                 return $that->onResponse($response, $request, $deferred, $state);
             }
         );
@@ -186,15 +186,15 @@ 
         $closer = null;
         $maximumSize = $this->maximumSize;
 
-        return $state->pending = new Promise(function ($resolve, $reject) use ($body, $maximumSize, $response, &$closer) {
+        return $state->pending = new Promise(function($resolve, $reject) use ($body, $maximumSize, $response, &$closer) {
             // resolve with current buffer when stream closes successfully
             $buffer = '';
-            $body->on('close', $closer = function () use (&$buffer, $response, $maximumSize, $resolve, $reject) {
+            $body->on('close', $closer = function() use (&$buffer, $response, $maximumSize, $resolve, $reject) {
                 $resolve($response->withBody(new BufferedBody($buffer)));
             });
 
             // buffer response body data in memory
-            $body->on('data', function ($data) use (&$buffer, $maximumSize, $body, $closer, $reject) {
+            $body->on('data', function($data) use (&$buffer, $maximumSize, $body, $closer, $reject) {
                 $buffer .= $data;
 
                 // close stream and reject promise if limit is exceeded
@@ -212,14 +212,14 @@ 
             });
 
             // reject buffering if body emits error
-            $body->on('error', function (\Exception $e) use ($reject) {
+            $body->on('error', function(\Exception $e) use ($reject) {
                 $reject(new \RuntimeException(
                     'Error while buffering response body: ' . $e->getMessage(),
                     $e->getCode(),
                     $e
                 ));
             });
-        }, function () use ($body, &$closer) {
+        }, function() use ($body, &$closer) {
             // cancelled buffering: remove close handler to avoid resolving, then close and reject
             assert($closer instanceof \Closure);
             $body->removeListener('close', $closer);