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\UserBundle\Entity\User;
  12. use Aqarmap\Bundle\UserBundle\Services\UserInterestManager;
  13. use Aqarmap\Bundle\UserBundle\Services\UserManager;
  14. use Doctrine\ORM\EntityManagerInterface;
  15. use Symfony\Component\EventDispatcher\EventDispatcherInterface;
  16. use Symfony\Component\HttpFoundation\Cookie;
  17. use Symfony\Component\HttpFoundation\RequestStack;
  18. use Symfony\Component\HttpFoundation\Response;
  19. use Symfony\Component\Messenger\MessageBusInterface;
  20. use Symfony\Component\Security\Core\User\UserInterface;
  21. use Symfony\Contracts\Service\Attribute\Required;
  23. class InteractionService
  24. {
  25. /** @var RequestStack */
  26. private $request;
  28. /** @var ListingManager */
  29. private $listingManager;
  31. /**
  32. * @var EventDispatcherInterface
  33. */
  34. protected $dispatcher;
  36. /**
  37. * @var Storage
  38. */
  39. protected $tokenStorage;
  41. /**
  42. * @var ProducerFactoryInterface
  43. */
  44. protected $buyerAlertProducer;
  46. /**
  47. * @var UserInterestManager
  48. */
  49. protected $interestManager;
  51. /** @var InteractionRepository */
  52. protected $interactionRepository;
  54. /** @var ListingContactRateService */
  55. protected $listingContactRateService;
  57. public function __construct(
  58. private readonly EntityManagerInterface $em,
  59. RequestStack $request,
  60. EventDispatcherInterface $dispatcher,
  61. ProducerFactoryInterface $pokeProducerFactory,
  62. UserInterestManager $interestManager,
  63. protected UserManager $userManager,
  64. InteractionRepository $interactionRepository,
  65. ListingContactRateService $listingContactRateService,
  66. private MessageBusInterface $bus
  67. ) {
  68. $this->request = $request->getCurrentRequest();
  69. $this->dispatcher = $dispatcher;
  70. $this->interestManager = $interestManager;
  71. $this->interactionRepository = $interactionRepository;
  72. $this->listingContactRateService = $listingContactRateService;
  73. }
  75. /**
  76. * @param int $type
  77. * @param User $user
  78. * @param string|null $source
  79. * @param bool $flush
  80. */
  81. public function addInteraction(
  82. $type,
  83. Listing $listing,
  84. $user = null,
  85. $source = null,
  86. $flush = true,
  87. $campaign = null,
  88. ?string $userIp = null
  89. ): ?Interaction {
  90. $isValid = true;
  91. $resolvedIp = $userIp ?? $this->request?->getClientIp();
  92. $interaction = new Interaction();
  93. $interaction
  94. ->setUser($user)
  95. ->setListing($listing)
  96. ->setType($type)
  97. ->setUserIp($resolvedIp)
  98. ->setSource($source)
  99. ->setCampaign($campaign)
  100. ;
  102. if (\in_array($type, [InteractionTypes::LISTING_VIEWS])) {
  103. $isValid = $this->validateInteractionsDuplications($interaction);
  104. }
  106. if (true === $isValid) {
  107. $this->em->persist($interaction);
  108. if ($flush) {
  109. $this->em->flush([$interaction]);
  110. }
  112. $this->listingManager->incrementViewsCounters($listing);
  114. return $interaction;
  115. }
  117. return null;
  118. }
  120. /**
  121. * @return bool
  122. */
  123. private function validateInteractionsDuplications(Interaction $interaction)
  124. {
  125. $duplicates = $this->interactionRepository->checkDuplicateInteraction($interaction);
  127. return $duplicates ? false : true;
  128. }
  130. public function increaseViews(Listing $listing, ?UserInterface $user = null): void
  131. {
  132. if (
  133. $user instanceof User
  134. && $listing->getUser()->getId() === $user->getId()
  135. ) {
  136. return;
  137. }
  139. $response = new Response();
  140. $views = [];
  141. if ($this->request->cookies->has('viewed_listings')) {
  142. $views = unserialize($this->request->cookies->get('viewed_listings'));
  143. if (\count($views) > 100) {
  144. array_pop($views);
  145. }
  146. }
  148. // Prevent duplication using cookies
  149. if (!\in_array($listing->getId(), $views)) {
  150. $views[] = $listing->getId();
  151. $response->headers->setCookie(Cookie::create('viewed_listings', serialize($views), time() + (86400 * 7)));
  152. $response->sendHeaders();
  154. $user = $user instanceof User ? $user : null;
  155. $this->bus->dispatch(
  156. new ListingViewsCounterUpdatedMessage(
  157. $listing->getId(),
  158. new \DateTimeImmutable(),
  159. $user?->getId(),
  160. $this->request->getClientIp(),
  161. 'interaction-service',
  162. $this->request->cookies->get('campaign')
  163. )
  164. );
  165. }
  166. }
  168. #[Required]
  169. public function setListingManager(ListingManager $listingManager): void
  170. {
  171. $this->listingManager = $listingManager;
  172. }
  173. }