src/Aqarmap/Bundle/SearchBundle/Controller/Api/V4/ListingSearchController.php line 592

  1. ], $response->getStatusCode());
  2. }
  4. #[Rest\Get('/api/v4/listings', options: ['i18n' => false], name: 'aqarmap_api_get_listings')]
  5. #[Rest\Get('/api/v4/listings/search', options: ['i18n' => false], name: 'aqarmap_api_listings_search_v4')]
  6. public function getListings(Request $request, ListingRepository $listingRepository, ListingManager $listingManager, CacheInterface $cache, MessageBusInterface $messageBus)
  7. {
  8. /** @var UserInterface $user */
  9. $user = $this->getUser();
  10. $hasSearchScoringRole = $user && $user->hasRole('ROLE_SEARCH_SCORING');
  11. if (!$hasSearchScoringRole && ($request->get('esdebug') || $request->get('scoredebug'))) {
  12. $request->query->remove('esdebug');
  13. $request->query->remove('scoredebug');
  14. }
  16. if ($request->get('location')) {
  17. $request->query->set('locations', explode(',', $request->query->get('location', '')));
  18. }
  20. $cacheKey = sprintf('api_listings_search_v4_%s_%s', $request->getLocale(), md5(http_build_query($request->query->all())));
  21. $cachedSerialize = $cache->getItem($cacheKey);
  22. if (!$cachedSerialize->isHit() || empty($cachedSerialize->get())) {
  23. $listingsElasticResponse = $listingManager->getListingsElasticResponse($request);
  24. $listingsQueryBuilder = $listingRepository->getListingsByIds(array_column($listingsElasticResponse['items'], 'id'));
  26. if ('aqarmap_api_listings_search_v4' === $request->attributes->get('_route')) {
  27. $listingsElasticResponse['pagination']['totalPages'] = (float) $listingsElasticResponse['pagination']['totalPages'];
  28. }
  30. $listings = $listingsQueryBuilder->getQuery()->getResult();
  32. $data = [
  33. 'default' => $this->mapPaginatedBody($listingsElasticResponse, $listings),
  34. 'related' => [],
  35. ];
  37. $data = $this->serializer->serialize(
  38. $data,
  39. 'json',
  40. SerializationContext::create()
  41. ->setGroups('SearchV4')
  42. ->enableMaxDepthChecks()
  43. );
  45. $cachedSerialize->set($data);
  46. $cachedSerialize->expiresAfter(3600 * 3);
  47. $cache->save($cachedSerialize);
  48. }
  50. return new Response($cachedSerialize->get());
  51. }
  53. #[Rest\Get('/api/v4/listings/debug', options: ['i18n' => false], name: 'aqarmap_api_get_listings_debug')]
  54. public function getListingsEsDebug(Request $request, ListingManager $listingManager)
  55. {
  56. /** @var UserInterface $user */
  57. $user = $this->getUser();
  59. if (!($user && $user->hasRole('ROLE_SEARCH_SCORING'))) {
  60. throw new UnauthorizedHttpException();
  61. }
  63. $request->query->set('esdebug', 1);
  65. if ($request->get('location')) {
  66. $request->query->set('locations', explode(',', $request->query->get('location', '')));
  67. }
  69. $listingsDebugElasticResponse = $listingManager->getListingsDebugElasticResponse($request);
  71. if ('aqarmap_api_listings_search_v4' === $request->attributes->get('_route')) {
  72. $listingsDebugElasticResponse['pagination']['totalPages'] = (float) $listingsDebugElasticResponse['pagination']['totalPages'];
  73. }
  75. $data = [
  76. 'default' => $this->mapPaginatedBody($listingsDebugElasticResponse, $listingsDebugElasticResponse['items']),
  77. ];
  79. return new JsonResponse($data);
  80. }
  82. #[Rest\Get('/api/v4/listings/search/ssr-data', options: ['i18n' => false], name: 'aqarmap_api_get_listings_search_ssr-data')]
  83. public function getListingsSearchSSRData(Request $request, ListingManager $listingManager, CacheInterface $cache, SectionService $sectionService)
  84. {
  85. $cacheKey = sprintf('api_listings_search_ssr_data_%s_%s', $request->getLocale(), md5(http_build_query($request->query->all())));
  86. $cachedResponse = $cache->getItem($cacheKey);
  88. if (!$cachedResponse->isHit() || empty($cachedResponse->get())) {
  89. $customParagraph = $locationChildren = $slugResolver = $faqData = $locationParents = [];
  91. if ($request->get('location')) {
  92. $request->query->set('locations', explode(',', $request->query->get('location', '')));
  93. }
  95. $location = $request->get('locations') ? $request->get('locations')[0] : null;
  96. $location = $this->locationRepository->findOneBy(['slug' => $location]);
  97. $section = $this->sectionRepository->findOneBy(['slug' => $request->query->get('section')]);
  98. $propertyType = $this->propertyTypeRepository->findOneBy(['slug' => $request->query->get('propertyType')]);
  100. if ($location) {
  101. $locationChildren = $listingManager->getSerializedLocationChildren($location);
  102. $locationParents = $listingManager->getLocationParents($location, $request->getLocale());
  103. }
  105. if ($section && $propertyType && $location) {
  106. $longTail = $this->seoListingSearchService->getSerializedLongTailData($section, $propertyType, $location) ?? [];
  107. }
  109. if ($section && $propertyType) {
  110. $byOwnerOnly = filter_var($request->get('byOwnerOnly'), FILTER_VALIDATE_BOOLEAN, FILTER_NULL_ON_FAILURE) ?? false;
  111. $customParagraph = $listingManager->getSerializedCustomParagraph($section, $propertyType, $location, $byOwnerOnly) ?? [];
  112. $slugResolver = $listingManager->getSerializedResolvedSlugs($section, $propertyType, (array) $request->query->get('locations', []));
  113. $faqData = $listingManager->getFaqs($section, $propertyType, $location, $request->getLocale());
  114. }
  116. $response = [
  117. 'locationChildren' => !empty($locationChildren) ? json_decode((string) $locationChildren, true) : [],
  118. 'longTail' => !empty($longTail) ? json_decode((string) $longTail, true) : [],
  119. 'customParagraph' => !empty($customParagraph) ? json_decode((string) $customParagraph, true) : [],
  120. 'slugResolver' => !empty($slugResolver) ? json_decode((string) $slugResolver, true) : [],
  121. 'faqData' => $faqData,
  122. 'locationParents' => $locationParents,
  123. 'sections' => json_decode((string) $sectionService->getSerializedSections(), true),
  124. 'propertyTypeChips' => $listingManager->getListingPropertyTypesChips($request, $location, $section, $propertyType),
  125. ];
  127. $cachedResponse->set(json_encode($response));
  128. $cachedResponse->expiresAfter(3600 * 3);
  129. $cache->save($cachedResponse);
  130. }
  132. return new JsonResponse(json_decode((string) $cachedResponse->get(), true));
  133. }
  135. #[Rest\Get('/api/v4/listings/trigger-search', options: ['i18n' => false], name: 'aqarmap_api_trigger_search_listings_v4')]
  136. public function triggerSearchListings(Request $request, MessageBusInterface $messageBus)
  137. {
  138. $user = $this->getUser();
  140. if ($request->get('location')) {
  141. $request->query->set('locations', explode(',', $request->query->get('location', '')));
  142. }
  144. if ($request->get('keywordSearch')) {
  145. $this->eventDispatcher->dispatch(new SearchTriggerEvent($request));
  146. }
  148. if ($user) {
  149. $messageBus->dispatch(new Search($request->query, $user));
  150. }
  152. return new JsonResponse([
  153. 'statusCode' => Response::HTTP_OK,
  154. 'statusMessage' => 'Search triggered successfully!',
  155. ]);
  156. }
  158. private function mapPaginatedBody(array $result, array $listings): array
  159. {
  160. if (!$result['pagination']) {
  161. return [
  162. 'statusCode' => $this->getStatusCode(),
  163. 'statusMessage' => $this->getStatusMessage(),
  164. 'paginate' => [],
  165. 'data' => [],
  166. 'errors' => $this->getErrors(),
  167. ];
  168. }
  170. return [
  171. 'statusCode' => $this->getStatusCode(),
  172. 'statusMessage' => $this->getStatusMessage(),
  173. 'paginate' => $result['pagination'],
  174. 'data' => $listings,
  175. 'errors' => $this->getErrors(),
  176. ];
  177. }
  178. }