Dev

config/parameters.yml.dist

@@ -37,6 +37,8 @@ parameters:
     env(REST_API_BASE_URL): 'http://api.phplist.local/api/v2'
     app.frontend_base_url: '%%env(FRONT_END_BASE_URL)%%'
     env(FRONT_END_BASE_URL): 'http://frontend.phplist.local'
+    parallel_use_with_phplist3: '%%env(parallel_use_with_phplist3)%%'
+    env(parallel_use_with_phplist3): '0'
 
     # Email configuration
     app.mailer_from: '%%env(MAILER_FROM)%%'
@@ -49,6 +51,8 @@ parameters:
     env(SUBSCRIPTION_CONFIRMATION_URL): 'http://api.phplist.local/api/v2/subscription/confirm/'
     app.password_reset_url: '%%env(PASSWORD_RESET_URL)%%'
     env(PASSWORD_RESET_URL): 'https://example.com/reset/'
+    app.show_unsubscribe_link: '%%env(SHOW_UNSUBSCRIBELINK)%%'
+    env(SHOW_UNSUBSCRIBELINK): '1'
 
     # bounce email settings
     imap_bounce.email: '%%env(BOUNCE_EMAIL)%%'

config/services/processor.yml

@@ -19,3 +19,5 @@ services:
   PhpList\Core\Bounce\Service\Processor\UnidentifiedBounceReprocessor: ~
 
   PhpList\Core\Bounce\Service\Processor\BounceDataProcessor: ~
+
+  PhpList\Core\Domain\Subscription\Service\SubscribePagePlaceholderProcessor: ~

config/services/services.yml

@@ -43,6 +43,14 @@ services:
     autoconfigure: true
     public: true
 
+  PhpList\Core\Domain\Subscription\Service\SubscribePageConfigMigrationService:
+    autowire: true
+    autoconfigure: true
+
+  PhpList\Core\Domain\Subscription\Service\Manager\SubscribePageManager:
+    autowire: true
+    autoconfigure: true
+
   PhpList\Core\Domain\Messaging\Service\MessageProcessingPreparator:
     autowire: true
     autoconfigure: true

src/Domain/Configuration/Service/Provider/ConfigProvider.php

@@ -8,6 +8,7 @@
 use PhpList\Core\Domain\Configuration\Model\ConfigOption;
 use PhpList\Core\Domain\Configuration\Repository\ConfigRepository;
 use Psr\SimpleCache\CacheInterface;
+use ValueError;
 
 class ConfigProvider
 {
@@ -71,16 +72,32 @@ public function getValue(ConfigOption $key): ?string
         return $this->defaultConfigs->has($key) ? (string) $this->defaultConfigs->get($key)['value'] : null;
     }
 
-    public function getValueWithNamespace(ConfigOption $key): ?string
+    public function getValueWithNamespace(ConfigOption|string $key): ?string
     {
-        $full = $this->getValue($key);
+        if ($key instanceof ConfigOption) {
+            $full = $this->getValue($key);
+            $keyValue = $key->value;
+        } else {
+            $keyValue = $key;
+            $cacheKey = 'cfg:' . $keyValue;
+            $full = $this->cache->get($cacheKey);
+            if ($full === null) {
+                $full = $this->configRepository->findValueByItem($keyValue);
+                $this->cache->set($cacheKey, $full, $this->ttlSeconds);
+            }
+        }
+
         if ($full !== null && $full !== '') {
             return $full;
         }
 
-        if (str_contains($key->value, ':')) {
-            [$parent] = explode(':', $key->value, 2);
-            $parentKey = ConfigOption::from($parent);
+        if (str_contains($keyValue, ':')) {
+            [$parent] = explode(':', $keyValue, 2);
+            try {
+                $parentKey = ConfigOption::from($parent);
+            } catch (ValueError) {
+                return null;
+            }
 
             return $this->getValue($parentKey);
         }

src/Domain/Subscription/Model/SubscribePage.php

@@ -30,6 +30,9 @@ class SubscribePage implements DomainModel, Identity, OwnableInterface
     #[ORM\JoinColumn(name: 'owner', referencedColumnName: 'id', nullable: true)]
     private ?Administrator $owner = null;
 
+    /** @var SubscribePageData[] */
+    private array $data = [];
+
     public function getId(): ?int
     {
         return $this->id;
@@ -50,6 +53,12 @@ public function getOwner(): ?Administrator
         return $this->owner;
     }
 
+    /** @return SubscribePageData[] */
+    public function getData(): array
+    {
+        return $this->data;
+    }
+
     public function setTitle(string $title): self
     {
         $this->title = $title;
@@ -67,4 +76,11 @@ public function setOwner(?Administrator $owner): self
         $this->owner = $owner;
         return $this;
     }
+
+    /** @param SubscribePageData[] $data */
+    public function setData(array $data): self
+    {
+        $this->data = $data;
+        return $this;
+    }
 }

src/Domain/Subscription/Repository/SubscriberAttributeDefinitionRepository.php

@@ -33,6 +33,7 @@ private function hydrateOptionsForAll(array $defs): array
         foreach ($defs as $def) {
             $this->hydrateOptions($def);
         }
+
         return $defs;
     }
 
@@ -81,9 +82,17 @@ public function findOneByName(string $name): ?SubscriberAttributeDefinition
         if ($def instanceof SubscriberAttributeDefinition) {
             $this->hydrateOptions($def);
         }
+
         return $def;
     }
 
+    public function getByIds(array $ids): array
+    {
+        $defs = $this->findBy(['id' => $ids]);
+
+        return $this->hydrateOptionsForAll($defs);
+    }
+
     public function existsByTableName(string $tableName): bool
     {
         return (bool) $this->createQueryBuilder('s')

src/Domain/Subscription/Repository/SubscriberListRepository.php

@@ -64,10 +64,13 @@ public function getListIdsByMessage(Message $message): array
             ->getSingleColumnResult();
     }
 
-    public function getAllActive(): array
+    /** @return SubscriberList[] */
+    public function getPublicByIds(array $ids): array
     {
         return $this->createQueryBuilder('l')
-            ->where('l.active = true')
+            ->where('l.public = true')
+            ->andWhere('l.id IN (:ids)')
+            ->setParameter('ids', $ids)
             ->getQuery()
             ->getResult();
     }

src/Domain/Subscription/Repository/SubscriberPageRepository.php

@@ -4,6 +4,8 @@
 
 namespace PhpList\Core\Domain\Subscription\Repository;
 
+use PhpList\Core\Domain\Common\Model\Filter\FilterRequestInterface;
+use PhpList\Core\Domain\Common\Model\PaginatedResult;
 use PhpList\Core\Domain\Common\Repository\AbstractRepository;
 use PhpList\Core\Domain\Common\Repository\CursorPaginationTrait;
 use PhpList\Core\Domain\Common\Repository\Interfaces\PaginatableRepositoryInterface;
@@ -14,17 +16,92 @@ class SubscriberPageRepository extends AbstractRepository implements Paginatable
 {
     use CursorPaginationTrait;
 
-    /** @return array{page: SubscribePage, data: SubscribePageData}[] */
-    public function findPagesWithData(int $pageId): array
+    public function findPageWithData(int $pageId): ?SubscribePage
     {
-        return $this->createQueryBuilder('p')
-            ->select('p AS page, d AS data')
-            ->from(SubscribePage::class, 'p')
-            ->from(SubscribePageData::class, 'd')
+        $result = $this->createQueryBuilder('p')
+            ->select('p AS page', 'd AS data')
+            ->leftJoin(
+                SubscribePageData::class,
+                'd',
+                'ON',
+                'd.id = p.id'
+            )
             ->where('p.id = :id')
-            ->andWhere('d.id = p.id')
             ->setParameter('id', $pageId)
             ->getQuery()
             ->getResult();
+
+        if ($result === []) {
+            return null;
+        }
+
+        return $this->loadPageData($result);
+    }
+
+    public function getFilteredAfterId(FilterRequestInterface $filter): PaginatedResult
+    {
+        $queryBuilder = $this->createQueryBuilder('p');
+
+        $countQb = clone $queryBuilder;
+        $total = (int) $countQb
+            ->select('COUNT(DISTINCT p.id)')
+            ->getQuery()
+            ->getSingleScalarResult();
+
+        $rows = $queryBuilder
+            ->select('p AS page', 'd AS data')
+            ->leftJoin(
+                SubscribePageData::class,
+                'd',
+                'ON',
+                'd.id = p.id'
+            )
+            ->andWhere('p.id > :afterId')
+            ->setParameter('afterId', $filter->getLastId())
+            ->orderBy('p.id', 'ASC')
+            ->setMaxResults($filter->getLimit())
+            ->getQuery()
+            ->getResult();
+
+        $grouped = [];
+        foreach ($rows as $row) {
+            /** @var SubscribePage $page */
+            $page = $row['page'] ?? null;
+            $data = $row['data'] ?? null;
+            if ($page !== null) {
+                $grouped[$page->getId()][] = $row;
+            }
+            if ($data !== null) {
+                $grouped[$data->getId()][] = ['data' => $data];
+            }
+        }
+
+        $pages = [];
+        foreach ($grouped as $group) {
+            $pages[] = $this->loadPageData($group);
+        }
+
+        return new PaginatedResult(
+            items: array_values($pages),
+            total: $total,
+            limit: $filter->getLimit(),
+            lastId: $filter->getLastId(),
+        );
+    }
+
+    private function loadPageData(array $result): SubscribePage
+    {
+        /** @var SubscribePage $page */
+        $page = array_shift($result)['page'];
+
+        $data = [];
+        foreach ($result as $row) {
+            if (isset($row['data'])) {
+                $data[] = $row['data'];
+            }
+        }
+        $page->setData($data);
+
+        return $page;
     }
 }