src/Aqarmap/Bundle/ListingBundle/EventListener/ListingActivityLogListener.php line 183

  1. <?php
  3. namespace Aqarmap\Bundle\ListingBundle\EventListener;
  5. use Aqarmap\Bundle\ListingBundle\Constant\ListingActivityType;
  6. use Aqarmap\Bundle\ListingBundle\Constant\ListingStatus;
  7. use Aqarmap\Bundle\ListingBundle\Document\ListingActivityLog;
  8. use Aqarmap\Bundle\ListingBundle\Entity\Listing;
  9. use Aqarmap\Bundle\ListingBundle\Event\BumpListingEvent;
  10. use Aqarmap\Bundle\ListingBundle\Event\ListingEvent;
  11. use Aqarmap\Bundle\ListingBundle\Event\ListingEventInterface;
  12. use Aqarmap\Bundle\ListingBundle\Service\ListingActivityLogService;
  13. use Aqarmap\Bundle\UserBundle\Entity\User;
  14. use JMS\Serializer\SerializationContext;
  15. use JMS\Serializer\Serializer;
  16. use JMS\Serializer\SerializerInterface;
  17. use Symfony\Component\EventDispatcher\EventDispatcherInterface;
  18. use Symfony\Component\EventDispatcher\EventSubscriberInterface;
  19. use Symfony\Component\Security\Core\Authentication\Token\Storage\TokenStorageInterface;
  20. use Symfony\Component\Security\Core\User\UserInterface;
  22. /**
  23. * Listing Activity Log listener.
  24. */
  25. class ListingActivityLogListener implements EventSubscriberInterface
  26. {
  27. /** @var UserInterface */
  28. protected $user;
  30. /** @var ListingActivityLogService */
  31. protected $listingActivity;
  33. /**
  34. * @var Serializer
  35. */
  36. protected $serializer;
  38. /**
  39. * @var EventDispatcherInterface
  40. */
  41. protected $dispatcher;
  43. public function __construct(EventDispatcherInterface $dispatcher, private readonly TokenStorageInterface $tokenStorage, ListingActivityLogService $listingActivity, SerializerInterface $serializer)
  44. {
  45. $this->dispatcher = $dispatcher;
  46. $this->user = $this->tokenStorage->getToken() ? $this->tokenStorage->getToken()->getUser() : null;
  47. $this->listingActivity = $listingActivity;
  48. $this->serializer = $serializer;
  49. }
  51. protected function serialize($object)
  52. {
  53. return $this->serializer->serialize($object, 'json', SerializationContext::create()->setGroups(['Default', 'Activity']));
  54. }
  56. /**
  57. * @param Listing $listing
  58. * @param UserInterface $user
  59. * @param array $rejectionReasons
  60. */
  61. protected function log($listing, $user, $actionType, $rejectionReasons = []): void
  62. {
  63. $user = $user instanceof User && $user->getId() ? $user : $listing->getUser();
  64. if ($user && $listing) {
  65. $listingActivityLog = new ListingActivityLog();
  66. $listingActivityLog->setUserId($user->getId());
  67. $listingActivityLog->setUser($this->serialize($user));
  68. $listingActivityLog->setListingId($listing->getId());
  69. $listingActivityLog->setListing($this->serialize($listing));
  70. $listingActivityLog->setRejectionReasons($rejectionReasons);
  71. $listingActivityLog->setActionType($actionType);
  72. $listingActivityLog->setTeamId($user->getTeam() ? $user->getTeam()->getId() : null);
  73. $listingActivityLog->setTeam($user->getTeam() ? $this->serialize($user->getTeam()) : null);
  74. // Workaround to avoid Fire created event after any other events
  75. $listingActivityLog->setCreatedAt(new \DateTime());
  76. if (ListingActivityType::CREATED == $actionType) {
  77. $listingActivityLog->setCreatedAt(new \DateTime('now -2 seconds'));
  78. }
  79. $this->listingActivity->execute($listingActivityLog);
  80. }
  81. }
  83. public function listingCreatedEvent(ListingEvent $event): void
  84. {
  85. $actionType = ListingActivityType::CREATED;
  86. $this->log($event->getlisting(), $this->user, $actionType);
  87. }
  89. public function listingPendingApprovalEvent(ListingEvent $event): void
  90. {
  91. $actionType = ListingActivityType::PENDING_APPROVAL;
  92. $this->log($event->getlisting(), $event->getListing()->getUser(), $actionType);
  93. }
  95. public function listingPublishEvent(ListingEventInterface $event): void
  96. {
  97. $actionType = $this->user instanceof UserInterface
  98. ? ListingActivityType::PUBLISH
  99. : ListingActivityType::APPROVED_BY_SYSTEM;
  101. $this->log($event->getlisting(), $this->user, $actionType);
  102. }
  104. public function listingDeleteEvent(ListingEvent $event): void
  105. {
  106. $actionType = ListingActivityType::DELETE;
  107. $this->log($event->getlisting(), $this->user, $actionType);
  108. }
  110. public function listingDeleteByUserEvent(ListingEvent $event): void
  111. {
  112. $actionType = ListingActivityType::DELETE_BY_USER;
  113. $this->log($event->getlisting(), $this->user, $actionType);
  114. }
  116. public function listingResetTitleEvent(ListingEvent $event): void
  117. {
  118. $actionType = ListingActivityType::RESET_TITLE;
  119. $this->log($event->getlisting(), $this->user, $actionType);
  120. }
  122. public function listingResetDescriptionEvent(ListingEvent $event): void
  123. {
  124. $actionType = ListingActivityType::RESET_DESCRIPTION;
  125. $this->log($event->getlisting(), $this->user, $actionType);
  126. }
  128. public function listingRemoveNumbersEvent(ListingEvent $event): void
  129. {
  130. $actionType = ListingActivityType::REMOVE_NUMBERS;
  131. $this->log($event->getlisting(), $this->user, $actionType);
  132. }
  134. public function listingRemoveVideoEvent(ListingEvent $event): void
  135. {
  136. $actionType = ListingActivityType::REMOVE_VIDEO;
  137. $this->log($event->getlisting(), $this->user, $actionType);
  138. }
  140. public function listingRemoveMapEvent(ListingEvent $event): void
  141. {
  142. $actionType = ListingActivityType::REMOVE_MAP;
  143. $this->log($event->getlisting(), $this->user, $actionType);
  144. }
  146. public function listingRemovePriceEvent(ListingEvent $event): void
  147. {
  148. $actionType = ListingActivityType::CLEAR_PRICE;
  149. $this->log($event->getlisting(), $this->user, $actionType);
  150. }
  152. public function listingFeaturedEvent(ListingEvent $event): void
  153. {
  154. $actionType = ListingActivityType::FEATURED;
  155. $this->log($event->getlisting(), $this->user, $actionType);
  156. }
  158. public function listingSuperFeaturedEvent(ListingEvent $event): void
  159. {
  160. $actionType = ListingActivityType::SUPER_FEATURED;
  161. $this->log($event->getlisting(), $this->user, $actionType);
  162. }
  164. public function listingPremiumFeaturedEvent(ListingEvent $event): void
  165. {
  166. $actionType = ListingActivityType::PREMIUM;
  167. $this->log($event->getlisting(), $this->user, $actionType);
  168. }
  170. public function listingSponsoredFeaturedEvent(ListingEvent $event): void
  171. {
  172. $actionType = ListingActivityType::SPONSORED;
  173. $this->log($event->getlisting(), $this->user, $actionType);
  174. }
  176. public function listingSpotlightFeaturedEvent(ListingEvent $event): void
  177. {
  178. $actionType = ListingActivityType::SPOTLIGHT;
  179. $this->log($event->getlisting(), $this->user, $actionType);
  180. }
  182. public function listingUnFeaturedEvent(ListingEvent $event): void
  183. {
  184. $actionType = ListingActivityType::UNFEATURED;
  185. $this->log($event->getlisting(), $this->user, $actionType);
  186. }
  188. public function listingExpiredEvent(ListingEvent $event): void
  189. {
  190. $actionType = ListingActivityType::EXPIRED;
  191. $this->log($event->getlisting(), $this->user, $actionType);
  192. }
  194. public function listingRejectedEvent(ListingEvent $event): void
  195. {
  196. $actionType = ListingActivityType::REJECTED;
  197. $this->log($event->getlisting(), $this->user, $actionType, $event->getRejectionReasons());
  198. }
  200. public function listingPendingPhotoEvent(ListingEvent $event): void
  201. {
  202. $actionType = ListingActivityType::PENDING_PHOTOS;
  203. $this->log($event->getlisting(), $this->user, $actionType);
  204. }
  206. public function listingPendingPaymentEvent(ListingEvent $event): void
  207. {
  208. $actionType = ListingActivityType::PENDING_PAYMENT;
  209. if (ListingStatus::PENDING_PAYMENT != $event->getListing()->getStatus()) {
  210. $this->log($event->getlisting(), $this->user, $actionType);
  211. }
  212. }
  214. public function listingPublishFreeEvent(ListingEvent $event): void
  215. {
  216. $actionType = ListingActivityType::FREE_PUBLISH;
  217. $this->log($event->getlisting(), $this->user, $actionType);
  218. }
  220. public function listingPublishWithOutPhotoEvent(ListingEvent $event): void
  221. {
  222. $actionType = $this->user instanceof UserInterface
  223. ? ListingActivityType::PUBLISH_WITHOUT_PHOTOS
  224. : ListingActivityType::PUBLISH_WITHOUT_PHOTOS_BY_SYSTEM;
  225. $this->log($event->getlisting(), $this->user, $actionType);
  226. }
  228. public function listingAutoBumpUpStartedEvent(BumpListingEvent $event): void
  229. {
  230. $this->log(
  231. $event->getListing(),
  232. $this->user,
  233. ListingActivityType::AUTO_BUMP_UP_STARTED
  234. );
  235. }
  237. public function listingAutoBumpUpRevertedEvent(BumpListingEvent $event): void
  238. {
  239. $this->log(
  240. $event->getListing(),
  241. $this->user,
  242. ListingActivityType::AUTO_BUMP_UP_REVERTED
  243. );
  244. }
  246. public function listingAutoBumpUpStepEvent(BumpListingEvent $event): void
  247. {
  248. $this->log(
  249. $event->getListing(),
  250. $event->getBumpUpOwner(),
  251. ListingActivityType::AUTO_BUMP_UP_STEP
  252. );
  253. }
  255. public function listingAutoBumpUpExpiredEvent(BumpListingEvent $event): void
  256. {
  257. $this->log(
  258. $event->getListing(),
  259. $event->getBumpUpOwner(),
  260. ListingActivityType::AUTO_BUMP_UP_EXPIRED
  261. );
  262. }
  264. public function listingSoldByOwnerFeaturedEvent(ListingEvent $event): void
  265. {
  266. $this->log($event->getlisting(), $this->user, ListingActivityType::SOLD_BY_ADMIN);
  267. }
  269. public function listingSoldByOwnerSponsoredEvent(ListingEvent $event): void
  270. {
  271. $this->log($event->getlisting(), $this->user, ListingActivityType::SOLD_BY_ADMIN);
  272. }
  274. public function firstListingForFreeEvent(ListingEvent $event): void
  275. {
  276. $this->log($event->getlisting(), $this->user, ListingActivityType::FIRST_LISTING_FOR_FREE);
  277. }
  279. public static function getSubscribedEvents(): array
  280. {
  281. return [
  282. 'aqarmap.listing.publish' => ['listingPublishEvent'],
  283. 'aqarmap.listing.scrapped.publish' => ['listingPublishEvent'],
  284. 'aqarmap.listing.delete' => ['listingDeleteEvent'],
  285. 'aqarmap.listing.delete_by_user' => ['listingDeleteByUserEvent'],
  286. 'aqarmap.listing.reset_title' => ['listingResetTitleEvent'],
  287. 'aqarmap.listing.reset_description' => ['listingResetDescriptionEvent'],
  288. 'aqarmap.listing.remove_numbers' => ['listingRemoveNumbersEvent'],
  289. 'aqarmap.listing.clear_video' => ['listingRemoveVideoEvent'],
  290. 'aqarmap.listing.clear_map' => ['listingRemoveMapEvent'],
  291. 'aqarmap.listing.clear_price' => ['listingRemovePriceEvent'],
  292. 'aqarmap.listing.featured' => ['listingFeaturedEvent'],
  293. 'aqarmap.listing.super_featured' => ['listingSuperFeaturedEvent'],
  294. 'aqarmap.listing.premium' => ['listingPremiumFeaturedEvent'],
  295. 'aqarmap.listing.sponsored' => ['listingSponsoredFeaturedEvent'],
  296. 'aqarmap.listing.spotlight' => ['listingSpotlightFeaturedEvent'],
  297. 'aqarmap.listing.bump_up_started' => ['listingAutoBumpUpStartedEvent'],
  298. 'aqarmap.listing.bump_up_reverted' => ['listingAutoBumpUpRevertedEvent'],
  299. 'aqarmap.listing.bump_up_step' => ['listingAutoBumpUpStepEvent'],
  300. 'aqarmap.listing.bump_up_expired' => ['listingAutoBumpUpExpiredEvent'],
  301. 'aqarmap.listing.unfeatured' => ['listingUnFeaturedEvent'],
  302. 'aqarmap.listing.expired' => ['listingExpiredEvent'],
  303. 'aqarmap.listing.rejected' => ['listingRejectedEvent'],
  304. 'aqarmap.listing.pending_photos' => ['listingPendingPhotoEvent'],
  305. 'aqarmap.listing.pending_payment' => ['listingPendingPaymentEvent'],
  306. 'aqarmap.listing.free_publish' => ['listingPublishFreeEvent'],
  307. 'aqarmap.listing.publish_without_photos' => ['listingPublishWithOutPhotoEvent'],
  308. 'aqarmap.listing.created' => ['listingCreatedEvent'],
  309. 'aqarmap.listing.pending_approval' => ['listingPendingApprovalEvent'],
  310. 'aqarmap.listing.sold_by_owner' => ['listingSoldByOwnerFeaturedEvent'],
  311. 'aqarmap.listing.sold_by_owner_sponsored' => ['listingSoldByOwnerSponsoredEvent'],
  312. 'aqarmap.listing.first_listing_for_free' => ['firstListingForFreeEvent'],
  313. ];
  314. }
  315. }