Add E2E tests for bundle pricing and fix feed token handling

Adds bundle-pricing.spec.ts covering 10 scenarios: both tax configs, all
Channable tax settings, fixed bundles, and OOS stock impact.

Stops feed tests from overwriting Channable token in config (broke order
tests). Sets default tax destination to NL in CI setup for correct
getTaxPrice() behavior in feed context.

Author: Marvin-Magmodules

.github/workflows/templates/magento/configure-channable.sh

@@ -25,6 +25,12 @@ bin/magento config:set tax/calculation/cross_border_trade_enabled 0
 bin/magento config:set tax/calculation/based_on shipping
 bin/magento config:set tax/calculation/algorithm TOTAL_BASE_CALCULATION
 
+# Default tax destination — must match shipping origin so getTaxPrice() resolves
+# the correct rate when no customer is logged in (e.g. feed generation context)
+bin/magento config:set tax/defaults/country NL
+bin/magento config:set tax/defaults/region 0
+bin/magento config:set tax/defaults/postcode '1000 AA'
+
 # Tax display settings
 bin/magento config:set tax/display/type 2
 bin/magento config:set tax/display/shipping 2

E2E-TESTS.md

@@ -50,6 +50,36 @@ Channable periodically polls Magento for order status updates and shipment infor
 | Shipments — recent order | Returns shipment array for known orders |
 | Shipments — LVB with tracking | Shipped order includes tracking information |
 
+## Bundle Pricing
+
+Dynamic bundle products derive their prices from their children rather than having a fixed price. This test suite validates that the feed correctly reports bundle prices across different tax configurations. The fix uses indexed prices (`$product->getData('min_price')`) instead of `getBaseAmount()`, matching how configurables are handled and ensuring correct behavior with Magento's `getTaxPrice()`.
+
+Test products are created via REST API: two simple children (€20 + €30, tax class 2), two bundles (one dynamic with two required options, one fixed at €100), and a single-option dynamic bundle for OOS testing. NL 21% tax rules are used.
+
+**Group A: Catalog prices including tax** (stored €50 = incl tax)
+
+| Test | Channable Config | Assert |
+|------|------------------|--------|
+| Dynamic, add tax on | `tax=1` | price = 50.00, min_price = 50.00 |
+| Dynamic, add tax off | `tax=0` | price = 50.00, min_price = 50.00 |
+| Dynamic, include both | `tax=1, tax_include_both=1` | price_incl = 50.00, price_excl ≈ 41.32 |
+| Fixed, add tax on | `tax=1` | price = 100.00 |
+
+**Group B: Catalog prices excluding tax** (stored €50 = excl tax, incl = €60.50)
+
+| Test | Channable Config | Assert |
+|------|------------------|--------|
+| Dynamic, add tax on | `tax=1` | price ≈ 60.50, min_price ≈ 60.50 |
+| Dynamic, add tax off | `tax=0` | price = 50.00, min_price = 50.00 |
+| Dynamic, include both | `tax=1, tax_include_both=1` | price_incl ≈ 60.50, price_excl = 50.00 |
+| Fixed, add tax on | `tax=1` | price ≈ 121.00 |
+
+**Group C: Stock scenarios** (prices incl tax)
+
+| Test | Setup | Assert |
+|------|-------|--------|
+| Dynamic (single option), OOS child | child-b set OOS + reindex | min_price = 20.00 (only in-stock child) |
+
 ## Upcoming: Feed Generation
 
 The next suite of E2E tests will cover feed generation — validating that product data is correctly exported to Channable based on attribute mapping, category filters, and feed configuration. This will include tests for price rendering, image URLs, stock status, and custom attribute handling.
@@ -74,4 +104,5 @@ Run a specific suite:
 npx playwright test tests/order/cross-border-tax.spec.ts
 npx playwright test tests/order/order-import.spec.ts
 npx playwright test tests/order/webhooks.spec.ts
+npx playwright test tests/feed/bundle-pricing.spec.ts
 ```

Test/End-2-end/support/services/ChannableApi.ts

@@ -5,6 +5,7 @@
 
 import * as fs from 'fs';
 import * as path from 'path';
+import { execSync } from 'child_process';
 import BaseApi from './BaseApi';
 
 export default class ChannableApi extends BaseApi {
@@ -191,4 +192,169 @@ export default class ChannableApi extends BaseApi {
 
     this.flushAllCaches();
   }
+
+  /**
+   * Create a product via the Magento REST API.
+   */
+  async createProduct(baseURL: string, payload: any): Promise<any> {
+    const token = process.env.admin_token;
+    const url = `${baseURL}rest/all/V1/products`;
+
+    const response = await fetch(url, {
+      method: 'POST',
+      headers: {
+        'Content-Type': 'application/json',
+        'Authorization': `Bearer ${token}`,
+      },
+      body: JSON.stringify({ product: payload }),
+    });
+
+    if (!response.ok) {
+      const text = await response.text();
+      throw new Error(`Failed to create product ${payload.sku}: ${response.status} - ${text}`);
+    }
+
+    return response.json();
+  }
+
+  /**
+   * Delete a product by SKU via the Magento REST API.
+   */
+  async deleteProduct(baseURL: string, sku: string): Promise<void> {
+    const token = process.env.admin_token;
+    const url = `${baseURL}rest/all/V1/products/${encodeURIComponent(sku)}`;
+
+    const response = await fetch(url, {
+      method: 'DELETE',
+      headers: { 'Authorization': `Bearer ${token}` },
+    });
+
+    if (!response.ok && response.status !== 404) {
+      const text = await response.text();
+      throw new Error(`Failed to delete product ${sku}: ${response.status} - ${text}`);
+    }
+  }
+
+  /**
+   * Set stock status and quantity for a product by SKU.
+   */
+  async setStockStatus(baseURL: string, sku: string, qty: number, inStock: boolean): Promise<void> {
+    const token = process.env.admin_token;
+    const url = `${baseURL}rest/all/V1/products/${encodeURIComponent(sku)}`;
+
+    const response = await fetch(url, {
+      method: 'PUT',
+      headers: {
+        'Content-Type': 'application/json',
+        'Authorization': `Bearer ${token}`,
+      },
+      body: JSON.stringify({
+        product: {
+          sku,
+          extension_attributes: {
+            stock_item: {
+              qty,
+              is_in_stock: inStock,
+            },
+          },
+        },
+      }),
+    });
+
+    if (!response.ok) {
+      const text = await response.text();
+      throw new Error(`Failed to set stock for ${sku}: ${response.status} - ${text}`);
+    }
+  }
+
+  /**
+   * Reindex catalog prices via docker exec.
+   */
+  reindexPrices(): void {
+    if (!this.container) {
+      throw new Error('MAGENTO_CONTAINER env var is required for reindexing');
+    }
+
+    execSync(
+      `docker exec ${this.container} bin/magento indexer:reindex catalog_product_price cataloginventory_stock`,
+      { stdio: 'pipe', timeout: 120000 }
+    );
+    console.log('Price index rebuilt.');
+  }
+
+  /**
+   * Full reindex of all indexers + cache flush via docker exec.
+   */
+  reindexAll(): void {
+    if (!this.container) {
+      throw new Error('MAGENTO_CONTAINER env var is required for reindexing');
+    }
+
+    execSync(
+      `docker exec ${this.container} bin/magento indexer:reindex`,
+      { stdio: 'pipe', timeout: 120000 }
+    );
+    this.flushAllCaches();
+    console.log('Full reindex + cache flush done.');
+  }
+
+  /**
+   * Fetch a single product from the Channable feed by product ID.
+   */
+  async getFeedProduct(baseURL: string, pid: number, storeId: number = 1): Promise<any> {
+    const token = process.env.CHANNABLE_TOKEN || 'e2e-test-token';
+    const url = `${baseURL}channable/feed/json?id=${storeId}&token=${token}&pid=${pid}`;
+
+    const response = await fetch(url, {
+      headers: { 'Accept': 'application/json' },
+    });
+
+    if (!response.ok) {
+      throw new Error(`Feed request failed: ${response.status}`);
+    }
+
+    const body = await response.json() as any;
+
+    // ?pid= returns {"products": {"product": {...}, "feed": {...}}}
+    // ?page= returns {"products": [...]}
+    const productsNode = body.products;
+
+    if (!productsNode) {
+      throw new Error(`Product ${pid} not found in feed (no products key)`);
+    }
+
+    // Single product via ?pid= — return the processed feed object
+    if (productsNode.feed) {
+      return productsNode.feed;
+    }
+
+    // Array from ?page=
+    if (Array.isArray(productsNode) && productsNode.length > 0) {
+      return productsNode[0];
+    }
+
+    throw new Error(`Product ${pid} not found in feed`);
+  }
+
+  /**
+   * Get the Magento entity ID for a product by SKU (via REST API).
+   */
+  async getProductId(baseURL: string, sku: string): Promise<number> {
+    const token = process.env.admin_token;
+    const url = `${baseURL}rest/all/V1/products/${encodeURIComponent(sku)}`;
+
+    const response = await fetch(url, {
+      headers: {
+        'Authorization': `Bearer ${token}`,
+        'Accept': 'application/json',
+      },
+    });
+
+    if (!response.ok) {
+      throw new Error(`Product ${sku} not found: ${response.status}`);
+    }
+
+    const data = await response.json() as any;
+    return data.id;
+  }
 }