Fix super slow products… finally !!!

unchainedshop · Nov 6, 2024 · 7931d34 · 7931d34
1 parent 3367045
commit 7931d34
Show file tree

Hide file tree

Showing 5 changed files with 19 additions and 30 deletions.
diff --git a/packages/core-filters/src/module/configureFilterSearchModule.ts b/packages/core-filters/src/module/configureFilterSearchModule.ts
@@ -101,17 +101,12 @@ export const configureFilterSearchModule = ({
           return leftIndex - rightIndex;
         });
 
-        const relevantProducts = await modules.products.findProducts(
-          {
-            productSelector,
-            productIds: totalProductIds,
-            includeDrafts: searchQuery.includeInactive,
-          },
-          {
-            projection: { _id: 1 },
-          },
-        );
-        const relevantProductIds = relevantProducts.map(({ _id }) => _id);
+        const relevantProductIds = await modules.products.findProductIds({
+          productSelector,
+          productIds: totalProductIds,
+          includeDrafts: searchQuery.includeInactive,
+        });
+
         return Promise.all(
           sortedFilters.map(async (filter) => {
             return loadFilter(

diff --git a/packages/core-filters/src/module/configureFiltersModule.ts b/packages/core-filters/src/module/configureFiltersModule.ts
@@ -72,19 +72,10 @@ export const configureFiltersModule = async ({
     );
 
     if (!productSelector) return [];
-    const products = await modules.products.findProducts(
-      {
-        productSelector,
-        includeDrafts: true,
-        sort: [],
-        offset: 0,
-        limit: 0,
-      },
-      {
-        projection: { _id: true },
-      },
-    );
-    return products.map(({ _id }) => _id);
+    return modules.products.findProductIds({
+      productSelector,
+      includeDrafts: true,
+    });
   };
 
   const buildProductIdMap = async (

diff --git a/packages/core-products/src/module/configureProductsModule.ts b/packages/core-products/src/module/configureProductsModule.ts
@@ -209,19 +209,24 @@ export const configureProductsModule = async ({
       return Products.findOne(selector, {});
     },
 
-    findProducts: async ({ limit, offset, sort, ...query }) => {
+    findProducts: async ({ limit, offset, sort, ...query }, options) => {
       const defaultSortOption: Array<SortOption> = [
         { key: 'sequence', value: SortDirection.ASC },
         { key: 'published', value: SortDirection.DESC },
       ];
       const products = Products.find(buildFindSelector(query), {
+        ...(options || {}),
         limit,
         skip: offset,
         sort: buildSortOptions(sort || defaultSortOption),
       });
       return products.toArray();
     },
 
+    findProductIds: async (query) => {
+      return Products.distinct('_id', buildFindSelector(query));
+    },
+
     count: async (query) => {
       return Products.countDocuments(buildFindSelector(query));
     },

diff --git a/packages/plugins/src/worker/zombie-killer.ts b/packages/plugins/src/worker/zombie-killer.ts
@@ -53,11 +53,7 @@ export const ZombieKillerWorker: IWorkerAdapter<
       });
 
       // Remove unreferenced product entities
-      const products = await modules.products.findProducts(
-        { includeDrafts: true },
-        { projection: { _id: 1 } },
-      );
-      const productIds = products.map((a) => a._id);
+      const productIds = await modules.products.findProductIds({ includeDrafts: true });
       const deletedProductTextsCount = await modules.products.texts.deleteMany({
         excludedProductIds: productIds,
       });

diff --git a/packages/types/products.ts b/packages/types/products.ts
@@ -181,6 +181,8 @@ export type ProductsModule = {
     options?: FindOptions,
   ) => Promise<Array<Product>>;
 
+  findProductIds: (params: ProductQuery) => Promise<Array<string>>;
+
   count: (query: ProductQuery) => Promise<number>;
   productExists: (params: { productId?: string; slug?: string }) => Promise<boolean>;