Format conversations before sending notifications.

Author: thisismeonmounteverest

src/Controller/MessageController.php

@@ -184,12 +184,14 @@ private function addMessageAndSendNotification(
     ): Message {
         $em = $this->getDoctrine()->getManager();
         $message = new Message();
+        $message->setMessage($body);
         if (null === $parent) {
             $subject = new Subject();
             $subject->setSubject($subjectText);
             $request = null;
             $em->persist($subject);
             $em->flush();
+            $message = $this->conversationModel->formatConversation($message);
         } else {
             $subject = $parent->getSubject();
             $request = $parent->getRequest();
@@ -201,7 +203,6 @@ private function addMessageAndSendNotification(
         $message->setParent($parent);
         $message->setSender($sender);
         $message->setReceiver($receiver);
-        $message->setMessage($body);
         $message->setStatus('Sent');
         $em->persist($message);
         $em->flush();

src/Controller/RequestController.php

@@ -40,21 +40,19 @@ class RequestController extends BaseRequestAndInvitationController
 
     private Mailer $mailer;
     private Logger $logger;
-    private HostingRequestModel $hostingRequestModel;
 
     public function __construct(
         ConversationModel      $conversationModel,
         HostingRequestModel    $requestModel,
         EntityManagerInterface $entityManager,
         Mailer                 $mailer,
-        Logger                 $logger, HostingRequestModel $hostingRequestModel
+        Logger                 $logger
     ) {
         parent::__construct($requestModel, $entityManager);
 
         $this->conversationModel = $conversationModel;
         $this->mailer = $mailer;
         $this->logger = $logger;
-        $this->hostingRequestModel = $hostingRequestModel;
     }
 
     /**
@@ -178,6 +176,7 @@ public function newHostingRequest(
         if ($requestForm->isSubmitted() && $requestForm->isValid()) {
             // Write request to database after doing some checks
             $hostingRequest = $this->getMessageFromData($requestForm->getData(), $guest, $host);
+            $hostingRequest = $this->conversationModel->formatConversation($hostingRequest);
 
             $em = $this->getDoctrine()->getManager();
             $em->persist($hostingRequest);
@@ -327,9 +326,7 @@ private function sendInitialRequestNotification(Member $host, Member $guest, Mes
     {
         $subject = $request->getSubject()->getSubject();
 
-        if ($this->hostingRequestModel->formatRequest($request)) {
-            $this->sendRequestNotification($guest, $host, $host, $request, $subject, 'request', false);
-        }
+        $this->sendRequestNotification($guest, $host, $host, $request, $subject, 'request', false);
     }
 
     private function sendHostReplyNotification(

src/Model/ConversationModel.php

@@ -285,6 +285,19 @@ public function markConversationAsRead(Member $member, array $thread)
         $em->flush();
     }
 
+    public function formatConversation(Message $message): Message
+    {
+        $messageText = $message->getMessage();
+        $found = preg_match("/@|at|.at.|-at-|\(at\)/i", $messageText);
+
+        if ($found != 0) {
+            $message->setSpamInfo(SpamInfoType::SPAM_BLOCKED_WORD);
+            $message->setMessage($messageText . '<p>This might be spam.</p>');
+        }
+
+        return $message;
+    }
+
     private function hasLimitExceeded(Member $member, string $sql, int $perHour, int $perDay): bool
     {
         $id = $member->getId();