Enabling exclusion of identifiersProductId from elastic search aggreg…

…ation
BitBagCommerce · Oct 24, 2024 · ffec3ba · ffec3ba
1 parent 6ebb13f
commit ffec3ba
Showing 1 changed file with 7 additions and 7 deletions.
diff --git a/src/Finder/RelatedProductsByOrderHistoryFinder.php b/src/Finder/RelatedProductsByOrderHistoryFinder.php
@@ -55,7 +55,7 @@ public function findRelatedByChannelAndSlug(
             throw new ProductNotFoundException($slug, $channel, $locale);
         }
 
-        return $this->getRelatedByOrderHistory($product->getId(), $channel, $maxResults);
+        return $this->getRelatedByOrderHistory($product->getId(), $channel, $maxResults, $excludedProductIds);
     }
 
     /**
@@ -65,14 +65,14 @@ protected function getRelatedByOrderHistory(
         int $productId,
         ChannelInterface $channel,
         int $maxResults,
+        array $excludedProductIds = []
     ): array {
-        $products = $this->relatedProductsFinder->findPaginated(
-            $this->queryBuilder->buildQuery($productId),
-        );
+        $products = $this->relatedProductsFinder->findPaginated($this->queryBuilder->buildQuery($productId));
+        $excludedProductIds[] = $productId;
 
         return $this->productRepository->findManyByChannelAndIds(
             $channel,
-            $this->extractProductIds($products, $productId),
+            $this->extractProductIds($products, $excludedProductIds),
             $maxResults,
         );
     }
@@ -82,7 +82,7 @@ protected function getRelatedByOrderHistory(
      *
      * @param Pagerfanta<mixed> $result
      */
-    protected function extractProductIds(Pagerfanta $result, int $excludeId): array
+    protected function extractProductIds(Pagerfanta $result, array $excludedProductIds = []): array
     {
         $result->setMaxPerPage(1);
         $result->setCurrentPage(1);
@@ -97,7 +97,7 @@ protected function extractProductIds(Pagerfanta $result, int $excludeId): array
         $productIds = [];
         foreach ($aggregation['buckets'] as $bucket) {
             $id = $bucket['key'];
-            if ($id === $excludeId) {
+            if (in_array($id, $excludedProductIds, true)) {
                 continue;
             }