Node.js - Product Data SDK

import { ProductClient } from "datafiniti-sdk";

const sdk = ProductClient.fromEnv();

const response = await sdk.searchByName("AirPods Pro", {
  brand: "Apple",
});

console.log("
=== NAME SEARCH TEST ===");
console.log("Matches:", response.num_found);

const records = response.records ?? [];

if (records.length) {
  const product = records[0];
  console.log("
Product:");
  console.log(product.name);
  console.log(product.brand);
  console.log(product.categories);
} else {
  console.log("No product found.");
}

import { ProductClient } from "datafiniti-sdk";

const sdk = ProductClient.fromEnv();

const count = await sdk.count('categories:"Laptops" AND brand:"Dell"');

console.log("
=== COUNT TEST ===");
console.log(`Products found: ${count.toLocaleString()}`);

import { ProductClient } from "datafiniti-sdk";

const sdk = ProductClient.fromEnv();

// Chain builder methods to assemble a query, then pass it to search.
// priceRange filters on prices.amountMin: [min TO max].
const query = sdk
  .query()
  .categories(["Laptops"])
  .brand("Dell")
  .priceRange(500, 1500)
  .build();

const response = await sdk.search({ query, numRecords: 5 });

console.log("
=== CATEGORY + PRICE SEARCH ===");
console.log(`Total matches: ${(response.num_found ?? 0).toLocaleString()}`);

const records = response.records ?? [];

for (const product of records) {
  console.log(`
${product.brand} — ${product.name}`);
}

import { ProductClient } from "datafiniti-sdk";

const sdk = ProductClient.fromEnv();

console.log("
=== PAGINATION TEST ===");

let recordsSeen = 0;

for await (const product of sdk.paginate({
  query: 'categories:"Headphones"',
  pageSize: 100,
  maxRecords: 250,
})) {
  recordsSeen += 1;
  console.log(`${recordsSeen}. ${product.name ?? "Unknown Product"}`);
}

console.log(`
Total Retrieved: ${recordsSeen}`);

/**
 * Product Views Example: Price Monitoring
 *
 * Uses a custom view to fetch only the fields needed to compare prices across
 * merchants for a set of products. Requesting a narrow view keeps responses
 * small and fast when you only care about pricing.
 *
 * Reference: https://docs.datafiniti.co/docs/using-a-custom-product-view
 */

import { ProductClient, type DatafinitiRecord } from "datafiniti-sdk";

// ---------------------------------------------------------------------------
// View options
//
// OPTION 1 (used below): Custom inline view
//   Pass an array of field objects directly in the request. No setup required.
//
// OPTION 2: Premade (named) view — pass a string instead of an array.
//   "default"  All fields (same as omitting view entirely).
//   Example: sdk.search({ query, view: "default", numRecords: 10 })
//   Reference: https://docs.datafiniti.co/docs/product-data-views
// ---------------------------------------------------------------------------

const PRODUCT_VIEW = [
  { name: "name" },
  { name: "brand" },
  { name: "categories" },
  { name: "prices" },
];

interface PriceEntry {
  amountMin?: string | number;
  currency?: string;
  merchant?: string;
  condition?: string;
}

function lowestPrice(prices: unknown): PriceEntry | null {
  if (!Array.isArray(prices) || prices.length === 0) return null;
  const entries = prices as PriceEntry[];
  return entries.reduce((lowest, entry) => {
    const current = Number(entry.amountMin);
    const best = Number(lowest.amountMin);
    return Number.isFinite(current) && current < best ? entry : lowest;
  });
}

async function checkPrices(sdk: ProductClient, name: string, brand: string) {
  const query = sdk.query().name(name).brand(brand).build();
  const response = await sdk.search({ query, numRecords: 1, view: PRODUCT_VIEW });
  const records = response.records ?? [];
  return records.length ? records[0] : null;
}

async function main() {
  // Products to monitor for pricing.
  const products = [
    { name: "AirPods Pro",         brand: "Apple" },
    { name: "Galaxy Buds2 Pro",    brand: "Samsung" },
    { name: "WH-1000XM5",          brand: "Sony" },
  ];

  const sdk = ProductClient.fromEnv();

  console.log("
=== PRICE MONITORING ===
");

  for (const item of products) {
    console.log(`${item.brand} ${item.name}`);

    const record: DatafinitiRecord | null = await checkPrices(sdk, item.name, item.brand);

    if (record === null) {
      console.log("  No product record found.
");
      continue;
    }

    const best = lowestPrice(record.prices);
    console.log(`  Name:   ${record.name ?? "N/A"}`);
    if (best) {
      console.log(`  Lowest: ${best.amountMin ?? "N/A"} ${best.currency ?? ""} at ${best.merchant ?? "N/A"} (${best.condition ?? "N/A"})`);
    } else {
      console.log("  Lowest: no pricing available");
    }
    console.log();
  }
}

main();

import { ProductClient, DatafinitiApiError } from "datafiniti-sdk";

const sdk = ProductClient.fromEnv();

try {
  const response = await sdk.search({ query: 'categories:"Laptops"', numRecords: 5 });
  console.log(`Matches: ${response.num_found}`);
} catch (err) {
  if (err instanceof DatafinitiApiError) {
    console.error(`API error ${err.statusCode}: ${err.message}`, err.errors);
  } else {
    throw err;
  }
}