Push Home Service Data into CRM and Field Service Tools

import { createHsdClient } from "hsd-client-sdk";
import type { HsdDatasetKey } from "hsd-client-sdk";

const hsd = createHsdClient({
  apiKey: process.env.HSD_API_KEY!,
  baseUrl: "https://homeservicedata.com",
});

// Step 1 — Seed your database from a full snapshot
async function seedFromSnapshot(dataset: HsdDatasetKey) {
  const snapshot = await hsd.getSnapshot(dataset, {
    trade: "hvac",
    quoteSafeOnly: true,
  });

  // snapshot.records — all current records
  // snapshot.sync.cursor — store this for delta polling
  await db.upsertMany("hsd_cache", snapshot.records);
  await db.setCursor(dataset, snapshot.sync.cursor);

  console.log(`Seeded ${snapshot.records.length} records for ${dataset}`);
}

// Step 2 — Poll for changes using the stored cursor
async function applyChanges(dataset: HsdDatasetKey) {
  const cursor = await db.getCursor(dataset);
  if (!cursor) {
    return seedFromSnapshot(dataset);
  }

  const delta = await hsd.getChanges(dataset, cursor);

  for (const change of delta.changes) {
    if (change.operation === "delete") {
      await db.delete("hsd_cache", change.record_id);
    } else {
      // upsert and supersede both write the latest payload
      await db.upsert("hsd_cache", change.record_id, change.payload);
    }
  }

  // Always persist the updated cursor
  await db.setCursor(dataset, delta.latest_cursor);

  console.log(`Applied ${delta.changes.length} changes for ${dataset}`);
}