Contact Center Compliance

async function scoreLeadList(phoneNumbers) {
  const response = await fetch('https://scamverify.ai/api/v1/batch/phone', {
    method: 'POST',
    headers: {
      'Authorization': `Bearer ${process.env.SCAMVERIFY_API_KEY}`,
      'Content-Type': 'application/json',
    },
    body: JSON.stringify({
      items: phoneNumbers.map(number => ({ phone_number: number })),
    }),
  });

  const result = await response.json();

  // Categorize leads by risk
  const approved = [];
  const flagged = [];
  const rejected = [];

  for (const item of result.results) {
    if (item.error) {
      flagged.push({ phone: item.phone_number, reason: item.error });
      continue;
    }

    if (item.risk_score >= 60) {
      rejected.push({
        phone: item.phone_number,
        score: item.risk_score,
        reason: item.explanation,
      });
    } else if (item.signals.ftc_complaints > 0 || item.signals.robocall_detected) {
      flagged.push({
        phone: item.phone_number,
        score: item.risk_score,
        ftcComplaints: item.signals.ftc_complaints,
      });
    } else {
      approved.push({
        phone: item.phone_number,
        score: item.risk_score,
        lineType: item.signals.line_type,
      });
    }
  }

  return { approved, flagged, rejected };
}

// Process a lead file in chunks of 50
async function processLeadFile(allNumbers) {
  const results = { approved: [], flagged: [], rejected: [] };

  for (let i = 0; i < allNumbers.length; i += 50) {
    const chunk = allNumbers.slice(i, i + 50);
    const chunkResults = await scoreLeadList(chunk);

    results.approved.push(...chunkResults.approved);
    results.flagged.push(...chunkResults.flagged);
    results.rejected.push(...chunkResults.rejected);
  }

  return results;
}

import requests
import os

def score_lead_list(phone_numbers: list[str]) -> dict:
    response = requests.post(
        "https://scamverify.ai/api/v1/batch/phone",
        headers={
            "Authorization": f"Bearer {os.environ['SCAMVERIFY_API_KEY']}",
            "Content-Type": "application/json",
        },
        json={
            "items": [{"phone_number": n} for n in phone_numbers]
        },
    )
    response.raise_for_status()
    result = response.json()

    approved, flagged, rejected = [], [], []

    for item in result["results"]:
        if "error" in item:
            flagged.append({"phone": item["phone_number"], "reason": item["error"]})
            continue

        if item["risk_score"] >= 60:
            rejected.append({
                "phone": item["phone_number"],
                "score": item["risk_score"],
                "reason": item["explanation"],
            })
        elif item["signals"]["ftc_complaints"] > 0 or item["signals"]["robocall_detected"]:
            flagged.append({
                "phone": item["phone_number"],
                "score": item["risk_score"],
                "ftc_complaints": item["signals"]["ftc_complaints"],
            })
        else:
            approved.append({
                "phone": item["phone_number"],
                "score": item["risk_score"],
                "line_type": item["signals"]["line_type"],
            })

    return {"approved": approved, "flagged": flagged, "rejected": rejected}