src/Aqarmap/Bundle/ListingBundle/Service/InteractionService.php line 138

  1. <?php
  3. namespace Aqarmap\Bundle\ListingBundle\Service;
  5. use App\Message\Listing\ListingViewsCounterUpdatedMessage;
  6. use Aqarmap\Bundle\ListingBundle\Constant\InteractionTypes;
  7. use Aqarmap\Bundle\ListingBundle\Entity\Interaction;
  8. use Aqarmap\Bundle\ListingBundle\Entity\Listing;
  9. use Aqarmap\Bundle\ListingBundle\Repository\InteractionRepository;
  10. use Aqarmap\Bundle\MainBundle\Contract\ProducerFactoryInterface;
  11. use Aqarmap\Bundle\MainBundle\Service\MobileDetectionService;
  12. use Aqarmap\Bundle\UserBundle\Entity\User;
  13. use Aqarmap\Bundle\UserBundle\Services\UserInterestManager;
  14. use Aqarmap\Bundle\UserBundle\Services\UserManager;
  15. use Doctrine\ORM\EntityManagerInterface;
  16. use Symfony\Component\EventDispatcher\EventDispatcherInterface;
  17. use Symfony\Component\HttpFoundation\Cookie;
  18. use Symfony\Component\HttpFoundation\RequestStack;
  19. use Symfony\Component\HttpFoundation\Response;
  20. use Symfony\Component\Messenger\MessageBusInterface;
  21. use Symfony\Component\Security\Core\User\UserInterface;
  22. use Symfony\Contracts\Service\Attribute\Required;
  24. class InteractionService
  25. {
  26. private const CAMPAIGN_MAX_LENGTH = 50;
  28. /** @var RequestStack */
  29. private $request;
  31. /** @var ListingManager */
  32. private $listingManager;
  34. /**
  35. * @var EventDispatcherInterface
  36. */
  37. protected $dispatcher;
  39. /**
  40. * @var Storage
  41. */
  42. protected $tokenStorage;
  44. /**
  45. * @var ProducerFactoryInterface
  46. */
  47. protected $buyerAlertProducer;
  49. /**
  50. * @var UserInterestManager
  51. */
  52. protected $interestManager;
  54. /** @var InteractionRepository */
  55. protected $interactionRepository;
  57. /** @var ListingContactRateService */
  58. protected $listingContactRateService;
  60. public function __construct(
  61. private readonly EntityManagerInterface $em,
  62. RequestStack $request,
  63. EventDispatcherInterface $dispatcher,
  64. ProducerFactoryInterface $pokeProducerFactory,
  65. UserInterestManager $interestManager,
  66. protected UserManager $userManager,
  67. InteractionRepository $interactionRepository,
  68. ListingContactRateService $listingContactRateService,
  69. private readonly MobileDetectionService $mobileDetectionService,
  70. private MessageBusInterface $bus
  71. ) {
  72. $this->request = $request->getCurrentRequest();
  73. $this->dispatcher = $dispatcher;
  74. $this->interestManager = $interestManager;
  75. $this->interactionRepository = $interactionRepository;
  76. $this->listingContactRateService = $listingContactRateService;
  77. }
  79. /**
  80. * @param int $type
  81. * @param User $user
  82. * @param string|null $source
  83. * @param bool $flush
  84. */
  85. public function addInteraction(
  86. $type,
  87. Listing $listing,
  88. $user = null,
  89. $source = null,
  90. $flush = true,
  91. $campaign = null,
  92. ?string $userIp = null
  93. ): ?Interaction {
  94. if (InteractionTypes::LISTING_VIEWS === $type && $this->isBotRequest()) {
  95. return null;
  96. }
  98. $isValid = true;
  99. $resolvedIp = $userIp ?? $this->request?->getClientIp();
  100. $interaction = new Interaction();
  101. $interaction
  102. ->setUser($user)
  103. ->setListing($listing)
  104. ->setType($type)
  105. ->setUserIp($resolvedIp)
  106. ->setSource($source)
  107. ->setCampaign($this->truncateText($campaign, self::CAMPAIGN_MAX_LENGTH))
  108. ;
  110. if (\in_array($type, [InteractionTypes::LISTING_VIEWS])) {
  111. $isValid = $this->validateInteractionsDuplications($interaction);
  112. }
  114. if (true === $isValid) {
  115. $this->em->persist($interaction);
  116. if ($flush) {
  117. $this->em->flush([$interaction]);
  118. }
  120. $this->listingManager->incrementViewsCounters($listing);
  122. return $interaction;
  123. }
  125. return null;
  126. }
  128. /**
  129. * @return bool
  130. */
  131. private function validateInteractionsDuplications(Interaction $interaction)
  132. {
  133. $duplicates = $this->interactionRepository->checkDuplicateInteraction($interaction);
  135. return $duplicates ? false : true;
  136. }
  138. public function increaseViews(Listing $listing, ?UserInterface $user = null): void
  139. {
  140. if ($this->isBotRequest()) {
  141. return;
  142. }
  144. if (
  145. $user instanceof User
  146. && $listing->getUser()->getId() === $user->getId()
  147. ) {
  148. return;
  149. }
  151. $response = new Response();
  152. $views = [];
  153. if ($this->request->cookies->has('viewed_listings')) {
  154. $views = unserialize($this->request->cookies->get('viewed_listings'));
  155. if (\count($views) > 100) {
  156. array_pop($views);
  157. }
  158. }
  160. // Prevent duplication using cookies
  161. if (!\in_array($listing->getId(), $views)) {
  162. $views[] = $listing->getId();
  163. $response->headers->setCookie(Cookie::create('viewed_listings', serialize($views), time() + (86400 * 7)));
  164. $response->sendHeaders();
  166. $user = $user instanceof User ? $user : null;
  167. $this->bus->dispatch(
  168. new ListingViewsCounterUpdatedMessage(
  169. $listing->getId(),
  170. new \DateTimeImmutable(),
  171. $user?->getId(),
  172. $this->request->getClientIp(),
  173. 'interaction-service',
  174. $this->request->cookies->get('campaign')
  175. )
  176. );
  177. }
  178. }
  180. private function isBotRequest(): bool
  181. {
  182. $userAgent = $this->request?->headers->get('user-agent');
  184. return $this->mobileDetectionService->isBot($userAgent);
  185. }
  187. private function truncateText(?string $text, int $maxLength): ?string
  188. {
  189. if (null === $text) {
  190. return null;
  191. }
  193. return mb_substr($text, 0, $maxLength);
  194. }
  196. #[Required]
  197. public function setListingManager(ListingManager $listingManager): void
  198. {
  199. $this->listingManager = $listingManager;
  200. }
  201. }