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

  1. use Aqarmap\Bundle\ListingBundle\Service\ListingManager;
  2. use Aqarmap\Bundle\ListingBundle\Service\RelatedResultService;
  3. use Aqarmap\Bundle\ListingBundle\Service\SectionService;
  4. use Aqarmap\Bundle\MainBundle\Controller\Api\V4\BaseController;
  5. use Aqarmap\Bundle\MainBundle\Model\Listing\V4\ListingDataMapper;
  6. use Aqarmap\Bundle\MainBundle\Repository\CustomParagraphRepository;
  7. use Aqarmap\Bundle\SearchBundle\CriteriaBuilders\BuilderDirector;
  8. use Aqarmap\Bundle\SearchBundle\CriteriaMediator\Contracts\MediatorInterface;
  9. use Aqarmap\Bundle\SearchBundle\Services\ListingFaqService;
  10. use Aqarmap\Bundle\SearchBundle\Services\SEOListingSearchService;
  11. use Aqarmap\Bundle\UserBundle\Entity\User;
  12. use FOS\RestBundle\Controller\Annotations as Rest;
  13. use FOS\UserBundle\Model\UserInterface;
  14. use JMS\Serializer\SerializationContext;
  15. use JMS\Serializer\SerializerInterface;
  16. use OpenApi\Attributes as OA;
  17. use Symfony\Component\EventDispatcher\EventDispatcherInterface;
  18. use Symfony\Component\HttpFoundation\JsonResponse;
  19. use Symfony\Component\HttpFoundation\Request;
  20. use Symfony\Component\HttpFoundation\Response;
  21. use Symfony\Component\HttpKernel\Attribute\Cache;
  22. use Symfony\Component\HttpKernel\Exception\AccessDeniedHttpException;
  23. use Symfony\Component\Messenger\MessageBusInterface;
  24. use Symfony\Contracts\Cache\CacheInterface;
  25. use Symfony\Contracts\Cache\ItemInterface;
  26. use Symfony\Contracts\HttpClient\HttpClientInterface;
  28. class ListingSearchController extends BaseController
  29. {
  30. public function __construct(private readonly BuilderDirector $builderDirector, private readonly MediatorInterface $mediator, private readonly EventDispatcherInterface $eventDispatcher, private readonly SerializerInterface $serializer, RelatedResultService $relatedResultService, private readonly LocationRepository $locationRepository, CustomParagraphRepository $customParagraphRepository, private readonly SEOListingSearchService $seoListingSearchService, private readonly SectionRepository $sectionRepository, private readonly PropertyTypeRepository $propertyTypeRepository, ListingFaqService $listingFaqService, private readonly MessageBusInterface $messageBus)
  31. {
  32. }
  34. /**
  35. * Listings Search V4 ( Legacy code ).
  36. */
  37. #[Rest\Get('/api/v4/listings/search-legacy', name: 'legacy_aqarmap_api_listings_search_v4', options: ['i18n' => false])]
  38. #[Rest\QueryParam(name: 'propertyType', requirements: '\d+', default: null, description: 'Property Type ID')]
  39. #[Rest\QueryParam(name: 'location', requirements: '\d+', default: null, description: 'Location ID comma spereted')]
  40. #[Rest\QueryParam(name: 'section', requirements: '\d+', default: null, description: 'Section ID')]
  41. #[Rest\QueryParam(name: 'bounds', requirements: 'South-West Latitude ,
  42. Longitude , North-East Latitude , Longitude')] // default=null,
  43. #[Rest\QueryParam(name: 'minPrice', requirements: '\d+', default: null, description: 'Minimum Prices')]
  44. #[Rest\QueryParam(name: 'maxPrice', requirements: '\d+', default: null, description: 'Maximum Prices')]
  45. #[Rest\QueryParam(name: 'minArea', requirements: '\d+', default: null, description: 'Minimum Area')]
  46. #[Rest\QueryParam(name: 'maxArea', requirements: '\d+', default: null, description: 'Maximum Area')]
  47. #[Rest\QueryParam(name: 'minFloor', requirements: '\d+', default: null, description: 'Minimum Floor')]
  48. #[Rest\QueryParam(name: 'minRoom', requirements: '\d+', default: null, description: 'Minimum Room')]
  49. #[Rest\QueryParam(name: 'floor', requirements: '\d+', default: null, description: 'Floor Number')]
  50. #[Rest\QueryParam(name: 'room', requirements: '\d+', default: null, description: 'Number of Rooms')]
  51. #[Rest\QueryParam(name: 'baths', requirements: '\d+', default: null, description: 'Number of Baths')]
  52. #[Rest\QueryParam(name: 'finishType', default: null, description: 'finish Type')]
  53. #[Rest\QueryParam(name: 'sellerRole', requirements: '\d+', default: null, description: 'sellerRole')]
  54. #[Rest\QueryParam(name: 'paymentMethod', requirements: '\d+', default: null, description: 'paymentMethod')]
  55. #[Rest\QueryParam(name: 'deliveryYear', requirements: '\d+', default: null, description: 'deliveryYear')]
  56. #[Rest\QueryParam(name: 'bath', default: null, description: 'Number of Baths')]
  57. #[Rest\QueryParam(name: 'photos', requirements: '(1)|(0)', default: '0', description: 'Get only listings with photos', strict: true, nullable: true)]
  58. #[Rest\QueryParam(name: 'isMortgage', requirements: '(1)|(0)', default: '0', description: 'Get only listings that support mortgage', strict: true, nullable: true)]
  59. #[Rest\QueryParam(name: 'eligibleForMortgage', description: 'Get listings that has mortgage Percentage', strict: true, nullable: true)]
  60. #[Rest\QueryParam(name: 'page', requirements: '\d+', default: 1, description: 'Page number, starting from 1.', nullable: true)]
  61. #[Rest\QueryParam(name: 'limit', requirements: '\d+', default: 10, description: 'Number of items per page.', nullable: true)]
  62. #[Rest\QueryParam(name: 'sort', requirements: 'price|area', default: null, description: 'Sort search results by price or area.', nullable: true)]
  63. #[Rest\QueryParam(name: 'direction', requirements: 'asc|desc', default: 'asc', description: 'Ascending (A to Z, 0 to 9), Descending (Z to A, 9 to 0)', nullable: true)]
  64. #[Rest\QueryParam(name: 'keywordSearch', description: "Search by keyword in listing's title, description and address")]
  65. #[Rest\QueryParam(name: 'unitOnly', requirements: '(1)|(0)', description: 'Get compound units only', nullable: true)]
  66. #[Rest\View]
  67. #[Cache(expires: '+2 hours', maxage: '+2 hours', smaxage: '+2 hours', public: true, vary: ['Accept-Language', 'X-Accept-Version', 'Accept'])]
  68. #[OA\Parameter(name: 'propertyType', description: 'Property Type ID', in: 'query', required: false)]
  69. #[OA\Parameter(name: 'location', description: 'Location ID comma spereted', in: 'query', required: false)]
  70. #[OA\Parameter(name: 'section', description: 'Section ID', in: 'query', required: false)]
  71. #[OA\Parameter(name: 'bounds', description: 'Map bounds (example: 24.6275450,46.6363017,24.6977461,46.817232)', in: 'query', required: false)]
  72. #[OA\Parameter(name: 'minPrice', description: 'Minimum Prices', in: 'query', required: false)]
  73. #[OA\Parameter(name: 'maxPrice', description: 'Maximum Prices', in: 'query', required: false)]
  74. #[OA\Parameter(name: 'minArea', description: 'Minimum Area', in: 'query', required: false)]
  75. #[OA\Parameter(name: 'maxArea', description: 'Maximum Area', in: 'query', required: false)]
  76. #[OA\Parameter(name: 'minFloor', description: 'Minimum Floor', in: 'query', required: false)]
  77. #[OA\Parameter(name: 'minRoom', description: 'Minimum Room', in: 'query', required: false)]
  78. #[OA\Parameter(name: 'floor', description: 'Floor Number', in: 'query', required: false)]
  79. #[OA\Parameter(name: 'room', description: 'Number of Rooms', in: 'query', required: false)]
  80. #[OA\Parameter(name: 'baths', description: 'Number of Baths', in: 'query', required: false)]
  81. #[OA\Parameter(name: 'finishType', description: 'finish Type', in: 'query', required: false)]
  82. #[OA\Parameter(name: 'sellerRole', description: 'sellerRole', in: 'query', required: false)]
  83. #[OA\Parameter(name: 'paymentMethod', description: 'paymentMethod', in: 'query', required: false)]
  84. #[OA\Parameter(name: 'deliveryYear', description: 'deliveryYear', in: 'query', required: false)]
  85. #[OA\Parameter(name: 'bath', description: 'Number of Baths', in: 'query', required: false)]
  86. #[OA\Parameter(name: 'photos', description: 'Get only listings with photos', in: 'query', required: false)]
  87. #[OA\Parameter(name: 'isMortgage', description: 'Get only listings that support mortgage', in: 'query', required: false)]
  88. #[OA\Parameter(name: 'eligibleForMortgage', description: 'Get listings that has mortgage Percentage', in: 'query', required: false)]
  89. #[OA\Parameter(name: 'page', description: 'Page number, starting from 1.', in: 'query', required: false)]
  90. #[OA\Parameter(name: 'limit', description: 'Number of items per page.', in: 'query', required: false)]
  91. #[OA\Parameter(name: 'sort', description: 'Sort search results by price or area.', in: 'query', required: false)]
  92. #[OA\Parameter(name: 'direction', description: 'Ascending (A to Z, 0 to 9), Descending (Z to A, 9 to 0)', in: 'query', required: false)]
  93. #[OA\Parameter(name: 'keywordSearch', description: "Search by keyword in listing's title, description and address", in: 'query', required: false)]
  94. #[OA\Parameter(name: 'unitOnly', description: 'Get compound units only', in: 'query', required: false)]
  95. #[OA\Response(response: 500, description: 'Returned when something went wrong, for example if you entered non existing propertyType ID')]
  96. public function getSearchListings(Request $request, CacheInterface $cache): Response
  97. {
  98. $criteria = $this->builderDirector->build($request)->getResult();
  99. $locations = explode(',', $request->query->get('location', ''));
  100. $request->query->set('locations', $locations);
  102. if (!empty($criteria['keywordSearch'])) {
  103. $this->eventDispatcher->dispatch(new SearchTriggerEvent($request));
  104. }
  106. if ($this->getUser() instanceof User) {
  107. $this->messageBus->dispatch(new Search($request->query, $this->getUser()));
  108. }
  110. $criteria['status'] = ListingStatus::LIVE;
  111. $cacheKey = sprintf('api_v4_listings_search_%s_%s', $request->getLocale(), md5(http_build_query($request->query->all())));
  113. $cachedSerialize = $cache->getItem($cacheKey);
  114. if (!$cachedSerialize->isHit() || empty($cachedSerialize->get())) {
  115. $result = $this->mediator->start($criteria)->getResults();
  116. $mapped = new ListingDataMapper();
  117. $mapped->setMapListingAttributes(true);
  118. $mapped->setMapListingMainPhoto(true);
  119. $mapped->setMapListingPhotos(true);
  121. $data = [
  122. 'default' => $this->makeMappedPaginatedBody($result['searchResults'], $mapped),
  123. 'related' => [],
  124. ];
  126. $data = $this->serializer->serialize(
  127. $data,
  128. 'json',
  129. SerializationContext::create()
  130. ->setGroups('SearchV4')
  131. ->enableMaxDepthChecks()
  132. );
  134. $cachedSerialize->set($data);
  135. $cachedSerialize->expiresAfter(3600 * 3);
  136. $cache->save($cachedSerialize);
  137. }
  139. return new Response($cachedSerialize->get());
  140. }
  142. /**
  143. * Related Listings Search V4.
  144. */
  145. #[Rest\Get('/api/v4/listings/search/related', name: 'aqarmap_api_get_related_results_v4', options: ['i18n' => false])]
  146. #[Rest\QueryParam(name: 'propertyType', requirements: '\d+', default: null, description: 'Property Type ID')]
  147. #[Rest\QueryParam(name: 'location', requirements: '\d+', default: null, description: 'Location ID comma spereted')]
  148. #[Rest\QueryParam(name: 'section', requirements: '\d+', default: null, description: 'Section ID')]
  149. #[Rest\QueryParam(name: 'page', requirements: '\d+', default: 1, description: 'Page number, starting from 1.', nullable: true)]
  150. #[Rest\QueryParam(name: 'limit', requirements: '\d+', default: 10, description: 'Number of items per page.', nullable: true)]
  151. #[Rest\QueryParam(name: 'sort', requirements: 'price|area', default: null, description: 'Sort search results by price or area.', nullable: true)]
  152. #[Rest\QueryParam(name: 'direction', requirements: 'asc|desc', default: 'asc', description: 'Ascending (A to Z, 0 to 9), Descending (Z to A, 9 to 0)', nullable: true)]
  153. #[Rest\View(serializerGroups: ['DefaultV4', 'SearchV4'])]
  154. #[OA\Parameter(name: 'propertyType', description: 'Property Type ID', in: 'query', required: false)]
  155. #[OA\Parameter(name: 'location', description: 'Location ID comma seperated', in: 'query', required: false)]
  156. #[OA\Parameter(name: 'section', description: 'Section ID', in: 'query', required: false)]
  157. #[OA\Parameter(name: 'page', description: 'Page number, starting from 1.', in: 'query', required: false)]
  158. #[OA\Parameter(name: 'limit', description: 'Number of items per page.', in: 'query', required: false)]
  159. #[OA\Parameter(name: 'sort', description: 'Sort search results by price or area.', in: 'query', required: false)]
  160. #[OA\Parameter(name: 'direction', description: 'Ascending (A to Z, 0 to 9), Descending (Z to A, 9 to 0)', in: 'query', required: false)]
  161. #[OA\Response(response: 500, description: 'Returned when something went wrong, for example if you entered non existing propertyType ID')]
  162. public function getRelatedSearchListings(Request $request, HttpClientInterface $searchClient, SerializerInterface $jmsSerializer, ListingRepository $listingRepository): JsonResponse
  163. {
  164. $response = $searchClient->request('GET', '/api/listing/nearest', [
  165. 'query' => $request->query->all(),
  166. 'headers' => [
  167. 'Accept-Language' => $request->getPreferredLanguage(),
  168. ],
  169. ]);
  171. if (200 === $response->getStatusCode()) {
  172. $data = $response->toArray();
  174. if (isset($data['data']) && is_array($data['data'])) {
  175. foreach ($data['data'] as &$item) {
  176. if (isset($item['listings']) && is_array($item['listings'])) {
  177. $listings = $listingRepository->getListingsByIds(array_column($item['listings'], 'id'))->getQuery()->getResult();
  178. $context = SerializationContext::create()
  179. ->setGroups(['DefaultV4', 'SearchV4']);
  181. $item['listings'] = json_decode(
  182. $jmsSerializer->serialize($listings, 'json', $context),
  183. true
  184. );
  185. }
  186. }
  187. }
  189. return $this->json($data);
  190. }
  192. return $this->json([
  193. 'error' => 'Failed to fetch nearest search listings',
  194. ], $response->getStatusCode());
  195. }
  197. #[Rest\Get('/api/v4/listings', name: 'aqarmap_api_get_listings', options: ['i18n' => false])]
  198. #[Rest\Get('/api/v4/listings/search', name: 'aqarmap_api_listings_search_v4', options: ['i18n' => false])]
  199. #[Rest\QueryParam(name: 'personalizedSearch', requirements: '(1)|(0)', default: '0', description: 'Enable personalized search', strict: true, nullable: true)]
  200. #[OA\Parameter(name: 'personalizedSearch', description: 'Enable personalized search (requires active subscription)', in: 'query', required: false)]
  201. #[Rest\QueryParam(name: 'amenities', description: 'A list of amenities to filter by.', map: true, nullable: true)]
  202. #[OA\Parameter(name: 'amenities', description: 'Filter by a list of amenities. Can be provided as an array.', in: 'query', required: false, schema: new OA\Schema(type: 'array', items: new OA\Items(type: 'string', enum: Amenities::ALL)))]
  203. #[Rest\QueryParam(name: 'downPayment', requirements: '\d+', default: null, description: 'Filter by maximum down payment amount', nullable: true)]
  204. #[OA\Parameter(name: 'downPayment', description: 'Filter by maximum down payment amount', in: 'query', required: false)]
  205. #[Rest\QueryParam(name: 'duration', requirements: '\d+', default: null, description: 'Filter by minimum installment duration (in days)', nullable: true)]
  206. #[OA\Parameter(name: 'duration', description: 'Filter by minimum installment duration (in days)', in: 'query', required: false)]
  207. public function getListings(Request $request, ListingRepository $listingRepository, ListingManager $listingManager, CacheInterface $cache, MessageBusInterface $messageBus)
  208. {
  209. // This to prevent the "result window is too large" exception in ElasticSearch.
  210. if ($request->get('page', 1) > 500) {
  211. throw new BadRequestHttpException('Page number must be less than or equal to 500');
  212. }
  214. /** @var UserInterface $user */
  215. $user = $this->getUser();
  216. $hasSearchScoringRole = $user && $user->hasRole('ROLE_SEARCH_SCORING');
  217. if (!$hasSearchScoringRole && ($request->get('esdebug') || $request->get('scoredebug'))) {
  218. $request->query->remove('esdebug');
  219. $request->query->remove('scoredebug');
  220. }
  222. if ($request->get('location')) {
  223. $request->query->set('locations', explode(',', $request->query->get('location', '')));
  224. }
  226. $personalizedSearch = $request->query->getBoolean('personalizedSearch', false);
  227. if ($personalizedSearch) {
  228. if (!$user instanceof User) {
  229. throw new UnauthorizedHttpException('Personalized search requires an active session. Please log in.');
  230. }
  232. if (!$user->hasSubscriptionPlan()) {
  233. throw new AccessDeniedHttpException('Active subscription required for personalized search.');
  234. }
  236. $request->query->set('personalizedSearch', true);
  237. $request->query->set('personalizedForUser', $user->getId());
  238. }
  240. if ($personalizedSearch) {
  241. $data = $this->getSerializedListingSearchResults($request, $listingRepository, $listingManager);
  242. } else {
  243. $cacheKey = sprintf('api_listings_search_v4_%s_%s', $request->getLocale(), md5(http_build_query($request->query->all())));
  244. $data = $cache->get(
  245. $cacheKey,
  246. function(ItemInterface $item) use ($request, $listingRepository, $listingManager) {
  247. $item->expiresAfter(3600 * 3);
  249. return $this->getSerializedListingSearchResults($request, $listingRepository, $listingManager);
  250. }
  251. );
  252. }
  254. return new Response($data);
  255. }
  257. private function getSerializedListingSearchResults(Request $request, ListingRepository $listingRepository, ListingManager $listingManager): string
  258. {
  259. $listingsElasticResponse = $listingManager->getListingsElasticResponse($request);
  260. $listingsQueryBuilder = $listingRepository->getListingsByIds(array_column($listingsElasticResponse['items'], 'id'));
  262. if ('aqarmap_api_listings_search_v4' === $request->attributes->get('_route')) {
  263. $listingsElasticResponse['pagination']['totalPages'] = (float) $listingsElasticResponse['pagination']['totalPages'];
  264. }
  266. $listings = $listingsQueryBuilder->getQuery()->getResult();
  268. $data = [
  269. 'default' => $this->mapPaginatedBody($listingsElasticResponse, $listings),
  270. 'related' => [],
  271. ];
  273. return $this->serializer->serialize(
  274. $data,
  275. 'json',
  276. SerializationContext::create()
  277. ->setGroups('SearchV4')
  278. ->enableMaxDepthChecks()
  279. );
  280. }
  282. #[Rest\Get('/api/v4/listings/debug', options: ['i18n' => false], name: 'aqarmap_api_get_listings_debug')]
  283. public function getListingsEsDebug(Request $request, ListingManager $listingManager)
  284. {
  285. /** @var UserInterface $user */
  286. $user = $this->getUser();
  288. if (!($user && $user->hasRole('ROLE_SEARCH_SCORING'))) {
  289. throw new UnauthorizedHttpException();
  290. }
  292. $request->query->set('esdebug', 1);
  294. if ($request->get('location')) {
  295. $request->query->set('locations', explode(',', $request->query->get('location', '')));
  296. }
  298. $listingsDebugElasticResponse = $listingManager->getListingsDebugElasticResponse($request);
  300. if ('aqarmap_api_listings_search_v4' === $request->attributes->get('_route')) {
  301. $listingsDebugElasticResponse['pagination']['totalPages'] = (float) $listingsDebugElasticResponse['pagination']['totalPages'];
  302. }
  304. $data = [
  305. 'default' => $this->mapPaginatedBody($listingsDebugElasticResponse, $listingsDebugElasticResponse['items']),
  306. ];
  308. return new JsonResponse($data);
  309. }
  311. #[Rest\Get('/api/v4/listings/search/ssr-data', name: 'aqarmap_api_get_listings_search_ssr-data', options: ['i18n' => false])]
  312. #[OA\Get(
  313. summary: 'Get listing search SSR data',
  314. description: 'Provides the pre-rendered content required for the listing search SSR page such as location hierarchy, SEO metadata and UI chips.',
  315. tags: ['Listings', 'Search']
  316. )]
  317. #[OA\Parameter(name: 'location', in: 'query', required: false, description: 'Slug of the primary location to load contextual data for.', schema: new OA\Schema(type: 'string'))]
  318. #[OA\Parameter(
  319. name: 'locations[]',
  320. in: 'query',
  321. required: false,
  322. description: 'Optional list of location slugs used to resolve additional data.',
  323. schema: new OA\Schema(type: 'array', items: new OA\Items(type: 'string'))
  324. )]
  325. #[OA\Parameter(name: 'section', in: 'query', required: false, description: 'Section slug to scope the returned data.', schema: new OA\Schema(type: 'string'))]
  326. #[OA\Parameter(name: 'propertyType', in: 'query', required: false, description: 'Property type slug to scope the returned data.', schema: new OA\Schema(type: 'string'))]
  327. #[OA\Parameter(name: 'byOwnerOnly', in: 'query', required: false, description: 'Whether to limit content to owner only listings.', schema: new OA\Schema(type: 'boolean'))]
  328. #[OA\Response(
  329. response: 200,
  330. description: 'Successful response containing SSR data required by the listing search page.',
  331. content: new OA\JsonContent(
  332. type: 'object',
  333. properties: [
  334. new OA\Property(
  335. property: 'locationChildren',
  336. description: 'Hierarchy of child locations related to the requested location.',
  337. type: 'array',
  338. items: new OA\Items(type: 'object')
  339. ),
  340. new OA\Property(
  341. property: 'longTail',
  342. description: 'SEO long-tail content blocks generated for the section, property type and location.',
  343. type: 'array',
  344. items: new OA\Items(type: 'object')
  345. ),
  346. new OA\Property(
  347. property: 'customParagraph',
  348. description: 'Custom paragraph content tailored to the current search context.',
  349. type: 'array',
  350. items: new OA\Items(type: 'object')
  351. ),
  352. new OA\Property(
  353. property: 'slugResolver',
  354. description: 'Resolved slugs mapping for the provided filters.',
  355. type: 'array',
  356. items: new OA\Items(type: 'object')
  357. ),
  358. new OA\Property(
  359. property: 'faqData',
  360. description: 'Frequently asked questions related to the current search.',
  361. type: 'array',
  362. items: new OA\Items(type: 'object')
  363. ),
  364. new OA\Property(
  365. property: 'locationParents',
  366. description: 'Ordered list of parent locations for breadcrumb generation.',
  367. type: 'array',
  368. items: new OA\Items(type: 'object')
  369. ),
  370. new OA\Property(
  371. property: 'sections',
  372. description: 'Available sections that can be displayed in the SSR page.',
  373. type: 'array',
  374. items: new OA\Items(type: 'object')
  375. ),
  376. new OA\Property(
  377. property: 'propertyTypeChips',
  378. description: 'Property type chips rendered in the search interface.',
  379. type: 'array',
  380. items: new OA\Items(type: 'object')
  381. ),
  382. ]
  383. )
  384. )]
  385. #[OA\Response(response: 500, description: 'Returned when SSR data could not be generated or cached.')]
  386. public function getListingsSearchSSRData(Request $request, ListingManager $listingManager, CacheInterface $cache, SectionService $sectionService)
  387. {
  388. $cacheKey = sprintf('api_listings_search_ssr_data_%s_%s', $request->getLocale(), md5(http_build_query($request->query->all())));
  389. $cachedResponse = $cache->getItem($cacheKey);
  391. if (!$cachedResponse->isHit() || empty($cachedResponse->get())) {
  392. $customParagraph = $locationChildren = $slugResolver = $faqData = $locationParents = [];
  394. if ($request->get('location')) {
  395. $request->query->set('locations', explode(',', $request->query->get('location', '')));
  396. }
  398. $location = $request->query->all('locations') ? $request->query->all('locations')[0] : null;
  399. $location = $this->locationRepository->findOneBy(['slug' => $location]);
  400. $section = $this->sectionRepository->findOneBy(['slug' => $request->query->get('section')]);
  401. $propertyType = $this->propertyTypeRepository->findOneBy(['slug' => $request->query->get('propertyType')]);
  403. if ($location) {
  404. $locationChildren = $listingManager->getSerializedLocationChildren($location);
  405. $locationParents = $listingManager->getLocationParents($location, $request->getLocale());
  406. }
  408. if ($section && $propertyType && $location) {
  409. $longTail = $this->seoListingSearchService->getSerializedLongTailData($section, $propertyType, $location) ?? [];
  410. }
  412. if ($section && $propertyType) {
  413. $byOwnerOnly = filter_var($request->get('byOwnerOnly'), FILTER_VALIDATE_BOOLEAN, FILTER_NULL_ON_FAILURE) ?? false;
  414. $customParagraph = $listingManager->getSerializedCustomParagraph($section, $propertyType, $location, $byOwnerOnly) ?? [];
  415. $slugResolver = $listingManager->getSerializedResolvedSlugs($section, $propertyType, $request->query->all('locations'));
  416. $faqData = $listingManager->getFaqs($section, $propertyType, $location, $request->getLocale());
  417. }
  419. $response = [
  420. 'locationChildren' => !empty($locationChildren) ? json_decode((string) $locationChildren, true) : [],
  421. 'longTail' => !empty($longTail) ? json_decode((string) $longTail, true) : [],
  422. 'customParagraph' => !empty($customParagraph) ? json_decode((string) $customParagraph, true) : [],
  423. 'slugResolver' => !empty($slugResolver) ? json_decode((string) $slugResolver, true) : [],
  424. 'faqData' => $faqData,
  425. 'locationParents' => $locationParents,
  426. 'sections' => json_decode((string) $sectionService->getSerializedSections(), true),
  427. 'propertyTypeChips' => $listingManager->getListingPropertyTypesChips($request, $location, $section, $propertyType),
  428. ];
  430. $cachedResponse->set(json_encode($response));
  431. $cachedResponse->expiresAfter(3600 * 3);
  432. $cache->save($cachedResponse);
  433. }
  435. return new JsonResponse(json_decode((string) $cachedResponse->get(), true));
  436. }
  438. #[Rest\Get('/api/v4/listings/trigger-search', options: ['i18n' => false], name: 'aqarmap_api_trigger_search_listings_v4')]
  439. public function triggerSearchListings(Request $request, MessageBusInterface $messageBus)
  440. {
  441. $user = $this->getUser();
  443. if ($request->get('location')) {
  444. $request->query->set('locations', explode(',', $request->query->get('location', '')));
  445. }
  447. if ($request->get('keywordSearch')) {
  448. $this->eventDispatcher->dispatch(new SearchTriggerEvent($request));
  449. }
  451. if ($user) {
  452. $messageBus->dispatch(new Search($request->query, $user));
  453. }
  455. return new JsonResponse([
  456. 'statusCode' => Response::HTTP_OK,
  457. 'statusMessage' => 'Search triggered successfully!',
  458. ]);
  459. }
  461. private function mapPaginatedBody(array $result, array $listings): array
  462. {
  463. if (!$result['pagination']) {
  464. return [
  465. 'statusCode' => $this->getStatusCode(),
  466. 'statusMessage' => $this->getStatusMessage(),
  467. 'paginate' => [],
  468. 'data' => [],
  469. 'errors' => $this->getErrors(),
  470. ];
  471. }
  473. return [
  474. 'statusCode' => $this->getStatusCode(),
  475. 'statusMessage' => $this->getStatusMessage(),
  476. 'paginate' => $result['pagination'],
  477. 'data' => $listings,
  478. 'errors' => $this->getErrors(),
  479. ];
  480. }
  481. }