GetProducts

import "./extended";
import { getNormalizers } from "@alokai/connect/integration-kit";
import { getLogger } from "@alokai/connect/middleware";

import { defineApi } from "@vsf-enterprise/unified-api-sfcc";

export const getProducts = defineApi.getProducts(async (context, { ids = [], skus = [] }) => {
  const { api } = await context.getApiClient();
  const logger = getLogger(context);
  try {
    // both, ids and skus, may be product ids
    const productIds = [...new Set([...ids, ...skus])];

    const { normalizeProductCatalogItem } = getNormalizers(context);

    const products = await api.getProducts({ ids: productIds, perPricebook: true });
    return {
      products: products.map((product) => normalizeProductCatalogItem(product)),
    };
  } catch (error) {
    logger.error({ error });
    return {
      products: [],
    };
  }
});