Syncing Data

async function initialSync(apiKey) {
	const contracts = [];
	let cursor = null;

	do {
		const url = new URL("https://prod-api.civicmarketplace.com/v1/contracts");
		url.searchParams.set("limit", "100");
		if (cursor) url.searchParams.set("cursor", cursor);

		const res = await fetch(url, {
			headers: { Authorization: `Bearer ${apiKey}` },
		});
		const page = await res.json();

		contracts.push(...page.data);
		cursor = page.meta.next_cursor;
	} while (cursor);

	// Store contracts and record the current timestamp
	await saveContracts(contracts);
	await saveLastSyncTime(new Date().toISOString());
}

async function incrementalSync(apiKey) {
	const lastSync = await getLastSyncTime();
	const updated = [];
	let cursor = null;

	do {
		const url = new URL("https://prod-api.civicmarketplace.com/v1/contracts");
		url.searchParams.set("limit", "100");
		url.searchParams.set("updated_since", lastSync);
		if (cursor) url.searchParams.set("cursor", cursor);

		const res = await fetch(url, {
			headers: { Authorization: `Bearer ${apiKey}` },
		});
		const page = await res.json();

		updated.push(...page.data);
		cursor = page.meta.next_cursor;
	} while (cursor);

	await upsertContracts(updated);
	await saveLastSyncTime(new Date().toISOString());
}

curl "https://prod-api.civicmarketplace.com/v1/suppliers?updated_since=2026-04-20T00:00:00Z&limit=100" \
  -H "Authorization: Bearer cmp_live_YOUR_KEY"