External Data Sync

export default async function main(input: {
  [key: string]: unknown
}): Promise<{ synced: number; errors: string[] }> {
  // Fetch data from external API
  const response = await http.get('https://api.example.com/data', {
    auth: secret('EXTERNAL_API_KEY'),
  })

  const records = response.data as { id: string; score: number }[]
  const errors: string[] = []
  let synced = 0

  for (const record of records) {
    try {
      // Find matching HubSpot contact by external ID
      const contacts = await hubspot.client.crm.contacts.basicApi.getPage(
        1, 0, ['hs_object_id'], undefined, undefined,
        [{ value: record.id, propertyName: 'external_id', operator: 'EQ' }]
      )

      if (contacts.results.length > 0) {
        await hubspot.client.crm.contacts.basicApi.update(
          contacts.results[0].id,
          { properties: { lead_score: record.score.toString() } }
        )
        synced++
      }
    } catch (err) {
      errors.push(`Failed to sync ${record.id}: ${err}`)
    }
  }

  return { synced, errors }
}