Internal: Message: Send mail when saving inbox message - refs BT#21613

config/services.yaml

@@ -91,6 +91,11 @@ services:
         $persistProcessor: '@api_platform.doctrine.orm.state.persist_processor'
         $removeProcessor: '@api_platform.doctrine.orm.state.remove_processor'
 
+    Chamilo\CoreBundle\State\MessageProcessor:
+        bind:
+            $persistProcessor: '@api_platform.doctrine.orm.state.persist_processor'
+            $removeProcessor: '@api_platform.doctrine.orm.state.remove_processor'
+
     Chamilo\CoreBundle\EventSubscriber\AnonymousUserSubscriber:
       tags:
         - name: kernel.event_subscriber

src/CoreBundle/Entity/Message.php

@@ -18,6 +18,7 @@
 use ApiPlatform\Metadata\Put;
 use Chamilo\CoreBundle\Repository\MessageRepository;
 use Chamilo\CoreBundle\State\MessageByGroupStateProvider;
+use Chamilo\CoreBundle\State\MessageProcessor;
 use DateTime;
 use Doctrine\Common\Collections\ArrayCollection;
 use Doctrine\Common\Collections\Collection;
@@ -56,7 +57,8 @@
     denormalizationContext: [
         'groups' => ['message:write'],
     ],
-    security: "is_granted('ROLE_USER')"
+    security: "is_granted('ROLE_USER')",
+    processor: MessageProcessor::class,
 )]
 #[ApiFilter(filterClass: OrderFilter::class, properties: ['title', 'sendDate'])]
 #[ApiFilter(

src/CoreBundle/State/MessageProcessor.php

@@ -0,0 +1,66 @@
+<?php
+
+/* For licensing terms, see /license.txt */
+
+declare(strict_types=1);
+
+namespace Chamilo\CoreBundle\State;
+
+use ApiPlatform\Metadata\DeleteOperationInterface;
+use ApiPlatform\Metadata\Operation;
+use ApiPlatform\Metadata\Post;
+use ApiPlatform\State\ProcessorInterface;
+use Chamilo\CoreBundle\Entity\Message;
+use MessageManager;
+
+final class MessageProcessor implements ProcessorInterface
+{
+    public function __construct(
+        private readonly ProcessorInterface $persistProcessor,
+        private readonly ProcessorInterface $removeProcessor,
+    ) {}
+
+    public function process($data, Operation $operation, array $uriVariables = [], array $context = [])
+    {
+        if ($operation instanceof DeleteOperationInterface) {
+            return $this->removeProcessor->process($data, $operation, $uriVariables, $context);
+        }
+
+        $message = $this->persistProcessor->process($data, $operation, $uriVariables, $context);
+
+        assert($message instanceof Message);
+
+        if ($operation instanceof Post) {
+            if (Message::MESSAGE_TYPE_INBOX === $message->getMsgType()) {
+                $this->sendMailForInboxMessage($message);
+            }
+        }
+
+        return $message;
+    }
+
+    private function sendMailForInboxMessage(Message $message): void
+    {
+        foreach ($message->getReceivers() as $receiver) {
+            $user = $receiver->getReceiver();
+
+            MessageManager::send_message(
+                $user->getId(),
+                $message->getTitle(),
+                $message->getContent(),
+                [],
+                [],
+                0,
+                0,
+                0,
+                0,
+                0,
+                false,
+                0,
+                true,
+                false,
+                Message::MESSAGE_TYPE_INBOX
+            );
+        }
+    }
+}