atRisk()

churn.atRisk(options?: AtRiskOptions): Promise<AtRiskResult>

interface AtRiskResult {
  users: AtRiskUser[]
  total: number    // total matching users (across all pages)
  offset: number
  limit: number
}

interface AtRiskUser {
  userId: string
  score: number
  tier: RiskTier
  signals: string[]
  recommendation: string
}

const { users, total } = await churn.atRisk({ threshold: 0.7 })

console.log(`${total} high-risk users`)
for (const user of users) {
  console.log(user.userId, user.score, user.signals)
}

// Only enterprise users above 0.5 risk
const { users } = await churn.atRisk({
  threshold: 0.5,
  plan: 'enterprise',
})

async function getAllAtRisk(threshold = 0.7): Promise<AtRiskUser[]> {
  const all: AtRiskUser[] = []
  let offset = 0

  while (true) {
    const { users, total } = await churn.atRisk({ threshold, limit: 100, offset })
    all.push(...users)
    offset += users.length
    if (offset >= total) break
  }

  return all
}

// cron: every night at 9pm
const { users, total } = await churn.atRisk({ threshold: 0.65, limit: 200 })

await sendSlackMessage({
  channel: '#customer-success',
  text: `🚨 ${total} at-risk users tonight`,
  blocks: users.slice(0, 10).map((u) => ({
    userId: u.userId,
    score: (u.score * 100).toFixed(0) + '%',
    signals: u.signals.join(', '),
  })),
})