vendor/shopware/core/Framework/Api/EventListener/ExpectationSubscriber.php line 50

Open in your IDE?
  1. <?php declare(strict_types=1);
  3. namespace Shopware\Core\Framework\Api\EventListener;
  5. use Composer\InstalledVersions;
  6. use Composer\Semver\Semver;
  7. use Shopware\Core\Framework\Api\Exception\ExceptionFailedException;
  8. use Shopware\Core\Framework\Routing\Annotation\RouteScope;
  9. use Shopware\Core\Framework\Routing\ApiRouteScope;
  10. use Shopware\Core\Framework\Routing\KernelListenerPriorities;
  11. use Shopware\Core\PlatformRequest;
  12. use Symfony\Component\EventDispatcher\EventSubscriberInterface;
  13. use Symfony\Component\HttpFoundation\Request;
  14. use Symfony\Component\HttpKernel\Event\ControllerEvent;
  15. use Symfony\Component\HttpKernel\KernelEvents;
  17. class ExpectationSubscriber implements EventSubscriberInterface
  18. {
  19.     private const SHOPWARE_CORE_PACKAGES = [
  20.         'shopware/platform',
  21.         'shopware/core',
  22.         'shopware/administration',
  23.         'shopware/elasticsearch',
  24.         'shopware/storefront',
  25.     ];
  27.     private string $shopwareVersion;
  29.     /**
  30.      * @var array{'composerName': string, 'active': bool, 'version': string}[]
  31.      */
  32.     private array $plugins;
  34.     /**
  35.      * @internal
  36.      */
  37.     public function __construct(string $shopwareVersion, array $plugins)
  38.     {
  39.         $this->shopwareVersion = $shopwareVersion;
  40.         $this->plugins = $plugins;
  41.     }
  43.     public static function getSubscribedEvents(): array
  44.     {
  45.         return [
  46.             KernelEvents::CONTROLLER => ['checkExpectations', KernelListenerPriorities::KERNEL_CONTROLLER_EVENT_SCOPE_VALIDATE_POST],
  47.         ];
  48.     }
  50.     public function checkExpectations(ControllerEvent $event): void
  51.     {
  52.         $request = $event->getRequest();
  54.         if (!$request->attributes->has(PlatformRequest::ATTRIBUTE_ROUTE_SCOPE)) {
  55.             return;
  56.         }
  58.         /** @var RouteScope|array $scope */
  59.         $scope = $request->attributes->get(PlatformRequest::ATTRIBUTE_ROUTE_SCOPE, []);
  61.         if ($scope instanceof RouteScope) {
  62.             $scope = $scope->getScopes();
  63.         }
  65.         if (!\in_array(ApiRouteScope::ID, $scope, true)) {
  66.             return;
  67.         }
  69.         $expectations = $this->checkPackages($request);
  71.         if (\count($expectations)) {
  72.             throw new ExceptionFailedException($expectations);
  73.         }
  74.     }
  76.     private function checkPackages(Request $request): array
  77.     {
  78.         // swag/plugin1:~6.1,swag/plugin2:~6.1
  79.         $extensionConstraints = array_filter(explode(',', (string) $request->headers->get(PlatformRequest::HEADER_EXPECT_PACKAGES)));
  80.         if ($extensionConstraints === []) {
  81.             return [];
  82.         }
  84.         $plugins = $this->getIndexedPackages();
  86.         $fails = [];
  88.         foreach ($extensionConstraints as $extension) {
  89.             $explode = explode(':', $extension);
  90.             if (\count($explode) !== 2) {
  91.                 $fails[] = sprintf('Got invalid string: "%s"', $extension);
  93.                 continue;
  94.             }
  96.             $name = $explode[0];
  97.             $constraint = $explode[1];
  99.             if (isset($plugins[$name])) {
  100.                 $installedVersion = $plugins[$name];
  101.             } else {
  102.                 try {
  103.                     $installedVersion = InstalledVersions::getPrettyVersion($name);
  104.                 } catch (\OutOfBoundsException $e) {
  105.                     $fails[] = sprintf('Requested package: %s is not available', $name);
  107.                     continue;
  108.                 }
  110.                 if (\in_array($name, self::SHOPWARE_CORE_PACKAGES, true)) {
  111.                     $installedVersion = $this->shopwareVersion;
  112.                 }
  113.             }
  115.             if (Semver::satisfies($installedVersion, $constraint)) {
  116.                 continue;
  117.             }
  119.             $fails[] = sprintf('Version constraint for %s is failed. Installed is: %s', $name, $installedVersion);
  120.         }
  122.         return $fails;
  123.     }
  125.     /**
  126.      * Plugins are not in the InstalledPackages file until now
  127.      */
  128.     private function getIndexedPackages(): array
  129.     {
  130.         $versions = [];
  132.         foreach ($this->plugins as $plugin) {
  133.             if (!$plugin['active']) {
  134.                 continue;
  135.             }
  137.             $versions[$plugin['composerName']] = $plugin['version'];
  138.         }
  140.         return $versions;
  141.     }
  142. }