src/EventSubscriber/AlertForecastReportTwitterEventSubscriber.php line 19

Open in your IDE?
  1. <?php
  3. namespace App\EventSubscriber;
  5. use App\Service\ReportModerationService;
  6. use App\Service\TwitterService;
  7. use Pimcore\Event\Model\DataObjectEvent;
  8. use Pimcore\Log\ApplicationLogger;
  9. use Pimcore\Model\DataObject\Report;
  11. class AlertForecastReportTwitterEventSubscriber
  12. {
  13.     public function __construct(
  14.         private TwitterService $twitterService,
  15.         private ApplicationLogger $logger,
  16.     ) {
  17.     }
  19.     public function onAlertForecastReportPublished(DataObjectEvent $event): void
  20.     {
  21.         $report = $event->getObject();
  22.         if (!$report instanceof Report) {
  23.             return;
  24.         }
  25.         if (!$this->shouldPostToTwitter($report)) {
  26.             return;
  27.         }
  28.         $baseUrl = rtrim((string) ($_ENV['PUBLIC_URL'] ?? NCM_PUBLIC_PORTAL_URL), '/');
  29.         $reportId = $report->getId();
  30.         $publicReportUrlEn = $baseUrl . '/en/weather/weather-reports/' . $reportId;
  31.         $publicReportUrlAr = $baseUrl . '/ar/weather/weather-reports/' . $reportId;
  33.         $tweetMessage = $this->buildTweetMessage($report, $publicReportUrlEn, $publicReportUrlAr);
  35.         try {
  36.             $tweet = $this->postTweetWithOptionalMedia($report, $tweetMessage);
  37.             $this->logger->info('Alert forecast report Twitter post response: ' . json_encode($tweet));
  39.             if (!empty($tweet['tweetId'])) {
  40.                 $report->setTwitterId($tweet['tweetId']);
  41.             }
  42.             if (isset($tweet['data'])) {
  43.                 $report->setTwitterLog($tweet['data']);
  44.             }
  45.             // Persist the tweet id without $report->save() (which would re-dispatch postUpdate
  46.             // and re-enter the email subscriber). Do NOT stamp deliveredVersion here - the email
  47.             // subscriber owns that, so stamping it here would suppress the email on the same publish.
  48.             ReportModerationService::persistReportColumns($report, [
  49.                 'twitterId' => $report->getTwitterId(),
  50.                 'twitterLog' => $report->getTwitterLog(),
  51.             ]);
  52.         } catch (\Throwable $e) {
  53.             $this->logger->error('Alert forecast report Twitter post failed: ' . $e->getMessage());
  54.         }
  55.     }
  57.     private function buildTweetMessage(Report $report, string $publicReportUrlEn, string $publicReportUrlAr): string
  58.     {
  59.         $titleEn = trim((string) $report->getReportTitle('en'));
  60.         $titleAr = trim((string) $report->getReportTitle('ar'));
  61.         $typeEn = trim((string) ($report->getReportType()?->getName('en') ?? ''));
  62.         $typeAr = trim((string) ($report->getReportType()?->getName('ar') ?? ''));
  63.         $twitterDescription = $this->buildTwitterDescriptionBlock($report);
  65.         $trimOrder = array_values(array_filter([
  66.             $twitterDescription !== '' ? $twitterDescription : null,
  67.             $this->buildTitleBlock($titleEn, $titleAr) ?: null,
  68.             $this->buildTypeBlock($typeEn, $typeAr) ?: null,
  69.         ]));
  71.         $linkBlock = $this->buildLinkBlock($publicReportUrlAr, $publicReportUrlEn);
  73.         return $this->fitTweetLength($trimOrder, $linkBlock);
  74.     }
  76.     private function buildTwitterDescriptionBlock(Report $report): string
  77.     {
  78.         return trim((string) $report->getTwitterDescription());
  79.     }
  81.     private function buildTitleBlock(string $titleEn, string $titleAr): string
  82.     {
  83.         $lines = [];
  85.         if ($titleEn !== '') {
  86.             $lines[] = '⚠️ ' . $titleEn;
  87.         }
  88.         if ($titleAr !== '' && $titleAr !== $titleEn) {
  89.             $lines[] = $titleAr;
  90.         }
  92.         return implode("\n", $lines);
  93.     }
  95.     private function buildTypeBlock(string $typeEn, string $typeAr): string
  96.     {
  97.         if ($typeEn === '' && $typeAr === '') {
  98.             return '';
  99.         }
  101.         if ($typeEn !== '' && $typeAr !== '' && $typeEn !== $typeAr) {
  102.             return '📋 ' . $typeEn . ' | ' . $typeAr;
  103.         }
  105.         return '📋 ' . ($typeEn !== '' ? $typeEn : $typeAr);
  106.     }
  108.     private function buildLinkBlock(string $publicReportUrlAr, string $publicReportUrlEn): string
  109.     {
  110.         $lines = [];
  112.         if ($publicReportUrlAr !== '') {
  113.             $lines[] = "🔗 عربي\n" . $publicReportUrlAr;
  114.         }
  115.         if ($publicReportUrlEn !== '') {
  116.             $lines[] = "🔗 EN\n" . $publicReportUrlEn;
  117.         }
  119.         return implode("\n", $lines);
  120.     }
  122.     /**
  123.      * Trims sections in order (twitterDescription → titles → type) while keeping the link block intact.
  124.      *
  125.      * @param string[] $bodySections
  126.      */
  127.     private function fitTweetLength(array $bodySections, string $linkBlock, int $maxLength = 280): string
  128.     {
  129.         if ($linkBlock === '') {
  130.             return $this->truncateToTweetLength(implode("\n\n", $bodySections), $maxLength);
  131.         }
  133.         $sectionIndex = 0;
  134.         $safety = 500;
  136.         while ($safety-- > 0) {
  137.             $body = implode("\n\n", array_filter($bodySections, static fn (string $section): bool => $section !== ''));
  138.             $message = $body === '' ? $linkBlock : $body . "\n\n" . $linkBlock;
  140.             if ($this->getTweetLength($message) <= $maxLength) {
  141.                 return $message;
  142.             }
  144.             if ($sectionIndex >= count($bodySections)) {
  145.                 return $linkBlock;
  146.             }
  148.             if ($bodySections[$sectionIndex] === '') {
  149.                 ++$sectionIndex;
  150.                 continue;
  151.             }
  153.             $currentLength = mb_strlen($bodySections[$sectionIndex]);
  154.             if ($currentLength <= 40) {
  155.                 $bodySections[$sectionIndex] = '';
  156.                 ++$sectionIndex;
  157.                 continue;
  158.             }
  160.             $bodySections[$sectionIndex] = $this->truncateText($bodySections[$sectionIndex], $currentLength - 30);
  161.         }
  163.         return $linkBlock;
  164.     }
  166.     private function truncateToTweetLength(string $text, int $maxLength): string
  167.     {
  168.         if ($this->getTweetLength($text) <= $maxLength) {
  169.             return $text;
  170.         }
  172.         $length = mb_strlen($text);
  173.         while ($length > 0 && $this->getTweetLength($this->truncateText($text, $length)) > $maxLength) {
  174.             $length -= 10;
  175.         }
  177.         return $this->truncateText($text, $length);
  178.     }
  180.     private function truncateText(string $text, int $maxLength): string
  181.     {
  182.         if ($maxLength <= 0) {
  183.             return '';
  184.         }
  186.         if (mb_strlen($text) <= $maxLength) {
  187.             return $text;
  188.         }
  190.         if ($maxLength === 1) {
  191.             return '…';
  192.         }
  194.         return rtrim(mb_substr($text, 0, $maxLength - 1)) . '…';
  195.     }
  197.     private function getTweetLength(string $text): int
  198.     {
  199.         $length = mb_strlen($text);
  201.         if (preg_match_all('#https?://\S+#ui', $text, $matches)) {
  202.             foreach ($matches[0] as $url) {
  203.                 $length -= mb_strlen($url);
  204.                 $length += 23;
  205.             }
  206.         }
  208.         return $length;
  209.     }
  211.     private function postTweetWithOptionalMedia(Report $report, string $tweetMessage): array
  212.     {
  213.         $mediaPaths = $this->resolveTwitterMediaPaths($report);
  214.         if ($mediaPaths === []) {
  215.             return $this->twitterService->postTweet($tweetMessage);
  216.         }
  218.         // Prefer video when present (Twitter does not allow mixing video + images).
  219.         foreach ($mediaPaths as $mediaPath) {
  220.             $mimeType = mime_content_type($mediaPath) ?: '';
  221.             if (str_starts_with($mimeType, 'video/')) {
  222.                 return $this->twitterService->uploadVideo($mediaPath, $tweetMessage);
  223.             }
  224.         }
  226.         $imagePaths = [];
  227.         foreach ($mediaPaths as $mediaPath) {
  228.             $mimeType = mime_content_type($mediaPath) ?: '';
  229.             if (str_starts_with($mimeType, 'image/')) {
  230.                 $imagePaths[] = $mediaPath;
  231.             }
  232.         }
  234.         if ($imagePaths !== []) {
  235.             return $this->twitterService->uploadMedia($imagePaths, $tweetMessage);
  236.         }
  238.         $this->logger->warning('Alert forecast Twitter attachment is not an image or video; posting text only.', [
  239.             'reportId' => $report->getId(),
  240.         ]);
  242.         return $this->twitterService->postTweet($tweetMessage);
  243.     }
  245.     /**
  246.      * @return string[] Readable local media paths (report media first, then ReportType xPostImage).
  247.      */
  248.     private function resolveTwitterMediaPaths(Report $report): array
  249.     {
  250.         $paths = [];
  251.         $seen = [];
  253.         $primaryAsset = $report->getTwitterImage() ?? $report->getAsset();
  254.         foreach ([$primaryAsset, $report->getReportType()?->getXPostImage()] as $asset) {
  255.             if (!$asset) {
  256.                 continue;
  257.             }
  259.             $path = PIMCORE_PROJECT_ROOT . '/public/var/assets' . $asset->getPath() . $asset->getFilename();
  260.             if (!is_readable($path) || isset($seen[$path])) {
  261.                 continue;
  262.             }
  264.             $seen[$path] = true;
  265.             $paths[] = $path;
  266.         }
  268.         return $paths;
  269.     }
  271.     private function shouldPostToTwitter($report): bool
  272.     {
  273.         return ($report instanceof Report) &&
  274.             $report->getDraftOf() === null &&
  275.             ReportModerationService::isReportApproved($report) &&
  276.             $report->isPublished(true) &&
  277.             $report->getForTwitterChannel() == true &&
  278.             $report->getReportType()?->getReportKey() == ALERT_FORECAST_REPORT_TYPE_KEY &&
  279.             empty($report->getTwitterId()) &&
  280.             empty($report->getTwitterLog());
  281.     }
  282. }