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

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

await client.acknowledgeWebhookEvents(events.map(e => e.eventId));

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

for event in events:
    save_to_your_database(event)

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

const processedIds: string[] = [];

for (const event of events) {
  try {
    await saveToYourDatabase(event);
    processedIds.push(event.eventId);
  } catch (err) {
    console.error('Failed to save', event.eventId, err);
  }
}

if (processedIds.length) {
  await client.acknowledgeWebhookEvents(processedIds);
}

processed_ids = []

for event in events:
    try:
        save_to_your_database(event)
        processed_ids.append(event["eventId"])
    except Exception as err:
        print(f"Failed to save {event['eventId']}: {err}")
        # Skip — will be re-delivered next poll

if processed_ids:
    client.acknowledge_webhook_events(processed_ids)

await db.collection('assessment_results').updateOne(
  { eventId: event.eventId },
  { $setOnInsert: mapEvent(event) },
  { upsert: true }
);

collection.update_one(
    {"eventId": event["eventId"]},
    {"$setOnInsert": map_event(event)},
    upsert=True,
)

{
  "acknowledged": 2
}