superdesk / web-publisher

src/SWP/Bundle/CoreBundle/Controller/ContentListController.php

Indentation +165 added lines, -165 removed lines

@@ -44,36 +44,36 @@ 
 
 class ContentListController extends AbstractController {
 
-  private ContentListRepositoryInterface $contentListRepository;
-  private ContentListItemRepositoryInterface $contentListItemRepository;
-  private ContentListServiceInterface $contentListService;
-  private FormFactoryInterface $formFactory;
-  private EntityManagerInterface $entityManager;
-  private EventDispatcherInterface $eventDispatcher;
-  private FactoryInterface $factory;
-  private string $invalidationCacheUrl;
-  private string $invalidationToken;
-
-  /**
-   * @param ContentListRepositoryInterface $contentListRepository
-   * @param ContentListItemRepositoryInterface $contentListItemRepository
-   * @param ContentListServiceInterface $contentListService
-   * @param FormFactoryInterface $formFactory
-   * @param EntityManagerInterface $entityManager
-   * @param EventDispatcherInterface $eventDispatcher
-   * @param FactoryInterface $factory
-   */
-  public function __construct(
-      ContentListRepositoryInterface     $contentListRepository,
-      ContentListItemRepositoryInterface $contentListItemRepository,
-      ContentListServiceInterface        $contentListService,
-      FormFactoryInterface               $formFactory,
-      EntityManagerInterface             $entityManager,
-      EventDispatcherInterface           $eventDispatcher,
-      FactoryInterface                   $factory,
-      string $invalidationCacheUrl,
-      string $invalidationToken
-  ) {
+    private ContentListRepositoryInterface $contentListRepository;
+    private ContentListItemRepositoryInterface $contentListItemRepository;
+    private ContentListServiceInterface $contentListService;
+    private FormFactoryInterface $formFactory;
+    private EntityManagerInterface $entityManager;
+    private EventDispatcherInterface $eventDispatcher;
+    private FactoryInterface $factory;
+    private string $invalidationCacheUrl;
+    private string $invalidationToken;
+
+    /**
+     * @param ContentListRepositoryInterface $contentListRepository
+     * @param ContentListItemRepositoryInterface $contentListItemRepository
+     * @param ContentListServiceInterface $contentListService
+     * @param FormFactoryInterface $formFactory
+     * @param EntityManagerInterface $entityManager
+     * @param EventDispatcherInterface $eventDispatcher
+     * @param FactoryInterface $factory
+     */
+    public function __construct(
+        ContentListRepositoryInterface     $contentListRepository,
+        ContentListItemRepositoryInterface $contentListItemRepository,
+        ContentListServiceInterface        $contentListService,
+        FormFactoryInterface               $formFactory,
+        EntityManagerInterface             $entityManager,
+        EventDispatcherInterface           $eventDispatcher,
+        FactoryInterface                   $factory,
+        string $invalidationCacheUrl,
+        string $invalidationToken
+    ) {
     $this->contentListRepository = $contentListRepository;
     $this->contentListItemRepository = $contentListItemRepository;
     $this->contentListService = $contentListService;
@@ -83,76 +83,76 @@ 
     $this->factory = $factory;
     $this->invalidationCacheUrl = $invalidationCacheUrl;
     $this->invalidationToken = $invalidationToken;
-  }
-
-  public static function invalidateCache(string $url, string $token, array $data = [])
-  {
-      // Skip cache invalidation if URL or token is empty (test environment)
-      if (empty($url) || empty($token)) {
-          return;
-      }
-
-      try {
-          $client = new Client();
-
-          $headers = [
-              'Content-Type' => 'application/json',
-          ];
-          $queryParams = [
-              'secret' => $token,
-          ];
-
-          $response = $client->request('POST', $url,  [
-              'headers' => $headers,
-              'json' => $data,
-              'query' => $queryParams
-          ]);
-          $responseBody = $response->getBody()->getContents();
-          $result = [
-              'request' => [
-                  'headers' => $headers,
-                  'json' => $data,
-                  'query' => $queryParams
-              ],
-              'response' => [
-                  'status' => $response->getStatusCode(),
-                  'body' => $responseBody,
-                  'ReasonPhrase' => $response->getReasonPhrase()
-              ]
-          ];
-
-          if (is_writable('/tmp')) {
-              file_put_contents('/tmp/cache_invalidation.json', json_encode($result) . PHP_EOL, FILE_APPEND);
-          }
-      } catch (\Throwable $e) {
-          if (is_writable('/tmp')) {
-              file_put_contents('/tmp/cache_invalidation_errors.json', $e->getMessage() . PHP_EOL, FILE_APPEND);
-          }
-          // Don't throw the exception, just log it
-          error_log('Cache invalidation failed: ' . $e->getMessage());
-      }
-  }
-
-  /**
-   * @Route("/api/{version}/content/lists/", options={"expose"=true}, defaults={"version"="v2"}, methods={"GET"}, name="swp_api_content_list_lists")
-   */
-  public function listAction(Request $request): ResourcesListResponseInterface {
+    }
+
+    public static function invalidateCache(string $url, string $token, array $data = [])
+    {
+        // Skip cache invalidation if URL or token is empty (test environment)
+        if (empty($url) || empty($token)) {
+            return;
+        }
+
+        try {
+            $client = new Client();
+
+            $headers = [
+                'Content-Type' => 'application/json',
+            ];
+            $queryParams = [
+                'secret' => $token,
+            ];
+
+            $response = $client->request('POST', $url,  [
+                'headers' => $headers,
+                'json' => $data,
+                'query' => $queryParams
+            ]);
+            $responseBody = $response->getBody()->getContents();
+            $result = [
+                'request' => [
+                    'headers' => $headers,
+                    'json' => $data,
+                    'query' => $queryParams
+                ],
+                'response' => [
+                    'status' => $response->getStatusCode(),
+                    'body' => $responseBody,
+                    'ReasonPhrase' => $response->getReasonPhrase()
+                ]
+            ];
+
+            if (is_writable('/tmp')) {
+                file_put_contents('/tmp/cache_invalidation.json', json_encode($result) . PHP_EOL, FILE_APPEND);
+            }
+        } catch (\Throwable $e) {
+            if (is_writable('/tmp')) {
+                file_put_contents('/tmp/cache_invalidation_errors.json', $e->getMessage() . PHP_EOL, FILE_APPEND);
+            }
+            // Don't throw the exception, just log it
+            error_log('Cache invalidation failed: ' . $e->getMessage());
+        }
+    }
+
+    /**
+     * @Route("/api/{version}/content/lists/", options={"expose"=true}, defaults={"version"="v2"}, methods={"GET"}, name="swp_api_content_list_lists")
+     */
+    public function listAction(Request $request): ResourcesListResponseInterface {
     $lists = $this->contentListRepository->getPaginatedByCriteria($this->eventDispatcher, new Criteria(), $request->query->all('sorting'), new PaginationData($request));
 
     return new ResourcesListResponse($lists);
-  }
+    }
 
-  /**
-   * @Route("/api/{version}/content/lists/{id}", options={"expose"=true}, defaults={"version"="v2"}, methods={"GET"}, name="swp_api_content_show_lists", requirements={"id"="\d+"})
-   */
-  public function getAction($id): SingleResourceResponseInterface {
+    /**
+     * @Route("/api/{version}/content/lists/{id}", options={"expose"=true}, defaults={"version"="v2"}, methods={"GET"}, name="swp_api_content_show_lists", requirements={"id"="\d+"})
+     */
+    public function getAction($id): SingleResourceResponseInterface {
     return new SingleResourceResponse($this->findOr404($id));
-  }
+    }
 
-  /**
-   * @Route("/api/{version}/content/lists/", options={"expose"=true}, defaults={"version"="v2"}, methods={"POST"}, name="swp_api_content_create_lists")
-   */
-  public function createAction(Request $request): SingleResourceResponseInterface {
+    /**
+     * @Route("/api/{version}/content/lists/", options={"expose"=true}, defaults={"version"="v2"}, methods={"POST"}, name="swp_api_content_create_lists")
+     */
+    public function createAction(Request $request): SingleResourceResponseInterface {
     /* @var ContentListInterface $contentList */
     $contentList = $this->factory->create();
     $form = $this->formFactory->createNamed('', ContentListType::class, $contentList, ['method' => $request->getMethod()]);
@@ -161,28 +161,28 @@ 
     $this->ensureContentListExists($contentList->getName());
 
     if ($form->isSubmitted() && $form->isValid()) {
-      $this->contentListRepository->add($contentList);
-      self::invalidateCache(
-          $this->invalidationCacheUrl,
-          $this->invalidationToken,
-          [
-              'id' => $contentList->getId(),
-              'name' => $contentList->getName(),
-              'type' => $contentList->getType(),
-              'action' => 'CREATE'
-          ]
+        $this->contentListRepository->add($contentList);
+        self::invalidateCache(
+            $this->invalidationCacheUrl,
+            $this->invalidationToken,
+            [
+                'id' => $contentList->getId(),
+                'name' => $contentList->getName(),
+                'type' => $contentList->getType(),
+                'action' => 'CREATE'
+            ]
         );
 
-      return new SingleResourceResponse($contentList, new ResponseContext(201));
+        return new SingleResourceResponse($contentList, new ResponseContext(201));
     }
 
     return new SingleResourceResponse($form, new ResponseContext(400));
-  }
+    }
 
-  /**
-   * @Route("/api/{version}/content/lists/{id}", options={"expose"=true}, defaults={"version"="v2"}, methods={"PATCH"}, name="swp_api_content_update_lists", requirements={"id"="\d+"})
-   */
-  public function updateAction(Request $request, int $id): SingleResourceResponseInterface {
+    /**
+     * @Route("/api/{version}/content/lists/{id}", options={"expose"=true}, defaults={"version"="v2"}, methods={"PATCH"}, name="swp_api_content_update_lists", requirements={"id"="\d+"})
+     */
+    public function updateAction(Request $request, int $id): SingleResourceResponseInterface {
     $objectManager = $this->entityManager;
     /** @var ContentListInterface $contentList */
     $contentList = $this->findOr404($id);
@@ -193,12 +193,12 @@ 
     $form->handleRequest($request);
 
     if ($form->isSubmitted() && $form->isValid()) {
-      $this->eventDispatcher->dispatch(
-          new GenericEvent($contentList, ['filters' => $filters, 'previousLimit' => $listLimit]),
-          ContentListEvents::LIST_CRITERIA_CHANGE
-      );
+        $this->eventDispatcher->dispatch(
+            new GenericEvent($contentList, ['filters' => $filters, 'previousLimit' => $listLimit]),
+            ContentListEvents::LIST_CRITERIA_CHANGE
+        );
 
-      $objectManager->flush();
+        $objectManager->flush();
         self::invalidateCache(
             $this->invalidationCacheUrl,
             $this->invalidationToken,
@@ -210,54 +210,54 @@ 
             ]
         );
 
-      return new SingleResourceResponse($contentList);
+        return new SingleResourceResponse($contentList);
     }
 
     return new SingleResourceResponse($form, new ResponseContext(400));
-  }
+    }
 
-  /**
-   * @Route("/api/{version}/content/lists/{id}", options={"expose"=true}, defaults={"version"="v2"}, methods={"DELETE"}, name="swp_api_content_delete_lists", requirements={"id"="\d+"})
-   */
-  public function deleteAction($id): SingleResourceResponseInterface {
+    /**
+     * @Route("/api/{version}/content/lists/{id}", options={"expose"=true}, defaults={"version"="v2"}, methods={"DELETE"}, name="swp_api_content_delete_lists", requirements={"id"="\d+"})
+     */
+    public function deleteAction($id): SingleResourceResponseInterface {
     $repository = $this->contentListRepository;
     $contentList = $this->findOr404($id);
 
     $repository->remove($contentList);
-      self::invalidateCache(
-          $this->invalidationCacheUrl,
-          $this->invalidationToken,
-          [
-              'id' => $contentList->getId(),
-              'name' => $contentList->getName(),
-              'type' => $contentList->getType(),
-              'action' => 'DELETE'
-          ]
-      );
+        self::invalidateCache(
+            $this->invalidationCacheUrl,
+            $this->invalidationToken,
+            [
+                'id' => $contentList->getId(),
+                'name' => $contentList->getName(),
+                'type' => $contentList->getType(),
+                'action' => 'DELETE'
+            ]
+        );
 
     return new SingleResourceResponse(null, new ResponseContext(204));
-  }
+    }
 
-  /**
-   * @Route("/api/{version}/content/lists/{id}", requirements={"id"="\w+"}, defaults={"version"="v2"}, methods={"LINK","UNLINK"}, name="swp_api_content_list_link_unlink")
-   */
-  public function linkUnlinkToContentListAction(Request $request, string $id): SingleResourceResponseInterface {
+    /**
+     * @Route("/api/{version}/content/lists/{id}", requirements={"id"="\w+"}, defaults={"version"="v2"}, methods={"LINK","UNLINK"}, name="swp_api_content_list_link_unlink")
+     */
+    public function linkUnlinkToContentListAction(Request $request, string $id): SingleResourceResponseInterface {
     $objectManager = $this->entityManager;
     /** @var ContentListInterface $contentList */
     $contentList = $this->findOr404($id);
 
     $matched = false;
     foreach ($request->attributes->get('links', []) as $key => $objectArray) {
-      if (!is_array($objectArray)) {
+        if (!is_array($objectArray)) {
         continue;
-      }
+        }
 
-      $object = $objectArray['object'];
-      if ($object instanceof Exception) {
+        $object = $objectArray['object'];
+        if ($object instanceof Exception) {
         throw $object;
-      }
+        }
 
-      if ($object instanceof ArticleInterface) {
+        if ($object instanceof ArticleInterface) {
         $contentListItem = $this->contentListItemRepository
             ->findOneBy([
                 'contentList' => $contentList,
@@ -265,59 +265,59 @@ 
             ]);
 
         if ('LINK' === $request->getMethod()) {
-          $position = 0;
-          if (count($notConvertedLinks = RequestParser::getNotConvertedLinks($request->attributes->get('links'))) > 0) {
+            $position = 0;
+            if (count($notConvertedLinks = RequestParser::getNotConvertedLinks($request->attributes->get('links'))) > 0) {
             foreach ($notConvertedLinks as $link) {
-              if (isset($link['resourceType']) && 'position' === $link['resourceType']) {
+                if (isset($link['resourceType']) && 'position' === $link['resourceType']) {
                 $position = $link['resource'];
-              }
+                }
+            }
             }
-          }
 
-          if (false === $position && $contentListItem) {
+            if (false === $position && $contentListItem) {
             throw new ConflictHttpException('This content is already linked to Content List');
-          }
+            }
 
-          if (!$contentListItem) {
+            if (!$contentListItem) {
             $contentListItem = $this->contentListService->addArticleToContentList($contentList, $object, $position);
             $objectManager->persist($contentListItem);
-          } else {
+            } else {
             $contentListItem->setPosition($position);
-          }
+            }
 
-          $objectManager->flush();
+            $objectManager->flush();
         } elseif ('UNLINK' === $request->getMethod()) {
-          if ($contentListItem->getContentList() !== $contentList) {
+            if ($contentListItem->getContentList() !== $contentList) {
             throw new ConflictHttpException('Content is not linked to content list');
-          }
-          $objectManager->remove($contentListItem);
+            }
+            $objectManager->remove($contentListItem);
         }
 
         $matched = true;
 
         break;
-      }
+        }
     }
     if (false === $matched) {
-      throw new NotFoundHttpException('Any supported link object was not found');
+        throw new NotFoundHttpException('Any supported link object was not found');
     }
 
     $objectManager->flush();
 
     return new SingleResourceResponse($contentList, new ResponseContext(201));
-  }
+    }
 
-  private function findOr404($id) {
+    private function findOr404($id) {
     if (null === $list = $this->contentListRepository->find($id)) {
-      throw new NotFoundHttpException(sprintf('Content list with id "%s" was not found.', $id));
+        throw new NotFoundHttpException(sprintf('Content list with id "%s" was not found.', $id));
     }
 
     return $list;
-  }
+    }
 
-  private function ensureContentListExists($name) {
+    private function ensureContentListExists($name) {
     if (null !== $this->contentListRepository->findOneBy(['name' => $name])) {
-      throw new ConflictHttpException(sprintf('Content list named "%s" already exists!', $name));
+        throw new ConflictHttpException(sprintf('Content list named "%s" already exists!', $name));
+    }
     }
-  }
 }