Added mock mailer service

Author: vlad

config/services.yaml

@@ -40,22 +40,22 @@ services:
   App\Service\TaskService\Contract\DelayServiceInterface:
     alias: App\Service\TaskServerGrpcAdapter\TaskServerGrpcAdapter
 
-
   task_server_grpc_adapter.serializer:
     class: App\Serializer\AmqpMessageSerializer
     arguments:
       $messageClass: App\Service\TaskServerGrpcAdapter\BusMessage\TaskExecuteMessage
 
-
   App\Service\TaskService\TaskService:
     tags:
       - name: kernel.event_listener
         event: App\Service\TaskServerGrpcAdapter\Event\TaskExecuteEvent
         method: onTaskExecuteEvent
 
-
   App\Domain\Message\MessageManager:
     tags:
       - name: kernel.event_listener
         event: App\Service\TaskService\Event\SendingTimeMessageTriggeredEvent
         method: onSendingTimeMessageTriggeredEvent
+
+  App\Contract\Mailer\MailerInterface:
+    class: App\Service\MailerMockService\MailerMockService

src/Contract/Mailer/MailerExceptionInterface.php

@@ -0,0 +1,10 @@
+<?php
+
+namespace App\Contract\Mailer;
+
+use Throwable;
+
+interface MailerExceptionInterface extends Throwable
+{
+
+}

src/Contract/Mailer/MailerInterface.php

@@ -0,0 +1,16 @@
+<?php
+
+
+namespace App\Contract\Mailer;
+
+
+interface MailerInterface
+{
+    /**
+     * @param string $recipient
+     * @param string $text
+     * @return bool
+     * @throws MailerExceptionInterface
+     */
+    public function send(string $recipient, string $text);
+}

src/Domain/Message/Entity/Message.php

@@ -18,17 +18,17 @@ class Message
 
     const STATUS_PENDING = 'pending';
     const STATUS_SHIPPED = 'shipped';
+    const STATUS_SHIPPING_FAILED = 'shipping_failed';
     const STATUS_CANCELED = 'canceled';
+    const STATUS_CANCELING_FAILED = 'canceling_failed';
     const STATUS_FAILED = 'failed';
 
     private static $statusStateMachine = [
         self::STATUS_PENDING => [
-            self::STATUS_SHIPPED => [
-                self::STATUS_FAILED => null
-            ],
-            self::STATUS_CANCELED => [
-                self::STATUS_FAILED => null
-            ]
+            self::STATUS_SHIPPED => null,
+            self::STATUS_SHIPPING_FAILED => null,
+            self::STATUS_CANCELED => null,
+            self::STATUS_CANCELING_FAILED => null,
         ]
     ];
 

src/Domain/Message/Event/MessageShippingFailedEvent.php

@@ -0,0 +1,12 @@
+<?php
+
+
+namespace App\Domain\Message\Event;
+
+
+use Symfony\Contracts\EventDispatcher\Event;
+
+class MessageShippingFailedEvent extends BaseEvent
+{
+
+}

src/Domain/Message/MessageManager.php

@@ -3,11 +3,14 @@
 
 namespace App\Domain\Message;
 
+use App\Contract\Mailer\MailerExceptionInterface;
+use App\Contract\Mailer\MailerInterface;
 use App\Domain\Message\Contract\SendingTimeMessageTriggeredEventInterface;
 use App\Domain\Message\Dto\ScheduleSendingMessage;
 use App\Domain\Message\Entity\Message;
 use App\Domain\Message\Event\MessageScheduledEvent;
 use App\Domain\Message\Event\MessageShippedEvent;
+use App\Domain\Message\Event\MessageShippingFailedEvent;
 use App\Domain\Message\Exception\MessageManagerException;
 use App\Domain\Message\Repository\MessageRepository;
 use App\Service\TaskService\Config;
@@ -27,19 +30,22 @@ class MessageManager
     private $eventDispatcher;
     private $messageRepository;
     private $logger;
+    private $mailer;
 
     public function __construct(
         TaskService $taskService,
         EntityManagerInterface $entityManager,
         EventDispatcherInterface $eventDispatcher,
         MessageRepository $messageRepository,
+        MailerInterface $mailer,
         LoggerInterface $logger
     )
     {
         $this->taskService = $taskService;
         $this->entityManager = $entityManager;
         $this->eventDispatcher = $eventDispatcher;
         $this->messageRepository = $messageRepository;
+        $this->mailer = $mailer;
         $this->logger = $logger;
     }
 
@@ -69,7 +75,7 @@ public function scheduleSending(ScheduleSendingMessage $data)
         } catch (Throwable $e) {
             $this->entityManager->rollback();
             $error = 'Error while schedule new message';
-            $this->logger->error($error, ['exception' => $e, 'method' => __METHOD__]);
+            $this->logger->error($error, ['exception' => $e, 'method' => __METHOD__, 'data' => $data]);
             throw new MessageManagerException($error);
         }
     }
@@ -155,14 +161,18 @@ public function onSendingTimeMessageTriggeredEvent(SendingTimeMessageTriggeredEv
 
             $message->setStatus(Message::STATUS_SHIPPED);
 
+            try {
+                $this->mailer->send($message->getEmail(), $message->getText());
+                $event = new MessageShippedEvent($message);
+            } catch (MailerExceptionInterface $e) {
+                $message->setStatus(Message::STATUS_SHIPPING_FAILED);
+                $event = new MessageShippingFailedEvent($message);
+            }
+
             $this->entityManager->persist($message);
             $this->entityManager->flush();
-
-            //use api to send
-
-
             $this->entityManager->commit();
-            $this->eventDispatcher->dispatch(new MessageShippedEvent($message));
+            $this->eventDispatcher->dispatch($event);
         } catch (Throwable $e) {
             $this->entityManager->rollback();
             $m = 'Error while handle event from task service';

src/Service/MailerMockService/MailerMockService.php

@@ -0,0 +1,21 @@
+<?php
+
+
+namespace App\Service\MailerMockService;
+
+
+use App\Contract\Mailer\MailerExceptionInterface;
+use App\Contract\Mailer\MailerInterface;
+
+class MailerMockService implements MailerInterface
+{
+    /**
+     * @param string $recipient
+     * @param string $text
+     * @throws MailerExceptionInterface
+     */
+    public function send(string $recipient, string $text)
+    {
+
+    }
+}