ggoffy / wggithub

lib/Github/Http/Client/Common/HttpClientPool/HttpClientPoolItem.php

Spacing +2 added lines, -2 removed lines

@@ -103,11 +103,11 @@
 
         $this->incrementRequestCount();
 
-        return $this->client->sendAsyncRequest($request)->then(function ($response) {
+        return $this->client->sendAsyncRequest($request)->then(function($response) {
             $this->decrementRequestCount();
 
             return $response;
-        }, function ($exception) {
+        }, function($exception) {
             $this->disable();
             $this->decrementRequestCount();
 

lib/Github/Http/Client/Common/HttpClientPool/LeastUsedClientPool.php

Spacing +2 added lines, -2 removed lines

@@ -20,7 +20,7 @@ 
      */
     protected function chooseHttpClient(): HttpClientPoolItem
     {
-        $clientPool = \array_filter($this->clientPool, function (HttpClientPoolItem $clientPoolItem) {
+        $clientPool = \array_filter($this->clientPool, function(HttpClientPoolItem $clientPoolItem) {
             return !$clientPoolItem->isDisabled();
         });
 
@@ -28,7 +28,7 @@ 
             throw new HttpClientNotFoundException('Cannot choose a http client as there is no one present in the pool');
         }
 
-        usort($clientPool, function (HttpClientPoolItem $clientA, HttpClientPoolItem $clientB) {
+        usort($clientPool, function(HttpClientPoolItem $clientA, HttpClientPoolItem $clientB) {
             if ($clientA->getSendingRequestCount() === $clientB->getSendingRequestCount()) {
                 return 0;
             }

lib/Github/Http/Client/NativeHttpClient.php

Spacing +9 added lines, -9 removed lines

@@ -117,7 +117,7 @@ 
             // Memoize the last progress to ease calling the callback periodically when no network transfer happens
             $lastProgress = [0, 0];
             $maxDuration = 0 < $options['max_duration'] ? $options['max_duration'] : \INF;
-            $onProgress = static function (...$progress) use ($onProgress, &$lastProgress, &$info, $maxDuration) {
+            $onProgress = static function(...$progress) use ($onProgress, &$lastProgress, &$info, $maxDuration) {
                 if ($info['total_time'] >= $maxDuration) {
                     throw new TransportException(\sprintf('Max duration was reached for "%s".', \implode('', $info['url'])));
                 }
@@ -137,7 +137,7 @@ 
             };
         } elseif (0 < $options['max_duration']) {
             $maxDuration = $options['max_duration'];
-            $onProgress = static function () use (&$info, $maxDuration): void {
+            $onProgress = static function() use (&$info, $maxDuration): void {
                 if ($info['total_time'] >= $maxDuration) {
                     throw new TransportException(\sprintf('Max duration was reached for "%s".', \implode('', $info['url'])));
                 }
@@ -145,7 +145,7 @@ 
         }
 
         // Always register a notification callback to compute live stats about the response
-        $notification = static function (int $code, int $severity, ?string $msg, int $msgCode, int $dlNow, int $dlSize) use ($onProgress, &$info) {
+        $notification = static function(int $code, int $severity, ?string $msg, int $msgCode, int $dlNow, int $dlSize) use ($onProgress, &$info) {
             $info['total_time'] = micro\time(true) - $info['start_time'];
 
             if (\STREAM_NOTIFY_PROGRESS === $code) {
@@ -205,7 +205,7 @@ 
                 'allow_self_signed' => (bool) $options['peer_fingerprint'],
                 'SNI_enabled' => true,
                 'disable_compression' => true,
-            ], static function ($v) { return null !== $v; }),
+            ], static function($v) { return null !== $v; }),
             'socket' => [
                 'bindto' => $options['bindto'] ?: '0:0',
                 'tcp_nodelay' => true,
@@ -214,7 +214,7 @@ 
 
         $context = stream_context_create($context, ['notification' => $notification]);
 
-        $resolver = static function ($multi) use ($context, $options, $url, &$info, $onProgress) {
+        $resolver = static function($multi) use ($context, $options, $url, &$info, $onProgress) {
             [$host, $port] = self::parseHostPort($url, $info);
 
             if (!isset($options['normalized_headers']['host'])) {
@@ -324,18 +324,18 @@ 
         $redirectHeaders = [];
         if (0 < $maxRedirects = $options['max_redirects']) {
             $redirectHeaders = ['host' => $host];
-            $redirectHeaders['with_auth'] = $redirectHeaders['no_auth'] = \array_filter($options['headers'], static function ($h) {
+            $redirectHeaders['with_auth'] = $redirectHeaders['no_auth'] = \array_filter($options['headers'], static function($h) {
                 return 0 !== stripos($h, 'Host:');
             });
 
             if (isset($options['normalized_headers']['authorization']) || isset($options['normalized_headers']['cookie'])) {
-                $redirectHeaders['no_auth'] = \array_filter($redirectHeaders['no_auth'], static function ($h) {
+                $redirectHeaders['no_auth'] = \array_filter($redirectHeaders['no_auth'], static function($h) {
                     return 0 !== stripos($h, 'Authorization:') && 0 !== stripos($h, 'Cookie:');
                 });
             }
         }
 
-        return static function (NativeClientState $multi, ?string $location, $context) use ($redirectHeaders, $proxy, &$info, $maxRedirects, $onProgress): ?string {
+        return static function(NativeClientState $multi, ?string $location, $context) use ($redirectHeaders, $proxy, &$info, $maxRedirects, $onProgress) : ?string {
             if (null === $location || $info['http_code'] < 300 || 400 <= $info['http_code']) {
                 $info['redirect_url'] = null;
 
@@ -368,7 +368,7 @@ 
                 if ('POST' === $options['method'] || 303 === $info['http_code']) {
                     $info['http_method'] = $options['method'] = 'HEAD' === $options['method'] ? 'HEAD' : 'GET';
                     $options['content'] = '';
-                    $options['header'] = \array_filter($options['header'], static function ($h) {
+                    $options['header'] = \array_filter($options['header'], static function($h) {
                         return 0 !== stripos($h, 'Content-Length:') && 0 !== stripos($h, 'Content-Type:');
                     });
 

lib/Github/Http/Client/EventSourceHttpClient.php

Spacing +1 added lines, -1 removed lines

@@ -66,7 +66,7 @@
             }
         }
 
-        return new AsyncResponse($this->client, $method, $url, $options, static function (ChunkInterface $chunk, AsyncContext $context) use ($state, $method, $url, $options) {
+        return new AsyncResponse($this->client, $method, $url, $options, static function(ChunkInterface $chunk, AsyncContext $context) use ($state, $method, $url, $options) {
             if (null !== $state->buffer) {
                 $context->setInfo('reconnection_time', $state->reconnectionTime);
                 $isTimeout = false;

lib/Github/Http/Client/HttplugClient.php

Spacing +2 added lines, -2 removed lines

@@ -119,9 +119,9 @@
 
         $waitLoop = $this->waitLoop;
 
-        $promise = new GuzzlePromise(static function () use ($response, $waitLoop) {
+        $promise = new GuzzlePromise(static function() use ($response, $waitLoop) {
             $waitLoop->wait($response);
-        }, static function () use ($response, $promisePool) {
+        }, static function() use ($response, $promisePool) {
             $response->cancel();
             unset($promisePool[$response]);
         });

lib/Github/Http/Client/NoPrivateNetworkHttpClient.php

Spacing +1 added lines, -1 removed lines

@@ -78,7 +78,7 @@
         $subnets = $this->subnets;
         $lastPrimaryIp = '';
 
-        $options['on_progress'] = function (int $dlNow, int $dlSize, array $info) use ($onProgress, $subnets, &$lastPrimaryIp): void {
+        $options['on_progress'] = function(int $dlNow, int $dlSize, array $info) use ($onProgress, $subnets, &$lastPrimaryIp): void {
             if ($info['primary_ip'] !== $lastPrimaryIp) {
                 if (IpUtils::checkIp($info['primary_ip'], $subnets ?? self::PRIVATE_SUBNETS)) {
                     throw new TransportException(\sprintf('IP "%s" is blocked for "%s".', $info['primary_ip'], $info['url']));

lib/Github/Http/Client/MockHttpClient.php

Spacing +1 added lines, -1 removed lines

@@ -41,7 +41,7 @@
         }
 
         if (!$responseFactory instanceof \Iterator && null !== $responseFactory && !\is_callable($responseFactory)) {
-            $responseFactory = (static function () use ($responseFactory) {
+            $responseFactory = (static function() use ($responseFactory) {
                 yield from $responseFactory;
             })();
         }

lib/Github/Http/Client/TraceableHttpClient.php

Spacing +1 added lines, -1 removed lines

@@ -57,7 +57,7 @@
             $content = false;
         }
 
-        $options['on_progress'] = function (int $dlNow, int $dlSize, array $info) use (&$traceInfo, $onProgress) {
+        $options['on_progress'] = function(int $dlNow, int $dlSize, array $info) use (&$traceInfo, $onProgress) {
             $traceInfo = $info;
 
             if (null !== $onProgress) {

lib/Github/Http/Client/Response/AsyncResponse.php

Spacing +3 added lines, -3 removed lines

@@ -46,13 +46,13 @@ 
 
         if (null !== $onProgress = $options['on_progress'] ?? null) {
             $thisInfo = &$this->info;
-            $options['on_progress'] = static function (int $dlNow, int $dlSize, array $info) use (&$thisInfo, $onProgress) {
+            $options['on_progress'] = static function(int $dlNow, int $dlSize, array $info) use (&$thisInfo, $onProgress) {
                 $onProgress($dlNow, $dlSize, $thisInfo + $info);
             };
         }
         $this->response = $client->request($method, $url, ['buffer' => false] + $options);
         $this->passthru = $passthru;
-        $this->initializer = static function (self $response) {
+        $this->initializer = static function(self $response) {
             if (null === $response->shouldBuffer) {
                 return false;
             }
@@ -125,7 +125,7 @@ 
             $this->getHeaders(true);
         }
 
-        $handle = function () {
+        $handle = function() {
             $stream = $this->response instanceof StreamableInterface ? $this->response->toStream(false) : StreamWrapper::createResource($this->response);
 
             return stream_get_meta_data($stream)['wrapper_data']->stream_cast(\STREAM_CAST_FOR_SELECT);