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

feat: ovh API implement

Browse Source
This commit is contained in:
Maël Gangloff
2024-07-29 16:10:34 +02:00
parent 0126238d45
commit c3714fbefd
1 changed files with 27 additions and 24 deletions
Download Patch File Download Diff File Expand all files Collapse all files

51
src/MessageHandler/ProcessDomainTriggerHandler.php
View File

@@ -46,33 +46,36 @@ final readonly class ProcessDomainTriggerHandler
/** @var Domain $domain */
$domain = $this->domainRepository->findOneBy(["ldhName" => $message->ldhName]);
/** @var DomainEvent $event */
foreach ($domain->getEvents()->filter(fn($event) => $message->updatedAt < $event->getDate()) as $event) {
$watchListTriggers = $watchList->getWatchListTriggers()
->filter(fn($trigger) => $trigger->getEvent() === $event->getAction());
$watchListTriggers = $watchList->getWatchListTriggers();
/** @var WatchListTrigger $watchListTrigger */
foreach ($watchListTriggers->getIterator() as $watchListTrigger) {
/** @var WatchListTrigger $watchListTrigger */
foreach ($watchListTriggers->getIterator() as $watchListTrigger) {
switch ($watchListTrigger->getAction()) {
case TriggerAction::SendEmail:
$this->sendEmailDomainUpdated($event, $watchList->getUser());
break;
case TriggerAction::BuyDomain :
if ($watchListTrigger->getConnector() === null) throw new Exception('Connector is missing');
$connector = $watchListTrigger->getConnector();
if ($connector->getProvider() === ConnectorProvider::OVH) {
$ovh = new OVHConnector($connector->getAuthData());
$isDebug = $this->kernel->isDebug();
$ovh->orderDomain(
$domain,
true,
true,
true,
$isDebug
);
if ($watchListTrigger->getAction() === TriggerAction::BuyDomain) {
} else throw new Exception("Unknown provider");
if ($watchListTrigger->getConnector() === null) throw new Exception('Connector is missing');
$connector = $watchListTrigger->getConnector();
if ($connector->getProvider() === ConnectorProvider::OVH) {
$ovh = new OVHConnector($connector->getAuthData());
$isDebug = $this->kernel->isDebug();
$ovh->orderDomain(
$domain,
true,
true,
true,
$isDebug
);
} else throw new Exception("Unknown provider");
}
/** @var DomainEvent $event */
foreach ($domain->getEvents()->filter(fn($event) => $message->updatedAt < $event->getDate()) as $event) {
if ($watchListTrigger->getAction() == TriggerAction::SendEmail) {
$this->sendEmailDomainUpdated($event, $watchList->getUser());
}
}
}