SmartAI Assessment

npm install @recordorg/smartai-assessment-backend

pip install smartai-assessment-backend

const AssessmentClient = require('@recordorg/smartai-assessment-backend');

app.post('/assessment/session', yourAuthMiddleware, async (req, res) => {
  const client = new AssessmentClient({
    apiKey:    process.env.ASSESSMENT_API_KEY,
    secretKey: process.env.ASSESSMENT_SECRET_KEY,
  });

  // users — array of { name, email }
  const { users, recruiterId, recruiterEmail } = req.body;

  if (!users?.length) {
    return res.status(400).json({ success: false, message: 'No candidates provided' });
  }

  if (!recruiterId && !recruiterEmail) {
    return res.status(400).json({ success: false, message: 'Provide at least one of recruiterId or recruiterEmail' });
  }

  const session = await client.createSession({
    users,           // [{ name, email }, ...]
    recruiterId,     // optional — pass one or both
    recruiterEmail,  // optional — pass one or both
  });

  res.json({ success: true, data: session });
});

from fastapi import FastAPI, HTTPException
from smartai_assessment_backend import AssessmentClient
from pydantic import BaseModel
import os

app = FastAPI()

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

class User(BaseModel):
    name: str
    email: str

class SessionRequest(BaseModel):
    users: list[User]
    recruiter_id: str | None = None
    recruiter_email: str | None = None

@app.post("/assessment/session")
def create_session(body: SessionRequest):
    if not body.users:
        raise HTTPException(status_code=400, detail="No candidates provided")

    if not body.recruiter_id and not body.recruiter_email:
        raise HTTPException(
            status_code=400,
            detail="Provide at least one of recruiter_id or recruiter_email",
        )

    users = [{"name": u.name, "email": u.email} for u in body.users]
    session = client.create_session(
        users=users,
        recruiter_id=body.recruiter_id,         # pass recruiter_id
        recruiter_email=body.recruiter_email,   # or recruiter_email — at least one required
    )
    return {"success": True, "data": session}

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

  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));
  }
}

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

import time
from smartai_assessment_backend import AssessmentClient
import os

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