const { events, pendingCount } = await client.getWebhookEvents({ limit: 50 });

console.log(`Got ${events.length} events, ${pendingCount} still pending`);

for (const event of events) {
  await saveToYourDatabase(event);
}

if (events.length) {
  await client.acknowledgeWebhookEvents(events.map(e => e.eventId));
}

result = client.get_webhook_events(limit=50)
events = result.get("events", [])
pending_count = result.get("pendingCount", 0)

print(f"Got {len(events)} events, {pending_count} still pending")

for event in events:
    save_to_your_database(event)

if events:
    client.acknowledge_webhook_events([e["eventId"] for e in events])

let hasMore = true;

while (hasMore) {
  const { events, pendingCount } = await client.getWebhookEvents({ limit: 50 });

  for (const event of events) {
    await saveToYourDatabase(event);
  }

  if (events.length) {
    await client.acknowledgeWebhookEvents(events.map(e => e.eventId));
  }

  hasMore = pendingCount > 0;
}

has_more = True

while has_more:
    result = client.get_webhook_events(limit=50)
    events = result.get("events", [])
    pending_count = result.get("pendingCount", 0)

    for event in events:
        save_to_your_database(event)

    if events:
        client.acknowledge_webhook_events([e["eventId"] for e in events])

    has_more = pending_count > 0

async function pollResults() {
  const client = new AssessmentClient({
    apiKey:    process.env.ASSESSMENT_API_KEY,
    secretKey: process.env.ASSESSMENT_SECRET_KEY,
  });

  try {
    const { events } = await client.getWebhookEvents({ limit: 50 });

    for (const event of events) {
      await saveToDatabase(event);
    }

    if (events.length) {
      await client.acknowledgeWebhookEvents(events.map(e => e.eventId));
    }
  } catch (err) {
    console.error('Poll failed:', err);
  }
}

setInterval(pollResults, 30_000);
pollResults();

import os
import time
from smartai_assessment_backend import AssessmentClient

client = AssessmentClient(
    api_key=os.getenv("ASSESSMENT_API_KEY"),
    secret_key=os.getenv("ASSESSMENT_SECRET_KEY"),
)

def poll_results():
    try:
        has_more = True
        while has_more:
            result = client.get_webhook_events(limit=50)
            events = result.get("events", [])
            pending_count = result.get("pendingCount", 0)

            for event in events:
                save_to_database(event)

            if events:
                client.acknowledge_webhook_events([e["eventId"] for e in events])

            has_more = pending_count > 0
    except Exception as err:
        print(f"Poll failed: {err}")

while True:
    poll_results()
    time.sleep(30)  # every 30 seconds

{
  "events": [
    {
      "eventId": "evt_01J9XYZABC",
      "event": "assessment.completed",
      "assessmentId": "asmt_xyz789",
      "candidateId": "cand_abc123",
      "candidateName": "Priya Sharma",
      "candidateEmail": "priya@example.com",
      "assessmentName": "Full Stack Developer Assessment",
      "jobTitle": "Senior Software Engineer",
      "score": 78,
      "totalMarks": 100,
      "passMarks": 60,
      "passed": true,
      "status": "completed",
      "submittedAt": "2026-06-09T10:30:00.000Z",
      "durationMinutes": 45,
      "reportUrl": "https://platform.smartai.app/reports/evt_01J9XYZABC",
      "proctoring": {
        "score": 88,
        "violationCount": 2
      },
      "storedAt": "2026-06-09T10:31:00.000Z"
    }
  ],
  "pendingCount": 3
}

{
  "events": [],
  "pendingCount": 0
}