// Query a dataset you've been granted (returns columns + rows)
const { columns, rows, row_count } = await erdo.queryDataset("acme.sales", {
  query: "SELECT month, revenue FROM data ORDER BY month",
  limit: 1000,
});

// Same query, shaped as objects keyed by column name (usually what you want)
const records = await erdo.queryAsObjects("acme.sales", { limit: 100 });

// File datasets (CSV/Excel) with multiple sheets: pass resource_key to pick one.
// Pass filters to apply the page's filter-bar state server-side.
const sheet = await erdo.queryAsObjects("acme.workbook", {
  resource_key: "Q1",
  filters: erdo.getFilters(),
});

// Discover and inspect datasets
const { datasets } = await erdo.listDatasets({ limit: 50 });
const dataset = await erdo.getDataset("acme.sales");   // schema, columns, resources

// Other resources you can dereference by id
await erdo.getResource("knowledge_object", id);
await erdo.getKnowledgeObject(id);   // { object, links, backlinks, related_objects }
await erdo.getAsk(id);               // a saved shortcut/ask
await erdo.runAsk(id);               // open it in a new thread
const { artifacts } = await erdo.listArtifacts({ type: "html_page", limit: 20 });

// 1. insertRows — direct, RBAC-checked append. Needs a SIGNED-IN viewer and a
//    page deployed with this dataset in writable_dataset_slugs.
await erdo.insertRows("acme.leads", [
  { name: "Ada", email: "[email protected]" },
], { key_column: "email" });          // → { rows_affected }

// 2. submitEvent — the pipeline path. Works for ANONYMOUS public-page visitors
//    too, so it's the right choice for public lead forms and actions.
const res = await erdo.submitEvent(pipelineId, { name, email }, { variant: "signup-form" });
// → { ok, status, body }

// Read (direct, viewer-authorized)
const { value, found, updated_at } = await erdo.kv.get("theme", { partition: "viewer" });
const { items } = await erdo.kv.list({ prefix: "todo:", partition: "shared" });

// Write (direct, RBAC-checked)
await erdo.kv.set("theme", { mode: "dark" }, { partition: "viewer" });
await erdo.kv.delete("todo:42", { partition: "shared" });

// Pass { kv: "slug" } to target a named, org-level store
await erdo.kv.set("count", 1, { partition: "shared", collection: "leaderboard" });

const chan = erdo.channel("cursors");

// Subscribe; returns an unsubscribe function
const off = chan.subscribe((msg) => render(msg));

// Publish to other viewers
await chan.publish({ x, y, user: "Ada" });

// later
off();

erdo.channel("kv.change").subscribe(({ kv, key }) => {
  // re-read the shared value that just changed
  erdo.kv.get(key, { partition: "shared" }).then(applyUpdate);
});

// Live row/event streams (open a subscription, then listen; clean up on unmount)
await erdo.subscribeLiveDataset(datasetId);
const offLive = erdo.onLiveEvent((evt) => append(evt));   // { datasetId, payload }
// later: offLive(); await erdo.unsubscribeLiveDataset(datasetId);

const filters = erdo.getFilters();                 // current filter-bar state
const offFilter = erdo.onFilterChange((f) => refetch(f));

// Scheduled/agent dataset refreshes — re-query when one lands
erdo.getDatasetUpdateVersion();                    // monotonic version token
const offData = erdo.onDatasetChange((e) => refetch()); // { version, datasetIds, updatedAt }

erdo.getTheme();                                   // 'light' | 'dark'
const offTheme = erdo.onThemeChange((t) => setTheme(t));

async function render() {
  const { value } = await erdo.kv.get("count", { partition: "shared" });
  document.getElementById("count").textContent = value ?? 0;
}

document.getElementById("inc").onclick = async () => {
  const { value } = await erdo.kv.get("count", { partition: "shared" });
  await erdo.kv.set("count", (value ?? 0) + 1, { partition: "shared" });
};

// Any viewer's write re-renders for everyone
erdo.channel("kv.change").subscribe(({ key }) => {
  if (key === "count") render();
});

render();