[Event] send push notification when live starts

migrations/2025/Version20250210161256.php

@@ -0,0 +1,19 @@
+<?php
+
+namespace Migrations;
+
+use Doctrine\DBAL\Schema\Schema;
+use Doctrine\Migrations\AbstractMigration;
+
+final class Version20250210161256 extends AbstractMigration
+{
+    public function up(Schema $schema): void
+    {
+        $this->addSql('ALTER TABLE events ADD push_sent_at DATETIME DEFAULT NULL');
+    }
+
+    public function down(Schema $schema): void
+    {
+        $this->addSql('ALTER TABLE `events` DROP push_sent_at');
+    }
+}

src/Command/EventPushNotificationCommand.php

@@ -0,0 +1,39 @@
+<?php
+
+namespace App\Command;
+
+use App\JeMengage\Push\Command\EventLiveBeginNotificationCommand;
+use App\Repository\Event\EventRepository;
+use Symfony\Component\Console\Attribute\AsCommand;
+use Symfony\Component\Console\Command\Command;
+use Symfony\Component\Console\Input\InputArgument;
+use Symfony\Component\Console\Input\InputInterface;
+use Symfony\Component\Console\Input\InputOption;
+use Symfony\Component\Console\Output\OutputInterface;
+use Symfony\Component\Console\Style\SymfonyStyle;
+use Symfony\Component\Messenger\MessageBusInterface;
+
+#[AsCommand(
+    name: 'app:events:push',
+    description: 'This command finds upcoming events and send push notification',
+)]
+class EventPushNotificationCommand extends Command
+{
+    public function __construct(
+        private readonly MessageBusInterface $bus,
+        private readonly EventRepository $eventRepository,
+    ) {
+        parent::__construct();
+    }
+
+    protected function execute(InputInterface $input, OutputInterface $output): int
+    {
+        $events = $this->eventRepository->findWithLiveToNotify();
+
+        foreach ($events as $event) {
+            $this->bus->dispatch(new EventLiveBeginNotificationCommand($event->getUuid()));
+        }
+
+        return self::SUCCESS;
+    }
+}

src/Command/RemindEventCommand.php → src/Command/EventReminderCommand.php

@@ -19,7 +19,7 @@
     name: 'app:events:remind',
     description: 'This command finds upcoming events and send reminders',
 )]
-class RemindEventCommand extends Command
+class EventReminderCommand extends Command
 {
     private SymfonyStyle $io;
 

src/Entity/Event/Event.php

@@ -278,6 +278,9 @@ class Event implements ReportableInterface, GeoPointInterface, AddressHolderInte
     #[ORM\Column(type: 'boolean', options: ['default' => false])]
     private bool $national = false;
 
+    #[ORM\Column(type: 'datetime', nullable: true)]
+    public ?\DateTime $pushSentAt = null;
+
     /**
      * @var string|null
      */

src/JeMengage/Push/Command/EventLiveBeginNotificationCommand.php

@@ -0,0 +1,13 @@
+<?php
+
+namespace App\JeMengage\Push\Command;
+
+use App\Entity\Event\Event;
+
+class EventLiveBeginNotificationCommand extends AbstractSendNotificationCommand
+{
+    public function getClass(): string
+    {
+        return Event::class;
+    }
+}

src/JeMengage/Push/Notification/EventLiveBeginNotification.php

@@ -0,0 +1,14 @@
+<?php
+
+namespace App\JeMengage\Push\Notification;
+
+use App\Entity\Event\Event;
+use App\Firebase\Notification\AbstractMulticastNotification;
+
+class EventLiveBeginNotification extends AbstractMulticastNotification
+{
+    public static function create(Event $event): self
+    {
+        return new self('🔴 On est en direct !', $event->getName());
+    }
+}

src/JeMengage/Push/NotificationFactory.php

@@ -47,6 +47,10 @@ private function initiateNotification(NotificationObjectInterface $object, Comma
             return Notification\EventReminderNotification::create($object);
         }
 
+        if ($command instanceof Command\EventLiveBeginNotificationCommand) {
+            return Notification\EventLiveBeginNotification::create($object);
+        }
+
         if ($command instanceof Command\NewsCreatedNotificationCommand) {
             return Notification\NewsCreatedNotification::create($object);
         }

src/Repository/Event/EventRepository.php

@@ -521,4 +521,22 @@ public function findWithLiveStream(): array
             ->getResult()
         ;
     }
+
+    public function findWithLiveToNotify(): array
+    {
+        return $this->createQueryBuilder('e')
+            ->where('e.status = :status')
+            ->andWhere('e.national = 1')
+            ->andWhere('e.liveUrl LIKE :live_url')
+            ->andWhere('e.pushSentAt IS NULL')
+            ->andWhere('e.beginAt < :now AND e.finishAt >= :now')
+            ->setParameters([
+                'status' => Event::STATUS_SCHEDULED,
+                'live_url' => 'https://vimeo.com/%',
+                'now' => $now = new \DateTime('now'),
+            ])
+            ->getQuery()
+            ->getResult()
+        ;
+    }
 }