Deal Health Score Calculator

export default async function main(input: {
  dealId?: string
  [key: string]: unknown
}): Promise<{ processed: number; scored: number; errors: string[] }> {
  const rawInput = (Array.isArray(input) ? input[0] : input) || {}
  const dealId = (rawInput.dealId || rawInput.deal_id || rawInput.objectId || (rawInput.object && (rawInput.object as Record<string, unknown>).objectId) || rawInput.hs_object_id) as string | undefined

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

  if (dealId) {
    const deal = await hubspot.client.crm.deals.basicApi.getById(
      dealId,
      ['dealname', 'amount', 'dealstage', 'closedate', 'hs_lastmodifieddate', 'hubspot_owner_id']
    )
    dealList = [deal]
  } else {
    // Fetch active open deals
    const deals = await hubspot.client.crm.deals.basicApi.getPage(
      100,
      0,
      ['dealname', 'amount', 'dealstage', 'closedate', 'hs_lastmodifieddate', 'hubspot_owner_id']
    )
    dealList = deals.results
  }

  const now = Date.now()
  const errors: string[] = []
  let scored = 0

  for (const deal of dealList) {
    try {
      let healthScore = 100

      // Inactivity penalty
      const lastModified = deal.properties.hs_lastmodifieddate
        ? new Date(deal.properties.hs_lastmodifieddate).getTime()
        : now
      if (now - lastModified > 30 * 86400 * 1000) {
        healthScore -= 20
      }

      // Past due close date penalty
      const closeDate = deal.properties.closedate
        ? new Date(deal.properties.closedate).getTime()
        : null
      if (closeDate && closeDate < now) {
        healthScore -= 35
      }

      // Unassigned penalty
      if (!deal.properties.hubspot_owner_id) {
        healthScore -= 25
      }

      healthScore = Math.max(0, Math.min(100, healthScore))

      await hubspot.client.crm.deals.basicApi.update(deal.id, {
        properties: {
          deal_health_score: healthScore.toString(),
          health_score_calculated_at: new Date().toISOString(),
        },
      })
      scored++
    } catch (err) {
      errors.push(`Failed to update deal ${deal.id}: ${err}`)
    }
  }

  return { processed: dealList.length, scored, errors }
}