test(core,elasticsearch-plugin): Add multi-channel productInStock e2e tests

Author: BibiSebi

packages/core/e2e/default-search-plugin.e2e-spec.ts

@@ -38,6 +38,7 @@ import {
     DeleteProductMutationVariables,
     DeleteProductVariantMutation,
     DeleteProductVariantMutationVariables,
+    GlobalFlag,
     LanguageCode,
     ReindexMutation,
     RemoveProductsFromChannelMutation,
@@ -1941,6 +1942,134 @@ describe('Default search plugin', () => {
             });
         });
     });
+
+    // https://github.com/vendurehq/community-plugins/issues/1
+    describe('multi-channel productInStock cache', () => {
+        const STOCK_CHANNEL_TOKEN = 'stock-test-channel-token';
+        let stockTestChannelId: string;
+        let testProductId: string;
+
+        beforeAll(async () => {
+            adminClient.setChannelToken(E2E_DEFAULT_CHANNEL_TOKEN);
+            await adminClient.asSuperAdmin();
+
+            // Create a second channel for testing stock isolation
+            const { createChannel } = await adminClient.query<
+                CreateChannelMutation,
+                CreateChannelMutationVariables
+            >(CREATE_CHANNEL, {
+                input: {
+                    code: 'stock-test-channel',
+                    token: STOCK_CHANNEL_TOKEN,
+                    defaultLanguageCode: LanguageCode.en,
+                    currencyCode: CurrencyCode.GBP,
+                    pricesIncludeTax: true,
+                    defaultTaxZoneId: 'T_2',
+                    defaultShippingZoneId: 'T_1',
+                },
+            });
+            stockTestChannelId = (createChannel as ChannelFragment).id;
+
+            // Create a product with a variant that has stock in the default channel
+            const { createProduct } = await adminClient.query<
+                CreateProductMutation,
+                CreateProductMutationVariables
+            >(CREATE_PRODUCT, {
+                input: {
+                    translations: [
+                        {
+                            languageCode: LanguageCode.en,
+                            name: 'Stock Test Product',
+                            slug: 'stock-test-product',
+                            description: 'A product for testing multi-channel stock',
+                        },
+                    ],
+                },
+            });
+            testProductId = createProduct.id;
+
+            await adminClient.query<CreateProductVariantsMutation, CreateProductVariantsMutationVariables>(
+                CREATE_PRODUCT_VARIANTS,
+                {
+                    input: [
+                        {
+                            productId: testProductId,
+                            sku: 'STOCK-TEST-1',
+                            price: 1000,
+                            stockOnHand: 100,
+                            trackInventory: GlobalFlag.TRUE,
+                            translations: [{ languageCode: LanguageCode.en, name: 'Stock Test Variant' }],
+                        },
+                    ],
+                },
+            );
+            await awaitRunningJobs(adminClient);
+
+            // Assign the product to the second channel (no stock location there)
+            await adminClient.query<
+                AssignProductsToChannelMutation,
+                AssignProductsToChannelMutationVariables
+            >(ASSIGN_PRODUCT_TO_CHANNEL, {
+                input: { channelId: stockTestChannelId, productIds: [testProductId] },
+            });
+            await awaitRunningJobs(adminClient);
+
+            // Reindex default channel first
+            adminClient.setChannelToken(E2E_DEFAULT_CHANNEL_TOKEN);
+            await adminClient.query<ReindexMutation>(REINDEX);
+            await awaitRunningJobs(adminClient);
+
+            // Reindex the second channel
+            adminClient.setChannelToken(STOCK_CHANNEL_TOKEN);
+            await adminClient.query<ReindexMutation>(REINDEX);
+            await awaitRunningJobs(adminClient);
+        });
+
+        it('product is inStock in default channel', async () => {
+            shopClient.setChannelToken(E2E_DEFAULT_CHANNEL_TOKEN);
+            const result = await shopClient.query<
+                SearchProductsShopQuery,
+                SearchProductsShopQueryVariablesExt
+            >(SEARCH_PRODUCTS_SHOP, {
+                input: {
+                    term: 'Stock Test Product',
+                    groupByProduct: true,
+                    inStock: true,
+                },
+            });
+            expect(result.search.items.map(i => i.productName)).toContain('Stock Test Product');
+        });
+
+        it('product is NOT inStock in second channel (no stock location)', async () => {
+            shopClient.setChannelToken(STOCK_CHANNEL_TOKEN);
+            const result = await shopClient.query<
+                SearchProductsShopQuery,
+                SearchProductsShopQueryVariablesExt
+            >(SEARCH_PRODUCTS_SHOP, {
+                input: {
+                    term: 'Stock Test Product',
+                    groupByProduct: true,
+                    inStock: true,
+                },
+            });
+            expect(result.search.items.map(i => i.productName)).not.toContain('Stock Test Product');
+        });
+
+        it('product appears when filtering inStock: false in second channel', async () => {
+            shopClient.setChannelToken(STOCK_CHANNEL_TOKEN);
+            const result = await shopClient.query<
+                SearchProductsShopQuery,
+                SearchProductsShopQueryVariablesExt
+            >(SEARCH_PRODUCTS_SHOP, {
+                input: {
+                    term: 'Stock Test Product',
+                    groupByProduct: true,
+                    inStock: false,
+                },
+            });
+            expect(result.search.items.map(i => i.productName)).toContain('Stock Test Product');
+        });
+    });
 });
 
 export const REINDEX = gql`

packages/elasticsearch-plugin/e2e/elasticsearch-plugin.e2e-spec.ts

@@ -1672,6 +1672,21 @@ describe('Elasticsearch plugin', () => {
             );
             expect(result.search.items.map(i => i.productName)).not.toContain('Stock Test Product');
         });
+
+        it('product appears when filtering inStock: false in second channel', async () => {
+            shopClient.setChannelToken(STOCK_CHANNEL_TOKEN);
+            const result = await shopClient.query<SearchProductsShopQuery, SearchProductShopVariables>(
+                SEARCH_PRODUCTS_SHOP,
+                {
+                    input: {
+                        term: 'Stock Test Product',
+                        groupByProduct: true,
+                        inStock: false,
+                    },
+                },
+            );
+            expect(result.search.items.map(i => i.productName)).toContain('Stock Test Product');
+        });
     });
 });