chore: remove debug changes

vendure-ecommerce · Dec 10, 2024 · 462b298 · 462b298
1 parent 431c364
commit 462b298
Showing 1 changed file with 7 additions and 10 deletions.
diff --git a/packages/core/src/plugin/default-search-plugin/indexer/indexer.controller.ts b/packages/core/src/plugin/default-search-plugin/indexer/indexer.controller.ts
@@ -400,6 +400,8 @@ export class IndexerController {
     }
 
     private async saveVariants(ctx: MutableRequestContext, variants: ProductVariant[]) {
+        const items: SearchIndexItem[] = [];
+
         await this.removeSyntheticVariants(ctx, variants);
         const productMap = new Map<ID, Product>();
 
@@ -419,8 +421,6 @@ export class IndexerController {
                 ? unique(ctx.channel.availableCurrencyCodes)
                 : [ctx.channel.defaultCurrencyCode];
 
-            const items: SearchIndexItem[] = [];
-
             for (const currencyCode of availableCurrencyCodes) {
                 for (const languageCode of availableLanguageCodes) {
                     const productTranslation = this.getTranslation(product, languageCode);
@@ -445,7 +445,6 @@ export class IndexerController {
                         ctx.setChannel(ch);
 
                         await this.productPriceApplicator.applyChannelPriceAndTax(variant, ctx);
-
                         const item = new SearchIndexItem({
                             channelId: ctx.channelId,
                             languageCode,
@@ -504,18 +503,16 @@ export class IndexerController {
                             );
                             item.productInStock = productInStock;
                         }
-
                         items.push(item);
                     }
                 }
             }
-
-            ctx.setChannel(originalChannel);
-
-            await this.queue.push(() =>
-                this.connection.rawConnection.getRepository(SearchIndexItem).save(items, { chunk: 2500 }),
-            );
         }
+        ctx.setChannel(originalChannel);
+
+        await this.queue.push(() =>
+            this.connection.getRepository(ctx, SearchIndexItem).save(items, { chunk: 2500 }),
+        );
     }
 
     /**