superdesk / web-publisher

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

Indentation +136 added lines, -136 removed lines

@@ -47,23 +47,23 @@ 
 use Gos\Bundle\WebSocketBundle\Pusher\PusherRegistry;
 
 class ContentListItemController extends AbstractController {
-  private ContentListItemRepositoryInterface $contentListItemRepository;
-  private EntityManagerInterface $entityManager;
-  private ContentListServiceInterface $contentListService;
-  private EventDispatcherInterface $eventDispatcher;
-
-  /**
-   * @var PusherInterface
-   */
-  private $pusher;
-
-  /**
-   * @param ContentListItemRepositoryInterface $contentListItemRepository
-   * @param EntityManagerInterface $entityManager
-   * @param ContentListServiceInterface $contentListService
-   * @param EventDispatcherInterface $eventDispatcher
-   */
-  public function __construct(
+    private ContentListItemRepositoryInterface $contentListItemRepository;
+    private EntityManagerInterface $entityManager;
+    private ContentListServiceInterface $contentListService;
+    private EventDispatcherInterface $eventDispatcher;
+
+    /**
+     * @var PusherInterface
+     */
+    private $pusher;
+
+    /**
+     * @param ContentListItemRepositoryInterface $contentListItemRepository
+     * @param EntityManagerInterface $entityManager
+     * @param ContentListServiceInterface $contentListService
+     * @param EventDispatcherInterface $eventDispatcher
+     */
+    public function __construct(
     ContentListItemRepositoryInterface $contentListItemRepository,
     EntityManagerInterface $entityManager,
     ContentListServiceInterface $contentListService,
@@ -71,7 +71,7 @@ 
     string $invalidationCacheUrl,
     string $invalidationToken,
     PusherRegistry $pusher
-  ) {
+    ) {
     $this->contentListItemRepository = $contentListItemRepository;
     $this->entityManager = $entityManager;
     $this->contentListService = $contentListService;
@@ -79,31 +79,31 @@ 
     $this->invalidationCacheUrl = $invalidationCacheUrl;
     $this->invalidationToken = $invalidationToken;
     $this->pusher = $pusher->getPusher('amqp');
-  }
+    }
 
 
-  /**
-   * @Route("/api/{version}/content/lists/{id}/items/", options={"expose"=true}, defaults={"version"="v2"}, methods={"GET"}, name="swp_api_core_list_items", requirements={"id"="\d+"})
-   */
-  public function listAction(Request $request, int $id): ResourcesListResponseInterface {
+    /**
+     * @Route("/api/{version}/content/lists/{id}/items/", options={"expose"=true}, defaults={"version"="v2"}, methods={"GET"}, name="swp_api_core_list_items", requirements={"id"="\d+"})
+     */
+    public function listAction(Request $request, int $id): ResourcesListResponseInterface {
     $sort = $request->query->all('sorting');
     if (empty($sort)) {
-      $sort = ['sticky' => 'desc'];
+        $sort = ['sticky' => 'desc'];
     }
 
     $items = $this->contentListItemRepository->getPaginatedByCriteria(
-      $this->eventDispatcher,
-      new Criteria([
+        $this->eventDispatcher,
+        new Criteria([
         'contentList' => $id,
         'sticky' => $request->query->get('sticky', ''),
-      ]),
-      $sort,
-      new PaginationData($request)
+        ]),
+        $sort,
+        new PaginationData($request)
     );
 
     $responseContext = new ResponseContext();
     $responseContext->setSerializationGroups(
-      [
+        [
         'Default',
         'api',
         'api_packages_list',
@@ -117,147 +117,147 @@ 
         'api_image_details',
         'api_routes_list',
         'api_tenant_list',
-      ]
+        ]
     );
 
     return new ResourcesListResponse($items, $responseContext);
-  }
+    }
 
-  /**
-   * @Route("/api/{version}/content/lists/{listId}/items/{id}", options={"expose"=true}, defaults={"version"="v2"}, methods={"GET"}, name="swp_api_core_show_lists_item", requirements={"id"="\d+"})
-   */
-  public function getAction($listId, $id) {
+    /**
+     * @Route("/api/{version}/content/lists/{listId}/items/{id}", options={"expose"=true}, defaults={"version"="v2"}, methods={"GET"}, name="swp_api_core_show_lists_item", requirements={"id"="\d+"})
+     */
+    public function getAction($listId, $id) {
     return new SingleResourceResponse($this->findOr404($listId, $id));
-  }
+    }
 
-  /**
-   * @Route("/api/{version}/content/lists/{listId}/items/{id}", options={"expose"=true}, defaults={"version"="v2"}, methods={"PATCH"}, name="swp_api_core_update_lists_item", requirements={"id"="\d+", "listId"="\d+"})
-   */
-  public function updateAction(
+    /**
+     * @Route("/api/{version}/content/lists/{listId}/items/{id}", options={"expose"=true}, defaults={"version"="v2"}, methods={"PATCH"}, name="swp_api_core_update_lists_item", requirements={"id"="\d+", "listId"="\d+"})
+     */
+    public function updateAction(
     Request $request,
     FormFactoryInterface $formFactory,
     $listId,
     $id
-  ): SingleResourceResponseInterface {
+    ): SingleResourceResponseInterface {
     $contentListItem = $this->findOr404($listId, $id);
     $form = $formFactory->createNamed(
-      '',
-      ContentListItemType::class,
-      $contentListItem,
-      ['method' => $request->getMethod()]
+        '',
+        ContentListItemType::class,
+        $contentListItem,
+        ['method' => $request->getMethod()]
     );
 
     $form->handleRequest($request);
 
     if ($form->isSubmitted() && $form->isValid()) {
-      $contentListItem->getContentList()->setUpdatedAt(new DateTime());
+        $contentListItem->getContentList()->setUpdatedAt(new DateTime());
 
-      if (null !== $contentListItem->getStickyPosition()) {
+        if (null !== $contentListItem->getStickyPosition()) {
         $contentListItem->setPosition($contentListItem->getStickyPosition());
-      }
+        }
 
-      $this->entityManager->flush();
-      ContentListController::invalidateCache(
+        $this->entityManager->flush();
+        ContentListController::invalidateCache(
         $this->invalidationCacheUrl,
         $this->invalidationToken,
         [
-          'id' => $contentListItem->getContentList()->getId(),
-          'name' => $contentListItem->getContentList()->getName(),
-          'type' => $contentListItem->getContentList()->getType(),
-          'action' => 'CREATE'
+            'id' => $contentListItem->getContentList()->getId(),
+            'name' => $contentListItem->getContentList()->getName(),
+            'type' => $contentListItem->getContentList()->getType(),
+            'action' => 'CREATE'
         ]
-      );
+        );
 
-      // Dispatch WebSocket update
-      $this->dispatchWebSocketUpdate('Content list item updated', 'UPDATE', $contentListItem->getContentList()->getId());
+        // Dispatch WebSocket update
+        $this->dispatchWebSocketUpdate('Content list item updated', 'UPDATE', $contentListItem->getContentList()->getId());
 
-      return new SingleResourceResponse($contentListItem);
+        return new SingleResourceResponse($contentListItem);
     }
 
     return new SingleResourceResponse($form, new ResponseContext(400));
-  }
+    }
 
-  /**
-   * @Route("/api/{version}/content/lists/{listId}/items/", options={"expose"=true}, defaults={"version"="v2"}, methods={"PATCH"}, name="swp_api_core_batch_update_lists_item", requirements={"listId"="\d+"})
-   */
-  public function batchUpdateAction(
+    /**
+     * @Route("/api/{version}/content/lists/{listId}/items/", options={"expose"=true}, defaults={"version"="v2"}, methods={"PATCH"}, name="swp_api_core_batch_update_lists_item", requirements={"listId"="\d+"})
+     */
+    public function batchUpdateAction(
     Request                        $request,
     FormFactoryInterface           $formFactory,
     ContentListRepositoryInterface $contentListRepository,
     ArticleRepositoryInterface     $articleRepository,
     EventDispatcherInterface       $eventDispatcher,
     int                            $listId
-  ): SingleResourceResponseInterface {
+    ): SingleResourceResponseInterface {
     /** @var ContentListInterface $list */
     $list = $contentListRepository->findOneBy(['id' => $listId]);
     if (null === $list) {
-      throw new NotFoundHttpException(sprintf('Content list with id "%s" was not found.', $list));
+        throw new NotFoundHttpException(sprintf('Content list with id "%s" was not found.', $list));
     }
 
     $form = $formFactory->createNamed('', ContentListItemsType::class, [], ['method' => $request->getMethod()]);
 
     $form->handleRequest($request);
     if ($form->isSubmitted() && $form->isValid()) {
-      $data = $form->getData();
-      $updatedAt = DateTime::createFromFormat(DateTime::RFC3339, $data['updatedAt'], new DateTimeZone('UTC'));
-      $updatedAt->setTimezone(new DateTimeZone('UTC'));
-      $listUpdatedAt = $list->getUpdatedAt();
-      $listUpdatedAt->setTimezone(new DateTimeZone('UTC'));
-      if ($updatedAt < $listUpdatedAt) {
+        $data = $form->getData();
+        $updatedAt = DateTime::createFromFormat(DateTime::RFC3339, $data['updatedAt'], new DateTimeZone('UTC'));
+        $updatedAt->setTimezone(new DateTimeZone('UTC'));
+        $listUpdatedAt = $list->getUpdatedAt();
+        $listUpdatedAt->setTimezone(new DateTimeZone('UTC'));
+        if ($updatedAt < $listUpdatedAt) {
         throw new ConflictHttpException('List was already updated');
-      }
+        }
 
-      $updatedArticles = [];
-      $updatedItemsInvalidateCache = [];
-      /** @var ContentListAction $item */
-      foreach ($data['items'] as $item) {
+        $updatedArticles = [];
+        $updatedItemsInvalidateCache = [];
+        /** @var ContentListAction $item */
+        foreach ($data['items'] as $item) {
         $position = $item->getPosition();
         $isSticky = $item->isSticky();
         $contentId = $item->getContentId();
 
         $updatedItemsInvalidateCache[] = [
-          'id' => $contentId,
-          'action' => $item->getAction(),
-          'sticky' => $item->isSticky(),
-          'postition' => $item->getPosition()
+            'id' => $contentId,
+            'action' => $item->getAction(),
+            'sticky' => $item->isSticky(),
+            'postition' => $item->getPosition()
         ];
 
 
         switch ($item->getAction()) {
-          case ContentListAction::ACTION_MOVE:
+            case ContentListAction::ACTION_MOVE:
             $updated = false;
             $contentListItem = $this->findByContentOr404($list, $contentId);
 
             if ($position !== $contentListItem->getPosition()) {
-              $this->ensureThereIsNoItemOnPositionOrThrow409(
+                $this->ensureThereIsNoItemOnPositionOrThrow409(
                 $listId,
                 $position,
                 $isSticky,
                 ContentListAction::ACTION_MOVE
-              );
-              $contentListItem->setPosition($position);
-              $updated = true;
+                );
+                $contentListItem->setPosition($position);
+                $updated = true;
             }
 
             if ($isSticky !== $contentListItem->getStickyPosition()) {
-              $this->contentListService->toggleStickOnItemPosition($contentListItem, $isSticky, $position);
-              $updated = true;
+                $this->contentListService->toggleStickOnItemPosition($contentListItem, $isSticky, $position);
+                $updated = true;
             }
 
             if ($updated) {
-              $list->setUpdatedAt(new DateTime('now'));
-              $this->entityManager->flush();
+                $list->setUpdatedAt(new DateTime('now'));
+                $this->entityManager->flush();
             }
 
             $updatedArticles[$contentId] = $contentListItem->getContent();
 
             break;
-          case ContentListAction::ACTION_ADD:
+            case ContentListAction::ACTION_ADD:
             $this->ensureThereIsNoItemOnPositionOrThrow409(
-              $listId,
-              $position,
-              $isSticky,
-              ContentListAction::ACTION_ADD
+                $listId,
+                $position,
+                $isSticky,
+                ContentListAction::ACTION_ADD
             );
 
             $object = $articleRepository->findOneById($contentId);
@@ -266,7 +266,7 @@ 
             $updatedArticles[$contentId] = $contentListItem->getContent();
 
             break;
-          case ContentListAction::ACTION_DELETE:
+            case ContentListAction::ACTION_DELETE:
             $contentListItem = $this->findByContentOr404($list, $contentId);
             $this->entityManager->remove($contentListItem);
             $list->setUpdatedAt(new DateTime('now'));
@@ -275,98 +275,98 @@ 
 
             break;
         }
-      }
+        }
 
-      $this->contentListService->repositionStickyItems($list);
+        $this->contentListService->repositionStickyItems($list);
 
-      foreach ($updatedArticles as $updatedArticle) {
+        foreach ($updatedArticles as $updatedArticle) {
         $eventDispatcher->dispatch(new ArticleEvent(
-          $updatedArticle,
-          $updatedArticle->getPackage(),
-          ArticleEvents::POST_UPDATE
+            $updatedArticle,
+            $updatedArticle->getPackage(),
+            ArticleEvents::POST_UPDATE
         ), ArticleEvents::POST_UPDATE);
-      }
-      ContentListController::invalidateCache(
+        }
+        ContentListController::invalidateCache(
         $this->invalidationCacheUrl,
         $this->invalidationToken,
         [
-          'id' => $list->getId(),
-          'name' => $list->getName(),
-          'type' => $list->getType(),
-          'action' => 'BATCH-UPDATE',
-          'items' => $updatedItemsInvalidateCache
+            'id' => $list->getId(),
+            'name' => $list->getName(),
+            'type' => $list->getType(),
+            'action' => 'BATCH-UPDATE',
+            'items' => $updatedItemsInvalidateCache
         ]
-      );
+        );
 
-      // Dispatch WebSocket update
-      $this->dispatchWebSocketUpdate('Manual list updated', 'BATCH-UPDATE', $list->getId());
+        // Dispatch WebSocket update
+        $this->dispatchWebSocketUpdate('Manual list updated', 'BATCH-UPDATE', $list->getId());
 
-      return new SingleResourceResponse($list, new ResponseContext(201));
+        return new SingleResourceResponse($list, new ResponseContext(201));
     }
 
     return new SingleResourceResponse($form, new ResponseContext(400));
-  }
+    }
 
-  private function findByContentOr404($listId, $contentId): ContentListItemInterface {
+    private function findByContentOr404($listId, $contentId): ContentListItemInterface {
     /** @var ContentListItemInterface $listItem */
     $listItem = $this->contentListItemRepository->findOneBy([
-      'contentList' => $listId,
-      'content' => $contentId,
+        'contentList' => $listId,
+        'content' => $contentId,
     ]);
 
     if (null === $listItem) {
-      throw new NotFoundHttpException(sprintf('Content list item with content_id "%s" was not found on that list. If You want to add new item - use action type "add".', $contentId));
+        throw new NotFoundHttpException(sprintf('Content list item with content_id "%s" was not found on that list. If You want to add new item - use action type "add".', $contentId));
     }
 
     return $listItem;
-  }
+    }
 
-  private function findOr404($listId, $id): ContentListItemInterface {
+    private function findOr404($listId, $id): ContentListItemInterface {
     /** @var ContentListItemInterface $listItem */
     $listItem = $this->contentListItemRepository->findOneBy([
-      'contentList' => $listId,
-      'id' => $id,
+        'contentList' => $listId,
+        'id' => $id,
     ]);
 
     if (null === $listItem) {
-      throw new NotFoundHttpException(sprintf('Content list item with id "%s" was not found.', $id));
+        throw new NotFoundHttpException(sprintf('Content list item with id "%s" was not found.', $id));
     }
 
     return $listItem;
-  }
+    }
 
-  private function ensureThereIsNoItemOnPositionOrThrow409(
+    private function ensureThereIsNoItemOnPositionOrThrow409(
     int $listId,
     int $position,
     bool $isSticky,
     string $action
-  ): void {
+    ): void {
     $existingContentListItem = $this->contentListService->isAnyItemPinnedOnPosition($listId, $position);
 
     if (!$existingContentListItem && !$isSticky) {
-      return;
+        return;
     }
 
     if ($existingContentListItem && $existingContentListItem->isSticky()) {
-      throw new ConflictHttpException('There is already an item pinned on that position. Unpin it first.');
+        throw new ConflictHttpException('There is already an item pinned on that position. Unpin it first.');
     }
 
     if ($action === ContentListAction::ACTION_MOVE && $isSticky) {
-      throw new ConflictHttpException('Cannot move pinned item. Unpin it first.');
+        throw new ConflictHttpException('Cannot move pinned item. Unpin it first.');
+    }
     }
-  }
 
-  private function dispatchWebSocketUpdate(string $message, string $action, ?int $contentListId = null): void {
+    private function dispatchWebSocketUpdate(string $message, string $action, ?int $contentListId = null): void {
     $pushData = [
-      'message' => $message,
-      'action' => $action,
-      'timestamp' => (new \DateTime())->format('c')
+        'message' => $message,
+        'action' => $action,
+        'timestamp' => (new \DateTime())->format('c')
     ];
 
     if ($contentListId !== null) {
-      $pushData['content_list_id'] = $contentListId;
+        $pushData['content_list_id'] = $contentListId;
     }
 
     $this->pusher->push($pushData, 'content_list_update');
-  }
+    }
 }