src/Services/Activity/EventSubscriber/VideoEventSubscriber.php line 37

Open in your IDE?
  1. <?php
  3. declare(strict_types=1);
  5. namespace App\Services\Activity\EventSubscriber;
  7. use App\Services\Activity\ActivityServiceInterface;
  8. use App\Services\Campaign\CampaignServiceInterface;
  9. use App\Services\Creator\CreatorServiceInterface;
  10. use App\Services\System\SettingsServiceInterface;
  11. use App\Services\Video\Event\VideoStatisticsUpdatedEvent;
  12. use App\Services\Video\VideoServiceInterface;
  13. use Symfony\Component\EventDispatcher\EventSubscriberInterface;
  14. use Symfony\Component\ExpressionLanguage\ExpressionLanguage;
  16. class VideoEventSubscriber implements EventSubscriberInterface
  17. {
  18.     public function __construct(
  19.         private readonly ActivityServiceInterface $activityService,
  20.         private readonly CreatorServiceInterface $creatorService,
  21.         private readonly SettingsServiceInterface $settingsService,
  22.         private readonly VideoServiceInterface $videoService,
  23.         private readonly CampaignServiceInterface $campaignService
  24.     ) {
  25.     }
  27.     public static function getSubscribedEvents(): array
  28.     {
  29.         return [
  30.             VideoStatisticsUpdatedEvent::class => [
  31.                 ['updatePrice', 1],
  32.                 ['validateStatistics', 0],
  33.             ],
  34.         ];
  35.     }
  37.     public function updatePrice(VideoStatisticsUpdatedEvent $event): void
  38.     {
  39.         $video = $this->videoService->get($event->getVideoId());
  41.         if ($event->isUpdateOnlyStatistics()) {
  42.             $campaignId = $this->activityService->getCampaignId($video->getActivityId());
  43.             $this->campaignService->updateCampaignStatistics($campaignId);
  45.             return;
  46.         }
  48.         $this->activityService->updatePrice($video->getActivityId());
  49.     }
  51.     public function validateStatistics(VideoStatisticsUpdatedEvent $event): void
  52.     {
  53.         $video = $this->videoService->get($event->getVideoId());
  54.         $expression = $this->settingsService->get()->getAutoBanAfterStatisticsUpdate();
  55.         $expressionLanguage = new ExpressionLanguage();
  57.         if (trim($expression) === '') {
  58.             return;
  59.         }
  61.         /** @var bool $ban */
  62.         $ban = $expressionLanguage->evaluate($expression, [
  63.             'views' => $video->getViews(),
  64.             'likes' => $video->getLikes(),
  65.             'shares' => $video->getShares(),
  66.             'comments' => $video->getComments(),
  67.         ]);
  69.         if ($ban) {
  70.             $this->creatorService->ban($video->getCreatorId());
  71.             $this->activityService->decline($video->getActivityId(), true);
  72.         }
  73.     }
  74. }