Add unsubscribe endpoint

Author: tatevikg1

src/Subscription/Controller/SubscribePagePublicController.php

@@ -6,6 +6,7 @@
 
 use Doctrine\ORM\EntityManagerInterface;
 use OpenApi\Attributes as OA;
+use PhpList\Core\Domain\Subscription\Model\SubscribePageData;
 use PhpList\Core\Domain\Subscription\Repository\SubscriberListRepository;
 use PhpList\Core\Domain\Subscription\Service\Manager\SubscribePageManager;
 use PhpList\Core\Domain\Subscription\Service\Manager\SubscriberAttributeManager;
@@ -127,7 +128,7 @@ public function subscribe(Request $request, int $pageId): JsonResponse
     {
         $page = $this->subscribePageManager->findPublicPage(id: $pageId);
         if (!$page) {
-            throw $this->createNotFoundException('Subscriber subscribe page not found.');
+            throw $this->createNotFoundException('Subscribe page not found.');
         }
 
         /** @var PublicSubscriptionRequest $subscriptionRequest */
@@ -162,4 +163,84 @@ public function subscribe(Request $request, int $pageId): JsonResponse
 
         return $this->json($normalized, Response::HTTP_CREATED);
     }
+
+    #[Route('/{pageId}', name: 'unsubscribe', methods: ['DELETE'])]
+    #[OA\Delete(
+        path: '/api/v2/public/subscribe-pages/{pageId}',
+        description: '🚧 **Status: Beta** – This method is under development. Avoid using in production.' .
+        'Unsubscribe subscriber from a list from subscribe page.',
+        summary: 'Delete subscription',
+        tags: ['subscribe-pages'],
+        parameters: [
+            new OA\Parameter(
+                name: 'pageId',
+                description: 'Subscribe page ID',
+                in: 'path',
+                required: true,
+                schema: new OA\Schema(type: 'integer')
+            ),
+            new OA\Parameter(
+                name: 'email',
+                description: 'Subscriber email',
+                in: 'query',
+                required: true,
+                schema: new OA\Schema(type: 'string')
+            ),
+        ],
+        responses: [
+            new OA\Response(
+                response: 200,
+                description: 'Success'
+            ),
+            new OA\Response(
+                response: 400,
+                description: 'Failure',
+                content: new OA\JsonContent(ref: '#/components/schemas/BadRequestResponse')
+            ),
+            new OA\Response(
+                response: 404,
+                description: 'Failure',
+                content: new OA\JsonContent(ref: '#/components/schemas/NotFoundErrorResponse')
+            ),
+            new OA\Response(
+                response: 422,
+                description: 'Failure',
+                content: new OA\JsonContent(ref: '#/components/schemas/ValidationErrorResponse')
+            ),
+        ]
+    )]
+    public function unsubscribe(Request $request, int $pageId): JsonResponse
+    {
+        $page = $this->subscribePageManager->findPage(id: $pageId);
+        if (!$page) {
+            throw $this->createNotFoundException('Subscribe page not found.');
+        }
+
+        /** @var SubscribePageData|null $listsField */
+        $listsField = array_find(
+            $page->getData(),
+            fn (SubscribePageData $data) => $data->getName() === 'lists'
+        );
+
+        if ($listsField === null) {
+            return $this->json(null, Response::HTTP_NO_CONTENT);
+        }
+
+        $listsIds = explode(',', $listsField->getData() ?? '');
+
+        if (empty($listsIds)) {
+            return $this->json(null, Response::HTTP_NO_CONTENT);
+        }
+
+        $lists = $this->subscriberListRepository->findBy(['id' => $listsIds]);
+        foreach ($lists as $list) {
+            $this->subscriptionManager->deleteSubscriptions(
+                subscriberList: $list,
+                emails: [$request->query->get('email')]
+            );
+        }
+        $this->entityManager->flush();
+
+        return $this->json(null, Response::HTTP_NO_CONTENT);
+    }
 }