#1724: Support batches processing for synchronization queue messages - updated synchronization consumer and added media content bulk service

Author: yolouiese

app/code/Magento/MediaContentSynchronization/Model/Consume.php

@@ -7,6 +7,8 @@
 
 namespace Magento\MediaContentSynchronization\Model;
 
+use Magento\Framework\Exception\LocalizedException;
+use Magento\MediaContentSynchronizationApi\Api\SynchronizeIdentitiesInterface;
 use Magento\MediaContentSynchronizationApi\Api\SynchronizeInterface;
 
 /**
@@ -19,19 +21,34 @@ class Consume
      */
     private $synchronize;
 
+    /**
+     * @var SynchronizeIdentitiesInterface
+     */
+    private $synchronizeIdentities;
+
     /**
      * @param SynchronizeInterface $synchronize
+     * @param SynchronizeIdentitiesInterface $synchronizeIdentities
      */
-    public function __construct(SynchronizeInterface $synchronize)
-    {
+    public function __construct(
+        SynchronizeInterface $synchronize,
+        SynchronizeIdentitiesInterface $synchronizeIdentities
+    ) {
         $this->synchronize = $synchronize;
+        $this->synchronizeIdentities = $synchronizeIdentities;
     }
 
     /**
      * Run media files synchronization.
+     * @param string[] $message
+     * @throws LocalizedException
      */
-    public function execute() : void
+    public function execute(array $message) : void
     {
         $this->synchronize->execute();
+
+        if (!empty($message)) {
+            $this->synchronizeIdentities->execute($message);
+        }
     }
 }

app/code/Magento/MediaContentSynchronizationApi/Api/SynchronizeIdentitiesInterface.php

@@ -0,0 +1,23 @@
+<?php
+/**
+ * Copyright © Magento, Inc. All rights reserved.
+ * See COPYING.txt for license details.
+ */
+declare(strict_types=1);
+
+namespace Magento\MediaContentSynchronizationApi\Api;
+
+use Magento\MediaContentApi\Api\Data\ContentIdentityInterface;
+
+/**
+ * Synchronize bulk assets and contents
+ */
+interface SynchronizeIdentitiesInterface
+{
+    /**
+     * Synchronize media contents
+     *
+     * @param ContentIdentityInterface[] $contentIdentities
+     */
+    public function execute(array $contentIdentities): void;
+}

app/code/Magento/MediaGallerySynchronization/Model/Consume.php

@@ -7,6 +7,8 @@
 
 namespace Magento\MediaGallerySynchronization\Model;
 
+use Magento\Framework\Exception\LocalizedException;
+use Magento\MediaGallerySynchronizationApi\Api\SynchronizeFilesInterface;
 use Magento\MediaGallerySynchronizationApi\Api\SynchronizeInterface;
 
 /**
@@ -19,19 +21,34 @@ class Consume
      */
     private $synchronize;
 
+    /**
+     * @var SynchronizeFilesInterface
+     */
+    private $synchronizeFiles;
+
     /**
      * @param SynchronizeInterface $synchronize
+     * @param SynchronizeFilesInterface $synchronizeFiles
      */
-    public function __construct(SynchronizeInterface $synchronize)
-    {
+    public function __construct(
+        SynchronizeInterface $synchronize,
+        SynchronizeFilesInterface $synchronizeFiles
+    ) {
         $this->synchronize = $synchronize;
+        $this->synchronizeFiles = $synchronizeFiles;
     }
 
     /**
      * Run media files synchronization.
+     * @param string[] $message
+     * @throws LocalizedException
      */
-    public function execute() : void
+    public function execute(array $message) : void
     {
         $this->synchronize->execute();
+
+        if (!empty($message)) {
+            $this->synchronizeFiles->execute($message);
+        }
     }
 }