Monitors API Reference

import Exa from "exa-js";
const exa = new Exa(process.env.EXA_API_KEY);

// 1. Create monitor
const monitor = await exa.monitors.create({
  search: {
    query: "AI startups that raised Series A funding",
    numResults: 10
  },
  webhook: {
    url: "https://example.com/webhook"
  }
});

// Store the webhook secret for signature verification — only returned on creation
// See: Webhook Signature Verification section
console.log(monitor.webhookSecret);

// 2. Trigger a run and poll for results
await exa.monitors.trigger(monitor.id);

let latest;
while (true) {
  const runs = await exa.monitors.runs.list(monitor.id);
  latest = runs.data[0];
  if (latest.status === "completed" || latest.status === "failed") break;
  await new Promise(r => setTimeout(r, 2000));
}

// 3. Print results
if (latest.status === "completed" && latest.output) {
  const run = await exa.monitors.runs.get(monitor.id, latest.id);
  for (const result of run.output.results) {
    console.log(`- ${result.title}: ${result.url}`);
  }
}

# 1. Create monitor
curl -X POST "https://api.exa.ai/monitors" \
  -H "Content-Type: application/json" \
  -H "x-api-key: $EXA_API_KEY" \
  -d '{
    "search": {
      "query": "AI startups that raised Series A funding",
      "numResults": 10
    },
    "webhook": {
      "url": "https://example.com/webhook"
    }
  }'

# 2. Trigger a run (replace MONITOR_ID with the id from the create response)
curl -X POST "https://api.exa.ai/monitors/{MONITOR_ID}/trigger" \
  -H "x-api-key: $EXA_API_KEY"

# 3. List runs to check status
curl "https://api.exa.ai/monitors/{MONITOR_ID}/runs" \
  -H "x-api-key: $EXA_API_KEY"

import crypto from "crypto";

function verifyWebhook(payload, header, secret) {
  const parts = Object.fromEntries(
    header.split(",").map(p => p.split("=", 2))
  );
  const signedPayload = `${parts.t}.${payload}`;
  const expected = crypto
    .createHmac("sha256", secret)
    .update(signedPayload)
    .digest("hex");

  const a = Buffer.from(expected);
  const b = Buffer.from(parts.v1 || "");
  if (a.length !== b.length) return false;
  return crypto.timingSafeEqual(a, b);
}

// Iterate through all monitors (async generator)
for await (const monitor of exa.monitors.listAll({ status: "active" })) {
  console.log(monitor.id);
}

// Collect all monitors into an array
const allMonitors = await exa.monitors.getAll({ status: "active" });

// Iterate through all runs for a monitor
for await (const run of exa.monitors.runs.listAll(monitorId)) {
  console.log(run.id, run.status);
}

// Collect all runs into an array
const allRuns = await exa.monitors.runs.getAll(monitorId);

import Exa from "exa-js";
const exa = new Exa(process.env.EXA_API_KEY);

// 1. Create
const monitor = await exa.monitors.create({
  name: "Funding Tracker",
  search: {
    query: "AI startups that raised Series A funding",
    numResults: 10,
    contents: {
      highlights: true
    }
  },
  trigger: {
    type: "interval",
    period: "7d"
  },
  webhook: {
    url: "https://example.com/webhook",
    events: ["monitor.run.completed"]
  }
});
console.log(`Created: ${monitor.id}`);
console.log(`Secret: ${monitor.webhookSecret}`); // Store this!

// 2. Trigger a test run
await exa.monitors.trigger(monitor.id);

// 3. Poll for completion
let latest;
while (true) {
  const runs = await exa.monitors.runs.list(monitor.id);
  latest = runs.data[0];
  if (latest.status === "completed" || latest.status === "failed") break;
  await new Promise(r => setTimeout(r, 2000));
}

// 4. Fetch results
if (latest.status === "completed") {
  const run = await exa.monitors.runs.get(monitor.id, latest.id);
  if (run.output?.results) {
    for (const result of run.output.results) {
      console.log(`- ${result.title}: ${result.url}`);
    }
  }
} else {
  console.log(`Failed: ${latest.failReason}`);
}

// 5. Pause when not needed
await exa.monitors.update(monitor.id, { status: "paused" });

// 6. Delete when done
await exa.monitors.delete(monitor.id);