src/EventsSubscriber/Activity/ActivityEventSubscriber.php line 59

Open in your IDE?
  1. <?php
  3. declare(strict_types=1);
  5. namespace App\EventsSubscriber\Activity;
  7. use App\Contracts\Activity\Status;
  8. use App\Event\Activity\ActivityActivatedEvent;
  9. use App\Event\Activity\ApproveAllReviewEvent;
  10. use App\Event\Activity\DeclineAllReviewEvent;
  11. use App\Event\Activity\DeclineCampaignActivityEvent;
  12. use App\Event\Campaign\RenewedCampaignEvent;
  13. use App\Messenger\Activity\ApproveAllReviewMessage;
  14. use App\Messenger\Activity\DeclineAllReviewMessage;
  15. use App\Messenger\Activity\DeclineCampaignActivityMessage;
  16. use App\Services\Activity\ActivityServiceInterface;
  17. use App\Services\Campaign\CampaignServiceInterface;
  18. use Symfony\Component\EventDispatcher\EventSubscriberInterface;
  19. use Symfony\Component\Messenger\MessageBusInterface;
  21. class ActivityEventSubscriber implements EventSubscriberInterface
  22. {
  23.     public static function getSubscribedEvents(): array
  24.     {
  25.         return [
  26.             ActivityActivatedEvent::class => 'onActivityActivated',
  27.             DeclineAllReviewEvent::class => 'declineAllReview',
  28.             ApproveAllReviewEvent::class => 'approveAllReview',
  29.             DeclineCampaignActivityEvent::class => 'declineCampaignActivity',
  30.             RenewedCampaignEvent::class => ['onRenewedCampaign', 10],
  31.         ];
  32.     }
  34.     public function __construct(
  35.         private readonly MessageBusInterface $bus,
  36.         private readonly ActivityServiceInterface $activityService,
  37.         private readonly CampaignServiceInterface $campaignService,
  38.     ) {}
  40.     public function onActivityActivated(ActivityActivatedEvent $event): void
  41.     {
  42.         $this->campaignService->updateCampaignStatistics($event->getActivity()->getCampaign()->getId());
  43.     }
  45.     public function declineAllReview(DeclineAllReviewEvent $event): void
  46.     {
  47.         $this->bus->dispatch(
  48.             new DeclineAllReviewMessage($event->getCampaign()->getId(), $event->getReason()),
  49.         );
  50.     }
  52.     public function approveAllReview(ApproveAllReviewEvent $event): void
  53.     {
  54.         $this->bus->dispatch(
  55.             new ApproveAllReviewMessage($event->getCampaign()->getId()),
  56.         );
  57.     }
  59.     public function declineCampaignActivity(DeclineCampaignActivityEvent $event): void
  60.     {
  61.         $this->bus->dispatch(
  62.             new DeclineCampaignActivityMessage($event->getCampaign()->getId()),
  63.         );
  64.     }
  66.     public function onRenewedCampaign(RenewedCampaignEvent $event): void
  67.     {
  68.         $activities = $this->activityService->getCampaignActivitiesByStatuses(
  69.             $event->getCampaign()->getId(),
  70.             [
  71.                 Status::ACCEPTED,
  72.                 Status::SPONSOR_REVIEW,
  73.                 Status::VIDEO_PENDING,
  74.                 Status::SPONSOR_DECLINE,
  75.                 Status::DRAFT_VIDEO_REVIEW,
  76.             ]
  77.         );
  79.         $this->activityService->deleteActivities($activities);
  80.     }
  81. }