Flush in controller

Author: tatevikg1

src/Domain/Subscription/Service/Manager/SubscriptionManager.php

@@ -4,6 +4,7 @@
 
 namespace PhpList\Core\Domain\Subscription\Service\Manager;
 
+use Doctrine\ORM\EntityManagerInterface;
 use PhpList\Core\Domain\Subscription\Exception\SubscriptionCreationException;
 use PhpList\Core\Domain\Subscription\Model\Subscriber;
 use PhpList\Core\Domain\Subscription\Model\SubscriberList;
@@ -19,17 +20,20 @@ class SubscriptionManager
     private SubscriberRepository $subscriberRepository;
     private SubscriberListRepository $subscriberListRepository;
     private TranslatorInterface $translator;
+    private EntityManagerInterface $entityManager;
 
     public function __construct(
         SubscriptionRepository $subscriptionRepository,
         SubscriberRepository $subscriberRepository,
         SubscriberListRepository $subscriberListRepository,
-        TranslatorInterface $translator
+        TranslatorInterface $translator,
+        EntityManagerInterface $entityManager
     ) {
         $this->subscriptionRepository = $subscriptionRepository;
         $this->subscriberRepository = $subscriberRepository;
         $this->subscriberListRepository = $subscriberListRepository;
         $this->translator = $translator;
+        $this->entityManager = $entityManager;
     }
 
     public function addSubscriberToAList(Subscriber $subscriber, int $listId): ?Subscription
@@ -49,7 +53,7 @@ public function addSubscriberToAList(Subscriber $subscriber, int $listId): ?Subs
         $subscription->setSubscriber($subscriber);
         $subscription->setSubscriberList($subscriberList);
 
-        $this->subscriptionRepository->save($subscription);
+        $this->entityManager->persist($subscription);
 
         return $subscription;
     }
@@ -83,7 +87,7 @@ private function createSubscription(SubscriberList $subscriberList, string $emai
         $subscription->setSubscriber($subscriber);
         $subscription->setSubscriberList($subscriberList);
 
-        $this->subscriptionRepository->save($subscription);
+        $this->entityManager->persist($subscription);;
 
         return $subscription;
     }
@@ -111,7 +115,7 @@ private function deleteSubscription(SubscriberList $subscriberList, string $emai
             throw new SubscriptionCreationException($message, 404);
         }
 
-        $this->subscriptionRepository->remove($subscription);
+        $this->entityManager->remove($subscription);
     }
 
     /** @return Subscriber[] */

tests/Unit/Domain/Subscription/Service/Manager/SubscriptionManagerTest.php

@@ -4,6 +4,7 @@
 
 namespace PhpList\Core\Tests\Unit\Domain\Subscription\Service\Manager;
 
+use Doctrine\ORM\EntityManagerInterface;
 use PhpList\Core\Domain\Subscription\Exception\SubscriptionCreationException;
 use PhpList\Core\Domain\Subscription\Model\Subscriber;
 use PhpList\Core\Domain\Subscription\Model\SubscriberList;
@@ -21,6 +22,7 @@ class SubscriptionManagerTest extends TestCase
     private SubscriptionRepository&MockObject $subscriptionRepository;
     private SubscriberRepository&MockObject $subscriberRepository;
     private TranslatorInterface&MockObject $translator;
+    private EntityManagerInterface&MockObject $entityManager;
     private SubscriptionManager $manager;
 
     protected function setUp(): void
@@ -29,11 +31,13 @@ protected function setUp(): void
         $this->subscriberRepository = $this->createMock(SubscriberRepository::class);
         $subscriberListRepository = $this->createMock(SubscriberListRepository::class);
         $this->translator = $this->createMock(TranslatorInterface::class);
+        $this->entityManager = $this->createMock(EntityManagerInterface::class);
         $this->manager = new SubscriptionManager(
             subscriptionRepository: $this->subscriptionRepository,
             subscriberRepository: $this->subscriberRepository,
             subscriberListRepository: $subscriberListRepository,
             translator: $this->translator,
+            entityManager: $this->entityManager,
         );
     }
 
@@ -45,7 +49,7 @@ public function testCreateSubscriptionWhenSubscriberExists(): void
 
         $this->subscriberRepository->method('findOneBy')->with(['email' => $email])->willReturn($subscriber);
         $this->subscriptionRepository->method('findOneBySubscriberListAndSubscriber')->willReturn(null);
-        $this->subscriptionRepository->expects($this->once())->method('save');
+        $this->entityManager->expects($this->once())->method('persist');
 
         $subscriptions = $this->manager->createSubscriptions($list, [$email]);
 
@@ -78,7 +82,7 @@ public function testDeleteSubscriptionSuccessfully(): void
             ->with($subscriberList->getId(), $email)
             ->willReturn($subscription);
 
-        $this->subscriptionRepository->expects($this->once())->method('remove')->with($subscription);
+        $this->entityManager->expects($this->once())->method('remove')->with($subscription);
 
         $this->manager->deleteSubscriptions($subscriberList, [$email]);
     }