diff --git a/config/parameters.yml.dist b/config/parameters.yml.dist
index 628f1e45..6de7d2ef 100644
--- a/config/parameters.yml.dist
+++ b/config/parameters.yml.dist
@@ -33,8 +33,8 @@ parameters:
     env(APP_POWERED_BY_PHPLIST): '0'
     app.preference_page_show_private_lists: '%%env(PREFERENCEPAGE_SHOW_PRIVATE_LISTS)%%'
     env(PREFERENCEPAGE_SHOW_PRIVATE_LISTS): '0'
-    app.rest_api_domain: '%%env(REST_API_DOMAIN)%%'
-    env(REST_API_DOMAIN): 'example.com'
+    app.rest_api_base_url: '%%env(REST_API_BASE_URL)%%'
+    env(REST_API_BASE_URL): 'https://example.com/api/v2'
 
     # Email configuration
     app.mailer_from: '%%env(MAILER_FROM)%%'
diff --git a/config/services/services.yml b/config/services/services.yml
index 5e7db66b..53a5f84d 100644
--- a/config/services/services.yml
+++ b/config/services/services.yml
@@ -53,6 +53,10 @@ services:
     autoconfigure: true
     public: true
 
+  PhpList\Core\Domain\Analytics\Service\UserMessageService:
+    autowire: true
+    autoconfigure: true
+
   PhpList\Core\Domain\Messaging\Service\SendRateLimiter:
     autowire: true
     autoconfigure: true
diff --git a/src/Domain/Analytics/Model/UserMessageView.php b/src/Domain/Analytics/Model/UserMessageView.php
index 846c8e97..b391d3f3 100644
--- a/src/Domain/Analytics/Model/UserMessageView.php
+++ b/src/Domain/Analytics/Model/UserMessageView.php
@@ -85,6 +85,11 @@ public function setViewed(?DateTime $viewed): self
         return $this;
     }
 
+    public function setViewedNow(): self
+    {
+        return $this->setViewed(new DateTime());
+    }
+
     public function setIp(?string $ip): self
     {
         $this->ip = $ip;
diff --git a/src/Domain/Analytics/Service/UserMessageService.php b/src/Domain/Analytics/Service/UserMessageService.php
new file mode 100644
index 00000000..c5a1cc5b
--- /dev/null
+++ b/src/Domain/Analytics/Service/UserMessageService.php
@@ -0,0 +1,56 @@
+<?php
+
+declare(strict_types=1);
+
+namespace PhpList\Core\Domain\Analytics\Service;
+
+use Doctrine\ORM\EntityManagerInterface;
+use PhpList\Core\Domain\Analytics\Model\UserMessageView;
+use PhpList\Core\Domain\Messaging\Repository\MessageRepository;
+use PhpList\Core\Domain\Messaging\Repository\UserMessageRepository;
+use PhpList\Core\Domain\Subscription\Repository\SubscriberRepository;
+
+class UserMessageService
+{
+    public function __construct(
+        private readonly UserMessageRepository $userMessageRepository,
+        private readonly SubscriberRepository $subscriberRepository,
+        private readonly MessageRepository $messageRepository,
+        private readonly EntityManagerInterface $entityManager
+    ) {
+    }
+
+    public function trackUserMessageView(string $uid, int $messageId, array $metadata): void
+    {
+        $subscriber = $this->subscriberRepository->findOneByUniqueId($uid);
+        $message = $this->messageRepository->findById($messageId);
+
+        if ($subscriber === null || $message === null) {
+            return;
+        }
+
+        $userMessage = $this->userMessageRepository->findByUserAndMessage($subscriber, $message);
+        if ($userMessage === null) {
+            return;
+        }
+
+        $userMessage->setViewedNow();
+        $message->getMetadata()->incrementViews();
+
+        $data = [];
+        foreach (['HTTP_USER_AGENT', 'HTTP_REFERER'] as $key) {
+            if (isset($metadata[$key])) {
+                $data[$key] = htmlspecialchars(strip_tags($metadata[$key]));
+            }
+        }
+
+        $userMessageView = new UserMessageView();
+        $userMessageView->setUserId($subscriber->getId());
+        $userMessageView->setMessageId($messageId);
+        $userMessageView->setViewedNow();
+        $userMessageView->setIp($metadata['client_ip'] ?? null);
+        $userMessageView->setData(serialize($data));
+
+        $this->entityManager->persist($userMessageView);
+    }
+}
diff --git a/src/Domain/Configuration/Service/Placeholder/UserTrackValueResolver.php b/src/Domain/Configuration/Service/Placeholder/UserTrackValueResolver.php
index 4983fc28..8a5b626d 100644
--- a/src/Domain/Configuration/Service/Placeholder/UserTrackValueResolver.php
+++ b/src/Domain/Configuration/Service/Placeholder/UserTrackValueResolver.php
@@ -13,7 +13,7 @@ final class UserTrackValueResolver implements PlaceholderValueResolverInterface
 {
     public function __construct(
         private readonly ConfigProvider $config,
-        #[Autowire('%rest_api_domain%')] private readonly string $restApiDomain,
+        #[Autowire('%app.rest_api_base_url%')] private readonly string $restApiBaseUrl,
     ) {
     }
 
@@ -24,7 +24,7 @@ public function name(): string
 
     public function __invoke(PlaceholderContext $ctx): string
     {
-        $base = $this->config->getValue(ConfigOption::Domain) ?? $this->restApiDomain;
+        $base = $this->config->getValue(ConfigOption::Domain) ?? $this->restApiBaseUrl;
 
         if ($ctx->isText() || empty($base)) {
             return '';
@@ -33,7 +33,7 @@ public function __invoke(PlaceholderContext $ctx): string
 
         return '<img src="'
             . $base
-            . '/ut.php?u='
+            . '/t/open.gif?u='
             . $uid
             . '&amp;m='
             . $ctx->messageId()
diff --git a/src/Domain/Messaging/MessageHandler/CampaignProcessorMessageHandler.php b/src/Domain/Messaging/MessageHandler/CampaignProcessorMessageHandler.php
index 0d0dbc9d..b8837a66 100644
--- a/src/Domain/Messaging/MessageHandler/CampaignProcessorMessageHandler.php
+++ b/src/Domain/Messaging/MessageHandler/CampaignProcessorMessageHandler.php
@@ -320,7 +320,7 @@ private function processSubscribersForCampaign(Message $campaign, array $subscri
                 break;
             }
 
-            $existing = $this->userMessageRepository->findOneByUserAndMessage($subscriber, $campaign);
+            $existing = $this->userMessageRepository->findByUserAndMessage($subscriber, $campaign);
             if ($existing && $existing->getStatus() !== UserMessageStatus::Todo) {
                 continue;
             }
diff --git a/src/Domain/Messaging/Model/Message/MessageMetadata.php b/src/Domain/Messaging/Model/Message/MessageMetadata.php
index 0d817c2e..f0662c90 100644
--- a/src/Domain/Messaging/Model/Message/MessageMetadata.php
+++ b/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;
diff --git a/src/Domain/Messaging/Model/UserMessage.php b/src/Domain/Messaging/Model/UserMessage.php
index 87150cd7..3f3c9cdf 100644
--- a/src/Domain/Messaging/Model/UserMessage.php
+++ b/src/Domain/Messaging/Model/UserMessage.php
@@ -82,4 +82,14 @@ public function setStatus(?UserMessageStatus $status): self
         $this->status = $status->value;
         return $this;
     }
+
+    public function isViewed(): bool
+    {
+        return $this->viewed !== null;
+    }
+
+    public function setViewedNow(): self
+    {
+        return $this->setViewed(new DateTime());
+    }
 }
diff --git a/src/Domain/Messaging/Repository/MessageRepository.php b/src/Domain/Messaging/Repository/MessageRepository.php
index a2db5ae3..883e56d5 100644
--- a/src/Domain/Messaging/Repository/MessageRepository.php
+++ b/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
     {
diff --git a/src/Domain/Messaging/Repository/UserMessageRepository.php b/src/Domain/Messaging/Repository/UserMessageRepository.php
index e8268025..f51020dc 100644
--- a/src/Domain/Messaging/Repository/UserMessageRepository.php
+++ b/src/Domain/Messaging/Repository/UserMessageRepository.php
@@ -13,7 +13,7 @@
 
 class UserMessageRepository extends AbstractRepository
 {
-    public function findOneByUserAndMessage(Subscriber $subscriber, Message $campaign): ?UserMessage
+    public function findByUserAndMessage(Subscriber $subscriber, Message $campaign): ?UserMessage
     {
         return $this->findOneBy(['user' => $subscriber, 'message' => $campaign]);
     }
diff --git a/src/Domain/Messaging/Service/Builder/HttpReceivedStampBuilder.php b/src/Domain/Messaging/Service/Builder/HttpReceivedStampBuilder.php
index 8c62a2af..fe06efca 100644
--- a/src/Domain/Messaging/Service/Builder/HttpReceivedStampBuilder.php
+++ b/src/Domain/Messaging/Service/Builder/HttpReceivedStampBuilder.php
@@ -12,7 +12,7 @@ class HttpReceivedStampBuilder
 {
     public function __construct(
         private readonly RequestStack $requestStack,
-        #[Autowire('%app.rest_api_domain%')] private readonly string $hostname,
+        #[Autowire('%app.rest_api_base_url%')] private readonly string $restApiBaseUrl,
     ) {
     }
 
@@ -40,7 +40,7 @@ public function buildStamp(): ?string
         $requestTime = $request->server->get('REQUEST_TIME') ?? time();
         $date = (new DateTimeImmutable('@' . $requestTime))->format(\DATE_RFC2822);
 
-        return sprintf('from %s by %s with HTTP; %s', $from, $this->hostname, $date);
+        return sprintf('from %s by %s with HTTP; %s', $from, $this->restApiBaseUrl, $date);
     }
 
     private function getHostByAddr(string $ipAddress): ?string
diff --git a/src/Domain/Messaging/Service/ForwardingGuard.php b/src/Domain/Messaging/Service/ForwardingGuard.php
index 565f3cce..51264dc2 100644
--- a/src/Domain/Messaging/Service/ForwardingGuard.php
+++ b/src/Domain/Messaging/Service/ForwardingGuard.php
@@ -31,7 +31,7 @@ public function assertCanForward(string $uid, Message $campaign): Subscriber
         if ($subscriber === null) {
             throw new MessageNotReceivedException();
         }
-        $receivedMessage = $this->userMessageRepository->findOneByUserAndMessage($subscriber, $campaign);
+        $receivedMessage = $this->userMessageRepository->findByUserAndMessage($subscriber, $campaign);
 
         if ($receivedMessage === null) {
             throw new MessageNotReceivedException();
diff --git a/tests/Unit/Domain/Analytics/Service/UserMessageServiceTest.php b/tests/Unit/Domain/Analytics/Service/UserMessageServiceTest.php
new file mode 100644
index 00000000..47da1520
--- /dev/null
+++ b/tests/Unit/Domain/Analytics/Service/UserMessageServiceTest.php
@@ -0,0 +1,192 @@
+<?php
+
+declare(strict_types=1);
+
+namespace PhpList\Core\Tests\Unit\Domain\Analytics\Service;
+
+use Doctrine\ORM\EntityManagerInterface;
+use PhpList\Core\Domain\Analytics\Model\UserMessageView;
+use PhpList\Core\Domain\Analytics\Service\UserMessageService;
+use PhpList\Core\Domain\Messaging\Model\Message;
+use PhpList\Core\Domain\Messaging\Model\Message\MessageMetadata;
+use PhpList\Core\Domain\Messaging\Model\UserMessage;
+use PhpList\Core\Domain\Messaging\Repository\MessageRepository;
+use PhpList\Core\Domain\Messaging\Repository\UserMessageRepository;
+use PhpList\Core\Domain\Subscription\Model\Subscriber;
+use PhpList\Core\Domain\Subscription\Repository\SubscriberRepository;
+use PHPUnit\Framework\MockObject\MockObject;
+use PHPUnit\Framework\TestCase;
+
+class UserMessageServiceTest extends TestCase
+{
+    private UserMessageService $subject;
+    private UserMessageRepository|MockObject $userMessageRepository;
+    private SubscriberRepository|MockObject $subscriberRepository;
+    private MessageRepository|MockObject $messageRepository;
+    private EntityManagerInterface|MockObject $entityManager;
+
+    protected function setUp(): void
+    {
+        $this->userMessageRepository = $this->createMock(UserMessageRepository::class);
+        $this->subscriberRepository = $this->createMock(SubscriberRepository::class);
+        $this->messageRepository = $this->createMock(MessageRepository::class);
+        $this->entityManager = $this->createMock(EntityManagerInterface::class);
+
+        $this->subject = new UserMessageService(
+            $this->userMessageRepository,
+            $this->subscriberRepository,
+            $this->messageRepository,
+            $this->entityManager
+        );
+    }
+
+    public function testReturnsEarlyWhenSubscriberNotFound(): void
+    {
+        $this->subscriberRepository
+            ->expects(self::once())
+            ->method('findOneByUniqueId')
+            ->with('sub-uid')
+            ->willReturn(null);
+
+        // Service fetches message regardless, then returns early because subscriber is null
+        $this->messageRepository
+            ->expects(self::once())
+            ->method('findById')
+            ->with(123)
+            ->willReturn($this->getMockBuilder(Message::class)->disableOriginalConstructor()->getMock());
+        $this->userMessageRepository->expects(self::never())->method('findByUserAndMessage');
+        $this->entityManager->expects(self::never())->method('persist');
+
+        $this->subject->trackUserMessageView('sub-uid', 123, []);
+    }
+
+    public function testReturnsEarlyWhenMessageNotFound(): void
+    {
+        $subscriber = $this->createMock(Subscriber::class);
+        $this->subscriberRepository
+            ->method('findOneByUniqueId')
+            ->willReturn($subscriber);
+
+        $this->messageRepository
+            ->expects(self::once())
+            ->method('findById')
+            ->with(123)
+            ->willReturn(null);
+
+        $this->userMessageRepository->expects(self::never())->method('findByUserAndMessage');
+        $this->entityManager->expects(self::never())->method('persist');
+
+        $this->subject->trackUserMessageView('sub-uid', 123, []);
+    }
+
+    public function testReturnsEarlyWhenUserMessageNotFound(): void
+    {
+        $subscriber = $this->createMock(Subscriber::class);
+        $message = $this->getMockBuilder(Message::class)
+            ->disableOriginalConstructor()
+            ->getMock();
+        $metadata = $this->createMock(MessageMetadata::class);
+
+        $this->subscriberRepository->method('findOneByUniqueId')->willReturn($subscriber);
+        $this->messageRepository->method('findById')->willReturn($message);
+        $message->method('getMetadata')->willReturn($metadata);
+
+        $this->userMessageRepository
+            ->expects(self::once())
+            ->method('findByUserAndMessage')
+            ->with($subscriber, $message)
+            ->willReturn(null);
+
+        $metadata->expects(self::never())->method('incrementViews');
+        $this->entityManager->expects(self::never())->method('persist');
+
+        $this->subject->trackUserMessageView('sub-uid', 321, []);
+    }
+
+    public function testHappyPathPersistsUserMessageViewAndMarksViewed(): void
+    {
+        $subscriberId = 17;
+        $messageId = 42;
+
+        $subscriber = $this->createMock(Subscriber::class);
+        $subscriber->method('getId')->willReturn($subscriberId);
+
+        $message = $this->getMockBuilder(Message::class)
+            ->disableOriginalConstructor()
+            ->getMock();
+        $metadataObj = $this->createMock(MessageMetadata::class);
+
+        $userMessage = $this->createMock(UserMessage::class);
+
+        $this->subscriberRepository->method('findOneByUniqueId')->willReturn($subscriber);
+        $this->messageRepository->method('findById')->with($messageId)->willReturn($message);
+        $message->method('getMetadata')->willReturn($metadataObj);
+        $this->userMessageRepository->method('findByUserAndMessage')->willReturn($userMessage);
+
+        $userMessage->expects(self::once())->method('setViewedNow');
+        $metadataObj->expects(self::once())->method('incrementViews');
+
+        $metadata = [
+            'client_ip' => '203.0.113.10',
+            'HTTP_USER_AGENT' => '<b>UnitTester/1.0</b>',
+            'HTTP_REFERER' => '<script>alert(1)</script>http://example.test/page',
+        ];
+
+        $this->entityManager
+            ->expects(self::once())
+            ->method('persist')
+            ->with(self::callback(function ($arg) use ($subscriberId, $messageId, $metadata): bool {
+                self::assertInstanceOf(UserMessageView::class, $arg);
+                $view = $arg;
+                self::assertSame($subscriberId, $view->getUserId());
+                self::assertSame($messageId, $view->getMessageId());
+                self::assertNotNull($view->getViewed());
+                self::assertSame($metadata['client_ip'], $view->getIp());
+                $data = unserialize((string) $view->getData());
+                self::assertIsArray($data);
+                self::assertSame('UnitTester/1.0', $data['HTTP_USER_AGENT']);
+                self::assertSame('alert(1)http://example.test/page', $data['HTTP_REFERER']);
+                return true;
+            }));
+
+        $this->subject->trackUserMessageView('any-uid', $messageId, $metadata);
+    }
+
+    public function testHandlesMissingOptionalMetadataGracefully(): void
+    {
+        $subscriber = $this->createMock(Subscriber::class);
+        $subscriber->method('getId')->willReturn(99);
+
+        $message = $this->getMockBuilder(Message::class)
+            ->disableOriginalConstructor()
+            ->getMock();
+        $metadataObj = $this->createMock(MessageMetadata::class);
+
+        $userMessage = $this->createMock(UserMessage::class);
+
+        $this->subscriberRepository->method('findOneByUniqueId')->willReturn($subscriber);
+        $this->messageRepository->method('findById')->willReturn($message);
+        $message->method('getMetadata')->willReturn($metadataObj);
+        $this->userMessageRepository->method('findByUserAndMessage')->willReturn($userMessage);
+
+        $metadataObj->expects(self::once())->method('incrementViews');
+        $userMessage->expects(self::once())->method('setViewedNow');
+
+        // No HTTP_* keys and no client_ip
+        $metadata = [];
+
+        $this->entityManager
+            ->expects(self::once())
+            ->method('persist')
+            ->with(self::callback(function ($arg): bool {
+                /** @var UserMessageView $arg */
+                self::assertInstanceOf(UserMessageView::class, $arg);
+                self::assertNull($arg->getIp());
+                // data should serialize an empty array
+                self::assertSame(serialize([]), $arg->getData());
+                return true;
+            }));
+
+        $this->subject->trackUserMessageView('uid', 5, $metadata);
+    }
+}
diff --git a/tests/Unit/Domain/Configuration/Service/Placeholder/UserTrackValueResolverTest.php b/tests/Unit/Domain/Configuration/Service/Placeholder/UserTrackValueResolverTest.php
index f68ce777..68818e5e 100644
--- a/tests/Unit/Domain/Configuration/Service/Placeholder/UserTrackValueResolverTest.php
+++ b/tests/Unit/Domain/Configuration/Service/Placeholder/UserTrackValueResolverTest.php
@@ -62,7 +62,7 @@ public function testHtmlUsesConfigDomainWhenAvailable(): void
 
         $result = $resolver($ctx);
 
-        $expected = '<img src="example.com/ut.php?u=UID-XYZ&amp;m=99" width="1" height="1" border="0" alt="" />';
+        $expected = '<img src="example.com/t/open.gif?u=UID-XYZ&amp;m=99" width="1" height="1" border="0" alt="" />';
         // Normalize double quotes for comparison
         $this->assertSame($expected, $result);
     }
@@ -86,7 +86,7 @@ public function testHtmlFallsBackToRestApiDomainWhenConfigMissing(): void
 
         $result = $resolver($ctx);
 
-        $expected = '<img src="https://api.example/ut.php?u=U1&amp;m=7" width="1" height="1" border="0" alt="" />';
+        $expected = '<img src="https://api.example/t/open.gif?u=U1&amp;m=7" width="1" height="1" border="0" alt="" />';
         $this->assertSame($expected, $result);
     }
 }
diff --git a/tests/Unit/Domain/Messaging/Service/ForwardingGuardTest.php b/tests/Unit/Domain/Messaging/Service/ForwardingGuardTest.php
index 8ac266f8..b1ee10b9 100644
--- a/tests/Unit/Domain/Messaging/Service/ForwardingGuardTest.php
+++ b/tests/Unit/Domain/Messaging/Service/ForwardingGuardTest.php
@@ -46,7 +46,7 @@ public function testAssertCanForwardReturnsSubscriber(): void
         $subscriber = new Subscriber();
 
         $this->subscriberRepo->method('findOneByUniqueId')->with($uid)->willReturn($subscriber);
-        $this->userMessageRepo->method('findOneByUserAndMessage')->willReturn(
+        $this->userMessageRepo->method('findByUserAndMessage')->willReturn(
             $this->createMock(UserMessage::class)
         );
         $this->forwardRepo->method('getCountByUserSince')->willReturn(1);
@@ -82,7 +82,7 @@ public function testAssertCanForwardThrowsWhenMessageNotReceived(): void
         );
 
         $this->subscriberRepo->method('findOneByUniqueId')->willReturn(new Subscriber());
-        $this->userMessageRepo->method('findOneByUserAndMessage')->willReturn(null);
+        $this->userMessageRepo->method('findByUserAndMessage')->willReturn(null);
 
         $this->expectException(MessageNotReceivedException::class);
         $guard->assertCanForward('uid', $this->createMock(Message::class));
@@ -99,7 +99,7 @@ public function testAssertCanForwardThrowsWhenLimitExceeded(): void
         );
 
         $this->subscriberRepo->method('findOneByUniqueId')->willReturn(new Subscriber());
-        $this->userMessageRepo->method('findOneByUserAndMessage')->willReturn($this->createMock(UserMessage::class));
+        $this->userMessageRepo->method('findByUserAndMessage')->willReturn($this->createMock(UserMessage::class));
         $this->forwardRepo->method('getCountByUserSince')->willReturn(2);
 
         $this->expectException(ForwardLimitExceededException::class);