import { isMedusaError } from 'lib/type-guards'; import { mapOptionIds } from 'lib/utils'; import { calculateVariantAmount, computeAmount, convertToDecimal } from './helpers'; import { Cart, CartItem, MedusaCart, MedusaLineItem, MedusaProduct, MedusaProductCollection, MedusaProductOption, MedusaProductVariant, Product, ProductCollection, ProductOption, ProductVariant, SelectedOption } from './types'; const ENDPOINT = process.env.NEXT_PUBLIC_MEDUSA_BACKEND_API; export default async function medusaRequest( method: string, path = '', payload?: Record | undefined ) { const options: RequestInit = { method, headers: { 'Content-Type': 'application/json' } }; if (payload) { options.body = JSON.stringify(payload); } try { const result = await fetch(`${ENDPOINT}${path}`, options); const body = await result.json(); if (body.errors) { throw body.errors[0]; } return { status: result.status, body }; } catch (e) { if (isMedusaError(e)) { throw { status: e.status || 500, message: e.message }; } throw { error: e }; } } const reshapeCart = (cart: MedusaCart): Cart => { const lines = cart?.items?.map((item) => reshapeLineItem(item)) || []; const totalQuantity = lines.reduce((a, b) => a + b.quantity, 0); const checkoutUrl = '/'; const currencyCode = cart.region?.currency_code.toUpperCase() || 'USD'; let subtotalAmount = '0'; if (cart.subtotal && cart.region) { subtotalAmount = computeAmount({ amount: cart.subtotal, region: cart.region }).toString(); } let totalAmount = '0'; if (cart.total && cart.region) { totalAmount = computeAmount({ amount: cart.total, region: cart.region }).toString(); } let totalTaxAmount = '0'; if (cart.tax_total && cart.region) { totalTaxAmount = computeAmount({ amount: cart.tax_total, region: cart.region }).toString(); } const cost = { subtotalAmount: { amount: subtotalAmount, currencyCode: currencyCode }, totalAmount: { amount: totalAmount, currencyCode: currencyCode }, totalTaxAmount: { amount: totalTaxAmount, currencyCode: currencyCode } }; return { ...cart, totalQuantity, checkoutUrl, lines, cost }; }; const reshapeLineItem = (lineItem: MedusaLineItem): CartItem => { const product = { title: lineItem.title, priceRange: { maxVariantPrice: calculateVariantAmount(lineItem.variant) }, updatedAt: lineItem.updated_at, createdAt: lineItem.created_at, tags: [], descriptionHtml: lineItem.description ?? '', featuredImage: { url: lineItem.thumbnail ?? '', altText: lineItem.title ?? '' }, availableForSale: true, variants: [lineItem.variant && reshapeProductVariant(lineItem.variant)], handle: lineItem.variant?.product?.handle ?? '' }; const selectedOptions = lineItem.variant?.options?.map((option) => ({ name: option.option?.title ?? '', value: option.value })) || []; const merchandise = { id: lineItem.variant_id || lineItem.id, selectedOptions, product, title: lineItem.title }; const cost = { totalAmount: { amount: convertToDecimal( lineItem.total, lineItem.variant?.prices?.[0]?.currency_code ).toString(), currencyCode: lineItem.variant?.prices?.[0]?.currency_code.toUpperCase() || 'EUR' } }; const quantity = lineItem.quantity; return { ...lineItem, merchandise, cost, quantity }; }; const reshapeProduct = (product: MedusaProduct): Product => { const variant = product.variants?.[0]; let amount = '0'; let currencyCode = 'USD'; if (variant && variant.prices?.[0]?.amount) { currencyCode = variant.prices?.[0]?.currency_code.toUpperCase() ?? 'USD'; amount = convertToDecimal(variant.prices[0].amount, currencyCode).toString(); } const priceRange = { maxVariantPrice: { amount, currencyCode: product.variants?.[0]?.prices?.[0]?.currency_code.toUpperCase() ?? '' } }; const updatedAt = product.updated_at; const createdAt = product.created_at; const tags = product.tags?.map((tag) => tag.value) || []; const descriptionHtml = product.description ?? ''; const featuredImage = { url: product.thumbnail ?? '', altText: product.title ?? '' }; const availableForSale = product.variants?.[0]?.purchasable || true; const variants = product.variants.map((variant) => reshapeProductVariant(variant, product.options) ); let options; product.options && (options = product.options.map((option) => reshapeProductOption(option))); return { ...product, featuredImage, priceRange, updatedAt, createdAt, tags, descriptionHtml, availableForSale, options, variants }; }; const reshapeProductOption = (productOption: MedusaProductOption): ProductOption => { const availableForSale = productOption.product?.variants?.[0]?.purchasable || true; const name = productOption.title; let values = productOption.values?.map((option) => option.value) || []; values = [...new Set(values)]; return { ...productOption, availableForSale, name, values }; }; const reshapeProductVariant = ( productVariant: MedusaProductVariant, productOptions?: MedusaProductOption[] ): ProductVariant => { let selectedOptions: SelectedOption[] = []; if (productOptions && productVariant.options) { const optionIdMap = mapOptionIds(productOptions); selectedOptions = productVariant.options.map((option) => ({ name: optionIdMap[option.option_id] ?? '', value: option.value })); } const availableForSale = productVariant.purchasable || true; const price = calculateVariantAmount(productVariant); return { ...productVariant, availableForSale, selectedOptions, price }; }; const reshapeCollection = (collection: MedusaProductCollection): ProductCollection => { const description = collection.metadata?.description?.toString() ?? ''; const seo = { title: collection?.metadata?.seo_title?.toString() ?? '', description: collection?.metadata?.seo_description?.toString() ?? '' }; const path = `/${collection.handle}`; const updatedAt = collection.updated_at; return { ...collection, description, seo, path, updatedAt }; }; export async function createCart(): Promise { const res = await medusaRequest('POST', '/carts', {}); return reshapeCart(res.body.cart); } export async function addToCart( cartId: string, lineItem: { variantId: string; quantity: number } ): Promise { const res = await medusaRequest('POST', `/carts/${cartId}/line-items`, { variant_id: lineItem?.variantId, quantity: lineItem?.quantity }); return reshapeCart(res.body.cart); } export async function removeFromCart(cartId: string, lineItemId: string): Promise { const res = await medusaRequest('DELETE', `/carts/${cartId}/line-items/${lineItemId}`); return reshapeCart(res.body.cart); } export async function updateCart( cartId: string, { lineItemId, quantity }: { lineItemId: string; quantity: number } ): Promise { const res = await medusaRequest('POST', `/carts/${cartId}/line-items/${lineItemId}`, { quantity }); return reshapeCart(res.body.cart); } export async function getCart(cartId: string): Promise { const res = await medusaRequest('GET', `/carts/${cartId}`); const cart = res.body.cart; if (!cart) { return null; } return reshapeCart(cart); } export async function getCollection(handle: string): Promise { const res = await medusaRequest('GET', `/collections?handle[]=${handle}&limit=1`); return res.body.collections[0]; } export async function getCollectionProducts(handle: string): Promise { const collection = await getCollection(handle); if (!collection) { return []; } const res = await medusaRequest('GET', `/products?collection_id[]=${collection.id}`); if (!res.body?.products) { return []; } const products: Product[] = res.body.products.map((product: MedusaProduct) => reshapeProduct(product) ); return products; } export async function getCollections(): Promise { const res = await medusaRequest('GET', '/collections'); // Reshape collections and hide collections starting with 'hidden' const collections = res.body.collections .map((collection: MedusaProductCollection) => reshapeCollection(collection)) .filter((collection: MedusaProductCollection) => !collection.handle.startsWith('hidden')); return collections; } export async function getProduct(handle: string): Promise { const res = await medusaRequest('GET', `/products?handle=${handle}&limit=1`); const product = res.body.products[0]; return reshapeProduct(product); } export async function getProducts({ query = '', reverse, sortKey }: { query?: string; reverse?: boolean; sortKey?: string; }): Promise { const res = await medusaRequest('GET', `/products?q=${query}&limit=20`); let products: Product[] = res.body.products.map((product: MedusaProduct) => reshapeProduct(product) ); sortKey === 'PRICE' && products.sort( (a, b) => parseFloat(a.priceRange.maxVariantPrice.amount) - parseFloat(b.priceRange.maxVariantPrice.amount) ); sortKey === 'CREATED_AT' && products.sort((a, b) => new Date(a.createdAt).getTime() - new Date(b.createdAt).getTime()); reverse && products.reverse(); return products; }