Quickstart

// The SDK retries automatically, but you can configure behavior:
const client = new CresvaClient({
  apiKey: process.env.CRESVA_API_KEY,
  brandId: process.env.CRESVA_BRAND_ID,
  retries: 3,            // max retry attempts (default: 3)
  retryDelay: 1000,      // initial delay in ms (default: 1000)
  retryBackoff: "exponential", // "exponential" or "linear"
});

// Or handle rate limits manually:
try {
  const results = await client.query({ intent: "search", query: "shoes" });
} catch (err) {
  if (err.status === 429) {
    const retryAfter = err.headers["retry-after"];
    console.log(`Rate limited. Retry after ${retryAfter}s`);
  }
}

const client = new CresvaClient({
  apiKey: process.env.CRESVA_API_KEY,
  brandId: process.env.CRESVA_BRAND_ID,
  debug: true,  // Logs all HTTP requests and responses
});

// You can also listen for specific events:
client.on("request", (req) => {
  console.log(`→ ${req.method} ${req.url}`);
  console.log(`  Headers: ${JSON.stringify(req.headers)}`);
});

client.on("response", (res) => {
  console.log(`← ${res.status} (${res.timing}ms)`);
  console.log(`  Rate limit remaining: ${res.headers["x-ratelimit-remaining"]}`);
});

// file: quickstart.mjs
// Run: node quickstart.mjs
//
// Prerequisites:
//   npm install @cresva/sdk dotenv
//   Create .env with CRESVA_API_KEY and CRESVA_BRAND_ID

import "dotenv/config";
import { CresvaClient } from "@cresva/sdk";

// ── Initialize client ──────────────────────────────────────────
const client = new CresvaClient({
  apiKey: process.env.CRESVA_API_KEY,
  brandId: process.env.CRESVA_BRAND_ID,
  debug: false,  // Set to true to see HTTP logs
  retries: 3,
});

async function main() {
  try {
    // ── Step 1: Search for products ────────────────────────────
    console.log("Searching for wireless headphones...\n");

    const results = await client.query({
      intent: "search",
      query: "wireless headphones under $200",
      filters: {
        price: { max: 200, currency: "USD" },
        in_stock: true,
      },
      limit: 5,
    });

    console.log(`Found ${results.total_results} products (${results.query_time_ms}ms)\n`);

    // ── Step 2: Display results ────────────────────────────────
    for (const product of results.products) {
      console.log(`  ${product.title}`);
      console.log(`    Price:  $${product.price} ${product.currency}`);
      console.log(`    Rating: ${product.reviews_summary?.average ?? "N/A"}/5`);
      console.log(`    Trust:  ${product.trust_score?.tier ?? "unknown"}`);
      console.log(`    URL:    ${product.url}\n`);
    }

    // ── Step 3: Paginate if more results exist ─────────────────
    if (results.has_more) {
      console.log("Fetching next page...\n");

      const page2 = await client.query({
        intent: "search",
        query: "wireless headphones under $200",
        filters: {
          price: { max: 200, currency: "USD" },
          in_stock: true,
        },
        limit: 5,
        cursor: results.next_cursor,
      });

      for (const product of page2.products) {
        console.log(`  ${product.title} - $${product.price}`);
      }
    }

    // ── Step 4: Get a single product recommendation ────────────
    console.log("\nGetting recommendations...\n");

    const recs = await client.query({
      intent: "recommend",
      query: "best noise cancelling headphones for commuting",
      limit: 3,
    });

    for (const product of recs.products) {
      console.log(`  Recommended: ${product.title} ($${product.price})`);
    }

    console.log("\nDone! Your Cresva integration is working.");
  } catch (err) {
    // ── Error handling ─────────────────────────────────────────
    if (err.status === 401) {
      console.error("Authentication failed. Check your CRESVA_API_KEY.");
    } else if (err.status === 429) {
      console.error(`Rate limited. Retry after ${err.headers?.["retry-after"]}s`);
    } else {
      console.error("Unexpected error:", err.message);
      if (err.requestId) {
        console.error(`Request ID: ${err.requestId} (share this with support)`);
      }
    }
    process.exit(1);
  }
}

main();