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

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.     public function __construct(string $shopwareVersion, array $plugins)
  35.     {
  36.         $this->shopwareVersion = $shopwareVersion;
  37.         $this->plugins = $plugins;
  38.     }
  40.     public static function getSubscribedEvents(): array
  41.     {
  42.         return [
  43.             KernelEvents::CONTROLLER => ['checkExpectations', KernelListenerPriorities::KERNEL_CONTROLLER_EVENT_SCOPE_VALIDATE_POST],
  44.         ];
  45.     }
  47.     public function checkExpectations(ControllerEvent $event): void
  48.     {
  49.         $request = $event->getRequest();
  51.         if (!$request->attributes->has(PlatformRequest::ATTRIBUTE_ROUTE_SCOPE)) {
  52.             return;
  53.         }
  55.         /** @var RouteScope|array $scope */
  56.         $scope = $request->attributes->get(PlatformRequest::ATTRIBUTE_ROUTE_SCOPE, []);
  58.         if ($scope instanceof RouteScope) {
  59.             $scope = $scope->getScopes();
  60.         }
  62.         if (!\in_array(ApiRouteScope::ID, $scope, true)) {
  63.             return;
  64.         }
  66.         $expectations = $this->checkPackages($request);
  68.         if (\count($expectations)) {
  69.             throw new ExceptionFailedException($expectations);
  70.         }
  71.     }
  73.     private function checkPackages(Request $request): array
  74.     {
  75.         // swag/plugin1:~6.1,swag/plugin2:~6.1
  76.         $extensionConstraints = array_filter(explode(',', (string) $request->headers->get(PlatformRequest::HEADER_EXPECT_PACKAGES)));
  77.         if ($extensionConstraints === []) {
  78.             return [];
  79.         }
  81.         $plugins = $this->getIndexedPackages();
  83.         $fails = [];
  85.         foreach ($extensionConstraints as $extension) {
  86.             $explode = explode(':', $extension);
  87.             if (\count($explode) !== 2) {
  88.                 $fails[] = sprintf('Got invalid string: "%s"', $extension);
  90.                 continue;
  91.             }
  93.             $name = $explode[0];
  94.             $constraint = $explode[1];
  96.             if (isset($plugins[$name])) {
  97.                 $installedVersion = $plugins[$name];
  98.             } else {
  99.                 try {
  100.                     $installedVersion = InstalledVersions::getPrettyVersion($name);
  101.                 } catch (\OutOfBoundsException $e) {
  102.                     $fails[] = sprintf('Requested package: %s is not available', $name);
  104.                     continue;
  105.                 }
  107.                 if (\in_array($name, self::SHOPWARE_CORE_PACKAGES, true)) {
  108.                     $installedVersion = $this->shopwareVersion;
  109.                 }
  110.             }
  112.             if (Semver::satisfies($installedVersion, $constraint)) {
  113.                 continue;
  114.             }
  116.             $fails[] = sprintf('Version constraint for %s is failed. Installed is: %s', $name, $installedVersion);
  117.         }
  119.         return $fails;
  120.     }
  122.     /**
  123.      * Plugins are not in the InstalledPackages file until now
  124.      */
  125.     private function getIndexedPackages(): array
  126.     {
  127.         $versions = [];
  129.         foreach ($this->plugins as $plugin) {
  130.             if (!$plugin['active']) {
  131.                 continue;
  132.             }
  134.             $versions[$plugin['composerName']] = $plugin['version'];
  135.         }
  137.         return $versions;
  138.     }
  139. }