custom/plugins/SwagPublisher/src/VersionControlSystem/Internal/PreviewMediaSync.php line 36

Open in your IDE?
  1. <?php declare(strict_types=1);
  2. /*
  3.  * (c) shopware AG <info@shopware.com>
  4.  * For the full copyright and license information, please view the LICENSE
  5.  * file that was distributed with this source code.
  6.  */
  8. namespace SwagPublisher\VersionControlSystem\Internal;
  10. use Shopware\Core\Content\Cms\CmsPageEvents;
  11. use Shopware\Core\Framework\Context;
  12. use Shopware\Core\Framework\DataAbstractionLayer\Event\EntityWrittenEvent;
  13. use Shopware\Core\Framework\DataAbstractionLayer\Search\Criteria;
  14. use Shopware\Core\Framework\DataAbstractionLayer\Search\Filter\AndFilter;
  15. use Shopware\Core\Framework\DataAbstractionLayer\Search\Filter\EqualsFilter;
  16. use Shopware\Core\Framework\DataAbstractionLayer\Search\Filter\MultiFilter;
  17. use Symfony\Component\EventDispatcher\EventSubscriberInterface;
  19. class PreviewMediaSync implements EventSubscriberInterface
  20. {
  21.     private VersionControlCmsGateway $cmsGateway;
  23.     public function __construct(
  24.         VersionControlCmsGateway $cmsGateway
  25.     ) {
  26.         $this->cmsGateway = $cmsGateway;
  27.     }
  29.     public static function getSubscribedEvents(): array
  30.     {
  31.         return [
  32.             CmsPageEvents::PAGE_WRITTEN_EVENT => 'updatePreviewMediaId',
  33.         ];
  34.     }
  36.     public function updatePreviewMediaId(EntityWrittenEvent $event): void
  37.     {
  38.         $payloads = [];
  39.         $writeResults = $event->getWriteResults();
  41.         foreach ($writeResults as $writeResult) {
  42.             if ($writeResult->hasPayload('previewMediaId')) {
  43.                 $key = $writeResult->getPrimaryKey();
  45.                 if (\is_array($key)) {
  46.                     continue;
  47.                 }
  49.                 $payloads[$key] = $writeResult->getPayload();
  50.             }
  51.         }
  53.         if (!$payloads) {
  54.             return;
  55.         }
  57.         $context = $event->getContext();
  59.         $drafts = $this->cmsGateway
  60.             ->searchDrafts(self::createCriteriaFromPayloads($payloads), $context);
  62.         if (!$drafts->count()) {
  63.             return;
  64.         }
  66.         $draftData = [];
  67.         foreach ($drafts as $draft) {
  68.             $draftData[] = [
  69.                 'id' => $draft->getId(),
  70.                 'previewMediaId' => $payloads[$draft->get('pageId')]['previewMediaId'],
  71.             ];
  72.         }
  74.         $context->scope(Context::SYSTEM_SCOPE, function ($systemContext) use ($draftData): void {
  75.             $this->cmsGateway->updateDrafts($draftData, $systemContext);
  76.         });
  77.     }
  79.     private static function createCriteriaFromPayloads(array $payloads): Criteria
  80.     {
  81.         $filters = [];
  82.         foreach ($payloads as $payload) {
  83.             $filters[] = new AndFilter([
  84.                 new EqualsFilter('pageId', $payload['id']),
  85.                 new EqualsFilter('draftVersion', $payload['versionId']),
  86.             ]);
  87.         }
  89.         $criteria = new Criteria();
  90.         $criteria->addFilter(new MultiFilter(MultiFilter::CONNECTION_OR, $filters));
  92.         return $criteria;
  93.     }
  94. }