command for sending bulk sms with tests

src/Bundle/ChillCalendarBundle/Service/ShortMessageNotification/BulkCalendarShortMessageSender.php

@@ -0,0 +1,64 @@
+<?php
+
+/**
+ * Chill is a software for social workers
+ *
+ * For the full copyright and license information, please view
+ * the LICENSE file that was distributed with this source code.
+ */
+
+declare(strict_types=1);
+
+namespace Chill\CalendarBundle\Service\ShortMessageNotification;
+
+use Chill\CalendarBundle\Entity\Calendar;
+use DateTimeImmutable;
+use Doctrine\ORM\EntityManagerInterface;
+use Psr\Log\LoggerInterface;
+use Symfony\Component\Messenger\MessageBusInterface;
+
+class BulkCalendarShortMessageSender
+{
+    private EntityManagerInterface $em;
+
+    private LoggerInterface $logger;
+
+    private MessageBusInterface $messageBus;
+
+    private ShortMessageForCalendarBuilderInterface $messageForCalendarBuilder;
+
+    private CalendarForShortMessageProvider $provider;
+
+    public function __construct(CalendarForShortMessageProvider $provider, EntityManagerInterface $em, LoggerInterface $logger, MessageBusInterface $messageBus, ShortMessageForCalendarBuilderInterface $messageForCalendarBuilder)
+    {
+        $this->provider = $provider;
+        $this->em = $em;
+        $this->logger = $logger;
+        $this->messageBus = $messageBus;
+        $this->messageForCalendarBuilder = $messageForCalendarBuilder;
+    }
+
+    public function sendBulkMessageToEligibleCalendars()
+    {
+        $countCalendars = 0;
+        $countSms = 0;
+
+        foreach ($this->provider->getCalendars(new DateTimeImmutable('now')) as $calendar) {
+            $smses = $this->messageForCalendarBuilder->buildMessageForCalendar($calendar);
+
+            foreach ($smses as $sms) {
+                $this->messageBus->dispatch($sms);
+                ++$countSms;
+            }
+
+            $this->em
+                ->createQuery('UPDATE ' . Calendar::class . ' c SET c.smsStatus = :smsStatus WHERE c.id = :id')
+                ->setParameters(['smsStatus' => Calendar::SMS_SENT, 'id' => $calendar->getId()])
+                ->execute();
+            ++$countCalendars;
+            $this->em->refresh($calendar);
+        }
+
+        $this->logger->info(__CLASS__ . 'a bulk of messages was sent', ['count_calendars' => $countCalendars, 'count_sms' => $countSms]);
+    }
+}

src/Bundle/ChillCalendarBundle/Service/ShortMessageNotification/CalendarForShortMessageProvider.php

@@ -0,0 +1,69 @@
+<?php
+
+/**
+ * Chill is a software for social workers
+ *
+ * For the full copyright and license information, please view
+ * the LICENSE file that was distributed with this source code.
+ */
+
+declare(strict_types=1);
+
+namespace Chill\CalendarBundle\Service\ShortMessageNotification;
+
+use Chill\CalendarBundle\Entity\Calendar;
+use Chill\CalendarBundle\Repository\CalendarRepository;
+use DateTimeImmutable;
+use Doctrine\ORM\EntityManagerInterface;
+use function count;
+
+class CalendarForShortMessageProvider
+{
+    private CalendarRepository $calendarRepository;
+
+    private EntityManagerInterface $em;
+
+    private RangeGeneratorInterface $rangeGenerator;
+
+    public function __construct(
+        CalendarRepository $calendarRepository,
+        EntityManagerInterface $em,
+        RangeGeneratorInterface $rangeGenerator
+    ) {
+        $this->calendarRepository = $calendarRepository;
+        $this->em = $em;
+        $this->rangeGenerator = $rangeGenerator;
+    }
+
+    /**
+     * Generate calendars instance.
+     *
+     * Warning: this method takes care of clearing the EntityManager at regular interval
+     *
+     * @return iterable|Calendar[]
+     */
+    public function getCalendars(DateTimeImmutable $at): iterable
+    {
+        ['startDate' => $startDate, 'endDate' => $endDate] = $this->rangeGenerator
+            ->generateRange($at);
+
+        $offset = 0;
+        $batchSize = 10;
+
+        $calendars = $this->calendarRepository
+            ->findByNotificationAvailable($startDate, $endDate, $batchSize, $offset);
+
+        do {
+            foreach ($calendars as $calendar) {
+                ++$offset;
+
+                yield $calendar;
+            }
+
+            $this->em->clear();
+
+            $calendars = $this->calendarRepository
+                ->findByNotificationAvailable($startDate, $endDate, $batchSize, $offset);
+        } while (count($calendars) === $batchSize);
+    }
+}

src/Bundle/ChillCalendarBundle/Service/ShortMessageNotification/DefaultShortMessageForCalendarBuilder.php

@@ -12,26 +12,22 @@ declare(strict_types=1);
 namespace Chill\CalendarBundle\Service\ShortMessageNotification;
 
 use Chill\CalendarBundle\Entity\Calendar;
-use Symfony\Component\DependencyInjection\ParameterBag\ParameterBagInterface;
+use Chill\MainBundle\Service\ShortMessage\ShortMessage;
 use Symfony\Component\Templating\EngineInterface;
 
 class DefaultShortMessageForCalendarBuilder implements ShortMessageForCalendarBuilderInterface
 {
-    private ?array $config = null;
-
     private EngineInterface $engine;
 
     public function __construct(
-        ParameterBagInterface $parameterBag,
         EngineInterface $engine
     ) {
-        $this->config = $parameterBag->get('chill_calendar.short_messages');
         $this->engine = $engine;
     }
 
     public function buildMessageForCalendar(Calendar $calendar): array
     {
-        if (null === $this->config || true !== $calendar->getSendSMS()) {
+        if (true !== $calendar->getSendSMS()) {
             return [];
         }
 
@@ -42,10 +38,19 @@ class DefaultShortMessageForCalendarBuilder implements ShortMessageForCalendarBu
                 continue;
             }
 
-            $toUsers[] = new \Chill\MainBundle\Service\ShortMessage\ShortMessage(
-                $this->engine->render('@ChillCalendar/CalendarShortMessage/short_message.txt.twig', ['calendar' => $calendar]),
-                $person->getMobilenumber()
-            );
+            if (Calendar::SMS_PENDING === $calendar->getSmsStatus()) {
+                $toUsers[] = new ShortMessage(
+                    $this->engine->render('@ChillCalendar/CalendarShortMessage/short_message.txt.twig', ['calendar' => $calendar]),
+                    $person->getMobilenumber(),
+                    ShortMessage::PRIORITY_LOW
+                );
+            } elseif (Calendar::SMS_CANCEL_PENDING === $calendar->getSmsStatus()) {
+                $toUsers[] = new ShortMessage(
+                    $this->engine->render('@ChillCalendar/CalendarShortMessage/short_message_canceled.txt.twig', ['calendar' => $calendar]),
+                    $person->getMobilenumber(),
+                    ShortMessage::PRIORITY_LOW
+                );
+            }
         }
 
         return $toUsers;

src/Bundle/ChillCalendarBundle/Service/ShortMessageNotification/Generator.php

@@ -1,28 +0,0 @@
-<?php
-
-/**
- * Chill is a software for social workers
- *
- * For the full copyright and license information, please view
- * the LICENSE file that was distributed with this source code.
- */
-
-declare(strict_types=1);
-
-namespace Chill\CalendarBundle\Service\ShortMessageNotification;
-
-use Chill\CalendarBundle\Repository\CalendarRepository;
-use Symfony\Component\Messenger\MessageBusInterface;
-
-class Generator
-{
-    private CalendarRepository $calendarRepository;
-
-    private MessageBusInterface $messageBus;
-
-    private RangeGeneratorInterface $rangeGenerator;
-
-    public function generateShortMessages(): void
-    {
-    }
-}