Polling

const search = await henry.products.search({
	type: 'global',
	filters: { type: 'text', query: 'Nike Air Max' },
	mode: 'sync',
});

// If completed within 30s, result is already populated
if (search.status === 'complete') {
	console.log(search.result?.products);
}

// utils/henry-poll.ts
export async function pollJob<T extends { status: string; refId: string }>(
	initial: T,
	poller: (args: { refId: string }) => Promise<T>,
	options: {
		intervalMs?: number;
		maxAttempts?: number;
	} = {},
): Promise<T> {
	const { intervalMs = 1000, maxAttempts = 60 } = options;

	let result = initial;
	let attempts = 0;

	while ((result.status === 'pending' || result.status === 'processing') && attempts < maxAttempts) {
		await new Promise((r) => setTimeout(r, intervalMs));
		result = await poller({ refId: initial.refId });
		attempts++;
	}

	if (result.status === 'pending' || result.status === 'processing') {
		throw new Error(`Henry request ${initial.refId} timed out after ${maxAttempts} attempts`);
	}

	return result;
}

import HenrySDK from '@henrylabs/sdk';
import { pollJob } from './utils/henry-poll';

const henry = new HenrySDK({ apiKey: process.env.HENRY_SDK_API_KEY! });

const searchResult = await pollJob(
	await henry.products.search({
		type: 'global',
		filters: {
			type: 'text',
			query: 'Nike Air Max',
			sortBy: 'price-low-to-high',
		},
		limit: 20,
	}),
	(args) => henry.products.pollSearch(args),
);

if (searchResult.status !== 'complete') {
	throw new Error(`Search ${searchResult.status}: ${JSON.stringify(searchResult.error)}`);
}

const { products, pagination } = searchResult.result!;
console.log(`Found ${products.length} products`);

const detailResult = await pollJob(
	await henry.products.details({
		link: 'https://www.nike.com/t/air-max-270-shoes/AH8050-002',
	}),
	(args) => henry.products.pollDetails(args),
);

const product = detailResult.result;
console.log(product?.name, product?.price);

const purchaseResult = await pollJob(
	await henry.cart.checkout.purchase('crt_sa2aEsCz9PRM', {
		buyer: {
			name: { firstName: 'Jane', lastName: 'Doe' },
			email: 'jane@example.com',
			phone: '+19175551234',
			shippingAddress: {
				line1: '350 5th Ave',
				city: 'New York',
				province: 'NY',
				postalCode: '10118',
				countryCode: 'US',
			},
			card: {
				nameOnCard: { firstName: 'Jane', lastName: 'Doe' },
				details: {
					cardToken: 'card_live_...',
				},
			},
		},
	}),
	(args) => henry.cart.checkout.pollPurchase(args),
	{ intervalMs: 10000, maxAttempts: 390 }, // ~65 minutes
);

if (purchaseResult.status === 'complete' || purchaseResult.status === 'partially_complete') {
	const { total } = purchaseResult.result!.costs;
	console.log(`Order placed - total: ${total.value} ${total.currency}`);
}