From 739fc7fcbfff35d3be96ce5b92721abcc2006552 Mon Sep 17 00:00:00 2001 From: =?UTF-8?q?Ma=C3=ABl=20Gangloff?= Date: Mon, 26 Aug 2024 23:45:30 +0200 Subject: [PATCH 1/2] refactor: split ProcessDomain message --- config/packages/messenger.yaml | 1 + src/Controller/DomainRefreshController.php | 4 +- ...ocessDomainTrigger.php => OrderDomain.php} | 2 +- src/Message/SendDomainEventNotif.php | 13 +++ ...ger.php => UpdateDomainsFromWatchlist.php} | 2 +- src/MessageHandler/OrderDomainHandler.php | 97 +++++++++++++++++++ .../ProcessWatchListsTriggerHandler.php | 4 +- ...er.php => SendDomainEventNotifHandler.php} | 68 ++----------- ... => UpdateDomainsFromWatchlistHandler.php} | 15 ++- 9 files changed, 137 insertions(+), 69 deletions(-) rename src/Message/{ProcessDomainTrigger.php => OrderDomain.php} (85%) create mode 100644 src/Message/SendDomainEventNotif.php rename src/Message/{ProcessWatchListTrigger.php => UpdateDomainsFromWatchlist.php} (71%) create mode 100644 src/MessageHandler/OrderDomainHandler.php rename src/MessageHandler/{ProcessDomainTriggerHandler.php => SendDomainEventNotifHandler.php} (58%) rename src/MessageHandler/{ProcessWatchListTriggerHandler.php => UpdateDomainsFromWatchlistHandler.php} (83%) diff --git a/config/packages/messenger.yaml b/config/packages/messenger.yaml index a34c133..f66c82d 100644 --- a/config/packages/messenger.yaml +++ b/config/packages/messenger.yaml @@ -25,6 +25,7 @@ framework: App\Message\ProcessWatchListsTrigger: async App\Message\ProcessWatchListTrigger: async App\Message\ProcessDomainTrigger: async + App\Message\OrderDomain: async # Route your messages to the transports # 'App\Message\YourMessage': async diff --git a/src/Controller/DomainRefreshController.php b/src/Controller/DomainRefreshController.php index 3fab035..4393f2e 100644 --- a/src/Controller/DomainRefreshController.php +++ b/src/Controller/DomainRefreshController.php @@ -4,7 +4,7 @@ namespace App\Controller; use App\Entity\Domain; use App\Entity\WatchList; -use App\Message\ProcessDomainTrigger; +use App\Message\SendDomainEventNotif; use App\Repository\DomainRepository; use App\Service\RDAPService; use Psr\Log\LoggerInterface; @@ -80,7 +80,7 @@ class DomainRefreshController extends AbstractController /** @var WatchList $watchList */ foreach ($watchLists as $watchList) { - $this->bus->dispatch(new ProcessDomainTrigger($watchList->getToken(), $domain->getLdhName(), $updatedAt)); + $this->bus->dispatch(new SendDomainEventNotif($watchList->getToken(), $domain->getLdhName(), $updatedAt)); } return $domain; diff --git a/src/Message/ProcessDomainTrigger.php b/src/Message/OrderDomain.php similarity index 85% rename from src/Message/ProcessDomainTrigger.php rename to src/Message/OrderDomain.php index 69dca3c..8a5dcc5 100644 --- a/src/Message/ProcessDomainTrigger.php +++ b/src/Message/OrderDomain.php @@ -2,7 +2,7 @@ namespace App\Message; -final class ProcessDomainTrigger +final class OrderDomain { public function __construct( public string $watchListToken, diff --git a/src/Message/SendDomainEventNotif.php b/src/Message/SendDomainEventNotif.php new file mode 100644 index 0000000..cbe3c54 --- /dev/null +++ b/src/Message/SendDomainEventNotif.php @@ -0,0 +1,13 @@ +sender = new Address($mailerSenderEmail, $mailerSenderName); + } + + /** + * @throws TransportExceptionInterface + * @throws \Symfony\Component\Notifier\Exception\TransportExceptionInterface + * @throws \Throwable + */ + public function __invoke(OrderDomain $message): void + { + /** @var WatchList $watchList */ + $watchList = $this->watchListRepository->findOneBy(['token' => $message->watchListToken]); + /** @var Domain $domain */ + $domain = $this->domainRepository->findOneBy(['ldhName' => $message->ldhName]); + + $connector = $watchList->getConnector(); + if (null !== $connector && $domain->getDeleted()) { + $this->logger->notice('Watchlist {watchlist} is linked to connector {connector}. A purchase attempt will be made for domain name {ldhName} with provider {provider}.', [ + 'watchlist' => $message->watchListToken, + 'connector' => $connector->getId(), + 'ldhName' => $message->ldhName, + 'provider' => $connector->getProvider()->value, + ]); + try { + $provider = $connector->getProvider(); + if (null === $provider) { + throw new \Exception('Provider not found'); + } + + $connectorProviderClass = $provider->getConnectorProvider(); + + /** @var AbstractProvider $connectorProvider */ + $connectorProvider = new $connectorProviderClass($connector->getAuthData(), $this->client, $this->cacheItemPool, $this->kernel); + + $connectorProvider->orderDomain($domain, $this->kernel->isDebug()); + + $notification = (new DomainOrderNotification($this->sender, $domain, $connector)); + $this->mailer->send($notification->asEmailMessage(new Recipient($watchList->getUser()->getEmail()))->getMessage()); + SendDomainEventNotifHandler::sendChatNotification($watchList, $notification, $this->logger); + + $this->statService->incrementStat('stats.domain.purchased'); + } catch (\Throwable $exception) { + $this->logger->warning('Unable to complete purchase. An error message is sent to user {username}.', [ + 'username' => $watchList->getUser()->getUserIdentifier(), + ]); + + $notification = (new DomainOrderErrorNotification($this->sender, $domain)); + $this->mailer->send($notification->asEmailMessage(new Recipient($watchList->getUser()->getEmail()))->getMessage()); + SendDomainEventNotifHandler::sendChatNotification($watchList, $notification, $this->logger); + + $this->statService->incrementStat('stats.domain.purchase.failed'); + + throw $exception; + } + } + } +} diff --git a/src/MessageHandler/ProcessWatchListsTriggerHandler.php b/src/MessageHandler/ProcessWatchListsTriggerHandler.php index ee2085c..881c255 100644 --- a/src/MessageHandler/ProcessWatchListsTriggerHandler.php +++ b/src/MessageHandler/ProcessWatchListsTriggerHandler.php @@ -4,7 +4,7 @@ namespace App\MessageHandler; use App\Entity\WatchList; use App\Message\ProcessWatchListsTrigger; -use App\Message\ProcessWatchListTrigger; +use App\Message\UpdateDomainsFromWatchlist; use App\Repository\WatchListRepository; use Random\Randomizer; use Symfony\Component\Messenger\Attribute\AsMessageHandler; @@ -30,7 +30,7 @@ final readonly class ProcessWatchListsTriggerHandler /** @var WatchList $watchList */ foreach ($watchLists as $watchList) { - $this->bus->dispatch(new ProcessWatchListTrigger($watchList->getToken())); + $this->bus->dispatch(new UpdateDomainsFromWatchlist($watchList->getToken())); } } } diff --git a/src/MessageHandler/ProcessDomainTriggerHandler.php b/src/MessageHandler/SendDomainEventNotifHandler.php similarity index 58% rename from src/MessageHandler/ProcessDomainTriggerHandler.php rename to src/MessageHandler/SendDomainEventNotifHandler.php index db7df13..5770ff8 100644 --- a/src/MessageHandler/ProcessDomainTriggerHandler.php +++ b/src/MessageHandler/SendDomainEventNotifHandler.php @@ -2,23 +2,18 @@ namespace App\MessageHandler; -use App\Config\Provider\AbstractProvider; use App\Config\TriggerAction; use App\Config\WebhookScheme; use App\Entity\Domain; use App\Entity\DomainEvent; use App\Entity\WatchList; use App\Entity\WatchListTrigger; -use App\Message\ProcessDomainTrigger; -use App\Notifier\DomainOrderErrorNotification; -use App\Notifier\DomainOrderNotification; +use App\Message\SendDomainEventNotif; use App\Notifier\DomainUpdateNotification; use App\Repository\DomainRepository; use App\Repository\WatchListRepository; use App\Service\StatService; -use Psr\Cache\CacheItemPoolInterface; use Psr\Log\LoggerInterface; -use Symfony\Component\HttpKernel\KernelInterface; use Symfony\Component\Mailer\Exception\TransportExceptionInterface; use Symfony\Component\Mailer\MailerInterface; use Symfony\Component\Messenger\Attribute\AsMessageHandler; @@ -28,24 +23,20 @@ use Symfony\Component\Notifier\Notification\ChatNotificationInterface; use Symfony\Component\Notifier\Recipient\Recipient; use Symfony\Component\Notifier\Transport\AbstractTransportFactory; use Symfony\Component\Notifier\Transport\Dsn; -use Symfony\Contracts\HttpClient\HttpClientInterface; #[AsMessageHandler] -final readonly class ProcessDomainTriggerHandler +final readonly class SendDomainEventNotifHandler { private Address $sender; public function __construct( string $mailerSenderEmail, string $mailerSenderName, - private WatchListRepository $watchListRepository, - private DomainRepository $domainRepository, - private KernelInterface $kernel, private LoggerInterface $logger, - private HttpClientInterface $client, private MailerInterface $mailer, - private CacheItemPoolInterface $cacheItemPool, - private StatService $statService + private StatService $statService, + private DomainRepository $domainRepository, + private WatchListRepository $watchListRepository ) { $this->sender = new Address($mailerSenderEmail, $mailerSenderName); } @@ -55,52 +46,13 @@ final readonly class ProcessDomainTriggerHandler * @throws \Exception * @throws ExceptionInterface */ - public function __invoke(ProcessDomainTrigger $message): void + public function __invoke(SendDomainEventNotif $message): void { /** @var WatchList $watchList */ $watchList = $this->watchListRepository->findOneBy(['token' => $message->watchListToken]); /** @var Domain $domain */ $domain = $this->domainRepository->findOneBy(['ldhName' => $message->ldhName]); - $connector = $watchList->getConnector(); - if (null !== $connector && $domain->getDeleted()) { - $this->logger->notice('Watchlist {watchlist} is linked to connector {connector}. A purchase attempt will be made for domain name {ldhName} with provider {provider}.', [ - 'watchlist' => $message->watchListToken, - 'connector' => $connector->getId(), - 'ldhName' => $message->ldhName, - 'provider' => $connector->getProvider()->value, - ]); - try { - $provider = $connector->getProvider(); - if (null === $provider) { - throw new \Exception('Provider not found'); - } - - $connectorProviderClass = $provider->getConnectorProvider(); - - /** @var AbstractProvider $connectorProvider */ - $connectorProvider = new $connectorProviderClass($connector->getAuthData(), $this->client, $this->cacheItemPool, $this->kernel); - - $connectorProvider->orderDomain($domain, $this->kernel->isDebug()); - - $notification = (new DomainOrderNotification($this->sender, $domain, $connector)); - $this->mailer->send($notification->asEmailMessage(new Recipient($watchList->getUser()->getEmail()))->getMessage()); - $this->sendChatNotification($watchList, $notification); - - $this->statService->incrementStat('stats.domain.purchased'); - } catch (\Throwable) { - $this->logger->warning('Unable to complete purchase. An error message is sent to user {username}.', [ - 'username' => $watchList->getUser()->getUserIdentifier(), - ]); - - $notification = (new DomainOrderErrorNotification($this->sender, $domain)); - $this->mailer->send($notification->asEmailMessage(new Recipient($watchList->getUser()->getEmail()))->getMessage()); - $this->sendChatNotification($watchList, $notification); - - $this->statService->incrementStat('stats.domain.purchase.failed'); - } - } - /** @var DomainEvent $event */ foreach ($domain->getEvents()->filter(fn ($event) => $message->updatedAt < $event->getDate() && $event->getDate() < new \DateTime()) as $event) { $watchListTriggers = $watchList->getWatchListTriggers() @@ -120,7 +72,7 @@ final readonly class ProcessDomainTriggerHandler if (TriggerAction::SendEmail == $watchListTrigger->getAction()) { $this->mailer->send($notification->asEmailMessage($recipient)->getMessage()); } elseif (TriggerAction::SendChat == $watchListTrigger->getAction()) { - $this->sendChatNotification($watchList, $notification); + $this->sendChatNotification($watchList, $notification, $this->logger); } $this->statService->incrementStat('stats.alert.sent'); @@ -131,7 +83,7 @@ final readonly class ProcessDomainTriggerHandler /** * @throws \Symfony\Component\Notifier\Exception\TransportExceptionInterface */ - private function sendChatNotification(WatchList $watchList, ChatNotificationInterface $notification): void + public static function sendChatNotification(WatchList $watchList, ChatNotificationInterface $notification, LoggerInterface $logger): void { $webhookDsn = $watchList->getWebhookDsn(); if (null !== $webhookDsn && 0 !== count($webhookDsn)) { @@ -147,13 +99,13 @@ final readonly class ProcessDomainTriggerHandler $transportFactory = new $transportFactoryClass(); try { $transportFactory->create($dsn)->send($notification->asChatMessage(new Recipient())); - $this->logger->info('Chat message sent with {schema} for Watchlist {token}', + $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}', + $logger->error('Unable to send a chat message to {scheme} for Watchlist {token}', [ 'scheme' => $webhookScheme->name, 'token' => $watchList->getToken(), diff --git a/src/MessageHandler/ProcessWatchListTriggerHandler.php b/src/MessageHandler/UpdateDomainsFromWatchlistHandler.php similarity index 83% rename from src/MessageHandler/ProcessWatchListTriggerHandler.php rename to src/MessageHandler/UpdateDomainsFromWatchlistHandler.php index c5c77fb..b651b00 100644 --- a/src/MessageHandler/ProcessWatchListTriggerHandler.php +++ b/src/MessageHandler/UpdateDomainsFromWatchlistHandler.php @@ -4,8 +4,9 @@ namespace App\MessageHandler; use App\Entity\Domain; use App\Entity\WatchList; -use App\Message\ProcessDomainTrigger; -use App\Message\ProcessWatchListTrigger; +use App\Message\OrderDomain; +use App\Message\SendDomainEventNotif; +use App\Message\UpdateDomainsFromWatchlist; use App\Notifier\DomainUpdateErrorNotification; use App\Repository\WatchListRepository; use App\Service\RDAPService; @@ -19,7 +20,7 @@ use Symfony\Component\Mime\Address; use Symfony\Component\Notifier\Recipient\Recipient; #[AsMessageHandler] -final readonly class ProcessWatchListTriggerHandler +final readonly class UpdateDomainsFromWatchlistHandler { private Address $sender; @@ -40,7 +41,7 @@ final readonly class ProcessWatchListTriggerHandler * @throws \Exception * @throws ExceptionInterface */ - public function __invoke(ProcessWatchListTrigger $message): void + public function __invoke(UpdateDomainsFromWatchlist $message): void { /** @var WatchList $watchList */ $watchList = $this->watchListRepository->findOneBy(['token' => $message->watchListToken]); @@ -71,7 +72,11 @@ final readonly class ProcessWatchListTriggerHandler $this->mailer->send($email->getMessage()); } - $this->bus->dispatch(new ProcessDomainTrigger($watchList->getToken(), $domain->getLdhName(), $updatedAt)); + $this->bus->dispatch(new SendDomainEventNotif($watchList->getToken(), $domain->getLdhName(), $updatedAt)); + + if (null !== $watchList->getConnector() && $domain->getDeleted()) { + $this->bus->dispatch(new OrderDomain($watchList->getToken(), $domain->getLdhName(), $updatedAt)); + } } } } From b5b958dd61eb337f5accc5b21a21f7b97c655e0d Mon Sep 17 00:00:00 2001 From: =?UTF-8?q?Ma=C3=ABl=20Gangloff?= Date: Tue, 27 Aug 2024 00:09:25 +0200 Subject: [PATCH 2/2] chore: refactor messages --- config/packages/messenger.yaml | 9 ++-- src/MessageHandler/OrderDomainHandler.php | 6 ++- .../SendDomainEventNotifHandler.php | 46 ++-------------- .../UpdateDomainsFromWatchlistHandler.php | 9 ++-- src/Service/ChatNotificationService.php | 52 +++++++++++++++++++ 5 files changed, 70 insertions(+), 52 deletions(-) create mode 100644 src/Service/ChatNotificationService.php diff --git a/config/packages/messenger.yaml b/config/packages/messenger.yaml index f66c82d..38a0041 100644 --- a/config/packages/messenger.yaml +++ b/config/packages/messenger.yaml @@ -21,11 +21,12 @@ framework: Symfony\Component\Mailer\Messenger\SendEmailMessage: async Symfony\Component\Notifier\Message\ChatMessage: async Symfony\Component\Notifier\Message\SmsMessage: async - App\Message\UpdateRdapServers: async - App\Message\ProcessWatchListsTrigger: async - App\Message\ProcessWatchListTrigger: async - App\Message\ProcessDomainTrigger: async + App\Message\OrderDomain: async + App\Message\ProcessWatchListsTrigger: async + App\Message\SendDomainEventNotif: async + App\Message\UpdateDomainsFromWatchlist: async + App\Message\UpdateRdapServers: async # Route your messages to the transports # 'App\Message\YourMessage': async diff --git a/src/MessageHandler/OrderDomainHandler.php b/src/MessageHandler/OrderDomainHandler.php index 7aad323..57c6601 100644 --- a/src/MessageHandler/OrderDomainHandler.php +++ b/src/MessageHandler/OrderDomainHandler.php @@ -10,6 +10,7 @@ use App\Notifier\DomainOrderErrorNotification; use App\Notifier\DomainOrderNotification; use App\Repository\DomainRepository; use App\Repository\WatchListRepository; +use App\Service\ChatNotificationService; use App\Service\StatService; use Psr\Cache\CacheItemPoolInterface; use Psr\Log\LoggerInterface; @@ -37,6 +38,7 @@ final readonly class OrderDomainHandler private MailerInterface $mailer, private LoggerInterface $logger, private StatService $statService, + private ChatNotificationService $chatNotificationService ) { $this->sender = new Address($mailerSenderEmail, $mailerSenderName); } @@ -76,7 +78,7 @@ final readonly class OrderDomainHandler $notification = (new DomainOrderNotification($this->sender, $domain, $connector)); $this->mailer->send($notification->asEmailMessage(new Recipient($watchList->getUser()->getEmail()))->getMessage()); - SendDomainEventNotifHandler::sendChatNotification($watchList, $notification, $this->logger); + $this->chatNotificationService->sendChatNotification($watchList, $notification); $this->statService->incrementStat('stats.domain.purchased'); } catch (\Throwable $exception) { @@ -86,7 +88,7 @@ final readonly class OrderDomainHandler $notification = (new DomainOrderErrorNotification($this->sender, $domain)); $this->mailer->send($notification->asEmailMessage(new Recipient($watchList->getUser()->getEmail()))->getMessage()); - SendDomainEventNotifHandler::sendChatNotification($watchList, $notification, $this->logger); + $this->chatNotificationService->sendChatNotification($watchList, $notification); $this->statService->incrementStat('stats.domain.purchase.failed'); diff --git a/src/MessageHandler/SendDomainEventNotifHandler.php b/src/MessageHandler/SendDomainEventNotifHandler.php index 5770ff8..481ed90 100644 --- a/src/MessageHandler/SendDomainEventNotifHandler.php +++ b/src/MessageHandler/SendDomainEventNotifHandler.php @@ -3,7 +3,6 @@ namespace App\MessageHandler; use App\Config\TriggerAction; -use App\Config\WebhookScheme; use App\Entity\Domain; use App\Entity\DomainEvent; use App\Entity\WatchList; @@ -12,6 +11,7 @@ use App\Message\SendDomainEventNotif; use App\Notifier\DomainUpdateNotification; use App\Repository\DomainRepository; use App\Repository\WatchListRepository; +use App\Service\ChatNotificationService; use App\Service\StatService; use Psr\Log\LoggerInterface; use Symfony\Component\Mailer\Exception\TransportExceptionInterface; @@ -19,10 +19,7 @@ use Symfony\Component\Mailer\MailerInterface; use Symfony\Component\Messenger\Attribute\AsMessageHandler; use Symfony\Component\Messenger\Exception\ExceptionInterface; use Symfony\Component\Mime\Address; -use Symfony\Component\Notifier\Notification\ChatNotificationInterface; use Symfony\Component\Notifier\Recipient\Recipient; -use Symfony\Component\Notifier\Transport\AbstractTransportFactory; -use Symfony\Component\Notifier\Transport\Dsn; #[AsMessageHandler] final readonly class SendDomainEventNotifHandler @@ -36,7 +33,8 @@ final readonly class SendDomainEventNotifHandler private MailerInterface $mailer, private StatService $statService, private DomainRepository $domainRepository, - private WatchListRepository $watchListRepository + private WatchListRepository $watchListRepository, + private ChatNotificationService $chatNotificationService ) { $this->sender = new Address($mailerSenderEmail, $mailerSenderName); } @@ -72,47 +70,11 @@ final readonly class SendDomainEventNotifHandler if (TriggerAction::SendEmail == $watchListTrigger->getAction()) { $this->mailer->send($notification->asEmailMessage($recipient)->getMessage()); } elseif (TriggerAction::SendChat == $watchListTrigger->getAction()) { - $this->sendChatNotification($watchList, $notification, $this->logger); + $this->chatNotificationService->sendChatNotification($watchList, $notification); } $this->statService->incrementStat('stats.alert.sent'); } } } - - /** - * @throws \Symfony\Component\Notifier\Exception\TransportExceptionInterface - */ - public static function sendChatNotification(WatchList $watchList, ChatNotificationInterface $notification, LoggerInterface $logger): void - { - $webhookDsn = $watchList->getWebhookDsn(); - if (null !== $webhookDsn && 0 !== count($webhookDsn)) { - foreach ($webhookDsn 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())); - $logger->info('Chat message sent with {schema} for Watchlist {token}', - [ - 'scheme' => $webhookScheme->name, - 'token' => $watchList->getToken(), - ]); - } catch (\Throwable) { - $logger->error('Unable to send a chat message to {scheme} for Watchlist {token}', - [ - 'scheme' => $webhookScheme->name, - 'token' => $watchList->getToken(), - ]); - } - } - } - } - } } diff --git a/src/MessageHandler/UpdateDomainsFromWatchlistHandler.php b/src/MessageHandler/UpdateDomainsFromWatchlistHandler.php index b651b00..de1aecd 100644 --- a/src/MessageHandler/UpdateDomainsFromWatchlistHandler.php +++ b/src/MessageHandler/UpdateDomainsFromWatchlistHandler.php @@ -11,6 +11,7 @@ use App\Notifier\DomainUpdateErrorNotification; use App\Repository\WatchListRepository; use App\Service\RDAPService; use Psr\Log\LoggerInterface; +use Symfony\Component\HttpKernel\Exception\NotFoundHttpException; use Symfony\Component\Mailer\Exception\TransportExceptionInterface; use Symfony\Component\Mailer\MailerInterface; use Symfony\Component\Messenger\Attribute\AsMessageHandler; @@ -62,6 +63,10 @@ final readonly class UpdateDomainsFromWatchlistHandler try { $this->RDAPService->registerDomain($domain->getLdhName()); + } catch (NotFoundHttpException) { + if (null !== $watchList->getConnector()) { + $this->bus->dispatch(new OrderDomain($watchList->getToken(), $domain->getLdhName(), $updatedAt)); + } } catch (\Throwable $e) { $this->logger->error('An update error email is sent to user {username}.', [ 'username' => $watchList->getUser()->getUserIdentifier(), @@ -73,10 +78,6 @@ final readonly class UpdateDomainsFromWatchlistHandler } $this->bus->dispatch(new SendDomainEventNotif($watchList->getToken(), $domain->getLdhName(), $updatedAt)); - - if (null !== $watchList->getConnector() && $domain->getDeleted()) { - $this->bus->dispatch(new OrderDomain($watchList->getToken(), $domain->getLdhName(), $updatedAt)); - } } } } diff --git a/src/Service/ChatNotificationService.php b/src/Service/ChatNotificationService.php new file mode 100644 index 0000000..72024d4 --- /dev/null +++ b/src/Service/ChatNotificationService.php @@ -0,0 +1,52 @@ +getWebhookDsn(); + if (null !== $webhookDsn && 0 !== count($webhookDsn)) { + foreach ($webhookDsn 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(), + ]); + } + } + } + } + } +}