ggoffy / wggithub

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

Spacing +8 added lines, -8 removed lines

@@ -75,7 +75,7 @@ 
             \curl_setopt($ch, \CURLOPT_PRIVATE, \in_array($method, ['GET', 'HEAD', 'OPTIONS', 'TRACE'], true) && 1.0 < (float) ($options['http_version'] ?? 1.1) ? 'H2' : 'H0'); // H = headers + retry counter
         }
 
-        \curl_setopt($ch, \CURLOPT_HEADERFUNCTION, static function ($ch, string $data) use (&$info, &$headers, $options, $multi, $id, &$location, $resolveRedirect, $logger): int {
+        \curl_setopt($ch, \CURLOPT_HEADERFUNCTION, static function($ch, string $data) use (&$info, &$headers, $options, $multi, $id, &$location, $resolveRedirect, $logger): int {
             if (0 !== substr_compare($data, "\r\n", -2)) {
                 return 0;
             }
@@ -91,7 +91,7 @@ 
 
         if (null === $options) {
             // Pushed response: buffer until requested
-            \curl_setopt($ch, \CURLOPT_WRITEFUNCTION, static function ($ch, string $data) use ($multi, $id): int {
+            \curl_setopt($ch, \CURLOPT_WRITEFUNCTION, static function($ch, string $data) use ($multi, $id): int {
                 $multi->handlesActivity[$id][] = $data;
                 curl_pause($ch, \CURLPAUSE_RECV);
 
@@ -102,7 +102,7 @@ 
         }
 
         $execCounter = $multi->execCounter;
-        $this->info['pause_handler'] = static function (float $duration) use ($ch, $multi, $execCounter) {
+        $this->info['pause_handler'] = static function(float $duration) use ($ch, $multi, $execCounter) {
             if (0 < $duration) {
                 if ($execCounter === $multi->execCounter) {
                     $multi->execCounter = !\is_float($execCounter) ? 1 + $execCounter : \PHP_INT_MIN;
@@ -128,7 +128,7 @@ 
         if ($onProgress = $options['on_progress']) {
             $url = isset($info['url']) ? ['url' => $info['url']] : [];
             \curl_setopt($ch, \CURLOPT_NOPROGRESS, false);
-            \curl_setopt($ch, \CURLOPT_PROGRESSFUNCTION, static function ($ch, $dlSize, $dlNow) use ($onProgress, &$info, $url, $multi, $debugBuffer) {
+            \curl_setopt($ch, \CURLOPT_PROGRESSFUNCTION, static function($ch, $dlSize, $dlNow) use ($onProgress, &$info, $url, $multi, $debugBuffer) {
                 try {
                     rewind($debugBuffer);
                     $debug = ['debug' => stream_get_contents($debugBuffer)];
@@ -144,7 +144,7 @@ 
             });
         }
 
-        \curl_setopt($ch, \CURLOPT_WRITEFUNCTION, static function ($ch, string $data) use ($multi, $id): int {
+        \curl_setopt($ch, \CURLOPT_WRITEFUNCTION, static function($ch, string $data) use ($multi, $id): int {
             if ('H' === (\curl_getinfo($ch, \CURLINFO_PRIVATE)[0] ?? null)) {
                 $multi->handlesActivity[$id][] = null;
                 $multi->handlesActivity[$id][] = new TransportException(\sprintf('Unsupported protocol for "%s"', \curl_getinfo($ch, \CURLINFO_EFFECTIVE_URL)));
@@ -152,7 +152,7 @@ 
                 return 0;
             }
 
-            \curl_setopt($ch, \CURLOPT_WRITEFUNCTION, static function ($ch, string $data) use ($multi, $id): int {
+            \curl_setopt($ch, \CURLOPT_WRITEFUNCTION, static function($ch, string $data) use ($multi, $id): int {
                 $multi->handlesActivity[$id][] = $data;
 
                 return \strlen($data);
@@ -163,7 +163,7 @@ 
             return \strlen($data);
         });
 
-        $this->initializer = static function (self $response) {
+        $this->initializer = static function(self $response) {
             $waitFor = \curl_getinfo($ch = $response->handle, \CURLINFO_PRIVATE);
 
             return 'H' === $waitFor[0];
@@ -173,7 +173,7 @@ 
         $multi->openHandles[$id] = [$ch, $options];
         curl_multi_add_handle($multi->handle, $ch);
 
-        $this->canary = new Canary(static function () use ($ch, $multi, $id) {
+        $this->canary = new Canary(static function() use ($ch, $multi, $id) {
             unset($multi->pauseExpiries[$id], $multi->openHandles[$id], $multi->handlesActivity[$id]);
             \curl_setopt($ch, \CURLOPT_PRIVATE, '_0');
 

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

Spacing +3 added lines, -3 removed lines

@@ -126,7 +126,7 @@ 
         $response->requestOptions = $options;
         $response->id = ++self::$idSequence;
         $response->shouldBuffer = $options['buffer'] ?? true;
-        $response->initializer = static function (self $response) {
+        $response->initializer = static function(self $response) {
             return \is_array($response->body[0] ?? null);
         };
 
@@ -224,7 +224,7 @@ 
      */
     private static function writeRequest(self $response, array $options, ResponseInterface $mock)
     {
-        $onProgress = $options['on_progress'] ?? static function () {};
+        $onProgress = $options['on_progress'] ?? static function() {};
         $response->info += $mock->getInfo() ?: [];
 
         // simulate "size_upload" if it is set
@@ -267,7 +267,7 @@ 
      */
     private static function readResponse(self $response, array $options, ResponseInterface $mock, int &$offset)
     {
-        $onProgress = $options['on_progress'] ?? static function () {};
+        $onProgress = $options['on_progress'] ?? static function() {};
 
         // populate info related to headers
         $info = $mock->getInfo() ?: [];

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

Spacing +9 added lines, -9 removed lines

@@ -67,7 +67,7 @@ 
             $request->setHeader('Accept-Encoding', 'gzip');
         }
 
-        $this->initializer = static function (self $response) {
+        $this->initializer = static function(self $response) {
             return null !== $response->options;
         };
 
@@ -89,8 +89,8 @@ 
         $info['user_data'] = $options['user_data'];
         $info['debug'] = '';
 
-        $onProgress = $options['on_progress'] ?? static function () {};
-        $onProgress = $this->onProgress = static function () use (&$info, $onProgress) {
+        $onProgress = $options['on_progress'] ?? static function() {};
+        $onProgress = $this->onProgress = static function() use (&$info, $onProgress) {
             $info['total_time'] = micro\time(true) - $info['start_time'];
             $onProgress((int) $info['size_download'], ((int) (1 + $info['download_content_length']) ?: 1) - 1, (array) $info);
         };
@@ -101,11 +101,11 @@ 
         $throttleWatcher = null;
 
         $this->id = $id = self::$nextId++;
-        Loop::defer(static function () use ($request, $multi, &$id, &$info, &$headers, $canceller, &$options, $onProgress, &$handle, $logger, &$pause) {
+        Loop::defer(static function() use ($request, $multi, &$id, &$info, &$headers, $canceller, &$options, $onProgress, &$handle, $logger, &$pause) {
             return new Coroutine(self::generateResponse($request, $multi, $id, $info, $headers, $canceller, $options, $onProgress, $handle, $logger, $pause));
         });
 
-        $info['pause_handler'] = static function (float $duration) use (&$throttleWatcher, &$pauseDeferred, &$pause) {
+        $info['pause_handler'] = static function(float $duration) use (&$throttleWatcher, &$pauseDeferred, &$pause) {
             if (null !== $throttleWatcher) {
                 Loop::cancel($throttleWatcher);
             }
@@ -117,7 +117,7 @@ 
                 $pauseDeferred = new Deferred();
                 $deferred->resolve();
             } else {
-                $throttleWatcher = Loop::delay(ceil(1000 * $duration), static function () use (&$pauseDeferred) {
+                $throttleWatcher = Loop::delay(ceil(1000 * $duration), static function() use (&$pauseDeferred) {
                     $deferred = $pauseDeferred;
                     $pauseDeferred = new Deferred();
                     $deferred->resolve();
@@ -128,7 +128,7 @@ 
         $multi->openHandles[$id] = $id;
         ++$multi->responseCount;
 
-        $this->canary = new Canary(static function () use ($canceller, $multi, $id) {
+        $this->canary = new Canary(static function() use ($canceller, $multi, $id) {
             $canceller->cancel();
             unset($multi->openHandles[$id], $multi->handlesActivity[$id]);
         });
@@ -202,7 +202,7 @@ 
     private static function select(ClientState $multi, float $timeout): int
     {
         $timeout += micro\time(true);
-        self::$delay = Loop::defer(static function () use ($timeout) {
+        self::$delay = Loop::defer(static function() use ($timeout) {
             if (0 < $timeout -= micro\time(true)) {
                 self::$delay = Loop::delay(ceil(1000 * $timeout), [Loop::class, 'stop']);
             } else {
@@ -217,7 +217,7 @@ 
 
     private static function generateResponse(Request $request, AmpClientState $multi, string $id, array &$info, array &$headers, CancellationTokenSource $canceller, array &$options, \Closure $onProgress, &$handle, ?LoggerInterface $logger, Promise &$pause)
     {
-        $request->setInformationalResponseHandler(static function (Response $response) use ($multi, $id, &$info, &$headers) {
+        $request->setInformationalResponseHandler(static function(Response $response) use ($multi, $id, &$info, &$headers) {
             self::addResponseHeaders($response, $info, $headers);
             $multi->handlesActivity[$id][] = new InformationalChunk($response->getStatus(), $response->getHeaders());
             self::stopLoop();

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

Spacing +1 added lines, -1 removed lines

@@ -73,7 +73,7 @@
             return null;
         }
 
-        return static function ($value) use ($callback) {
+        return static function($value) use ($callback) {
             return promise_for($callback($value));
         };
     }

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

Spacing +1 added lines, -1 removed lines

@@ -153,7 +153,7 @@
         $this->info['previous_info'][] = $this->response->getInfo();
         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);
             };
         }

lib/Github/Http/Client/Internal/AmpClientState.php

Spacing +5 added lines, -5 removed lines

@@ -53,7 +53,7 @@ 
 
     public function __construct(?callable $clientConfigurator, int $maxHostConnections, int $maxPendingPushes, ?LoggerInterface &$logger)
     {
-        $this->clientConfigurator = $clientConfigurator ?? static function (PooledHttpClient $client) {
+        $this->clientConfigurator = $clientConfigurator ?? static function(PooledHttpClient $client) {
             return new InterceptedHttpClient($client, new RetryRequests(2));
         };
         $this->maxHostConnections = $maxHostConnections;
@@ -94,12 +94,12 @@ 
         }
 
         $request->addEventListener(new AmpListener($info, $options['peer_fingerprint']['pin-sha256'] ?? [], $onProgress, $handle));
-        $request->setPushHandler(function ($request, $response) use ($options): Promise {
+        $request->setPushHandler(function($request, $response) use ($options): Promise {
             return $this->handlePush($request, $response, $options);
         });
 
         ($request->hasHeader('content-length') ? new Success((int) $request->getHeader('content-length')) : $request->getBody()->getBodyLength())
-            ->onResolve(static function ($e, $bodySize) use (&$info) {
+            ->onResolve(static function($e, $bodySize) use (&$info) {
                 if (null !== $bodySize && 0 <= $bodySize) {
                     $info['upload_content_length'] = ((1 + $info['upload_content_length']) ?? 1) - 1 + $bodySize;
                 }
@@ -107,7 +107,7 @@ 
 
         [$client, $connector] = $this->getClient($options);
         $response = $client->request($request, $cancellation);
-        $response->onResolve(static function ($e) use ($connector, &$handle) {
+        $response->onResolve(static function($e) use ($connector, &$handle) {
             if (null === $e) {
                 $handle = $connector->handle;
             }
@@ -152,7 +152,7 @@ 
             public function connect(string $uri, ?ConnectContext $context = null, ?CancellationToken $token = null): Promise
             {
                 $result = $this->connector->connect($this->uri ?? $uri, $context, $token);
-                $result->onResolve(function ($e, $socket) {
+                $result->onResolve(function($e, $socket) {
                     $this->handle = null !== $socket ? $socket->getResource() : false;
                 });
 

lib/Github/Http/Client/Internal/AmpBody.php

Spacing +1 added lines, -1 removed lines

@@ -78,7 +78,7 @@
         ($this->onProgress)();
 
         $chunk = $this->doRead();
-        $chunk->onResolve(function ($e, $data) {
+        $chunk->onResolve(function($e, $data) {
             if (null !== $data) {
                 $this->uploaded = \strlen($data);
             } else {

lib/Github/Http/Client/CurlHttpClient.php

Spacing +7 added lines, -7 removed lines

@@ -41,7 +41,7 @@ 
         'auth_ntlm' => null, // array|string - an array containing the username as first value, and optionally the
                              //   password as the second one; or string like username:password - enabling NTLM auth
         'extra' => [
-            'curl' => [],    // A list of extra curl options indexed by their corresponding CURLOPT_*
+            'curl' => [], // A list of extra curl options indexed by their corresponding CURLOPT_*
         ],
     ];
 
@@ -97,7 +97,7 @@ 
             return;
         }
 
-        curl_multi_setopt($this->multi->handle, \CURLMOPT_PUSHFUNCTION, function ($parent, $pushed, array $requestHeaders) use ($maxPendingPushes) {
+        curl_multi_setopt($this->multi->handle, \CURLMOPT_PUSHFUNCTION, function($parent, $pushed, array $requestHeaders) use ($maxPendingPushes) {
             return $this->handlePush($parent, $pushed, $requestHeaders, $maxPendingPushes);
         });
     }
@@ -243,7 +243,7 @@ 
             } else {
                 $eof = false;
                 $buffer = '';
-                $curlopts[\CURLOPT_READFUNCTION] = static function ($ch, $fd, $length) use ($body, &$buffer, &$eof) {
+                $curlopts[\CURLOPT_READFUNCTION] = static function($ch, $fd, $length) use ($body, &$buffer, &$eof) {
                     return self::readRequestBody($length, $body, $buffer, $eof);
                 };
             }
@@ -473,18 +473,18 @@ 
         $redirectHeaders = [];
         if (0 < $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'][0]) || isset($options['normalized_headers']['cookie'][0])) {
-                $redirectHeaders['no_auth'] = \array_filter($options['headers'], static function ($h) {
+                $redirectHeaders['no_auth'] = \array_filter($options['headers'], static function($h) {
                     return 0 !== stripos($h, 'Authorization:') && 0 !== stripos($h, 'Cookie:');
                 });
             }
         }
 
-        return static function ($ch, string $location) use ($redirectHeaders) {
+        return static function($ch, string $location) use ($redirectHeaders) {
             try {
                 $location = self::parseUrl($location);
             } catch (InvalidArgumentException $e) {
@@ -504,7 +504,7 @@ 
 
     private function findConstantName($opt): ?string
     {
-        $constants = \array_filter(get_defined_constants(), static function ($v, $k) use ($opt) {
+        $constants = \array_filter(get_defined_constants(), static function($v, $k) use ($opt) {
             return $v === $opt && 'C' === $k[0] && (0 === \strpos($k, 'CURLOPT_') || 0 === \strpos($k, 'CURLINFO_'));
         }, \ARRAY_FILTER_USE_BOTH);
 

lib/Github/Http/Client/CachingHttpClient.php

Spacing +1 added lines, -1 removed lines

@@ -136,7 +136,7 @@
             return new ResponseStream(MockResponse::stream($mockResponses, $timeout));
         }
 
-        return new ResponseStream((function () use ($mockResponses, $clientResponses, $timeout) {
+        return new ResponseStream((function() use ($mockResponses, $clientResponses, $timeout) {
             yield from MockResponse::stream($mockResponses, $timeout);
             yield $this->client->stream($clientResponses, $timeout);
         })());