import {z} from 'zod' export type GetApiV1AmazonProductsAsinArgs = {asin: string, domain?: string | undefined, zip?: string | undefined, language?: string | undefined}; export type GetApiV1AmazonProductsAsinOptions = {baseUrl?: string | undefined, apiKey?: string | undefined, fetch?: typeof fetch | undefined}; export const amazonPrice = z.object({value: z.number().nullable().optional(), currency: z.string().nullable().optional(), symbol: z.string().nullable().optional(), raw: z.string().nullable().optional()}); export const review = z.object({id: z.string().optional(), title: z.string().optional(), body: z.string().optional(), rating: z.number().int().optional(), date_raw: z.string().nullable().optional(), date_utc: z.number().nullable().optional(), date_at: z.string().nullable().optional(), review_country: z.string().nullable().optional(), is_global_review: z.boolean().optional(), profile: z.object({}).optional(), verified_purchase: z.boolean().optional(), vine_program: z.boolean().optional(), helpful_votes: z.number().int().nullable().optional(), variant: z.string().nullable().optional(), images: z.array(z.string()).optional()}); export const product = z.object({asin: z.string().optional(), parent_asin: z.string().nullable().optional(), title: z.string().optional(), link: z.string().optional(), brand: z.string().nullable().optional(), manufacturer: z.string().nullable().optional(), model_number: z.string().nullable().optional(), price: amazonPrice.optional(), list_price: amazonPrice.optional(), savings_amount: amazonPrice.optional(), discount_percent: z.number().int().nullable().optional(), rating: z.number().nullable().optional(), ratings_total: z.number().int().nullable().optional(), rating_breakdown: z.object({}).optional(), bought_past_month: z.string().nullable().optional(), in_stock: z.boolean().optional(), availability: z.string().nullable().optional(), feature_bullets: z.array(z.string()).optional(), description: z.string().nullable().optional(), main_image: z.string().nullable().optional(), images: z.array(z.string()).optional(), images_count: z.number().int().optional(), videos: z.array(z.string()).optional(), videos_count: z.number().int().optional(), has_aplus_content: z.boolean().optional(), variants: z.array(z.object({})).optional(), variant_asins: z.array(z.string()).optional(), categories: z.array(z.object({})).optional(), bestsellers_rank: z.array(z.object({})).optional(), attributes: z.object({}).optional(), specifications: z.object({}).optional(), dimensions: z.string().nullable().optional(), weight: z.string().nullable().optional(), first_available: z.string().nullable().optional(), country_of_origin: z.string().nullable().optional(), buybox: z.object({}).optional(), sold_by: z.string().nullable().optional(), ships_from: z.string().nullable().optional(), fulfilled_by: z.string().nullable().optional(), is_amazon_seller: z.boolean().optional(), badges: z.object({}).optional(), coupon: z.object({}).nullable().optional(), deal: z.object({}).nullable().optional(), delivery: z.object({}).nullable().optional(), frequently_bought_together: z.array(z.string()).optional(), also_bought: z.array(z.string()).optional(), answered_questions: z.number().int().nullable().optional(), top_reviews: z.array(review).optional(), scraped_utc: z.number().optional(), scraped_at: z.string().optional()}); export const getApiV1AmazonProductsAsinResponse = z.object({domain: z.string().optional(), product: product.optional()}); export const validateResponse = async ( schema: { readonly '~standard': { readonly validate: (value: unknown) => ({ readonly value: Output; readonly issues?: undefined } | { readonly issues: ReadonlyArray<{ readonly message: string; readonly path?: ReadonlyArray | undefined }> }) | Promise<{ readonly value: Output; readonly issues?: undefined } | { readonly issues: ReadonlyArray<{ readonly message: string; readonly path?: ReadonlyArray | undefined }> }> } }, value: unknown ): Promise => { const result = await schema['~standard'].validate(value) if (result.issues !== undefined) { const detail = result.issues .map(({ message, path }) => path?.length ? `${path.map((segment) => String(typeof segment === 'object' ? segment.key : segment)).join('.')}: ${message}` : message ) .join('; ') throw new Error(`Response does not match the schema: ${detail}`, { cause: { issues: result.issues } }) } return result.value }; /** * Get Product Detail * * GET /v1/amazon/products/{asin} */ export const getApiV1AmazonProductsAsin = async (args: GetApiV1AmazonProductsAsinArgs, options?: GetApiV1AmazonProductsAsinOptions) => { const {baseUrl = "https://scrapebadger.com", fetch: fetchFn = fetch, apiKey} = options ?? {} const query = new URLSearchParams() const headers = new Headers() headers.set('accept', "application/json") if (args.domain != null) query.append("domain", String(args.domain)) if (args.zip != null) query.append("zip", String(args.zip)) if (args.language != null) query.append("language", String(args.language)) if (apiKey !== undefined) headers.set("x-api-key", apiKey) const url = `${baseUrl.replace(/\/+$/, '')}/v1/amazon/products/${encodeURIComponent(String(args.asin))}${query.size > 0 ? `?${query}` : ''}` const res = await fetchFn(url, {method: "GET", headers}) if (!res.ok) throw new Error(`Request failed with status ${res.status}`, {cause: {status: res.status, body: await res.text()}}) return validateResponse(getApiV1AmazonProductsAsinResponse, await res.json()) };