src/Blog.php line 149

Open in your IDE?
  1. <?php
  2. namespace App;
  3. use Psr\Log\LoggerAwareInterface;
  4. use Psr\Log\LoggerAwareTrait;
  5. use Symfony\Contracts\Cache\CacheInterface;
  6. use Symfony\Contracts\Cache\ItemInterface;
  7. use Symfony\Contracts\HttpClient\Exception\HttpExceptionInterface;
  8. use Symfony\Contracts\HttpClient\HttpClientInterface;
  9. class Blog implements LoggerAwareInterface
  10. {
  11.     use LoggerAwareTrait;
  12.     private CacheInterface $cache;
  13.     private string $hubSpotKey;
  14.     private HttpClientInterface $httpClient;
  15.     private array $posts;
  16.     private array $authors;
  17.     private array $tags;
  18.     public function __construct(CacheInterface $cachestring $hubSpotKeyHttpClientInterface $httpClient)
  19.     {
  20.         $this->cache $cache;
  21.         $this->hubSpotKey $hubSpotKey;
  22.         $this->httpClient $httpClient;
  23.     }
  24.     /**
  25.      * This busts the cached blog data and reloads everything.
  26.      * WARNING: This will be slow and should not be called
  27.      * unless intentional.
  28.      */
  29.     public function bustCache(): void
  30.     {
  31.         $this->getAuthors(true);
  32.         $this->getTags(true);
  33.         $this->getAllPosts(true);
  34.     }
  35.     public function getAuthor(string $slug): ?array
  36.     {
  37.         foreach ($this->getAuthors() as $author) {
  38.             if ($author['slug'] == $slug) {
  39.                 return $author;
  40.             }
  41.         }
  42.         return null;
  43.     }
  44.     public function getTag(string $slug): ?array
  45.     {
  46.         foreach ($this->getTags() as $tag) {
  47.             if ($tag['slug'] == $slug) {
  48.                 return $tag;
  49.             }
  50.         }
  51.         return null;
  52.     }
  53.     public function getPosts(int $perPage 3int $page 1string $tag ''string $author ''): array
  54.     {
  55.         $offset = ($page 1) * $perPage;
  56.         $posts $this->getAllPosts();
  57.         if ($tag) {
  58.             $postsFiltered = [];
  59.             foreach ($posts as $post) {
  60.                 foreach ($post['tags'] as $tag2) {
  61.                     if ($tag2['slug'] == $tag) {
  62.                         $postsFiltered[] = $post;
  63.                         break;
  64.                     }
  65.                 }
  66.             }
  67.             $posts $postsFiltered;
  68.         }
  69.         if ($author) {
  70.             $postsFiltered = [];
  71.             foreach ($posts as $post) {
  72.                 if ($post['author']['slug'] == $author) {
  73.                     $postsFiltered[] = $post;
  74.                 }
  75.             }
  76.             $posts $postsFiltered;
  77.         }
  78.         if ($perPage 0) {
  79.             return $posts;
  80.         }
  81.         return array_slice($posts$offset$perPage);
  82.     }
  83.     public function hasMorePosts(int $perPageint $page, ?string $tag '', ?string $author ''): bool
  84.     {
  85.         $posts $this->getPosts(-11$tag$author);
  86.         return $perPage $page count($posts);
  87.     }
  88.     public function getPost(string $id): ?array
  89.     {
  90.         $posts $this->getAllPosts();
  91.         foreach ($posts as $post) {
  92.             if ($post['slug'] == $id) {
  93.                 return $post;
  94.             }
  95.         }
  96.         return null;
  97.     }
  98.     public function getPrevious(string $id): ?array
  99.     {
  100.         $found false;
  101.         foreach ($this->getAllPosts() as $post) {
  102.             if ($post['slug'] == $id) {
  103.                 $found true;
  104.             } elseif ($found) {
  105.                 return $post;
  106.             }
  107.         }
  108.         return null;
  109.     }
  110.     public function getNext(string $id): ?array
  111.     {
  112.         $previous null;
  113.         foreach ($this->getAllPosts() as $post) {
  114.             if ($post['slug'] == $id) {
  115.                 return $previous;
  116.             }
  117.             $previous $post;
  118.         }
  119.         return null;
  120.     }
  121.     public function getAuthors(bool $bustCache false): array
  122.     {
  123.         if (!isset($this->authors)) {
  124.             $beta $bustCache INF null;
  125.             $this->authors $this->cache->get('blog_authors', function (ItemInterface $item) {
  126.                 $item->expiresAfter(86400); // cache for 1 day
  127.                 return $this->loadBlogAuthors();
  128.             }, $beta);
  129.         }
  130.         return $this->authors;
  131.     }
  132.     private function getAuthorById(int $id): array
  133.     {
  134.         $authors $this->getAuthors();
  135.         foreach ($authors as $author) {
  136.             if ($author['id'] == $id) {
  137.                 return $author;
  138.             }
  139.         }
  140.         return $authors[0];
  141.     }
  142.     private function loadBlogAuthors(?string $after null): array
  143.     {
  144.         try {
  145.             $response $this->httpClient->request('GET''https://api.hubapi.com/cms/v3/blogs/authors', [
  146.                 'query' => [
  147.                     'hapikey' => $this->hubSpotKey,
  148.                     'after' => $after,
  149.                 ],
  150.             ]);
  151.             $result json_decode($response->getContent(), true);
  152.         } catch (HttpExceptionInterface $e) {
  153.             $this->logger->error('Could not load blog posts from HubSpot', ['exception' => $e]);
  154.             throw $e;
  155.         }
  156.         $authors $result['results'];
  157.         foreach ($authors as &$author) {
  158.             $author['slug'] = $this->slugify($author['name']);
  159.         }
  160.         // load all pages of data
  161.         if (isset($result['paging']['next'])) {
  162.             $authors array_merge(
  163.                 $result['results'],
  164.                 $this->loadBlogAuthors($result['paging']['next']['after'])
  165.             );
  166.         }
  167.         return $authors;
  168.     }
  169.     public function getAllPosts(bool $bustCache false): array
  170.     {
  171.         if (!isset($this->posts)) {
  172.             $beta $bustCache INF null;
  173.             $this->posts $this->cache->get('blog_posts', function (ItemInterface $item) {
  174.                 $item->expiresAfter(86400); // cache for 1 day
  175.                 return $this->loadBlogPosts();
  176.             }, $beta);
  177.         }
  178.         return $this->posts;
  179.     }
  180.     private function loadBlogPosts(?string $after null): array
  181.     {
  182.         try {
  183.             $response $this->httpClient->request('GET''https://api.hubapi.com/cms/v3/blogs/posts', [
  184.                 'query' => [
  185.                     'hapikey' => $this->hubSpotKey,
  186.                     'after' => $after,
  187.                 ],
  188.             ]);
  189.             $result json_decode($response->getContent(), true);
  190.         } catch (HttpExceptionInterface $e) {
  191.             $this->logger->error('Could not load blog posts from HubSpot', ['exception' => $e]);
  192.             throw $e;
  193.         }
  194.         $posts = [];
  195.         foreach ($result['results'] as $post) {
  196.             // Remove draft and archived posts
  197.             if ('PUBLISHED' != $post['currentState']) {
  198.                 continue;
  199.             }
  200.             // determine the author
  201.             $post['author'] = $this->getAuthorById($post['blogAuthorId']);
  202.             // determine the primary tag
  203.             $post['tags'] = [];
  204.             foreach ($post['tagIds'] as $tagId) {
  205.                 $post['tags'][] = $this->getTagById($tagId);
  206.             }
  207.             $post['tag'] = count($post['tags']) > $post['tags'][0] : null;
  208.             // strip not allowed characters from slug
  209.             $post['slug'] = $this->slugify($post['slug']);
  210.             $posts[] = $post;
  211.         }
  212.         // load all pages of data
  213.         if (isset($result['paging']['next'])) {
  214.             $posts array_merge(
  215.                 $posts,
  216.                 $this->loadBlogPosts($result['paging']['next']['after'])
  217.             );
  218.         }
  219.         // sort by date
  220.         usort($posts, [$this'sortPost']);
  221.         return $posts;
  222.     }
  223.     public function getTags(bool $bustCache false): array
  224.     {
  225.         if (!isset($this->tags)) {
  226.             $beta $bustCache INF null;
  227.             $this->tags $this->cache->get('blog_tags', function (ItemInterface $item) {
  228.                 $item->expiresAfter(86400); // cache for 1 day
  229.                 return $this->loadBlogTags();
  230.             }, $beta);
  231.         }
  232.         return $this->tags;
  233.     }
  234.     private function getTagById(int $id): ?array
  235.     {
  236.         foreach ($this->getTags() as $tagDetail) {
  237.             if ($tagDetail['id'] == $id) {
  238.                 return $tagDetail;
  239.             }
  240.         }
  241.         return null;
  242.     }
  243.     private function loadBlogTags(?string $after null): array
  244.     {
  245.         try {
  246.             $response $this->httpClient->request('GET''https://api.hubapi.com/cms/v3/blogs/tags', [
  247.                 'query' => [
  248.                     'hapikey' => $this->hubSpotKey,
  249.                     'after' => $after,
  250.                 ],
  251.             ]);
  252.             $result json_decode($response->getContent(), true);
  253.         } catch (HttpExceptionInterface $e) {
  254.             $this->logger->error('Could not load blog posts from HubSpot', ['exception' => $e]);
  255.             throw $e;
  256.         }
  257.         $tags $result['results'];
  258.         foreach ($tags as &$tag) {
  259.             $tag['slug'] = $this->slugify($tag['name']);
  260.         }
  261.         // load all pages of data
  262.         if (isset($result['paging']['next'])) {
  263.             $tags array_merge(
  264.                 $tags,
  265.                 $this->loadBlogTags($result['paging']['next']['after'])
  266.             );
  267.         }
  268.         // sort by name
  269.         usort($tags, [$this'sortTag']);
  270.         return $tags;
  271.     }
  272.     /**
  273.      * Sorts two blog posts in reverse date order.
  274.      */
  275.     public function sortPost(array $a, array $b): int
  276.     {
  277.         return $b['publishDate'] <=> $a['publishDate'];
  278.     }
  279.     /**
  280.      * Sorts two blog tags in alphabetical order.
  281.      */
  282.     public function sortTag(array $a, array $b): int
  283.     {
  284.         return $a['name'] <=> $b['name'];
  285.     }
  286.     private function slugify(string $input): string
  287.     {
  288.         $slug strtolower(str_replace(' ''-'$input));
  289.         return preg_replace('/[^0-9a-zA-Z\-]/'''$slug);
  290.     }
  291. }
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

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

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

Logs 3

Level Channel Message
INFO 12:32:52 php User Deprecated: Since symfony/framework-bundle 5.3: The "session.storage.native" service is deprecated, use "session.storage.factory.native" instead.
{
    "exception": {}
}
INFO 12:32:52 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 12:32:52 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=src%2FBlog.php&line=149",
    "method": "GET"
}
INFO 12:32:52 cache Lock acquired, now computing item "lastContentRefresh"
{
    "key": "lastContentRefresh"
}
INFO 12:32:52 cache Lock acquired, now computing item "blog_authors"
{
    "key": "blog_authors"
}
INFO 12:32:52 http_client Request: "GET https://api.hubapi.com/cms/v3/blogs/authors?hapikey=41d1972b-a2ce-454d-9e57-cd6355e00240"
INFO 12:32:52 http_client Response: "401 https://api.hubapi.com/cms/v3/blogs/authors?hapikey=41d1972b-a2ce-454d-9e57-cd6355e00240"
ERROR 12:32:52 app Could not load blog posts from HubSpot
{
    "exception": {}
}
CRITICAL 12:32:52 php Uncaught Exception: HTTP/2 401 returned for "https://api.hubapi.com/cms/v3/blogs/authors?hapikey=41d1972b-a2ce-454d-9e57-cd6355e00240".
{
    "exception": {}
}
CRITICAL 12:32:52 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)