src/Cms/DomainBundle/Subscriber/Dns/LookupSubscriber.php line 59

Open in your IDE?
  1. <?php
  3. namespace Cms\DomainBundle\Subscriber\Dns;
  6. use Amp\Dns\DnsRecord;
  7. use Cms\CoreBundle\Util\Doctrine\EntityManager;
  8. use Cms\DomainBundle\Entity\Apex;
  9. use Cms\DomainBundle\Entity\Domain;
  10. use Cms\DomainBundle\Service\Dns\Lookup;
  11. use Platform\QueueBundle\Event\AsyncEvent;
  12. use Symfony\Component\EventDispatcher\EventSubscriberInterface;
  14. final class LookupSubscriber implements EventSubscriberInterface
  15. {
  16.     public const EVENT_APEX = 'app.dns.lookup.apex';
  17.     public const EVENT_DOMAIN = 'app.dns.lookup.domain';
  19.     private EntityManager $em;
  21.     private Lookup $lookup;
  23.     public function __construct(EntityManager $em, Lookup $lookup)
  24.     {
  25.         $this->em = $em;
  26.         $this->lookup = $lookup;
  27.     }
  29.     /**
  30.      * {@inheritDoc}
  31.      */
  32.     public static function getSubscribedEvents(): array
  33.     {
  34.         return [
  35.             self::EVENT_APEX => ['onApexLookup', 0],
  36.             self::EVENT_DOMAIN => ['onDomainLookup', 0],
  37.         ];
  38.     }
  40.     public function onApexLookup(AsyncEvent $event): void
  41.     {
  42.         $apex = $this->em->getRepository(Apex::class)->find(
  43.             $event->getBody()->get('id'),
  44.         );
  46.         if ( ! $apex instanceof Apex) {
  47.             throw new \RuntimeException();
  48.         }
  50.         $event->getOutput()->writeln(
  51.             sprintf('DNS lookup for Apex  %s...', $apex->getHost())
  52.         );
  54.         $this->em->save(
  55.             $apex->setDnsLookupResult($this->lookup->lookup($apex, DnsRecord::A))
  56.         );
  57.     }
  59.     public function onDomainLookup(AsyncEvent $event): void
  60.     {
  61.         $domain = $this->em->getRepository(Domain::class)->find(
  62.             $event->getBody()->get('id'),
  63.         );
  65.         if ( ! $domain instanceof Domain) {
  66.             throw new \RuntimeException();
  67.         }
  69.         $event->getOutput()->writeln(
  70.             sprintf('DNS lookup for Domain  %s...', $domain->getHost())
  71.         );
  73.         $this->em->save(
  74.             $domain->setDnsLookupResult($this->lookup->lookup($domain, DnsRecord::CNAME))
  75.         );
  76.     }
  77. }