forked from crowetic/commerce
82 lines
2.5 KiB
TypeScript
82 lines
2.5 KiB
TypeScript
import type {
|
|
OperationContext,
|
|
OperationOptions,
|
|
} from '@commerce/api/operations'
|
|
import type {
|
|
GetCustomerWishlistOperation,
|
|
Wishlist,
|
|
} from '../../types/wishlist'
|
|
import type { RecursivePartial, RecursiveRequired } from '../utils/types'
|
|
import { BigcommerceConfig, Provider } from '..'
|
|
import getAllProducts, { ProductEdge } from './get-all-products'
|
|
|
|
export default function getCustomerWishlistOperation({
|
|
commerce,
|
|
}: OperationContext<Provider>) {
|
|
async function getCustomerWishlist<
|
|
T extends GetCustomerWishlistOperation
|
|
>(opts: {
|
|
variables: T['variables']
|
|
config?: BigcommerceConfig
|
|
includeProducts?: boolean
|
|
}): Promise<T['data']>
|
|
|
|
async function getCustomerWishlist<T extends GetCustomerWishlistOperation>(
|
|
opts: {
|
|
variables: T['variables']
|
|
config?: BigcommerceConfig
|
|
includeProducts?: boolean
|
|
} & OperationOptions
|
|
): Promise<T['data']>
|
|
|
|
async function getCustomerWishlist<T extends GetCustomerWishlistOperation>({
|
|
config,
|
|
variables,
|
|
includeProducts,
|
|
}: {
|
|
url?: string
|
|
variables: T['variables']
|
|
config?: BigcommerceConfig
|
|
includeProducts?: boolean
|
|
}): Promise<T['data']> {
|
|
config = commerce.getConfig(config)
|
|
|
|
const { data = [] } = await config.storeApiFetch<
|
|
RecursivePartial<{ data: Wishlist[] }>
|
|
>(`/v3/wishlists?customer_id=${variables.customerId}`)
|
|
const wishlist = data[0]
|
|
|
|
if (includeProducts && wishlist?.items?.length) {
|
|
const ids = wishlist.items
|
|
?.map((item) => (item?.product_id ? String(item?.product_id) : null))
|
|
.filter((id): id is string => !!id)
|
|
|
|
if (ids?.length) {
|
|
const graphqlData = await commerce.getAllProducts({
|
|
variables: { first: 50, ids },
|
|
config,
|
|
})
|
|
// Put the products in an object that we can use to get them by id
|
|
const productsById = graphqlData.products.reduce<{
|
|
[k: number]: ProductEdge
|
|
}>((prods, p) => {
|
|
prods[Number(p.id)] = p as any
|
|
return prods
|
|
}, {})
|
|
// Populate the wishlist items with the graphql products
|
|
wishlist.items.forEach((item) => {
|
|
const product = item && productsById[item.product_id!]
|
|
if (item && product) {
|
|
// @ts-ignore Fix this type when the wishlist type is properly defined
|
|
item.product = product
|
|
}
|
|
})
|
|
}
|
|
}
|
|
|
|
return { wishlist: wishlist as RecursiveRequired<typeof wishlist> }
|
|
}
|
|
|
|
return getCustomerWishlist
|
|
}
|