Blacklisted

Author: tatevikg1

src/Domain/Identity/Repository/UserBlacklistRepository.php

@@ -2,12 +2,12 @@
 
 declare(strict_types=1);
 
-namespace PhpList\Core\Domain\Identity\Model;
+namespace PhpList\Core\Domain\Subscription\Model;
 
 use DateTime;
 use Doctrine\ORM\Mapping as ORM;
 use PhpList\Core\Domain\Common\Model\Interfaces\DomainModel;
-use PhpList\Core\Domain\Identity\Repository\UserBlacklistRepository;
+use PhpList\Core\Domain\Subscription\Repository\UserBlacklistRepository;
 
 #[ORM\Entity(repositoryClass: UserBlacklistRepository::class)]
 #[ORM\Table(name: 'phplist_user_blacklist')]
@@ -21,6 +21,9 @@ class UserBlacklist implements DomainModel
     #[ORM\Column(name: 'added', type: 'datetime', nullable: true)]
     private ?DateTime $added = null;
 
+    #[ORM\OneToOne(targetEntity: UserBlacklistData::class, mappedBy: 'email')]
+    private ?UserBlacklistData $blacklistData = null;
+
     public function getEmail(): string
     {
         return $this->email;
@@ -42,4 +45,9 @@ public function setAdded(?DateTime $added): self
         $this->added = $added;
         return $this;
     }
+
+    public function getBlacklistData(): ?UserBlacklistData
+    {
+        return $this->blacklistData;
+    }
 }

…/Domain/Identity/Model/UserBlacklist.php …ain/Subscription/Model/UserBlacklist.phpsrc/Domain/Identity/Model/UserBlacklist.php renamed to src/Domain/Subscription/Model/UserBlacklist.php src/Domain/Identity/Model/UserBlacklist.php renamed to src/Domain/Subscription/Model/UserBlacklist.php

@@ -2,11 +2,11 @@
 
 declare(strict_types=1);
 
-namespace PhpList\Core\Domain\Identity\Model;
+namespace PhpList\Core\Domain\Subscription\Model;
 
 use Doctrine\ORM\Mapping as ORM;
 use PhpList\Core\Domain\Common\Model\Interfaces\DomainModel;
-use PhpList\Core\Domain\Identity\Repository\UserBlacklistDataRepository;
+use PhpList\Core\Domain\Subscription\Repository\UserBlacklistDataRepository;
 
 #[ORM\Entity(repositoryClass: UserBlacklistDataRepository::class)]
 #[ORM\Table(name: 'phplist_user_blacklist_data')]

…ain/Identity/Model/UserBlacklistData.php …Subscription/Model/UserBlacklistData.phpsrc/Domain/Identity/Model/UserBlacklistData.php renamed to src/Domain/Subscription/Model/UserBlacklistData.php src/Domain/Identity/Model/UserBlacklistData.php renamed to src/Domain/Subscription/Model/UserBlacklistData.php

@@ -127,4 +127,18 @@ public function findSubscriberWithSubscriptions(int $id): ?Subscriber
             ->getQuery()
             ->getOneOrNullResult();
     }
+
+    public function isEmailBlacklisted(string $email): bool
+    {
+        $qb = $this->getEntityManager()->createQueryBuilder();
+
+        $qb->select('u.email')
+            ->from(Subscriber::class, 'u')
+            ->where('u.email = :email')
+            ->andWhere('u.blacklisted = 1')
+            ->setParameter('email', $email)
+            ->setMaxResults(1);
+
+        return !($qb->getQuery()->getOneOrNullResult() === null);
+    }
 }

src/Domain/Subscription/Repository/SubscriberRepository.php

@@ -2,7 +2,7 @@
 
 declare(strict_types=1);
 
-namespace PhpList\Core\Domain\Identity\Repository;
+namespace PhpList\Core\Domain\Subscription\Repository;
 
 use PhpList\Core\Domain\Common\Repository\AbstractRepository;
 

…pository/UserBlacklistDataRepository.php …pository/UserBlacklistDataRepository.phpsrc/Domain/Identity/Repository/UserBlacklistDataRepository.php renamed to src/Domain/Subscription/Repository/UserBlacklistDataRepository.php src/Domain/Identity/Repository/UserBlacklistDataRepository.php renamed to src/Domain/Subscription/Repository/UserBlacklistDataRepository.php

@@ -0,0 +1,26 @@
+<?php
+
+declare(strict_types=1);
+
+namespace PhpList\Core\Domain\Subscription\Repository;
+
+use PhpList\Core\Domain\Common\Repository\AbstractRepository;
+use PhpList\Core\Domain\Subscription\Model\UserBlacklist;
+use PhpList\Core\Domain\Subscription\Model\UserBlacklistData;
+
+class UserBlacklistRepository extends AbstractRepository
+{
+    public function getBlacklistInfoByEmail(string $email): ?array
+    {
+        $qb = $this->getEntityManager()->createQueryBuilder();
+
+        $qb->select('ub.email, ub.added, ubd.data AS reason')
+            ->from(UserBlacklist::class, 'ub')
+            ->innerJoin(UserBlacklistData::class, 'ubd', 'WITH', 'ub.email = ubd.email')
+            ->where('ub.email = :email')
+            ->setParameter('email', $email)
+            ->setMaxResults(1);
+
+        return $qb->getQuery()->getOneOrNullResult();
+    }
+}

src/Domain/Subscription/Repository/UserBlacklistRepository.php

@@ -0,0 +1,86 @@
+<?php
+
+declare(strict_types=1);
+
+namespace PhpList\Core\Domain\Subscription\Service\Manager;
+
+use PhpList\Core\Domain\Subscription\Model\Subscriber;
+use PhpList\Core\Domain\Subscription\Model\UserBlacklist;
+use PhpList\Core\Domain\Subscription\Model\UserBlacklistData;
+use PhpList\Core\Domain\Subscription\Repository\SubscriberRepository;
+use PhpList\Core\Domain\Subscription\Repository\UserBlacklistRepository;
+
+class SubscriberBlacklistManager
+{
+    public function __construct(
+        private readonly SubscriberRepository $subscriberRepository,
+        private readonly UserBlacklistRepository $userBlacklistRepository,
+    ) {
+    }
+
+    public function isEmailBlacklisted(string $email): bool
+    {
+        return $this->subscriberRepository->isEmailBlacklisted($email);
+    }
+
+    public function getBlacklistInfo(string $email): ?Subscriber
+    {
+        return $this->userBlacklistRepository->findBlacklistedByEmail($email);
+    }
+// 095-38-25-55
+    public function addEmailToBlacklist(string $email, ?string $reasonData = null): void
+    {
+        $existing = $this->getBlacklistInfo($email);
+        if ($existing) {
+            return;
+        }
+
+        $blacklistEntry = new UserBlacklist();
+        $blacklistEntry->setEmail($email);
+        $blacklistEntry->setAdded(new \DateTime());
+
+        $entityManager->persist($blacklistEntry);
+
+        if ($reasonData !== null) {
+            $blacklistData = new UserBlacklistData();
+            $blacklistData->setEmail($email);
+            $blacklistData->setName('reason'); // or a relevant name
+            $blacklistData->setData($reasonData);
+            $entityManager->persist($blacklistData);
+        }
+
+        $entityManager->flush();
+    }
+
+    public function removeEmailFromBlacklist(string $email)
+    {
+        $entityManager = $this->entityManager;
+
+        $blacklistEntry = $entityManager->getRepository(UserBlacklist::class)->find($email);
+        if ($blacklistEntry) {
+            $entityManager->remove($blacklistEntry);
+        }
+
+        $blacklistData = $entityManager->getRepository(UserBlacklistData::class)->find($email);
+        if ($blacklistData) {
+            $entityManager->remove($blacklistData);
+        }
+
+        // Also, update the user record
+        $userRepo = $entityManager->getRepository(Subscriber::class);
+        $user = $userRepo->findOneBy(['email' => $email]);
+        if ($user) {
+            $user->setBlacklisted(false);
+        }
+
+        $entityManager->flush();
+    }
+
+    public function getBlacklistReason(string $email): ?string
+    {
+        $repository = $this->entityManager->getRepository(UserBlacklistData::class);
+        $data = $repository->findOneBy(['email' => $email]);
+        return $data ? $data->getData() : null;
+    }
+
+}