import { AmazonScraperAPI } from 'amazon-scraper-api-sdk';

const asa = new AmazonScraperAPI(process.env.ASA_API_KEY!);

const product = await asa.product({ query: 'B09HN3Q81F', domain: 'com' });

console.log(product.title);
// "Apple AirPods Pro (2nd Generation)..."
console.log(product.price);
// { current: 199.00, currency: 'USD', was: 249.00 }
console.log(product.rating.average, product.rating.count);
// 4.7 58214

const results = await asa.search({
  query: 'wireless headphones',
  domain: 'co.uk',
  sort_by: 'avg_customer_review',
  pages: 1,
});

for (const r of results.results) {
  console.log(r.position, r.asin, r.title, r.price?.current);
}

const batch = await asa.createBatch({
  endpoint: 'amazon.product',
  items: [
    { query: 'B09HN3Q81F', domain: 'com' },
    { query: 'B000ALVUM6', domain: 'de', language: 'de_DE' },
    // ... up to 1,000 items
  ],
  webhook_url: 'https://your.server/webhooks/asa',
});

console.log('batch id:', batch.id);
// SAVE THIS. The webhook signing secret is returned only once:
console.log('webhook secret:', batch.webhook_signature_secret);

// Alternatively poll:
const status = await asa.getBatch(batch.id);
console.log(`${status.processed_count}/${status.total_count} processed`);

import { verifyWebhookSignature } from 'amazon-scraper-api-sdk';

// Express / Fastify / Hono. Read the RAW body, not the parsed JSON.
app.post('/webhooks/asa', async (req, res) => {
  const signature = req.header('X-ASA-Signature');
  const rawBody = req.rawBody;
  const valid = await verifyWebhookSignature(signature, rawBody, process.env.WEBHOOK_SECRET!);
  if (!valid) return res.status(401).send('invalid signature');
  const { id, status, results } = req.body;
  // process results safely
});

try {
  await asa.product({ query: 'INVALID_ASIN', domain: 'com' });
} catch (err) {
  if (err.code === 'INSUFFICIENT_CREDITS') {
    // top up
  } else if (err.code === 'RATE_LIMITED') {
    await sleep(err.retryAfterMs);
  } else {
    throw err;
  }
}

class AmazonScraperAPI {
  constructor(apiKey: string, opts?: { baseUrl?: string; timeoutMs?: number; fetchImpl?: typeof fetch });

  product(params: {
    query: string;                            // ASIN or Amazon URL
    domain?: 'com' | 'co.uk' | 'de' | string; // 20 marketplaces
    language?: string;                        // 'en_US', 'de_DE', etc.
    add_html?: boolean;                       // include raw HTML in response
    country?: string;                         // residential IP country (ISO-2)
  }): Promise<AmazonProduct>;

  search(params: {
    query: string;
    domain?: AmazonDomain;
    sort_by?: 'best_match' | 'price_asc' | 'price_desc' | 'avg_customer_review' | 'newest';
    start_page?: number;
    pages?: number;
  }): Promise<AmazonSearchResult>;

  createBatch(params: {
    endpoint: 'amazon.product' | 'amazon.search';
    items: Array<Record<string, unknown>>;
    webhook_url?: string;
  }): Promise<BatchCreateResponse>;

  getBatch(id: string): Promise<BatchStatusResponse>;
}