bulk_verify.js

/**
 * Bulk verify emails using the OrbiSearch API.
 */

const API_KEY = "your_api_key_here";
const BASE_URL = "https://api.orbisearch.com";

/**
 * Submit a bulk verification job.
 * @param {string[]} emails - Array of email addresses
 * @returns {Promise<object>} Job submission response
 */
async function submitBulkJob(emails) {
  const response = await fetch(`${BASE_URL}/v1/bulk`, {
    method: "POST",
    headers: {
      "X-API-Key": API_KEY,
      "Content-Type": "application/json",
    },
    body: JSON.stringify(emails),
  });

  if (!response.ok) {
    throw new Error(`HTTP ${response.status}: ${response.statusText}`);
  }

  return response.json();
}

/**
 * Get the status of a bulk job.
 * @param {string} jobId - Job ID
 * @returns {Promise<object>} Job status
 */
async function getJobStatus(jobId) {
  const response = await fetch(`${BASE_URL}/v1/bulk/${jobId}`, {
    headers: { "X-API-Key": API_KEY },
  });

  if (!response.ok) {
    throw new Error(`HTTP ${response.status}: ${response.statusText}`);
  }

  return response.json();
}

/**
 * Get the results of a completed bulk job.
 * @param {string} jobId - Job ID
 * @returns {Promise<object>} Job results
 */
async function getJobResults(jobId) {
  const response = await fetch(`${BASE_URL}/v1/bulk/${jobId}/results`, {
    headers: { "X-API-Key": API_KEY },
  });

  if (!response.ok) {
    throw new Error(`HTTP ${response.status}: ${response.statusText}`);
  }

  return response.json();
}

/**
 * Sleep for a given number of milliseconds.
 * @param {number} ms - Milliseconds to sleep
 */
function sleep(ms) {
  return new Promise(resolve => setTimeout(resolve, ms));
}

/**
 * Verify a list of emails and wait for results.
 * @param {string[]} emails - Array of email addresses
 * @param {number} pollInterval - Seconds between status checks
 * @returns {Promise<object[]>} Array of verification results
 */
async function verifyBulk(emails, pollInterval = 5) {
  // Submit the job
  const job = await submitBulkJob(emails);
  console.log(`Job submitted: ${job.job_id}`);
  console.log(`Total emails: ${job.total_emails}`);
  console.log(`Estimated cost: ${job.estimated_cost} credits`);

  // Poll for completion
  while (true) {
    const status = await getJobStatus(job.job_id);
    console.log(`Status: ${status.status} (${status.emails_processed}/${status.total_emails})`);

    if (status.status === "complete") {
      break;
    } else if (status.status === "failed") {
      throw new Error("Job failed");
    }

    await sleep(pollInterval * 1000);
  }

  // Get results
  const results = await getJobResults(job.job_id);
  return results.results;
}

// Example usage
async function main() {
  const emails = [
    "john@company.com",
    "jane@company.com",
    "info@company.com",
  ];

  try {
    const results = await verifyBulk(emails);

    for (const result of results) {
      console.log(`${result.email}: ${result.status} (${result.substatus || "n/a"})`);
    }
  } catch (error) {
    console.error("Error:", error.message);
  }
}

main();