src/Aqarmap/Bundle/DiscussionBundle/Service/WordpressManager.php line 78

  1. <?php
  3. namespace Aqarmap\Bundle\DiscussionBundle\Service;
  5. use Aqarmap\Bundle\DiscussionBundle\Client\WordpressClient;
  6. use Aqarmap\Bundle\MainBundle\Service\Setting;
  7. use Predis\Client;
  9. class WordpressManager
  10. {
  11. /**
  12. * @var WordpressClient
  13. */
  14. private $wordpressClient;
  16. public function __construct(private readonly Client $redis, private readonly Setting $settings)
  17. {
  18. $this->wordpressClient = new WordpressClient();
  19. }
  21. /**
  22. * @param string $locale
  23. * @param int $limit
  24. */
  25. public function getPosts($locale = 'en', $limit = 4)
  26. {
  27. $excludedCategoriesIds = explode(
  28. ',',
  29. (string) $this->settings->getSetting('features', 'wp_excluded_categories_'.$locale)
  30. );
  31. $posts = $this->wordpressClient->getPosts($locale, $limit, $excludedCategoriesIds) ?: [];
  32. $postsData = [];
  33. foreach ($posts as $post) {
  34. $postData = [];
  35. $postData['id'] = $post->id;
  36. $postData['title'] = $post->title->rendered;
  37. $postData['link'] = $post->link;
  39. if ($postImage = $post->featured_media) {
  40. $media = $this->wordpressClient->getMedia($postImage, $locale);
  41. $postData['image'] = $media->source_url;
  42. }
  43. $postsData[] = $postData;
  44. }
  46. return $postsData;
  47. }
  49. public function setCachedPosts($locale = 'en'): void
  50. {
  51. $posts = $this->getPosts($locale);
  52. if (\count($posts)) {
  53. $this->handleCaching($locale.'_mostWordpressPosts', $posts);
  54. }
  55. }
  57. /**
  58. * @return string
  59. */
  60. public function getCachedPosts($locale = 'en')
  61. {
  62. if ($this->redis->exists($locale.'_mostWordpressPosts')) {
  63. return $this->redis->get($locale.'_mostWordpressPosts');
  64. }
  66. $this->setCachedPosts($locale);
  68. return $this->redis->get($locale.'_mostWordpressPosts');
  69. }
  71. /**
  72. * Serialize and set data in redis.
  73. */
  74. private function handleCaching($key, $result): void
  75. {
  76. $result = json_encode($result);
  77. $this->redis->set($key, $result);
  78. $this->redis->expire($key, 86400);
  79. }
  80. }