External/domain-watchdog
1
0
Fork 0
mirror of https://github.com/maelgangloff/domain-watchdog.git synced 2025-12-29 16:15:04 +00:00
Code Issues Packages Projects Releases Wiki Activity

fix: prevent domainPurchase duplicates

Browse Source
This commit is contained in:
Maël Gangloff
2025-11-02 12:05:32 +01:00
parent bf492e96cf
commit 39f607e95d
1 changed files with 20 additions and 10 deletions
Download Patch File Download Diff File Expand all files Collapse all files

30
src/MessageHandler/OrderDomainHandler.php
View File

@@ -8,6 +8,7 @@ use App\Entity\Watchlist;
use App\Message\OrderDomain;
use App\Notifier\DomainOrderErrorNotification;
use App\Notifier\DomainOrderNotification;
use App\Repository\DomainPurchaseRepository;
use App\Repository\DomainRepository;
use App\Repository\WatchlistRepository;
use App\Service\ChatNotificationService;
@@ -42,7 +43,7 @@ final readonly class OrderDomainHandler
#[Autowire(service: 'service_container')]
private ContainerInterface $locator,
#[Autowire(param: 'influxdb_enabled')]
private bool $influxdbEnabled, private EntityManagerInterface $em,
private bool $influxdbEnabled, private EntityManagerInterface $em, private DomainPurchaseRepository $domainPurchaseRepository,
) {
$this->sender = new Address($mailerSenderEmail, $mailerSenderName);
}
@@ -142,15 +143,24 @@ final readonly class OrderDomainHandler
$this->mailer->send($notification->asEmailMessage(new Recipient($watchlist->getUser()->getEmail()))->getMessage());
$this->chatNotificationService->sendChatNotification($watchlist, $notification);
$this->em->persist((new DomainPurchase())
->setDomain($domain)
->setConnector($connector)
->setConnectorProvider($connector->getProvider())
->setDomainOrderedAt(null)
->setUser($watchlist->getUser())
->setDomainDeletedAt($domain->getUpdatedAt())
->setDomainUpdatedAt($message->updatedAt));
$this->em->flush();
$domainPurchase = $this->domainPurchaseRepository->findOneBy([
'domain' => $domain,
'connector' => $connector,
'domainOrderedAt' => null,
'domainUpdatedAt' => $message->updatedAt,
'user' => $watchlist->getUser(),
]);
if (null === $domainPurchase) {
$this->em->persist((new DomainPurchase())
->setDomain($domain)
->setConnector($connector)
->setConnectorProvider($connector->getProvider())
->setDomainOrderedAt(null)
->setUser($watchlist->getUser())
->setDomainDeletedAt($domain->getUpdatedAt())
->setDomainUpdatedAt($message->updatedAt));
$this->em->flush();
}
throw $exception;
}