[GraphQL] Compare products

app/code/Magento/Catalog/Controller/Product/Compare/Remove.php

@@ -7,6 +7,7 @@
 namespace Magento\Catalog\Controller\Product\Compare;
 
 use Magento\Catalog\Model\Product\Attribute\Source\Status;
+use Magento\Catalog\Model\ResourceModel\Product\Compare\Item\Collection;
 use Magento\Framework\App\Action\HttpPostActionInterface as HttpPostActionInterface;
 use Magento\Framework\Exception\NoSuchEntityException;
 

app/code/Magento/Catalog/Model/CompareList.php

@@ -0,0 +1,24 @@
+<?php
+/**
+ * Copyright © Magento, Inc. All rights reserved.
+ * See COPYING.txt for license details.
+ */
+
+declare(strict_types=1);
+
+namespace Magento\Catalog\Model;
+
+use Magento\Framework\Model\AbstractModel;
+
+class CompareList extends AbstractModel
+{
+    /**
+     * Initialize resource
+     *
+     * @return void
+     */
+    protected function _construct()
+    {
+        $this->_init(ResourceModel\Product\Compare\CompareList::class);
+    }
+}

app/code/Magento/Catalog/Model/CompareListIdToMaskedListId.php

@@ -0,0 +1,58 @@
+<?php
+/**
+ * Copyright © Magento, Inc. All rights reserved.
+ * See COPYING.txt for license details.
+ */
+declare(strict_types=1);
+
+namespace Magento\Catalog\Model;
+
+use Magento\Catalog\Model\ResourceModel\Product\Compare\CompareList as CompareListResource;
+use Magento\Framework\Exception\LocalizedException;
+
+/**
+ *  CompareListId to MaskedListId resolver
+ */
+class CompareListIdToMaskedListId
+{
+    /**
+     * @var CompareListFactory
+     */
+    private $compareListFactory;
+
+    /**
+     * @var CompareListResource
+     */
+    private $compareListResource;
+
+    /**
+     * @param CompareListFactory $compareListFactory
+     * @param CompareListResource $compareListResource
+     */
+    public function __construct(
+        CompareListFactory $compareListFactory,
+        CompareListResource $compareListResource
+    ) {
+        $this->compareListFactory = $compareListFactory;
+        $this->compareListResource = $compareListResource;
+    }
+
+    /**
+     * Get listIdMask by listId
+     *
+     * @param int $listId
+     *
+     * @param int|null $customerId
+     * @return null|string
+     * @throws LocalizedException
+     */
+    public function execute(int $listId, int $customerId = null): ?string
+    {
+        $compareList = $this->compareListFactory->create();
+        $this->compareListResource->load($compareList, $listId, 'list_id');
+        if ((int)$compareList->getCustomerId() !== (int)$customerId) {
+            throw new LocalizedException(__('This customer is not authorized to access this list'));
+        }
+        return $compareList->getListIdMask() ?? null;
+    }
+}

app/code/Magento/Catalog/Model/MaskedListIdToCompareListId.php

@@ -0,0 +1,57 @@
+<?php
+/**
+ * Copyright © Magento, Inc. All rights reserved.
+ * See COPYING.txt for license details.
+ */
+declare(strict_types=1);
+
+namespace Magento\Catalog\Model;
+
+use Magento\Catalog\Model\ResourceModel\Product\Compare\CompareList as CompareListResource;
+use Magento\Framework\Exception\LocalizedException;
+
+/**
+ * MaskedListId to ListId resolver
+ */
+class MaskedListIdToCompareListId
+{
+    /**
+     * @var CompareListFactory
+     */
+    private $compareListFactory;
+
+    /**
+     * @var CompareListResource
+     */
+    private $compareListResource;
+
+    /**
+     * @param CompareListFactory $compareListFactory
+     * @param CompareListResource $compareListResource
+     */
+    public function __construct(
+        CompareListFactory $compareListFactory,
+        CompareListResource $compareListResource
+    ) {
+        $this->compareListFactory = $compareListFactory;
+        $this->compareListResource = $compareListResource;
+    }
+
+    /**
+     * Get maskedId by listId
+     *
+     * @param string $maskedListId
+     * @param int $customerId
+     * @return int
+     * @throws LocalizedException
+     */
+    public function execute(string $maskedListId, int $customerId = null): int
+    {
+        $compareList = $this->compareListFactory->create();
+        $this->compareListResource->load($compareList, $maskedListId, 'list_id_mask');
+        if ((int)$compareList->getCustomerId() !== (int)$customerId) {
+            throw new LocalizedException(__('This customer is not authorized to access this list'));
+        }
+        return (int)$compareList->getListId();
+    }
+}

app/code/Magento/Catalog/Model/ResourceModel/Product/Compare/CompareList.php

@@ -0,0 +1,25 @@
+<?php
+/**
+ * Copyright © Magento, Inc. All rights reserved.
+ * See COPYING.txt for license details.
+ */
+
+declare(strict_types=1);
+
+namespace Magento\Catalog\Model\ResourceModel\Product\Compare;
+
+use Magento\Framework\Model\ResourceModel\Db\AbstractDb;
+
+/**
+ * Compare List resource class
+ */
+class CompareList extends AbstractDb
+{
+    /**
+     * @inheritdoc
+     */
+    protected function _construct()
+    {
+        $this->_init('catalog_compare_list', 'list_id');
+    }
+}

app/code/Magento/Catalog/Model/ResourceModel/Product/Compare/Item.php

@@ -45,6 +45,10 @@ public function loadByProduct(\Magento\Catalog\Model\Product\Compare\Item $objec
             $select->where('visitor_id = ?', (int)$object->getVisitorId());
         }
 
+        if ($object->getListId()) {
+            $select->where('list_id = ?', (int)$object->getListId());
+        }
+
         $data = $connection->fetchRow($select);
 
         if (!$data) {
@@ -140,6 +144,7 @@ public function purgeVisitorByCustomer($object)
 
     /**
      * Update (Merge) customer data from visitor
+     *
      * After Login process
      *
      * @param \Magento\Catalog\Model\Product\Compare\Item $object

app/code/Magento/Catalog/Model/ResourceModel/Product/Compare/Item/Collection.php

@@ -31,6 +31,13 @@ class Collection extends \Magento\Catalog\Model\ResourceModel\Product\Collection
      */
     protected $_visitorId = 0;
 
+    /**
+     * List Id Filter
+     *
+     * @var int
+     */
+    protected $listId = 0;
+
     /**
      * Comparable attributes cache
      *
@@ -156,6 +163,30 @@ public function setCustomerId($customerId)
         return $this;
     }
 
+    /**
+     * Set listId filter to collection
+     *
+     * @param int $listId
+     *
+     * @return $this
+     */
+    public function setListId(int $listId)
+    {
+        $this->listId = $listId;
+        $this->_addJoinToSelect();
+        return $this;
+    }
+
+    /**
+     * Retrieve listId filter applied to collection
+     *
+     * @return int
+     */
+    public function getListId(): int
+    {
+        return (int)$this->listId;
+    }
+
     /**
      * Set visitor filter to collection
      *
@@ -204,6 +235,10 @@ public function getConditionForJoin()
             return ['visitor_id' => $this->getVisitorId()];
         }
 
+        if ($this->getListId()) {
+            return ['list_id' => $this->getListId()];
+        }
+
         return ['customer_id' => ['null' => true], 'visitor_id' => '0'];
     }
 
@@ -232,6 +267,82 @@ public function _addJoinToSelect()
         return $this;
     }
 
+    /**
+     * Get products ids by for compare list
+     *
+     * @param int $listId
+     *
+     * @return array
+     */
+    public function getProductsByListId(int $listId): array
+    {
+        $select = $this->getConnection()->select()->
+        from(
+            $this->getTable('catalog_compare_item'),
+            'product_id'
+        )->where(
+            'list_id = ?',
+            $listId
+        );
+        return $this->getConnection()->fetchCol($select);
+    }
+
+
+    /**
+     * Set list_id for customer compare item
+     *
+     * @param int $listId
+     * @param int $customerId
+     */
+    public function setListIdToCustomerCompareItems(int $listId, int $customerId)
+    {
+        foreach ($this->getCustomerCompareItems($customerId) as $itemId) {
+            $this->getConnection()->update(
+                $this->getTable('catalog_compare_item'),
+                ['list_id' => $listId],
+                ['catalog_compare_item_id = ?' => (int)$itemId]
+            );
+        }
+    }
+
+    /**
+     * Remove compare list if customer compare list empty
+     *
+     * @param int|null $customerId
+     */
+    public function removeCompareList(?int $customerId)
+    {
+        if (empty($this->getCustomerCompareItems($customerId))) {
+            $this->getConnection()->delete(
+                $this->getTable('catalog_compare_list'),
+                ['customer_id = ?' => $customerId]
+            );
+        }
+    }
+
+    /**
+     * Get customer compare items
+     *
+     * @param int|null $customerId
+     * @return array
+     */
+    private function getCustomerCompareItems(?int $customerId): array
+    {
+        if ($customerId) {
+            $select = $this->getConnection()->select()->
+            from(
+                $this->getTable('catalog_compare_item')
+            )->where(
+                'customer_id = ?',
+                $customerId
+            );
+
+            return $this->getConnection()->fetchCol($select);
+        }
+
+        return [];
+    }
+
     /**
      * Retrieve comapre products attribute set ids
      *

app/code/Magento/Catalog/etc/db_schema.xml

@@ -547,6 +547,8 @@
                 default="0" comment="Product ID"/>
         <column xsi:type="smallint" name="store_id" unsigned="true" nullable="true" identity="false"
                 comment="Store ID"/>
+        <column xsi:type="int" name="list_id" padding="10" unsigned="true" nullable="true" identity="false"
+                comment="List ID"/>
         <constraint xsi:type="primary" referenceId="PRIMARY">
             <column name="catalog_compare_item_id"/>
         </constraint>
@@ -558,6 +560,8 @@
                     referenceColumn="entity_id" onDelete="CASCADE"/>
         <constraint xsi:type="foreign" referenceId="CATALOG_COMPARE_ITEM_STORE_ID_STORE_STORE_ID" table="catalog_compare_item"
                     column="store_id" referenceTable="store" referenceColumn="store_id" onDelete="SET NULL"/>
+        <constraint xsi:type="foreign" referenceId="CATALOG_COMPARE_ITEM_LIST_ID_CATALOG_COMPARE_LIST_LIST_ID" table="catalog_compare_item"
+                    column="list_id" referenceTable="catalog_compare_list" referenceColumn="list_id" onDelete="CASCADE"/>
         <index referenceId="CATALOG_COMPARE_ITEM_PRODUCT_ID" indexType="btree">
             <column name="product_id"/>
         </index>
@@ -573,6 +577,25 @@
             <column name="store_id"/>
         </index>
     </table>
+    <table name="catalog_compare_list" resource="default" engine="innodb" comment="Catalog Compare List with hash Table">
+        <column xsi:type="int" name="list_id" padding="10" unsigned="true" nullable="false"
+                identity="true" comment="Compare List ID"/>
+        <column xsi:type="varchar" name="list_id_mask" nullable="true" length="32" comment="Masked ID"/>
+        <column xsi:type="int" name="customer_id" padding="10" unsigned="true" nullable="true" identity="false"
+                comment="Customer ID"/>
+        <constraint xsi:type="primary" referenceId="PRIMARY">
+            <column name="list_id"/>
+        </constraint>
+        <constraint xsi:type="unique" referenceId="CATALOG_COMPARE_LIST_CUSTOMER_ID">
+            <column name="customer_id"/>
+        </constraint>
+        <constraint xsi:type="foreign" referenceId="CATALOG_COMPARE_LIST_CUSTOMER_ID_CUSTOMER_ENTITY_ENTITY_ID"
+                    table="catalog_compare_list" column="customer_id" referenceTable="customer_entity"
+                    referenceColumn="entity_id" onDelete="CASCADE"/>
+        <index referenceId="CATALOG_COMPARE_LIST_LIST_ID_MASK" indexType="btree">
+            <column name="list_id_mask"/>
+        </index>
+    </table>
     <table name="catalog_product_website" resource="default" engine="innodb"
            comment="Catalog Product To Website Linkage Table">
         <column xsi:type="int" name="product_id" unsigned="true" nullable="false" identity="false"