vendor/symfony/http-client/Response/CurlResponse.php line 105

Open in your IDE?
  1. <?php
  3. /*
  4.  * This file is part of the Symfony package.
  5.  *
  6.  * (c) Fabien Potencier <fabien@symfony.com>
  7.  *
  8.  * For the full copyright and license information, please view the LICENSE
  9.  * file that was distributed with this source code.
  10.  */
  12. namespace Symfony\Component\HttpClient\Response;
  14. use Psr\Log\LoggerInterface;
  15. use Symfony\Component\HttpClient\Chunk\FirstChunk;
  16. use Symfony\Component\HttpClient\Chunk\InformationalChunk;
  17. use Symfony\Component\HttpClient\Exception\TransportException;
  18. use Symfony\Component\HttpClient\Internal\Canary;
  19. use Symfony\Component\HttpClient\Internal\ClientState;
  20. use Symfony\Component\HttpClient\Internal\CurlClientState;
  21. use Symfony\Contracts\HttpClient\ResponseInterface;
  23. /**
  24.  * @author Nicolas Grekas <p@tchwork.com>
  25.  *
  26.  * @internal
  27.  */
  28. final class CurlResponse implements ResponseInterface, StreamableInterface
  29. {
  30.     use CommonResponseTrait {
  31.         getContent as private doGetContent;
  32.     }
  33.     use TransportResponseTrait;
  35.     private static $performing = false;
  36.     private $multi;
  37.     private $debugBuffer;
  39.     /**
  40.      * @param \CurlHandle|resource|string $ch
  41.      *
  42.      * @internal
  43.      */
  44.     public function __construct(CurlClientState $multi, $ch, array $options = null, LoggerInterface $logger = null, string $method = 'GET', callable $resolveRedirect = null, int $curlVersion = null)
  45.     {
  46.         $this->multi = $multi;
  48.         if (\is_resource($ch) || $ch instanceof \CurlHandle) {
  49.             $this->handle = $ch;
  50.             $this->debugBuffer = fopen('php://temp', 'w+');
  51.             if (0x074000 === $curlVersion) {
  52.                 fwrite($this->debugBuffer, 'Due to a bug in curl 7.64.0, the debug log is disabled; use another version to work around the issue.');
  53.             } else {
  54.                 curl_setopt($ch, \CURLOPT_VERBOSE, true);
  55.                 curl_setopt($ch, \CURLOPT_STDERR, $this->debugBuffer);
  56.             }
  57.         } else {
  58.             $this->info['url'] = $ch;
  59.             $ch = $this->handle;
  60.         }
  62.         $this->id = $id = (int) $ch;
  63.         $this->logger = $logger;
  64.         $this->shouldBuffer = $options['buffer'] ?? true;
  65.         $this->timeout = $options['timeout'] ?? null;
  66.         $this->info['http_method'] = $method;
  67.         $this->info['user_data'] = $options['user_data'] ?? null;
  68.         $this->info['start_time'] = $this->info['start_time'] ?? microtime(true);
  69.         $info = &$this->info;
  70.         $headers = &$this->headers;
  71.         $debugBuffer = $this->debugBuffer;
  73.         if (!$info['response_headers']) {
  74.             // Used to keep track of what we're waiting for
  75.             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
  76.         }
  78.         curl_setopt($ch, \CURLOPT_HEADERFUNCTION, static function ($ch, string $data) use (&$info, &$headers, $options, $multi, $id, &$location, $resolveRedirect, $logger): int {
  79.             if (0 !== substr_compare($data, "\r\n", -2)) {
  80.                 return 0;
  81.             }
  83.             $len = 0;
  85.             foreach (explode("\r\n", substr($data, 0, -2)) as $data) {
  86.                 $len += 2 + self::parseHeaderLine($ch, $data, $info, $headers, $options, $multi, $id, $location, $resolveRedirect, $logger);
  87.             }
  89.             return $len;
  90.         });
  92.         if (null === $options) {
  93.             // Pushed response: buffer until requested
  94.             curl_setopt($ch, \CURLOPT_WRITEFUNCTION, static function ($ch, string $data) use ($multi, $id): int {
  95.                 $multi->handlesActivity[$id][] = $data;
  96.                 curl_pause($ch, \CURLPAUSE_RECV);
  98.                 return \strlen($data);
  99.             });
  101.             return;
  102.         }
  104.         $execCounter = $multi->execCounter;
  105.         $this->info['pause_handler'] = static function (float $duration) use ($ch, $multi, $execCounter) {
  106.             if (0 < $duration) {
  107.                 if ($execCounter === $multi->execCounter) {
  108.                     $multi->execCounter = !\is_float($execCounter) ? 1 + $execCounter : \PHP_INT_MIN;
  109.                     curl_multi_remove_handle($multi->handle, $ch);
  110.                 }
  112.                 $lastExpiry = end($multi->pauseExpiries);
  113.                 $multi->pauseExpiries[(int) $ch] = $duration += microtime(true);
  114.                 if (false !== $lastExpiry && $lastExpiry > $duration) {
  115.                     asort($multi->pauseExpiries);
  116.                 }
  117.                 curl_pause($ch, \CURLPAUSE_ALL);
  118.             } else {
  119.                 unset($multi->pauseExpiries[(int) $ch]);
  120.                 curl_pause($ch, \CURLPAUSE_CONT);
  121.                 curl_multi_add_handle($multi->handle, $ch);
  122.             }
  123.         };
  125.         $this->inflate = !isset($options['normalized_headers']['accept-encoding']);
  126.         curl_pause($ch, \CURLPAUSE_CONT);
  128.         if ($onProgress = $options['on_progress']) {
  129.             $url = isset($info['url']) ? ['url' => $info['url']] : [];
  130.             curl_setopt($ch, \CURLOPT_NOPROGRESS, false);
  131.             curl_setopt($ch, \CURLOPT_PROGRESSFUNCTION, static function ($ch, $dlSize, $dlNow) use ($onProgress, &$info, $url, $multi, $debugBuffer) {
  132.                 try {
  133.                     rewind($debugBuffer);
  134.                     $debug = ['debug' => stream_get_contents($debugBuffer)];
  135.                     $onProgress($dlNow, $dlSize, $url + curl_getinfo($ch) + $info + $debug);
  136.                 } catch (\Throwable $e) {
  137.                     $multi->handlesActivity[(int) $ch][] = null;
  138.                     $multi->handlesActivity[(int) $ch][] = $e;
  140.                     return 1; // Abort the request
  141.                 }
  143.                 return null;
  144.             });
  145.         }
  147.         curl_setopt($ch, \CURLOPT_WRITEFUNCTION, static function ($ch, string $data) use ($multi, $id): int {
  148.             if ('H' === (curl_getinfo($ch, \CURLINFO_PRIVATE)[0] ?? null)) {
  149.                 $multi->handlesActivity[$id][] = null;
  150.                 $multi->handlesActivity[$id][] = new TransportException(sprintf('Unsupported protocol for "%s"', curl_getinfo($ch, \CURLINFO_EFFECTIVE_URL)));
  152.                 return 0;
  153.             }
  155.             curl_setopt($ch, \CURLOPT_WRITEFUNCTION, static function ($ch, string $data) use ($multi, $id): int {
  156.                 $multi->handlesActivity[$id][] = $data;
  158.                 return \strlen($data);
  159.             });
  161.             $multi->handlesActivity[$id][] = $data;
  163.             return \strlen($data);
  164.         });
  166.         $this->initializer = static function (self $response) {
  167.             $waitFor = curl_getinfo($ch = $response->handle, \CURLINFO_PRIVATE);
  169.             return 'H' === $waitFor[0];
  170.         };
  172.         // Schedule the request in a non-blocking way
  173.         $multi->lastTimeout = null;
  174.         $multi->openHandles[$id] = [$ch, $options];
  175.         curl_multi_add_handle($multi->handle, $ch);
  177.         $this->canary = new Canary(static function () use ($ch, $multi, $id) {
  178.             unset($multi->pauseExpiries[$id], $multi->openHandles[$id], $multi->handlesActivity[$id]);
  179.             curl_setopt($ch, \CURLOPT_PRIVATE, '_0');
  181.             if (self::$performing) {
  182.                 return;
  183.             }
  185.             curl_multi_remove_handle($multi->handle, $ch);
  186.             curl_setopt_array($ch, [
  187.                 \CURLOPT_NOPROGRESS => true,
  188.                 \CURLOPT_PROGRESSFUNCTION => null,
  189.                 \CURLOPT_HEADERFUNCTION => null,
  190.                 \CURLOPT_WRITEFUNCTION => null,
  191.                 \CURLOPT_READFUNCTION => null,
  192.                 \CURLOPT_INFILE => null,
  193.             ]);
  195.             if (!$multi->openHandles) {
  196.                 // Schedule DNS cache eviction for the next request
  197.                 $multi->dnsCache->evictions = $multi->dnsCache->evictions ?: $multi->dnsCache->removals;
  198.                 $multi->dnsCache->removals = $multi->dnsCache->hostnames = [];
  199.             }
  200.         });
  201.     }
  203.     /**
  204.      * {@inheritdoc}
  205.      */
  206.     public function getInfo(string $type = null)
  207.     {
  208.         if (!$info = $this->finalInfo) {
  209.             $info = array_merge($this->info, curl_getinfo($this->handle));
  210.             $info['url'] = $this->info['url'] ?? $info['url'];
  211.             $info['redirect_url'] = $this->info['redirect_url'] ?? null;
  213.             // workaround curl not subtracting the time offset for pushed responses
  214.             if (isset($this->info['url']) && $info['start_time'] / 1000 < $info['total_time']) {
  215.                 $info['total_time'] -= $info['starttransfer_time'] ?: $info['total_time'];
  216.                 $info['starttransfer_time'] = 0.0;
  217.             }
  219.             rewind($this->debugBuffer);
  220.             $info['debug'] = stream_get_contents($this->debugBuffer);
  221.             $waitFor = curl_getinfo($this->handle, \CURLINFO_PRIVATE);
  223.             if ('H' !== $waitFor[0] && 'C' !== $waitFor[0]) {
  224.                 curl_setopt($this->handle, \CURLOPT_VERBOSE, false);
  225.                 rewind($this->debugBuffer);
  226.                 ftruncate($this->debugBuffer, 0);
  227.                 $this->finalInfo = $info;
  228.             }
  229.         }
  231.         return null !== $type ? $info[$type] ?? null : $info;
  232.     }
  234.     /**
  235.      * {@inheritdoc}
  236.      */
  237.     public function getContent(bool $throw = true): string
  238.     {
  239.         $performing = self::$performing;
  240.         self::$performing = $performing || '_0' === curl_getinfo($this->handle, \CURLINFO_PRIVATE);
  242.         try {
  243.             return $this->doGetContent($throw);
  244.         } finally {
  245.             self::$performing = $performing;
  246.         }
  247.     }
  249.     public function __destruct()
  250.     {
  251.         try {
  252.             if (null === $this->timeout) {
  253.                 return; // Unused pushed response
  254.             }
  256.             $this->doDestruct();
  257.         } finally {
  258.             curl_setopt($this->handle, \CURLOPT_VERBOSE, false);
  259.         }
  260.     }
  262.     /**
  263.      * {@inheritdoc}
  264.      */
  265.     private static function schedule(self $response, array &$runningResponses): void
  266.     {
  267.         if (isset($runningResponses[$i = (int) $response->multi->handle])) {
  268.             $runningResponses[$i][1][$response->id] = $response;
  269.         } else {
  270.             $runningResponses[$i] = [$response->multi, [$response->id => $response]];
  271.         }
  273.         if ('_0' === curl_getinfo($ch = $response->handle, \CURLINFO_PRIVATE)) {
  274.             // Response already completed
  275.             $response->multi->handlesActivity[$response->id][] = null;
  276.             $response->multi->handlesActivity[$response->id][] = null !== $response->info['error'] ? new TransportException($response->info['error']) : null;
  277.         }
  278.     }
  280.     /**
  281.      * {@inheritdoc}
  282.      *
  283.      * @param CurlClientState $multi
  284.      */
  285.     private static function perform(ClientState $multi, array &$responses = null): void
  286.     {
  287.         if (self::$performing) {
  288.             if ($responses) {
  289.                 $response = current($responses);
  290.                 $multi->handlesActivity[(int) $response->handle][] = null;
  291.                 $multi->handlesActivity[(int) $response->handle][] = new TransportException(sprintf('Userland callback cannot use the client nor the response while processing "%s".', curl_getinfo($response->handle, \CURLINFO_EFFECTIVE_URL)));
  292.             }
  294.             return;
  295.         }
  297.         try {
  298.             self::$performing = true;
  299.             ++$multi->execCounter;
  300.             $active = 0;
  301.             while (\CURLM_CALL_MULTI_PERFORM === ($err = curl_multi_exec($multi->handle, $active))) {
  302.             }
  304.             if (\CURLM_OK !== $err) {
  305.                 throw new TransportException(curl_multi_strerror($err));
  306.             }
  308.             while ($info = curl_multi_info_read($multi->handle)) {
  309.                 if (\CURLMSG_DONE !== $info['msg']) {
  310.                     continue;
  311.                 }
  312.                 $result = $info['result'];
  313.                 $id = (int) $ch = $info['handle'];
  314.                 $waitFor = @curl_getinfo($ch, \CURLINFO_PRIVATE) ?: '_0';
  316.                 if (\in_array($result, [\CURLE_SEND_ERROR, \CURLE_RECV_ERROR, /*CURLE_HTTP2*/ 16, /*CURLE_HTTP2_STREAM*/ 92], true) && $waitFor[1] && 'C' !== $waitFor[0]) {
  317.                     curl_multi_remove_handle($multi->handle, $ch);
  318.                     $waitFor[1] = (string) ((int) $waitFor[1] - 1); // decrement the retry counter
  319.                     curl_setopt($ch, \CURLOPT_PRIVATE, $waitFor);
  320.                     curl_setopt($ch, \CURLOPT_FORBID_REUSE, true);
  322.                     if (0 === curl_multi_add_handle($multi->handle, $ch)) {
  323.                         continue;
  324.                     }
  325.                 }
  327.                 if (\CURLE_RECV_ERROR === $result && 'H' === $waitFor[0] && 400 <= ($responses[(int) $ch]->info['http_code'] ?? 0)) {
  328.                     $multi->handlesActivity[$id][] = new FirstChunk();
  329.                 }
  331.                 $multi->handlesActivity[$id][] = null;
  332.                 $multi->handlesActivity[$id][] = \in_array($result, [\CURLE_OK, \CURLE_TOO_MANY_REDIRECTS], true) || '_0' === $waitFor || curl_getinfo($ch, \CURLINFO_SIZE_DOWNLOAD) === curl_getinfo($ch, \CURLINFO_CONTENT_LENGTH_DOWNLOAD) ? null : new TransportException(ucfirst(curl_error($ch) ?: curl_strerror($result)).sprintf(' for "%s".', curl_getinfo($ch, \CURLINFO_EFFECTIVE_URL)));
  333.             }
  334.         } finally {
  335.             self::$performing = false;
  336.         }
  337.     }
  339.     /**
  340.      * {@inheritdoc}
  341.      *
  342.      * @param CurlClientState $multi
  343.      */
  344.     private static function select(ClientState $multi, float $timeout): int
  345.     {
  346.         if (\PHP_VERSION_ID < 70211) {
  347.             // workaround https://bugs.php.net/76480
  348.             $timeout = min($timeout, 0.01);
  349.         }
  351.         if ($multi->pauseExpiries) {
  352.             $now = microtime(true);
  354.             foreach ($multi->pauseExpiries as $id => $pauseExpiry) {
  355.                 if ($now < $pauseExpiry) {
  356.                     $timeout = min($timeout, $pauseExpiry - $now);
  357.                     break;
  358.                 }
  360.                 unset($multi->pauseExpiries[$id]);
  361.                 curl_pause($multi->openHandles[$id][0], \CURLPAUSE_CONT);
  362.                 curl_multi_add_handle($multi->handle, $multi->openHandles[$id][0]);
  363.             }
  364.         }
  366.         if (0 !== $selected = curl_multi_select($multi->handle, $timeout)) {
  367.             return $selected;
  368.         }
  370.         if ($multi->pauseExpiries && 0 < $timeout -= microtime(true) - $now) {
  371.             usleep((int) (1E6 * $timeout));
  372.         }
  374.         return 0;
  375.     }
  377.     /**
  378.      * Parses header lines as curl yields them to us.
  379.      */
  380.     private static function parseHeaderLine($ch, string $data, array &$info, array &$headers, ?array $options, CurlClientState $multi, int $id, ?string &$location, ?callable $resolveRedirect, ?LoggerInterface $logger): int
  381.     {
  382.         $waitFor = @curl_getinfo($ch, \CURLINFO_PRIVATE) ?: '_0';
  384.         if ('H' !== $waitFor[0]) {
  385.             return \strlen($data); // Ignore HTTP trailers
  386.         }
  388.         if ('' !== $data) {
  389.             // Regular header line: add it to the list
  390.             self::addResponseHeaders([$data], $info, $headers);
  392.             if (!str_starts_with($data, 'HTTP/')) {
  393.                 if (0 === stripos($data, 'Location:')) {
  394.                     $location = trim(substr($data, 9));
  395.                 }
  397.                 return \strlen($data);
  398.             }
  400.             if (\function_exists('openssl_x509_read') && $certinfo = curl_getinfo($ch, \CURLINFO_CERTINFO)) {
  401.                 $info['peer_certificate_chain'] = array_map('openssl_x509_read', array_column($certinfo, 'Cert'));
  402.             }
  404.             if (300 <= $info['http_code'] && $info['http_code'] < 400) {
  405.                 if (curl_getinfo($ch, \CURLINFO_REDIRECT_COUNT) === $options['max_redirects']) {
  406.                     curl_setopt($ch, \CURLOPT_FOLLOWLOCATION, false);
  407.                 } elseif (303 === $info['http_code'] || ('POST' === $info['http_method'] && \in_array($info['http_code'], [301, 302], true))) {
  408.                     $info['http_method'] = 'HEAD' === $info['http_method'] ? 'HEAD' : 'GET';
  409.                     curl_setopt($ch, \CURLOPT_POSTFIELDS, '');
  410.                 }
  411.             }
  413.             return \strlen($data);
  414.         }
  416.         // End of headers: handle informational responses, redirects, etc.
  418.         if (200 > $statusCode = curl_getinfo($ch, \CURLINFO_RESPONSE_CODE)) {
  419.             $multi->handlesActivity[$id][] = new InformationalChunk($statusCode, $headers);
  420.             $location = null;
  422.             return \strlen($data);
  423.         }
  425.         $info['redirect_url'] = null;
  427.         if (300 <= $statusCode && $statusCode < 400 && null !== $location) {
  428.             if (null === $info['redirect_url'] = $resolveRedirect($ch, $location)) {
  429.                 $options['max_redirects'] = curl_getinfo($ch, \CURLINFO_REDIRECT_COUNT);
  430.                 curl_setopt($ch, \CURLOPT_FOLLOWLOCATION, false);
  431.                 curl_setopt($ch, \CURLOPT_MAXREDIRS, $options['max_redirects']);
  432.             } else {
  433.                 $url = parse_url($location ?? ':');
  435.                 if (isset($url['host']) && null !== $ip = $multi->dnsCache->hostnames[$url['host'] = strtolower($url['host'])] ?? null) {
  436.                     // Populate DNS cache for redirects if needed
  437.                     $port = $url['port'] ?? ('http' === ($url['scheme'] ?? parse_url(curl_getinfo($ch, \CURLINFO_EFFECTIVE_URL), \PHP_URL_SCHEME)) ? 80 : 443);
  438.                     curl_setopt($ch, \CURLOPT_RESOLVE, ["{$url['host']}:$port:$ip"]);
  439.                     $multi->dnsCache->removals["-{$url['host']}:$port"] = "-{$url['host']}:$port";
  440.                 }
  441.             }
  442.         }
  444.         if (401 === $statusCode && isset($options['auth_ntlm']) && 0 === strncasecmp($headers['www-authenticate'][0] ?? '', 'NTLM ', 5)) {
  445.             // Continue with NTLM auth
  446.         } elseif ($statusCode < 300 || 400 <= $statusCode || null === $location || curl_getinfo($ch, \CURLINFO_REDIRECT_COUNT) === $options['max_redirects']) {
  447.             // Headers and redirects completed, time to get the response's content
  448.             $multi->handlesActivity[$id][] = new FirstChunk();
  450.             if ('HEAD' === $info['http_method'] || \in_array($statusCode, [204, 304], true)) {
  451.                 $waitFor = '_0'; // no content expected
  452.                 $multi->handlesActivity[$id][] = null;
  453.                 $multi->handlesActivity[$id][] = null;
  454.             } else {
  455.                 $waitFor[0] = 'C'; // C = content
  456.             }
  458.             curl_setopt($ch, \CURLOPT_PRIVATE, $waitFor);
  459.         } elseif (null !== $info['redirect_url'] && $logger) {
  460.             $logger->info(sprintf('Redirecting: "%s %s"', $info['http_code'], $info['redirect_url']));
  461.         }
  463.         $location = null;
  465.         return \strlen($data);
  466.     }
  467. }
HTTP/2 401 returned for "https://api.hubapi.com/cms/v3/blogs/authors?hapikey=41d1972b-a2ce-454d-9e57-cd6355e00240". (500 Internal Server Error)

Symfony Exception

Symfony Docs

ClientException

HTTP 500 Internal Server Error

HTTP/2 401 returned for "https://api.hubapi.com/cms/v3/blogs/authors?hapikey=41d1972b-a2ce-454d-9e57-cd6355e00240".

Exception

Symfony\Component\HttpClient\Exception\ ClientException

in vendor/symfony/http-client/Response/TraceableResponse.php (line 212)
  1.         if (500 <= $code) {
  2.             throw new ServerException($this);
  3.         }
  5.         if (400 <= $code) {
  6.             throw new ClientException($this);
  7.         }
  9.         if (300 <= $code) {
  10.             throw new RedirectionException($this);
  11.         }
in vendor/symfony/http-client/Response/TraceableResponse.php -> checkStatusCode (line 103)
  1.         } finally {
  2.             if ($this->event && $this->event->isStarted()) {
  3.                 $this->event->stop();
  4.             }
  5.             if ($throw) {
  6.                 $this->checkStatusCode($this->response->getStatusCode());
  7.             }
  8.         }
  9.     }
  11.     public function toArray(bool $throw = true): array
TraceableResponse->getContent() in src/Blog.php (line 181)
  1.                     'hapikey' => $this->hubSpotKey,
  2.                     'after' => $after,
  3.                 ],
  4.             ]);
  6.             $result = json_decode($response->getContent(), true);
  7.         } catch (HttpExceptionInterface $e) {
  8.             $this->logger->error('Could not load blog posts from HubSpot', ['exception' => $e]);
  10.             throw $e;
  11.         }
Blog->loadBlogAuthors() in src/Blog.php (line 152)
  1.         if (!isset($this->authors)) {
  2.             $beta = $bustCache ? INF : null;
  3.             $this->authors = $this->cache->get('blog_authors', function (ItemInterface $item) {
  4.                 $item->expiresAfter(86400); // cache for 1 day
  6.                 return $this->loadBlogAuthors();
  7.             }, $beta);
  8.         }
  10.         return $this->authors;
  11.     }
in vendor/symfony/cache/Adapter/TraceableAdapter.php -> App\{closure} (line 51)
  2.         $isHit = true;
  3.         $callback = function (CacheItem $item, bool &$save) use ($callback, &$isHit) {
  4.             $isHit = $item->isHit();
  6.             return $callback($item, $save);
  7.         };
  9.         $event = $this->start(__FUNCTION__);
  10.         try {
  11.             $value = $this->pool->get($key, $callback, $beta, $metadata);
in vendor/symfony/cache/LockRegistry.php -> Symfony\Component\Cache\Adapter\{closure} (line 108)
  2.                 if ($locked || !$wouldBlock) {
  3.                     $logger && $logger->info(sprintf('Lock %s, now computing item "{key}"', $locked ? 'acquired' : 'not supported'), ['key' => $item->getKey()]);
  4.                     self::$lockedFiles[$key] = true;
  6.                     $value = $callback($item, $save);
  8.                     if ($save) {
  9.                         if ($setMetadata) {
  10.                             $setMetadata($item);
  11.                         }
in vendor/symfony/cache/Traits/ContractsTrait.php :: compute (line 100)
  1.             }
  3.             try {
  4.                 $value = ($this->callbackWrapper)($callback, $item, $save, $pool, function (CacheItem $item) use ($setMetadata, $startTime, &$metadata) {
  5.                     $setMetadata($item, $startTime, $metadata);
  6.                 }, $this->logger ?? null);
  7.                 $setMetadata($item, $startTime, $metadata);
  9.                 return $value;
  10.             } finally {
  11.                 unset($this->computing[$key]);
in vendor/symfony/cache-contracts/CacheTrait.php -> Symfony\Component\Cache\Traits\{closure} (line 72)
  1.             }
  2.         }
  4.         if ($recompute) {
  5.             $save = true;
  6.             $item->set($callback($item, $save));
  7.             if ($save) {
  8.                 $pool->save($item);
  9.             }
  10.         }
in vendor/symfony/cache/Traits/ContractsTrait.php -> contractsGet (line 107)
  2.                 return $value;
  3.             } finally {
  4.                 unset($this->computing[$key]);
  5.             }
  6.         }, $beta, $metadata, $this->logger ?? null);
  7.     }
  8. }
in vendor/symfony/cache-contracts/CacheTrait.php -> doGet (line 35)
  1.      *
  2.      * @return mixed
  3.      */
  4.     public function get(string $key, callable $callback, float $beta = null, array &$metadata = null)
  5.     {
  6.         return $this->doGet($this, $key, $callback, $beta, $metadata);
  7.     }
  9.     /**
  10.      * {@inheritdoc}
  11.      */
in vendor/symfony/cache/Adapter/TraceableAdapter.php -> get (line 56)
  1.             return $callback($item, $save);
  2.         };
  4.         $event = $this->start(__FUNCTION__);
  5.         try {
  6.             $value = $this->pool->get($key, $callback, $beta, $metadata);
  7.             $event->result[$key] = get_debug_type($value);
  8.         } finally {
  9.             $event->end = microtime(true);
  10.         }
  11.         if ($isHit) {
TraceableAdapter->get('blog_authors', object(Closure), INF) in src/Blog.php (line 149)
  2.     public function getAuthors(bool $bustCache = false): array
  3.     {
  4.         if (!isset($this->authors)) {
  5.             $beta = $bustCache ? INF : null;
  6.             $this->authors = $this->cache->get('blog_authors', function (ItemInterface $item) {
  7.                 $item->expiresAfter(86400); // cache for 1 day
  9.                 return $this->loadBlogAuthors();
  10.             }, $beta);
  11.         }
Blog->getAuthors(true) in src/Blog.php (line 37)
  1.      * WARNING: This will be slow and should not be called
  2.      * unless intentional.
  3.      */
  4.     public function bustCache(): void
  5.     {
  6.         $this->getAuthors(true);
  7.         $this->getTags(true);
  8.         $this->getAllPosts(true);
  9.     }
  11.     public function getAuthor(string $slug): ?array
Blog->bustCache() in src/EventSubscriber/ContentRefreshSubscriber.php (line 45)
  1.         // Update the last refresh time now to minimize cache stampede
  2.         $this->cache->get('lastContentRefresh', function () {
  3.             return time();
  4.         }, INF);
  6.         $this->blog->bustCache();
  7.     }
  9.     public static function getSubscribedEvents(): array
  10.     {
  11.         return [
ContentRefreshSubscriber->refresh() in src/EventSubscriber/ContentRefreshSubscriber.php (line 34)
  1.         $lastRefresh = $this->cache->get('lastContentRefresh', function () {
  2.             return 0;
  3.         });
  5.         if ($lastRefresh < strtotime('-5 minutes')) {
  6.             $this->refresh();
  7.         }
  8.     }
  10.     private function refresh(): void
  11.     {
in vendor/symfony/event-dispatcher/EventDispatcher.php -> onKernelTerminate (line 270)
  1.                     $closure = static function (...$args) use (&$listener, &$closure) {
  2.                         if ($listener[0] instanceof \Closure) {
  3.                             $listener[0] = $listener[0]();
  4.                             $listener[1] = $listener[1] ?? '__invoke';
  5.                         }
  6.                         ($closure = \Closure::fromCallable($listener))(...$args);
  7.                     };
  8.                 } else {
  9.                     $closure = $listener instanceof \Closure || $listener instanceof WrappedListener ? $listener : \Closure::fromCallable($listener);
  10.                 }
  11.             }
in vendor/symfony/event-dispatcher/EventDispatcher.php :: Symfony\Component\EventDispatcher\{closure} (line 230)
  2.         foreach ($listeners as $listener) {
  3.             if ($stoppable && $event->isPropagationStopped()) {
  4.                 break;
  5.             }
  6.             $listener($event, $eventName, $this);
  7.         }
  8.     }
  10.     /**
  11.      * Sorts the internal list of listeners for the given event by priority.
in vendor/symfony/event-dispatcher/EventDispatcher.php -> callListeners (line 59)
  1.         } else {
  2.             $listeners = $this->getListeners($eventName);
  3.         }
  5.         if ($listeners) {
  6.             $this->callListeners($listeners, $eventName, $event);
  7.         }
  9.         return $event;
  10.     }
in vendor/symfony/http-kernel/HttpKernel.php -> dispatch (line 94)
  1.     /**
  2.      * {@inheritdoc}
  3.      */
  4.     public function terminate(Request $request, Response $response)
  5.     {
  6.         $this->dispatcher->dispatch(new TerminateEvent($this, $request, $response), KernelEvents::TERMINATE);
  7.     }
  9.     /**
  10.      * @internal
  11.      */
in vendor/symfony/http-kernel/Kernel.php -> terminate (line 159)
  1.         if (false === $this->booted) {
  2.             return;
  3.         }
  5.         if ($this->getHttpKernel() instanceof TerminableInterface) {
  6.             $this->getHttpKernel()->terminate($request, $response);
  7.         }
  8.     }
  10.     /**
  11.      * {@inheritdoc}
Kernel->terminate(object(Request), object(Response)) in public/index.php (line 36)
  2. $kernel = new Kernel($_SERVER['APP_ENV'], (bool) $_SERVER['APP_DEBUG']);
  3. $request = Request::createFromGlobals();
  4. $response = $kernel->handle($request);
  5. $response->send();
  6. $kernel->terminate($request, $response);

Logs 3

Level Channel Message
INFO 08:51:24 php User Deprecated: Since symfony/framework-bundle 5.3: The "session.storage.native" service is deprecated, use "session.storage.factory.native" instead. 
{
    "exception": {}
}
INFO 08:51:24 php User Deprecated: Since symfony/framework-bundle 5.3: The "session.storage.metadata_bag" service is deprecated, create your own "session.storage.factory" instead. 
{
    "exception": {}
}
INFO 08:51:24 request Matched route "_profiler_open_file". 
{
    "route": "_profiler_open_file",
    "route_parameters": {
        "_route": "_profiler_open_file",
        "_controller": "web_profiler.controller.profiler::openAction"
    },
    "request_uri": "http://invoiced.project-release.info/_profiler/open?file=vendor%2Fsymfony%2Fhttp-client%2FResponse%2FCurlResponse.php&line=105",
    "method": "GET"
}
INFO 08:51:24 cache Lock acquired, now computing item "lastContentRefresh" 
{
    "key": "lastContentRefresh"
}
INFO 08:51:24 cache Lock acquired, now computing item "blog_authors" 
{
    "key": "blog_authors"
}
INFO 08:51:24 http_client Request: "GET https://api.hubapi.com/cms/v3/blogs/authors?hapikey=41d1972b-a2ce-454d-9e57-cd6355e00240"
INFO 08:51:24 http_client Response: "401 https://api.hubapi.com/cms/v3/blogs/authors?hapikey=41d1972b-a2ce-454d-9e57-cd6355e00240"
ERROR 08:51:24 app Could not load blog posts from HubSpot 
{
    "exception": {}
}
CRITICAL 08:51:24 php Uncaught Exception: HTTP/2 401 returned for "https://api.hubapi.com/cms/v3/blogs/authors?hapikey=41d1972b-a2ce-454d-9e57-cd6355e00240". 
{
    "exception": {}
}
CRITICAL 08:51:24 request Uncaught PHP Exception Symfony\Component\HttpClient\Exception\ClientException: "HTTP/2 401 returned for "https://api.hubapi.com/cms/v3/blogs/authors?hapikey=41d1972b-a2ce-454d-9e57-cd6355e00240"." at /var/www/invoiced/data/www/invoiced.project-release.info/vendor/symfony/http-client/Response/TraceableResponse.php line 212 
{
    "exception": {}
}

Stack Trace

ClientException 
Symfony\Component\HttpClient\Exception\ClientException:
HTTP/2 401  returned for "https://api.hubapi.com/cms/v3/blogs/authors?hapikey=41d1972b-a2ce-454d-9e57-cd6355e00240".

  at vendor/symfony/http-client/Response/TraceableResponse.php:212
  at Symfony\Component\HttpClient\Response\TraceableResponse->checkStatusCode(401)
     (vendor/symfony/http-client/Response/TraceableResponse.php:103)
  at Symfony\Component\HttpClient\Response\TraceableResponse->getContent()
     (src/Blog.php:181)
  at App\Blog->loadBlogAuthors()
     (src/Blog.php:152)
  at App\Blog->App\{closure}(object(CacheItem), true)
     (vendor/symfony/cache/Adapter/TraceableAdapter.php:51)
  at Symfony\Component\Cache\Adapter\TraceableAdapter->Symfony\Component\Cache\Adapter\{closure}(object(CacheItem), true)
     (vendor/symfony/cache/LockRegistry.php:108)
  at Symfony\Component\Cache\LockRegistry::compute(object(Closure), object(CacheItem), true, object(FilesystemAdapter), object(Closure), object(Logger))
     (vendor/symfony/cache/Traits/ContractsTrait.php:100)
  at Symfony\Component\Cache\Adapter\AbstractAdapter->Symfony\Component\Cache\Traits\{closure}(object(CacheItem), true)
     (vendor/symfony/cache-contracts/CacheTrait.php:72)
  at Symfony\Component\Cache\Adapter\AbstractAdapter->contractsGet(object(FilesystemAdapter), 'blog_authors', object(Closure), INF, array(), object(Logger))
     (vendor/symfony/cache/Traits/ContractsTrait.php:107)
  at Symfony\Component\Cache\Adapter\AbstractAdapter->doGet(object(FilesystemAdapter), 'blog_authors', object(Closure), INF, array())
     (vendor/symfony/cache-contracts/CacheTrait.php:35)
  at Symfony\Component\Cache\Adapter\AbstractAdapter->get('blog_authors', object(Closure), INF, array())
     (vendor/symfony/cache/Adapter/TraceableAdapter.php:56)
  at Symfony\Component\Cache\Adapter\TraceableAdapter->get('blog_authors', object(Closure), INF)
     (src/Blog.php:149)
  at App\Blog->getAuthors(true)
     (src/Blog.php:37)
  at App\Blog->bustCache()
     (src/EventSubscriber/ContentRefreshSubscriber.php:45)
  at App\EventSubscriber\ContentRefreshSubscriber->refresh()
     (src/EventSubscriber/ContentRefreshSubscriber.php:34)
  at App\EventSubscriber\ContentRefreshSubscriber->onKernelTerminate(object(TerminateEvent), 'kernel.terminate', object(EventDispatcher))
     (vendor/symfony/event-dispatcher/EventDispatcher.php:270)
  at Symfony\Component\EventDispatcher\EventDispatcher::Symfony\Component\EventDispatcher\{closure}(object(TerminateEvent), 'kernel.terminate', object(EventDispatcher))
     (vendor/symfony/event-dispatcher/EventDispatcher.php:230)
  at Symfony\Component\EventDispatcher\EventDispatcher->callListeners(array(object(Closure), object(Closure)), 'kernel.terminate', object(TerminateEvent))
     (vendor/symfony/event-dispatcher/EventDispatcher.php:59)
  at Symfony\Component\EventDispatcher\EventDispatcher->dispatch(object(TerminateEvent), 'kernel.terminate')
     (vendor/symfony/http-kernel/HttpKernel.php:94)
  at Symfony\Component\HttpKernel\HttpKernel->terminate(object(Request), object(Response))
     (vendor/symfony/http-kernel/Kernel.php:159)
  at Symfony\Component\HttpKernel\Kernel->terminate(object(Request), object(Response))
     (public/index.php:36)