vendor/can/rest/src/Can/RestBundle/EventListener/ZoneMatcherListener.php line 79

Open in your IDE?
  1. <?php
  3. namespace Can\RestBundle\EventListener;
  5. use Can\RestBundle\CanRestBundle;
  6. use Can\RestBundle\Token\Generator\UUIDGenerator;
  7. use Can\RestBundle\URI\ServiceNode;
  8. use Can\RestBundle\URI\ServiceNodeStorage;
  9. use Can\RestBundle\URI\URIParserInterface;
  10. use Can\URI\Exception\MalformedURIException;
  11. use Can\URI\URI;
  13. use Symfony\Component\HttpFoundation\RequestMatcherInterface;
  14. use Symfony\Component\HttpKernel\Event\RequestEvent;
  15. use Symfony\Component\HttpKernel\Exception\BadRequestHttpException;
  17. use Exception;
  19. /**
  20.  * Matches REST zones.
  21.  *
  22.  * @group service
  23.  *
  24.  * @package can/rest-bundle
  25.  * @author lechecacharro <lechecacharro@gmail.com>
  26.  */
  27. class ZoneMatcherListener
  28. {
  30.     /**
  31.      * @var ServiceNodeStorage
  32.      */
  33.     private $storage;
  35.     /**
  36.      * @var URIParserInterface
  37.      */
  38.     private $parser;
  40.     /**
  41.      * @var UUIDGenerator
  42.      */
  43.     private $generator;
  45.     /**
  46.      * @var RequestMatcherInterface[]
  47.      */
  48.     private $matchers = [];
  51.     /**
  52.      * ZoneMatcherListener constructor.
  53.      *
  54.      * @param ServiceNodeStorage $storage
  55.      * @param URIParserInterface $parser
  56.      * @param UUIDGenerator      $generator
  57.      */
  58.     public function __construct(ServiceNodeStorage $storage, URIParserInterface $parser, UUIDGenerator $generator)
  59.     {
  60.         $this->storage = $storage;
  61.         $this->parser = $parser;
  62.         $this->generator = $generator;
  63.     }
  66.     /**
  67.      * @param RequestMatcherInterface $matcher
  68.      */
  69.     public function addRequestMatcher(RequestMatcherInterface $matcher): void
  70.     {
  71.         $this->matchers[] = $matcher;
  72.     }
  74.     /**
  75.      * @param RequestEvent $event
  76.      *
  77.      * @throws Exception
  78.      */
  79.     public function onRequest(RequestEvent $event): void
  80.     {
  81.         if (! $event->isMasterRequest()) {
  82.             return;
  83.         }
  85.         $request = $event->getRequest();
  87.         try {
  88.             $requestUri = new URI($request->getUri());
  89.         } catch (MalformedURIException $e) {
  90.             throw new BadRequestHttpException(null, $e);
  91.         }
  93.         foreach ($this->matchers as $matcher) {
  94.             if ($matcher->matches($request)) {
  95.                 $node = $this->parser->parse($requestUri);
  96.                 $uuid = $this->generator->uuid();
  98.                 $request->attributes->set(CanRestBundle::ATTR_SERVICE_NODE, $node);
  99.                 $request->attributes->set(CanRestBundle::ATTR_SERVICE_VERSION, $node->getVersionNumber());
  100.                 $request->attributes->set(CanRestBundle::ATTR_SERVICE_ZONE, true);
  101.                 $request->attributes->set(CanRestBundle::ATTR_REQUEST_UUID, $uuid);
  103.                 // Populate also the service node storage, so all services
  104.                 // which require access to the current service node (which
  105.                 // use the storage) have it available from now on...
  106.                 $this->storage->setServiceNode($node);
  108.                 return;
  109.             }
  110.         }
  112.         $request->attributes->set(CanRestBundle::ATTR_SERVICE_ZONE, false);
  113.     }
  115. }