save

Author: tatevikg1

src/Identity/Controller/AdminAttributeDefinitionController.php

@@ -91,6 +91,8 @@ public function create(Request $request): JsonResponse
         $definitionRequest = $this->validator->validate($request, CreateAttributeDefinitionRequest::class);
 
         $attributeDefinition = $this->definitionManager->create($definitionRequest->getDto());
+        $this->entityManager->flush();
+
         $json = $this->normalizer->normalize($attributeDefinition, 'json');
 
         return $this->json($json, Response::HTTP_CREATED);
@@ -158,6 +160,7 @@ public function update(
             attributeDefinition: $attributeDefinition,
             attributeDefinitionDto: $definitionRequest->getDto(),
         );
+        $this->entityManager->flush();
         $json = $this->normalizer->normalize($attributeDefinition, 'json');
 
         return $this->json($json, Response::HTTP_OK);

src/Identity/Controller/PasswordResetController.php

@@ -4,6 +4,7 @@
 
 namespace PhpList\RestBundle\Identity\Controller;
 
+use Doctrine\ORM\EntityManagerInterface;
 use OpenApi\Attributes as OA;
 use PhpList\Core\Domain\Identity\Service\PasswordManager;
 use PhpList\Core\Security\Authentication;
@@ -29,6 +30,7 @@ public function __construct(
         Authentication $authentication,
         RequestValidator $validator,
         PasswordManager $passwordManager,
+        private readonly EntityManagerInterface $entityManager,
     ) {
         parent::__construct($authentication, $validator);
 
@@ -74,6 +76,7 @@ public function requestPasswordReset(Request $request): JsonResponse
         $resetRequest = $this->validator->validate($request, RequestPasswordResetRequest::class);
 
         $this->passwordManager->generatePasswordResetToken($resetRequest->email);
+        $this->entityManager->flush();
 
         return $this->json(null, Response::HTTP_NO_CONTENT);
     }
@@ -117,6 +120,7 @@ public function validateToken(Request $request): JsonResponse
         $validateRequest = $this->validator->validate($request, ValidateTokenRequest::class);
 
         $administrator = $this->passwordManager->validatePasswordResetToken($validateRequest->token);
+        $this->entityManager->flush();
 
         return $this->json([ 'valid' => $administrator !== null]);
     }
@@ -169,6 +173,7 @@ public function resetPassword(Request $request): JsonResponse
             $resetRequest->token,
             $resetRequest->newPassword
         );
+        $this->entityManager->flush();
 
         if ($success) {
             return $this->json([ 'message' => 'Password updated successfully']);

src/Messaging/Controller/BounceRegexController.php

@@ -190,6 +190,7 @@ public function createOrUpdate(Request $request): JsonResponse
             comment: $dto->comment,
             status: $dto->status
         );
+        $this->entityManager->flush();
 
         return $this->json($this->normalizer->normalize($entity), Response::HTTP_CREATED);
     }

src/Messaging/Controller/CampaignController.php

@@ -214,11 +214,10 @@ public function createMessage(Request $request): JsonResponse
 
         /** @var CreateMessageRequest $createMessageRequest */
         $createMessageRequest = $this->validator->validate($request, CreateMessageRequest::class);
+        $message = $this->campaignService->createMessage($createMessageRequest, $authUser);
+        $this->entityManager->flush();
 
-        return $this->json(
-            $this->campaignService->createMessage($createMessageRequest, $authUser),
-            Response::HTTP_CREATED
-        );
+        return $this->json(data: $message, status: Response::HTTP_CREATED);
     }
 
     #[Route('/{messageId}', name: 'update', requirements: ['messageId' => '\d+'], methods: ['PUT'])]
@@ -287,11 +286,10 @@ public function updateMessage(
 
         /** @var UpdateMessageRequest $updateMessageRequest */
         $updateMessageRequest = $this->validator->validate($request, UpdateMessageRequest::class);
+        $message = $this->campaignService->updateMessage($updateMessageRequest, $authUser, $message);
+        $this->entityManager->flush();
 
-        return $this->json(
-            $this->campaignService->updateMessage($updateMessageRequest, $authUser, $message),
-            Response::HTTP_OK
-        );
+        return $this->json(data:$message, status: Response::HTTP_OK);
     }
 
     #[Route('/{messageId}', name: 'delete', requirements: ['messageId' => '\d+'], methods: ['DELETE'])]

src/Subscription/Controller/SubscriberAttributeDefinitionController.php

@@ -89,6 +89,7 @@ public function create(Request $request): JsonResponse
         $definitionRequest = $this->validator->validate($request, CreateAttributeDefinitionRequest::class);
 
         $attributeDefinition = $this->definitionManager->create($definitionRequest->getDto());
+        $this->entityManager->flush();
         $json = $this->normalizer->normalize($attributeDefinition, 'json');
 
         return $this->json($json, Response::HTTP_CREATED);
@@ -156,6 +157,7 @@ public function update(
             attributeDefinition: $attributeDefinition,
             attributeDefinitionDto: $definitionRequest->getDto(),
         );
+        $this->entityManager->flush();
         $json = $this->normalizer->normalize($attributeDefinition, 'json');
 
         return $this->json($json, Response::HTTP_OK);

src/Subscription/Controller/SubscriberController.php

@@ -96,6 +96,7 @@ public function createSubscriber(Request $request): JsonResponse
         /** @var CreateSubscriberRequest $subscriberRequest */
         $subscriberRequest = $this->validator->validate($request, CreateSubscriberRequest::class);
         $subscriberData = $this->subscriberService->createSubscriber($subscriberRequest);
+        $this->entityManager->flush();
 
         return $this->json($subscriberData, Response::HTTP_CREATED);
     }
@@ -166,6 +167,7 @@ public function updateSubscriber(
         /** @var UpdateSubscriberRequest $updateSubscriberRequest */
         $updateSubscriberRequest = $this->validator->validate($request, UpdateSubscriberRequest::class);
         $subscriberData = $this->subscriberService->updateSubscriber($updateSubscriberRequest, $admin);
+        $this->entityManager->flush();
 
         return $this->json($subscriberData, Response::HTTP_OK);
     }
@@ -373,6 +375,7 @@ public function deleteSubscriber(
             throw $this->createNotFoundException('Subscriber not found.');
         }
         $this->subscriberService->deleteSubscriber($subscriber);
+        $this->entityManager->flush();
 
         return $this->json(null, Response::HTTP_NO_CONTENT);
     }