Score Bullhorn candidates with HireLayer

const HIRELAYER = 'https://hirelayer.co'
const headers = { 'X-API-Key': process.env.HIRELAYER_API_KEY! }

// restUrl and BhRestToken come from POST /rest-services/login.
// Reuse the session: do not log in again before every call.
export async function poll(restUrl: string, bhRestToken: string) {
  const bh = (path: string, init?: RequestInit) =>
    fetch(`${restUrl}${path}${path.includes('?') ? '&' : '?'}BhRestToken=${bhRestToken}`, init)
      .then((r) => r.text())
      .then((text) => (text ? JSON.parse(text) : null))

  // Created once: PUT event/subscription/hirelayer?type=entity&names=JobSubmission&eventTypes=INSERTED
  const batch = await bh('event/subscription/hirelayer?maxEvents=100')
  for (const event of batch?.events ?? []) {
    const { data: submission } = await bh(
      `entity/JobSubmission/${event.entityId}?fields=id,candidate,jobOrder`
    )
    const candidateId = submission.candidate.id
    const files = await bh(`entity/Candidate/${candidateId}/fileAttachments?fields=id,name,type`)
    const resume = files.data.find((f: { type: string }) => f.type === 'Resume')
    if (!resume) continue

    // 1. Download (JSON with base64 content) and parse (about 35 s)
    const { File } = await bh(`file/Candidate/${candidateId}/${resume.id}`)
    const form = new FormData()
    form.append('file', new Blob([Buffer.from(File.fileContent, 'base64')]), File.name)
    form.append('application_id', String(submission.id))
    const parsed = await fetch(`${HIRELAYER}/api/v3/parser`, {
      method: 'POST', headers, body: form, signal: AbortSignal.timeout(150_000),
    }).then((r) => r.json())

    // 2. Score with the criteria stored for this job order
    const criteria = await loadCriteria(submission.jobOrder.id)
    const match = await fetch(`${HIRELAYER}/api/v1/matching/job-candidate`, {
      method: 'POST',
      headers: { ...headers, 'Content-Type': 'application/json' },
      body: JSON.stringify({
        job_text: criteria.jobText,
        candidate_text: parsed.info_resume.text,
        matching_criteria: criteria.items,
      }),
    }).then((r) => r.json())

    // 3. Note on the candidate, linked to the job order (PUT creates)
    await bh('entity/Note', {
      method: 'PUT',
      headers: { 'Content-Type': 'application/json' },
      body: JSON.stringify({
        personReference: { id: candidateId },
        commentingPerson: { id: Number(process.env.BULLHORN_USER_ID) },
        jobOrder: { id: submission.jobOrder.id },
        action: 'HireLayer score', // a value of your commentActionList
        comments: `HireLayer score: ${Math.round(match.score * 100)}/100\n${match.summary}`,
      }),
    })
  }
}