incrementViews

Author: tatevikg1

src/Domain/Analytics/Service/UserMessageService.php

@@ -6,6 +6,7 @@
 
 use Doctrine\ORM\EntityManagerInterface;
 use PhpList\Core\Domain\Analytics\Model\UserMessageView;
+use PhpList\Core\Domain\Messaging\Model\Message\MessageStatus;
 use PhpList\Core\Domain\Messaging\Repository\MessageRepository;
 use PhpList\Core\Domain\Messaging\Repository\UserMessageRepository;
 use PhpList\Core\Domain\Subscription\Repository\SubscriberRepository;
@@ -23,7 +24,7 @@ public function __construct(
     public function trackUserMessageView(string $uid, int $messageId, array $metadata): void
     {
         $subscriber = $this->subscriberRepository->findOneByUniqueId($uid);
-        $message = $this->messageRepository->find($messageId);
+        $message = $this->messageRepository->findById($messageId);
 
         if ($subscriber === null || $message === null) {
             return;
@@ -35,7 +36,7 @@ public function trackUserMessageView(string $uid, int $messageId, array $metadat
         }
 
         $userMessage->setViewedNow();
-        $message->incrementViews();
+        $message->getMetadata()->incrementViews();
 
         $data = [];
         foreach (['HTTP_USER_AGENT', 'HTTP_REFERER'] as $key) {

src/Domain/Messaging/Model/Message/MessageMetadata.php

@@ -81,6 +81,13 @@ public function setViews(int $viewed): self
         return $this;
     }
 
+    public function incrementViews(): self
+    {
+        $this->viewed += 1;
+
+        return $this;
+    }
+
     public function getViews(): int
     {
         return $this->viewed;

src/Domain/Messaging/Repository/MessageRepository.php

@@ -27,6 +27,7 @@ public function findCampaignsWithoutUuid(): array
             ->getResult();
     }
 
+    /** @return Message[] */
     public function getByOwnerId(int $ownerId): array
     {
         return $this->createQueryBuilder('m')
@@ -36,6 +37,15 @@ public function getByOwnerId(int $ownerId): array
             ->getResult();
     }
 
+    public function findById(int $id): ?Message
+    {
+        return $this->createQueryBuilder('m')
+            ->where('m.id = :id')
+            ->setParameter('id', $id)
+            ->getQuery()
+            ->getOneOrNullResult();
+    }
+
     /** @return Message[] */
     public function getFilteredAfterId(int $lastId, int $limit, ?FilterRequestInterface $filter = null): array
     {