vendor/roothirsch/notification-bundle/src/Controller/FetchController.php line 66

Open in your IDE?
  1. <?php
  3. namespace Roothirsch\NotificationBundle\Controller;
  5. use Doctrine\ORM\EntityManagerInterface;
  6. use Roothirsch\DamBundle\Entity\Category;
  7. use Roothirsch\DamBundle\Repository\CategoryRepository;
  8. use Roothirsch\NotificationBundle\Entity\NotificationReadOn;
  9. use Roothirsch\NotificationBundle\Repository\NotificationReadOnRepository;
  10. use Roothirsch\NotificationBundle\Repository\NotificationRepository;
  11. use Symfony\Bundle\FrameworkBundle\Controller\AbstractController;
  12. use Symfony\Component\HttpFoundation\JsonResponse;
  13. use Symfony\Component\HttpFoundation\RequestStack;
  14. use Symfony\Component\Security\Core\Authentication\Token\Storage\TokenStorageInterface;
  15. use Symfony\Component\Routing\Annotation\Route;
  16. use Symfony\Component\Serializer\SerializerInterface;
  19. /**
  20. * @Route("/api/notifications", name="api_notifications_")
  21. */
  22. class FetchController extends AbstractController
  23. {
  25. /**
  26. * @var TokenStorageInterface
  27. */
  28. private $tokenStorage;
  30. /**
  31. * @var NotificationRepository
  32. */
  33. private $notificationRepository;
  35. /**
  36. * @var EntityManagerInterface
  37. */
  38. private $entityManager;
  40. /**
  41. * @var NotificationReadOnRepository
  42. */
  43. private $readOnRepository;
  45. /** @var SerializerInterface */
  46. private $serializer;
  48. /**
  49. * @param TokenStorageInterface $tokenStorage
  50. * @param NotificationRepository $notificationRepository
  51. * @param EntityManagerInterface $entityManager
  52. * @param NotificationReadOnRepository $readOnRepository
  53. */
  54. public function __construct(TokenStorageInterface $tokenStorage, NotificationRepository $notificationRepository, EntityManagerInterface $entityManager, NotificationReadOnRepository $readOnRepository, SerializerInterface $serializer)
  55. {
  56. $this->tokenStorage = $tokenStorage;
  57. $this->notificationRepository = $notificationRepository;
  58. $this->entityManager = $entityManager;
  59. $this->readOnRepository = $readOnRepository;
  60. $this->serializer = $serializer;
  61. }
  63. /**
  64. * @Route("/unread", name="read", methods={"GET"})
  65. */
  66. public function read()
  67. {
  68. $readOn = $this->readOnRepository->findOneBy(["user" => $this->tokenStorage->getToken()->getUser()]);
  69. if(!$readOn) {
  70. $readOn = new NotificationReadOn();
  71. $readOn->setDate(new \DateTime());
  72. }
  73. $unread = $this->notificationRepository->findUnreadNotifications($readOn);
  74. $read = $this->notificationRepository->findReadNotifications($readOn);
  76. return new JsonResponse([
  77. 'read' => json_decode($this->serializer->serialize($read, 'json'), TRUE),
  78. 'unread' => json_decode($this->serializer->serialize($unread, 'json'), TRUE)
  79. ]);
  80. }
  82. /**
  83. * @Route("/read", name="check", methods={"POST"})
  84. */
  85. public function check()
  86. {
  87. $user = $this->tokenStorage->getToken()->getUser();
  88. /** @var NotificationReadOn $readOne */
  89. $readOne = $this->readOnRepository->findOneBy([
  90. "user" => $user
  91. ]);
  92. if(!$readOne){
  93. $readOne = new NotificationReadOn();
  94. $readOne->setUser($user);
  95. }
  96. $readOne->setDate(new \DateTime());
  97. $this->entityManager->persist($readOne);
  98. $this->entityManager->flush();
  99. return $readOne;
  100. }
  101. }