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

refactor: move sendChatNotification

Browse Source
This commit is contained in:
Maël Gangloff
2024-08-18 21:49:34 +02:00
parent c039477eec
commit 0351bc552a
1 changed files with 42 additions and 18 deletions
Download Patch File Download Diff File Expand all files Collapse all files

60
src/MessageHandler/ProcessDomainTriggerHandler.php
View File

@@ -22,6 +22,7 @@ use Symfony\Component\Mailer\MailerInterface;
use Symfony\Component\Messenger\Attribute\AsMessageHandler; use Symfony\Component\Messenger\Attribute\AsMessageHandler;
use Symfony\Component\Messenger\Exception\ExceptionInterface; use Symfony\Component\Messenger\Exception\ExceptionInterface;
use Symfony\Component\Mime\Address; use Symfony\Component\Mime\Address;
use Symfony\Component\Notifier\Notification\ChatNotificationInterface;
use Symfony\Component\Notifier\Recipient\Recipient; use Symfony\Component\Notifier\Recipient\Recipient;
use Symfony\Component\Notifier\Transport\AbstractTransportFactory; use Symfony\Component\Notifier\Transport\AbstractTransportFactory;
use Symfony\Component\Notifier\Transport\Dsn; use Symfony\Component\Notifier\Transport\Dsn;
@@ -78,16 +79,17 @@ final readonly class ProcessDomainTriggerHandler
$connectorProvider->orderDomain($domain, $this->kernel->isDebug()); $connectorProvider->orderDomain($domain, $this->kernel->isDebug());
$email = (new DomainOrderNotification($this->sender, $domain, $connector)) $notification = (new DomainOrderNotification($this->sender, $domain, $connector));
->asEmailMessage(new Recipient($watchList->getUser()->getEmail())); $this->mailer->send($notification->asEmailMessage(new Recipient($watchList->getUser()->getEmail()))->getMessage());
$this->mailer->send($email->getMessage()); $this->sendChatNotification($watchList, $notification);
} catch (\Throwable) { } catch (\Throwable) {
$this->logger->warning('Unable to complete purchase. An error message is sent to user {username}.', [ $this->logger->warning('Unable to complete purchase. An error message is sent to user {username}.', [
'username' => $watchList->getUser()->getUserIdentifier(), 'username' => $watchList->getUser()->getUserIdentifier(),
]); ]);
$email = (new DomainOrderErrorNotification($this->sender, $domain))
->asEmailMessage(new Recipient($watchList->getUser()->getEmail())); $notification = (new DomainOrderErrorNotification($this->sender, $domain));
$this->mailer->send($email->getMessage()); $this->mailer->send($notification->asEmailMessage(new Recipient($watchList->getUser()->getEmail()))->getMessage());
$this->sendChatNotification($watchList, $notification);
} }
} }
@@ -110,19 +112,41 @@ final readonly class ProcessDomainTriggerHandler
if (TriggerAction::SendEmail == $watchListTrigger->getAction()) { if (TriggerAction::SendEmail == $watchListTrigger->getAction()) {
$this->mailer->send($notification->asEmailMessage($recipient)->getMessage()); $this->mailer->send($notification->asEmailMessage($recipient)->getMessage());
} elseif (TriggerAction::SendChat == $watchListTrigger->getAction()) { } elseif (TriggerAction::SendChat == $watchListTrigger->getAction()) {
if (null !== $watchList->getWebhookDsn()) { $this->sendChatNotification($watchList, $notification);
foreach ($watchList->getWebhookDsn() as $dsnString) { }
$dsn = new Dsn($dsnString); }
}
}
$scheme = $dsn->getScheme(); /**
$webhookScheme = WebhookScheme::tryFrom($scheme); * @throws \Symfony\Component\Notifier\Exception\TransportExceptionInterface
if (null !== $webhookScheme) { */
$transportFactoryClass = $webhookScheme->getChatTransportFactory(); private function sendChatNotification(WatchList $watchList, ChatNotificationInterface $notification): void
/** @var AbstractTransportFactory $transportFactory */ {
$transportFactory = new $transportFactoryClass(); if (null !== $watchList->getWebhookDsn()) {
$transportFactory->create($dsn)->send($notification->asChatMessage()); foreach ($watchList->getWebhookDsn() as $dsnString) {
} $dsn = new Dsn($dsnString);
}
$scheme = $dsn->getScheme();
$webhookScheme = WebhookScheme::tryFrom($scheme);
if (null !== $webhookScheme) {
$transportFactoryClass = $webhookScheme->getChatTransportFactory();
/** @var AbstractTransportFactory $transportFactory */
$transportFactory = new $transportFactoryClass();
try {
$transportFactory->create($dsn)->send($notification->asChatMessage(new Recipient()));
$this->logger->info('Chat message sent with {schema} for Watchlist {token}',
[
'scheme' => $webhookScheme->name,
'token' => $watchList->getToken(),
]);
} catch (\Throwable) {
$this->logger->error('Unable to send a chat message to {scheme} for Watchlist {token}',
[
'scheme' => $webhookScheme->name,
'token' => $watchList->getToken(),
]);
} }
} }
} }