[DuplicatesIndex] make sure that found duplicates are removed when customer object is deleted - fixes #7

Author: markus-moser

src/CustomerSaveManager/DefaultCustomerSaveManager.php

@@ -18,6 +18,7 @@
 use CustomerManagementFrameworkBundle\CustomerProvider\CustomerProviderInterface;
 use CustomerManagementFrameworkBundle\CustomerSaveHandler\CustomerSaveHandlerInterface;
 use CustomerManagementFrameworkBundle\CustomerSaveValidator\CustomerSaveValidatorInterface;
+use CustomerManagementFrameworkBundle\DuplicatesIndex\DuplicatesIndexInterface;
 use CustomerManagementFrameworkBundle\Model\CustomerInterface;
 use CustomerManagementFrameworkBundle\Newsletter\Queue\NewsletterQueueInterface;
 use CustomerManagementFrameworkBundle\SegmentManager\SegmentBuilderExecutor\SegmentBuilderExecutorInterface;
@@ -197,6 +198,12 @@ public function postDelete(CustomerInterface $customer)
         $this->addToDeletionsTable($customer);
 
         $this->handleNewsletterQueue($customer, NewsletterQueueInterface::OPERATION_DELETE);
+
+        /**
+         * @var DuplicatesIndexInterface $duplicatesIndex
+         */
+        $duplicatesIndex = \Pimcore::getContainer()->get(DuplicatesIndexInterface::class);
+        $duplicatesIndex->deleteCustomerFromDuplicateIndex($customer);
     }
 
     public function validateOnSave(CustomerInterface $customer, $withDuplicatesCheck = true)

src/DuplicatesIndex/DefaultMariaDbDuplicatesIndex.php

@@ -135,6 +135,12 @@ public function isRelevantForDuplicateIndex(CustomerInterface $customer)
 
     public function deleteCustomerFromDuplicateIndex(CustomerInterface $customer)
     {
+        if (!$this->enableDuplicatesIndex) {
+            $this->getLogger()->debug('duplicate index disabled');
+
+            return;
+        }
+
         $db = Db::get();
         $db->query(
             sprintf('delete from %s where customer_id = ?', self::DUPLICATESINDEX_CUSTOMERS_TABLE),