src/Service/Sync/Routing/Routing.php line 37

Open in your IDE?
  1. <?php
  3. /*
  4.  * This file is part of the nellapp-core package.
  5.  *
  6.  * (c) Benjamin Georgeault
  7.  *
  8.  * For the full copyright and license information, please view the LICENSE
  9.  * file that was distributed with this source code.
  10.  */
  12. namespace App\Service\Sync\Routing;
  14. use App\Entity\App\App;
  15. use App\Repository\App\AppRepository;
  16. use Nellapp\Bundle\SDKBundle\Enum\AppEnum;
  17. use Nellapp\Bundle\SDKBundle\Routing\Utils\ChannelMainDomainUtils;
  18. use Nellapp\Bundle\SDKBundle\Routing\Utils\DomainsRoutingUtils;
  19. use Nellapp\Bundle\SDKBundle\Sync\Routing\RouteCollection;
  20. use Symfony\Component\Routing\Route;
  21. use Symfony\Component\Routing\RouterInterface;
  22. use Symfony\Contracts\Cache\CacheInterface;
  23. use Symfony\Contracts\Cache\ItemInterface;
  24. use Symfony\Contracts\HttpClient\Exception\ExceptionInterface;
  25. use Symfony\Contracts\HttpClient\HttpClientInterface;
  27. /**
  28.  * Class Routing
  29.  *
  30.  * @author Benjamin Georgeault
  31.  */
  32. class Routing
  33. {
  34.     /** @var RouteCollection[] */
  35.     private array $routes = [];
  37.     public function __construct(
  38.         private CacheInterface      $nellappSyncRoutesCache,
  39.         private HttpClientInterface $client,
  40.         private AppRepository       $appRepository,
  41.         private RouterInterface     $router,
  42.         private string              $superAdminDomain,
  43.         private string              $commercialDomain,
  44.         private string              $syncDomain,
  45.         private bool                $debug = false,
  46.         private DomainsRoutingUtils $domainsRoutingUtils,
  47.     )
  48.     {
  49.     }
  51.     /**
  52.      * @return RouteCollection[]
  53.      */
  54.     public function getCollections(?App $ignoreApp = null, bool $cache = true): array
  55.     {
  56.         $array = [
  57.             'core' => RouteCollection::createFromSymfonyCollection($this->router->getRouteCollection(), AppEnum::CORE, $this->domainsRoutingUtils->getDefaultDomain(),
  58.                 function (Route $route) {
  59.                     return !in_array($route->getHost(), [
  60.                         $this->superAdminDomain,
  61.                         $this->syncDomain,
  62.                     ]);
  63.                 }),
  64.         ];
  66.         foreach ($this->appRepository->findAllExclude($ignoreApp) as $app) {
  67.             if ((null === $url = $app->getUrl()) || !filter_var($url, FILTER_VALIDATE_URL)) {
  68.                 continue;
  69.             }
  71.             $routes = $cache ? $this->getRoutes($app) : $this->doGetRoutes($app);
  72.             if (null !== $routes) {
  73.                 $array[$app->getQueueName()] = $routes;
  74.             }
  75.         }
  77.         return $array;
  78.     }
  80.     private function getRoutes(App $app): ?RouteCollection
  81.     {
  82.         if (array_key_exists($queue = $app->getQueueName(), $this->routes)) {
  83.             return $this->routes[$queue];
  84.         }
  86.         return $this->routes[$queue] = $this->nellappSyncRoutesCache->get(sprintf('global_routes_%s', $app->getQueueName()), function (ItemInterface $item) use ($app) {
  87.             $item->expiresAfter($this->debug ? 300 : 3600);
  88.             return $this->doGetRoutes($app);
  89.         });
  90.     }
  92.     private function doGetRoutes(App $app): ?RouteCollection
  93.     {
  94.         if ((null === $url = $app->getUrl()) || !filter_var($url, FILTER_VALIDATE_URL)) {
  95.             return null;
  96.         }
  98.         try {
  99.             $response = $this->client->request('GET', $url . 'routing/routes', [
  100.                 'timeout' => $this->debug ? 15 : 10,
  101.                 'headers' => [
  102.                     'Authorization' => 'Core ' . $app->getSecret(),
  103.                 ],
  104.             ]);
  106.             return RouteCollection::createFromArray([
  107.                 'app_name' => $app->getQueueName(),
  108.                 'routes' => $response->toArray(),
  109.                 'host' => $app->getHost(),
  110.             ]);
  111.         } catch (ExceptionInterface) {
  112.             return null;
  113.         }
  114.     }
  115. }