src/Aqarmap/Bundle/DiscussionBundle/Controller/DiscussionController.php line 267

  1. <?php
  3. namespace Aqarmap\Bundle\DiscussionBundle\Controller;
  5. use App\Exception\BadRequestHttpException;
  6. use Aqarmap\Bundle\DiscussionBundle\Constant\DiscussionSearchTabs;
  7. use Aqarmap\Bundle\DiscussionBundle\Constant\DiscussionStatus;
  8. use Aqarmap\Bundle\DiscussionBundle\Entity\Comment;
  9. use Aqarmap\Bundle\DiscussionBundle\Entity\Discussion;
  10. use Aqarmap\Bundle\DiscussionBundle\Form\CommentType;
  11. use Aqarmap\Bundle\DiscussionBundle\Form\DiscussionSearchType;
  12. use Aqarmap\Bundle\DiscussionBundle\Form\DiscussionType;
  13. use Aqarmap\Bundle\DiscussionBundle\Repository\CategoryRepository;
  14. use Aqarmap\Bundle\DiscussionBundle\Repository\CommentRepository;
  15. use Aqarmap\Bundle\DiscussionBundle\Repository\DiscussionRepository;
  16. use Aqarmap\Bundle\DiscussionBundle\Service\DiscussionManager;
  17. use Aqarmap\Bundle\DiscussionBundle\Service\WordpressManager;
  18. use Aqarmap\Bundle\ListingBundle\Entity\Location;
  19. use Aqarmap\Bundle\ListingBundle\Form\QuickLeadType;
  20. use Aqarmap\Bundle\ListingBundle\Repository\ListingRepository;
  21. use Aqarmap\Bundle\ListingBundle\Repository\LocationRepository;
  22. use Aqarmap\Bundle\ListingBundle\Repository\SectionRepository;
  23. use Aqarmap\Bundle\ListingBundle\Service\LocationManager;
  24. use Aqarmap\Bundle\ListingBundle\Service\SupplyDemandManager;
  25. use Aqarmap\Bundle\MainBundle\Form\ConfirmFormType;
  26. use Aqarmap\Bundle\NotificationBundle\DatabaseNotification;
  27. use Aqarmap\Bundle\UserBundle\Entity\User;
  28. use Aqarmap\Bundle\UserBundle\Form\QuickRegistrationFormType;
  29. use Aqarmap\Bundle\UserBundle\Repository\UserInterestRepository;
  30. use Aqarmap\Bundle\UserBundle\Services\UserInterestManager;
  31. use Aqarmap\Bundle\UserBundle\Services\UserManager;
  32. use Doctrine\ORM\EntityManagerInterface;
  33. use Knp\Component\Pager\PaginatorInterface;
  34. use Predis\Client;
  35. use Psr\Log\LoggerInterface;
  36. use Psr\Log\LogLevel;
  37. use Symfony\Bundle\FrameworkBundle\Controller\AbstractController;
  38. use Symfony\Component\DependencyInjection\ParameterBag\ParameterBagInterface;
  39. use Symfony\Component\Form\FormInterface;
  40. use Symfony\Component\HttpFoundation\RedirectResponse;
  41. use Symfony\Component\HttpFoundation\Request;
  42. use Symfony\Component\HttpFoundation\Response;
  43. use Symfony\Component\HttpFoundation\Session\SessionInterface;
  44. use Symfony\Component\Routing\Attribute\Route;
  45. use Symfony\Component\Security\Csrf\TokenStorage\TokenStorageInterface;
  46. use Symfony\Contracts\EventDispatcher\EventDispatcherInterface;
  47. use Symfony\Contracts\Translation\TranslatorInterface;
  49. /**
  50. * Discussion controller.
  51. */
  52. class DiscussionController extends AbstractController
  53. {
  54. public function __construct(
  55. private readonly DiscussionManager $discussionManager,
  56. private readonly WordpressManager $wordpressManager,
  57. private readonly UserInterestRepository $userInterestRepository,
  58. private readonly UserInterestManager $userInterestManager,
  59. private readonly EntityManagerInterface $em,
  60. Client $redisClient,
  61. private readonly LocationRepository $locationRepository,
  62. private readonly DiscussionRepository $discussionRepository,
  63. private readonly ListingRepository $listingRepository,
  64. private readonly SectionRepository $sectionRepository,
  65. private readonly CategoryRepository $categoryRepository,
  66. TokenStorageInterface $tokenStorage,
  67. private readonly SupplyDemandManager $supplyDemandManager,
  68. private readonly ParameterBagInterface $parameterBag,
  69. private readonly TranslatorInterface $translator,
  70. private readonly PaginatorInterface $paginator,
  71. private readonly UserManager $userManager,
  72. private readonly CommentRepository $commentRepository,
  73. EventDispatcherInterface $eventDispatcher,
  74. LoggerInterface $logger,
  75. private readonly \Doctrine\Persistence\ManagerRegistry $managerRegistry,
  76. ) {
  77. }
  79. /**
  80. * Lists all Discussion entities.
  81. */
  82. #[Route(path: 'ask-neighbors/', name: 'neighborhood_discussion_list', methods: ['GET'])]
  83. #[Route(path: 'discussion/', name: 'discussion_list', methods: ['GET'])]
  84. #[Route(path: 'question/', name: 'neighborhood_question_discussion_list', methods: ['GET'])]
  85. public function discussions(Request $request, LocationManager $locationManager)
  86. {
  87. $response = $this->removePageQuery($request);
  88. if ($response instanceof RedirectResponse) {
  89. return $response;
  90. }
  92. if ('discussion_list' == $request->get('_route')) {
  93. return $this->redirectToRoute('neighborhood_discussion_list', $request->query->all(), Response::HTTP_MOVED_PERMANENTLY);
  94. }
  96. $this->managerRegistry->getManager();
  97. $user = $this->getUser();
  99. $userInterests = [];
  100. if ($user instanceof User) {
  101. $userInterests = $this->userInterestRepository->getUserInterests($user, 4)->getQuery()->getResult();
  102. }
  103. $userInterests = !empty($userInterests) ? $userInterests : [$this->userInterestManager->getListingsMayBeInterested()];
  104. $interestsListings = $this->discussionManager->getInterestsListings($userInterests);
  106. $location = $request->query->get('location') ? $this->locationRepository->find($request->query->get('location')) : null;
  108. $discussion = new Discussion();
  109. $discussionForm = $form = $this->createForm(DiscussionType::class, $discussion, [
  110. 'action' => $this->generateUrl('neighborhood_discussion_create'),
  111. 'method' => 'POST',
  112. 'flatLocations' => [],
  113. 'selectedLocation' => $location ? [$location->getTitle() => $location->getId()] : [],
  114. 'selectedLocationId' => $location ? $location->getId() : null,
  115. ]);
  116. $discussionSearchForm = $form = $this->createForm(DiscussionSearchType::class, $discussion, [
  117. 'action' => $this->generateUrl('neighborhood_discussion_list'),
  118. 'method' => 'GET',
  119. 'flatLocations' => serialize($locationManager->getFlatByMaxLevel(2)),
  120. 'selectedLocation' => $location ? [$location->getTitle() => $location->getId()] : [],
  121. 'selectedLocationId' => $location ? $location->getId() : null,
  122. ]);
  123. $locationChildren = [];
  124. if ($location) {
  125. $locationChildren = $this->supplyDemandManager->getLocationChildren($location);
  126. }
  127. $criteria = [
  128. 'status' => DiscussionStatus::APPROVED,
  129. 'location' => $locationChildren,
  130. 'category' => $request->query->get('category'),
  131. 'tab' => $request->query->get('tab', DiscussionSearchTabs::TRENDING),
  132. 'sort' => 'commentsCounter',
  133. ];
  135. $discussions = $this->discussionRepository->filter($criteria);
  137. if (
  138. $request->query->get('submitted')
  139. && DiscussionSearchTabs::TRENDING == $request->query->get('tab')
  140. && empty($discussions)
  141. ) {
  142. $criteria = $request->query->all();
  143. $criteria['tab'] = DiscussionSearchTabs::ALLQUESTIONS;
  145. return $this->redirectToRoute('neighborhood_discussion_list', $criteria);
  146. }
  148. $discussions = $this->paginator->paginate(
  149. $discussions,
  150. $request->query->getInt('page', 1),
  151. 10
  152. );
  154. $latestLocationListings = [];
  155. if ($location) {
  156. $latestLocationListings = $this->listingRepository->getLatestListings(4, $this->supplyDemandManager->getLocationChildren($location))->getQuery()->getResult();
  157. }
  159. return $this->render('@AqarmapDiscussionBundle/Discussion/discussions.html.twig', [
  160. 'subLinksSections' => $this->sectionRepository->getSearchableSection(),
  161. 'discussionForm' => $discussionForm,
  162. 'responsiveDiscussionForm' => $discussionForm,
  163. 'discussionSearchForm' => $discussionSearchForm,
  164. 'discussions' => $discussions,
  165. 'interestsListings' => $interestsListings,
  166. 'quick_registration_form' => $this->createForm(QuickRegistrationFormType::class, null, [
  167. 'method' => 'POST',
  168. 'action' => $this->generateUrl('aqarmap_user_quick_registration'),
  169. ]),
  170. 'location' => $location,
  171. 'latestLocationListings' => $latestLocationListings,
  172. 'popularArticles' => json_decode(
  173. $this->wordpressManager->getCachedPosts($request->getLocale()),
  174. true
  175. ),
  176. 'aqarmap_advice_link' => $this->parameterBag->get('aqarmap_advice_url'),
  177. 'form' => $this->createQuickLeadForm(),
  178. 'metaDescriptionContent' => $this->discussionManager->concatTitles($discussions->getItems()),
  179. 'selectedCategory' => $request->get('category') ?
  180. $this->categoryRepository->find($request->get('category')) : null,
  181. ]);
  182. }
  184. /**
  185. * Creates a new Discussion entity.
  186. */
  187. #[Route(path: 'question/create/', name: 'neighborhood_discussion_create', methods: ['POST'])]
  188. public function create(
  189. Request $request,
  190. LocationManager $locationManager,
  191. SessionInterface $session,
  192. ): RedirectResponse {
  193. $entity = new Discussion();
  194. $form = $this->createForm(DiscussionType::class, $entity, [
  195. 'action' => $this->generateUrl('neighborhood_discussion_create'),
  196. 'method' => 'POST',
  197. 'flatLocations' => serialize($locationManager->getLocationsArrayWithParent($request->getLocale())['searchable']) ?? serialize([]),
  198. ]);
  200. $location = null;
  201. if ($locationId = $request->request->get('location')) {
  202. $location = $this->locationRepository->find($locationId);
  203. $request->request->set('location', null);
  204. $form->get('location')->setData(null);
  205. }
  206. $form->handleRequest($request);
  207. if ($form->isValid() && $this->getUser()) {
  208. $entity->setLocation($location);
  209. $entity->setUser($this->getUser());
  210. $this->em->persist($entity);
  211. $this->em->flush();
  212. $this->discussionManager->createSubscriber($this->getUser(), $entity);
  213. $session->getFlashBag()->add(
  214. 'success',
  215. $this->translator->trans('neighborhoods.discussion.success_message')
  216. );
  217. }
  219. return $this->redirect($request->headers->get('referer') ?: $this->generateUrl('homepage'));
  220. }
  222. /**
  223. * Lists all Discussion comments.
  224. */
  225. #[Route(path: 'ask-neighbors/{discussion}/answers/', name: 'neighborhood_discussion_comments', methods: ['GET'])]
  226. #[Route(path: 'discussion/{discussion}/comments/', name: 'discussion_comments', methods: ['GET'])]
  227. #[Route(path: 'question/{discussion}/comments/', name: 'neighborhood_question_discussion_comments', methods: ['GET'])]
  228. public function discussionComments(
  229. Request $request,
  230. DatabaseNotification $databaseNotification,
  231. LoggerInterface $logger,
  232. SessionInterface $session,
  233. ?Discussion $discussion = null,
  234. ) {
  235. if ($request->get('notification')) {
  236. try {
  237. $databaseNotification->markOneAsRead($request->get('notification'));
  238. } catch (\Exception $exception) {
  239. $logger->log(LogLevel::ERROR, $exception->getMessage());
  240. }
  241. }
  243. if (!$discussion) {
  244. return $this->redirectToRoute('neighborhood_discussion_list', [], Response::HTTP_MOVED_PERMANENTLY);
  245. }
  247. if ($discussion->getDeletedAt()) {
  248. if ($discussion->getUser() != $this->getUser()) {
  249. return $this->redirectWhenDiscussionDeleted($discussion);
  250. }
  252. $session->getFlashBag()->add(
  253. 'warning',
  254. $this->translator->trans('neighborhoods.discussion.already_deleted')
  255. );
  256. } elseif (DiscussionStatus::PENDING == $discussion->getStatus()) {
  257. $session->getFlashBag()->add(
  258. 'warning',
  259. $this->translator->trans('neighborhoods.discussion.pending_approval')
  260. );
  261. }
  263. if (\in_array($request->get('_route'), [
  264. 'neighborhood_question_discussion_comments',
  265. 'discussion_comments',
  266. ])) {
  267. return $this->redirectToRoute('neighborhood_discussion_comments', array_merge(['discussion' => $discussion->getId()], $request->query->all()), Response::HTTP_MOVED_PERMANENTLY);
  268. }
  270. $comment = new Comment();
  271. $commentForm = $this->createForm(CommentType::class, $comment, [
  272. 'action' => $this->generateUrl('neighborhood_comment_create', ['discussion' => $discussion->getId()]),
  273. 'method' => 'POST',
  274. ]);
  276. $user = $this->getUser();
  278. $userInterests = [];
  279. if ($user instanceof User) {
  280. $userInterests = $this->userInterestRepository->getUserInterests($user, 4)->getQuery()->getResult();
  281. }
  282. $userInterests[] = $this->userInterestManager->getListingsMayBeInterested($discussion->getLocation());
  283. $interestsListings = $this->discussionManager->getInterestsListings($userInterests);
  285. return $this->render('@AqarmapDiscussionBundle/Discussion/discussionComments.html.twig', [
  286. 'commentForm' => $commentForm,
  287. 'discussion' => $discussion,
  288. 'discussionComments' => $this->commentRepository->getCommentsWithLikes($discussion),
  289. 'interestsListings' => $interestsListings,
  290. 'quick_registration_form' => $this->createForm(QuickRegistrationFormType::class, null, [
  291. 'method' => 'POST',
  292. 'action' => $this->generateUrl('aqarmap_user_quick_registration'),
  293. ]),
  294. 'popularArticles' => json_decode(
  295. $this->wordpressManager->getCachedPosts($request->getLocale()),
  296. true
  297. ),
  298. 'aqarmap_advice_link' => $this->parameterBag->get('aqarmap_advice_url'),
  299. ]);
  300. }
  302. /**
  303. * Add Discussion Subscribers.
  304. */
  305. #[Route(path: 'question/add/subscriber/{discussion}/', name: 'neighborhood_discussion_add_subscriber')]
  306. public function addDiscussionSubscriber(
  307. Discussion $discussion,
  308. Request $request,
  309. SessionInterface $session,
  310. ): RedirectResponse {
  311. $user = $this->getUser();
  312. $this->discussionManager->createSubscriber($user, $discussion);
  313. $session->getFlashBag()->add(
  314. 'success',
  315. $this->translator->trans('neighborhoods.discussion.subscriber_success_message')
  316. );
  318. return $this->redirect($request->headers->get('referer') ?: $this->generateUrl('homepage'));
  319. }
  321. /**
  322. * Remove Discussion Subscribers.
  323. */
  324. #[Route(path: 'question/remove/subscriber/{discussion}/', name: 'neighborhood_discussion_remove_subscriber')]
  325. public function unsetDiscussionSubscriber(
  326. Discussion $discussion,
  327. Request $request,
  328. SessionInterface $session,
  329. ): RedirectResponse {
  330. $this->discussionManager->unsetSubscriber($this->getUser(), $discussion);
  332. $session->getFlashBag()->add(
  333. 'success',
  334. $this->container->get('translator')->trans('neighborhoods.discussion.subscriber_unset_message')
  335. );
  337. return $this->redirect($request->headers->get('referer') ?: $this->generateUrl('homepage'));
  338. }
  340. /**
  341. * @return RedirectResponse
  342. *
  343. * @throws BadRequestHttpException
  344. */
  345. #[Route(path: 'question/un-subscribe/{user}/{discussion}/', name: 'neighborhood_discussion_mail_remove_subscriber')]
  346. public function unsubscribeConfirm(
  347. User $user,
  348. Discussion $discussion,
  349. Request $request,
  350. SessionInterface $session,
  351. ) {
  352. /* Valid User Md5 valid */
  353. if (md5($user->getId()).$this->parameterBag->get('secret') !== $request->query->get('token')) {
  354. throw new BadRequestHttpException('Permission Denied !');
  355. }
  357. // Create confirmation form (button)
  358. $form = $this->createForm(ConfirmFormType::class, null, [
  359. 'method' => 'POST',
  360. 'action' => $this->generateUrl(
  361. 'neighborhood_discussion_mail_remove_subscriber',
  362. ['discussion' => $discussion->getId(), 'user' => $user->getId(), 'token' => $request->query->get('token')]
  363. ),
  364. ]);
  366. $form->handleRequest($request);
  368. if ($form->isSubmitted() && $form->isValid()) {
  369. if ($form->get('confirm')->isClicked()) {
  370. $this->discussionManager->unsetSubscriber($user, $discussion);
  372. $session->getFlashBag()->add(
  373. 'success',
  374. $this->translator->trans('neighborhoods.discussion.subscriber_unset_message')
  375. );
  377. return $this->redirectToRoute('homepage');
  378. }
  379. }
  381. return $this->render('@AqarmapDiscussionBundle/Discussion/unsubscribeConfirm.html.twig', [
  382. 'form' => $form,
  383. 'discussion' => $discussion,
  384. ]);
  385. }
  387. /**
  388. * Edit Comment entity.
  389. *
  390. * @return array|RedirectResponse
  391. */
  392. #[Route(path: 'question/{discussion}/edit', name: 'neighborhood_discussion_edit')]
  393. public function edit(
  394. Request $request,
  395. Discussion $discussion,
  396. LocationManager $locationManager,
  397. SessionInterface $session,
  398. ) {
  399. $form = $this->createForm(DiscussionType::class, $discussion, [
  400. 'action' => $this->generateUrl('neighborhood_discussion_edit', [
  401. 'discussion' => $discussion->getId(),
  402. ]),
  403. 'method' => 'POST',
  404. 'flatLocations' => serialize($locationManager->getLocationsArrayWithParent($request->getLocale())['searchable']) ?? serialize([]),
  405. ]);
  406. $form->handleRequest($request);
  408. if ($form->isSubmitted() && $form->isValid()) {
  409. $em = $this->managerRegistry->getManager();
  410. $discussion->setStatus(DiscussionStatus::PENDING);
  411. $em->persist($discussion);
  412. $em->flush();
  414. $session->getFlashBag()->add(
  415. 'success',
  416. $this->translator->trans('neighborhoods.comment.edit_success_message')
  417. );
  419. return $this->redirectToRoute('neighborhood_discussion_comments', ['discussion' => $discussion->getId()]);
  420. }
  422. return $this->render('@AqarmapDiscussionBundle/Discussion/edit.html.twig', [
  423. 'form' => $form,
  424. 'discussion' => $discussion,
  425. ]);
  426. }
  428. /**
  429. * Delete Discussion.
  430. *
  431. * @return RedirectResponse|Response
  432. */
  433. #[Route(path: 'question/{discussion}/delete', name: 'discussion_delete')]
  434. public function delete(Discussion $discussion, SessionInterface $session): RedirectResponse
  435. {
  436. if (!$discussion) {
  437. throw $this->createNotFoundException('The Discussion does not exist');
  438. }
  439. $this->discussionManager->remove($discussion);
  440. $session->getFlashBag()->add(
  441. 'success',
  442. $this->translator->trans('neighborhoods.discussion.delete_success_message')
  443. );
  445. return $this->redirectToRoute('neighborhood_discussion_list');
  446. }
  448. /**
  449. * Redirect when the discssuion is deleted.
  450. *
  451. * @return RedirectResponse
  452. */
  453. public function redirectWhenDiscussionDeleted(?Discussion $discussion = null)
  454. {
  455. $criteria = [];
  456. if ($discussion) {
  457. $location = $discussion->getLocation();
  458. if ($location) {
  459. $criteria['location'] = $location->getId();
  460. }
  461. $category = $discussion->getCategory();
  462. if ($category) {
  463. $criteria['category'] = $category->getId();
  464. }
  465. }
  467. return $this->redirectToRoute('neighborhood_discussion_list', $criteria, Response::HTTP_MOVED_PERMANENTLY);
  468. }
  470. /**
  471. * Create Quick Lead Form.
  472. */
  473. private function createQuickLeadForm(): FormInterface
  474. {
  475. return $this->createForm(
  476. QuickLeadType::class,
  477. null,
  478. [
  479. 'action' => $this->generateUrl('add_quick_lead'),
  480. 'method' => 'POST',
  481. ]
  482. );
  483. }
  485. #[Route(path: 'unsubscribe-ask-neighbors/{token}/{location}', requirements: ['id' => '\d+'], name: 'aqarmap_discussion_unsubscribe', methods: ['GET'])]
  486. public function unsubscribe(Request $request, SessionInterface $session, ?Location $location = null): RedirectResponse
  487. {
  488. $user = $this->userManager->findEncryptedBy($request->get('token'));
  490. if (!$user) {
  491. throw new \Exception('User Not Found!');
  492. }
  494. $criteria = [
  495. 'user' => $user,
  496. ];
  498. if ($location) {
  499. $criteria['location'] = $location;
  500. }
  502. $this->userInterestManager->removeBy($criteria);
  504. $session->getFlashBag()->add(
  505. 'success',
  506. $this->translator
  507. ->trans($location ? 'neighborhoods.unsubscribe_from_successeded' : 'neighborhoods.unsubscribe_all_successeded', ['%location%' => $location])
  508. );
  510. return $this->redirectToRoute('homepage');
  511. }
  513. /**
  514. * Remove the page query if equals one.
  515. *
  516. * @return RedirectResponse|void
  517. */
  518. private function removePageQuery(Request $request)
  519. {
  520. if ($request->query->getInt('page') && 1 == $request->query->getInt('page')) {
  521. $request->query->remove('page');
  523. return $this->redirectToRoute($request->get('_route'), $request->query->all(), Response::HTTP_MOVED_PERMANENTLY);
  524. }
  525. }
  526. }