Lead Routing

export default async function main(input: {
  email?: string
  contactId?: string
  company?: string
  [key: string]: unknown
}): Promise<{ ownerId: string; assigned: boolean; assignedCount?: number; details?: 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
  let email = (rawInput.email || (rawInput.fields && (rawInput.fields as Record<string, unknown>).email) || (rawInput.properties && (rawInput.properties as Record<string, unknown>).email)) as string | undefined

  const owners = await hubspot.client.crm.owners.ownersApi.getPage()
  const availableOwners = owners.results.filter((o) => o.archived !== true)

  if (availableOwners.length === 0) {
    return { ownerId: 'unassigned', assigned: false, details: 'No active HubSpot owners found' }
  }

  if (contactId && !email) {
    const contact = await hubspot.client.crm.contacts.basicApi.getById(contactId, ['email', 'hubspot_owner_id'])
    email = contact.properties.email
    if (contact.properties.hubspot_owner_id) {
      return { ownerId: contact.properties.hubspot_owner_id, assigned: true, details: `Contact ${contactId} already assigned` }
    }
  }

  if (contactId) {
    const targetOwner = availableOwners[0]
    await hubspot.client.crm.contacts.basicApi.update(contactId, {
      properties: { hubspot_owner_id: targetOwner.id },
    })
    return { ownerId: targetOwner.id, assigned: true, details: `Assigned Contact ${contactId} to owner ${targetOwner.email || targetOwner.id}` }
  }

  if (email) {
    const contacts = await hubspot.client.crm.contacts.basicApi.getPage(
      1, 0, ['email', 'hubspot_owner_id'], undefined, undefined, [{ value: email, propertyName: 'email', operator: 'EQ' }]
    )
    if (contacts.results.length > 0) {
      const contact = contacts.results[0]
      if (contact.properties.hubspot_owner_id) {
        return { ownerId: contact.properties.hubspot_owner_id, assigned: true, details: `Contact ${email} already assigned` }
      }
      const targetOwner = availableOwners[0]
      await hubspot.client.crm.contacts.basicApi.update(contact.id, {
        properties: { hubspot_owner_id: targetOwner.id },
      })
      return { ownerId: targetOwner.id, assigned: true, details: `Assigned Contact ${contact.id} to owner ${targetOwner.email || targetOwner.id}` }
    }
  }

  // Trigger-Agnostic Fallback: Batch assign unassigned leads
  const unassigned = await hubspot.client.crm.contacts.basicApi.getPage(
    25, 0, ['email', 'firstname', 'lastname', 'hubspot_owner_id']
  )
  let count = 0
  let idx = 0
  for (const c of unassigned.results) {
    if (!c.properties.hubspot_owner_id) {
      const targetOwner = availableOwners[idx % availableOwners.length]
      await hubspot.client.crm.contacts.basicApi.update(c.id, {
        properties: { hubspot_owner_id: targetOwner.id },
      })
      count++
      idx++
    }
  }

  return {
    ownerId: availableOwners[0]?.id || 'unassigned',
    assigned: count > 0,
    assignedCount: count,
    details: `Trigger-agnostic scan: routed ${count} unassigned contact(s) across ${availableOwners.length} owner(s)`,
  }
}