Webhook Setup & Configuration

// src/jobs/pollAssessments.ts
const AssessmentClient = require('@recordorg/smartai-assessment-backend');

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

  // ─── 1. Fetch pending events ─────────────────────────────────────
  const { events, pendingCount } = await client.getWebhookEvents({ limit: 50 });

  if (events.length === 0) return;

  console.log(`Fetched ${events.length} events — ${pendingCount} still pending`);

  // ─── 2. Route and save each event ────────────────────────────────
  const processedIds: string[] = [];

  for (const event of events) {
    try {
      if (event.event === 'assessment.sent') {
        // Assessment was sent to candidates — store the invitation
        await saveAssessmentSent(event);

      } else if (event.event === 'assessment.completed') {
        // Candidate submitted — store the result
        await saveAssessmentResult(event);
      }

      processedIds.push(event.eventId);
    } catch (err) {
      console.error(`Failed to save event ${event.eventId}:`, err);
      // Don't push — event stays in queue and retries next poll
    }
  }

  // ─── 3. Acknowledge saved events ─────────────────────────────────
  if (processedIds.length > 0) {
    await client.acknowledgeWebhookEvents(processedIds);
    console.log(`Acknowledged ${processedIds.length} events`);
  }

  // ─── 4. Drain if more events are waiting ─────────────────────────
  if (pendingCount > 0) {
    await pollAssessmentResults();
  }
}

// ─── assessment.sent handler ──────────────────────────────────────────
async function saveAssessmentSent(event: any) {
  // event.candidates is an array — one record per candidate
  for (const candidate of event.candidates) {
    await db.assessmentInvitations.upsert({
      where:  { eventId: event.eventId, candidateEmail: candidate.email },
      create: {
        eventId:       event.eventId,
        assessmentId:  event.assessmentId,
        assessmentUrl: event.assessmentUrl,  // URL to send to the candidate
        jobTitle:      event.jobTitle,
        orgId:         event.orgId,
        candidateId:   candidate.id,
        candidateName: candidate.name,
        candidateEmail:candidate.email,
        totalCandidates: event.totalCandidates,
        storedAt:      new Date(event.storedAt),
      },
      update: {},
    });
  }
}

// ─── Start the poller when your server boots ─────────────────────────
export function startAssessmentPoller() {
  setInterval(async () => {
    try {
      await pollAssessmentResults();
    } catch (err) {
      console.error('Assessment poller error:', err);
    }
  }, 30_000);

  pollAssessmentResults().catch(console.error);
  console.log('✓ Assessment result poller started (every 30s)');
}

# jobs/poll_assessments.py
from smartai_assessment_backend import AssessmentClient
import os
import time
import threading

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

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

    if not events:
        return

    print(f"Fetched {len(events)} events — {pending_count} still pending")

    processed_ids = []

    for event in events:
        try:
            if event.get("event") == "assessment.sent":
                save_assessment_sent(event)
            elif event.get("event") == "assessment.completed":
                save_assessment_result(event)

            processed_ids.append(event["eventId"])
        except Exception as err:
            print(f"Failed to save event {event['eventId']}: {err}")

    if processed_ids:
        client.acknowledge_webhook_events(processed_ids)
        print(f"Acknowledged {len(processed_ids)} events")

    if pending_count > 0:
        poll_assessment_results()  # drain remaining


def start_assessment_poller():
    def run():
        while True:
            try:
                poll_assessment_results()
            except Exception as err:
                print(f"Assessment poller error: {err}")
            time.sleep(30)

    thread = threading.Thread(target=run, daemon=True)
    thread.start()
    print("✓ Assessment result poller started (every 30s)")

from fastapi import FastAPI
from jobs.poll_assessments import start_assessment_poller

app = FastAPI()

@app.on_event("startup")
def startup():
    start_assessment_poller()  # ← add this