Stale Lead SLA Monitor & Unassigned Alerting

export default async function main(input: {
  slaDays?: number
  slackAlertWebhook?: string
  contactId?: string
  [key: string]: unknown
}): Promise<{
  scanned: number
  breachedCount: number
  breachedContactIds: string[]
}> {
  const rawInput = (Array.isArray(input) ? input[0] : input) || {}
  const contactId = (rawInput.contactId || rawInput.contact_id || rawInput.objectId || (rawInput.object && (rawInput.object as Record<string, unknown>).objectId) || rawInput.hs_object_id) as string | undefined

  const slaDays = input.slaDays ?? 5
  const cutoffTime = Date.now() - (slaDays * 24 * 60 * 60 * 1000)

  let contactsToScan: Array<{ id: string; properties: Record<string, string> }> = []

  if (contactId) {
    const c = await hubspot.client.crm.contacts.basicApi.getById(
      contactId,
      ['email', 'firstname', 'lastname', 'hs_lead_status', 'createdate', 'notes_last_contacted', 'hubspot_owner_id']
    )
    contactsToScan = [c]
  } else {
    // Query contacts in NEW or OPEN lead status
    const contacts = await hubspot.client.crm.contacts.basicApi.getPage(
      100,
      0,
      ['email', 'firstname', 'lastname', 'hs_lead_status', 'createdate', 'notes_last_contacted', 'hubspot_owner_id']
    )
    contactsToScan = contacts.results
  }

  const breachedContactIds: string[] = []

  for (const contact of contactsToScan) {
    const status = (contact.properties.hs_lead_status || '').toUpperCase()
    const isUnworked = !status || status === 'NEW' || status === 'OPEN' || status === 'UNQUALIFIED'
    const createdAt = contact.properties.createdate ? new Date(contact.properties.createdate).getTime() : 0
    const lastContacted = contact.properties.notes_last_contacted ? new Date(contact.properties.notes_last_contacted).getTime() : 0

    if (isUnworked && createdAt > 0 && createdAt < cutoffTime && lastContacted === 0) {
      breachedContactIds.push(contact.id)
      await hubspot.client.crm.contacts.basicApi.update(contact.id, {
        properties: {
          lead_sla_breached: 'true',
          lead_sla_breach_date: new Date().toISOString(),
        },
      })
    }
  }

  if (breachedContactIds.length > 0 && input.slackAlertWebhook) {
    await http.post(input.slackAlertWebhook, {
      text: `⚠️ *SLA Alert:* ${breachedContactIds.length} lead(s) have exceeded the ${slaDays}-day response SLA without contact.`,
    })
  }

  return {
    scanned: contactsToScan.length,
    breachedCount: breachedContactIds.length,
    breachedContactIds,
  }
}