Function fetchZoomInfoAccessToken

apps/sim/app/api/tools/zoominfo/shared.ts:117–169

(
  auth: ZoomInfoAuth,
  requestId: string
)

}

export async function fetchZoomInfoAccessToken(
  auth: ZoomInfoAuth,
  requestId: string
): Promise<string> {
  const cacheKey = tokenCacheKey(auth)
  const cached = TOKEN_CACHE.get(cacheKey)
  if (cached && cached.expiresAt - TOKEN_SAFETY_WINDOW_MS > Date.now()) {
    return cached.accessToken
  }

  const tokenUrl = assertSafeZoomInfoUrl(ZOOMINFO_TOKEN_URL, 'tokenUrl').toString()
  const basic = Buffer.from(`${auth.clientId}:${auth.clientSecret}`).toString('base64')

  const params = new URLSearchParams()
  params.set('grant_type', 'client_credentials')

  const response = await secureFetchWithValidation(
    tokenUrl,
    {
      method: 'POST',
      headers: {
        Authorization: `Basic ${basic}`,
        'Content-Type': 'application/x-www-form-urlencoded',
        Accept: 'application/json',
      },
      body: params.toString(),
      timeout: ZOOMINFO_OUTBOUND_FETCH_TIMEOUT_MS,
    },
    'tokenUrl'
  )

  if (!response.ok) {
    const text = await response.text().catch(() => '')
    logger.warn(`[${requestId}] ZoomInfo token fetch failed (${response.status}): ${text}`)
    throw new Error(`ZoomInfo token request failed: HTTP ${response.status}`)
  }

  const data = (await response.json()) as {
    access_token?: string
    expires_in?: number
  }

  if (!data.access_token) {
    throw new Error('ZoomInfo token response missing access_token')
  }

  const expiresInMs = (data.expires_in ?? 3300) * 1000
  rememberToken(cacheKey, {
    accessToken: data.access_token,
    expiresAt: Date.now() + expiresInMs,
  })
  return data.access_token
}

export function extractZoomInfoError(body: unknown, status: number): string {
  if (body && typeof body === 'object') {