Function test

apps/sim/lib/data-drains/destinations/bigquery.ts:292–308

* Probes table existence, IAM access, and credential validity in a single * `tables.get` call. `fields=id` minimises response size — we only care * whether the call succeeds, not the payload.

({ config, credentials, signal })

   * whether the call succeeds, not the payload.
   */
  async test({ config, credentials, signal }) {
    const account = parseServiceAccount(credentials.serviceAccountJson)
    const jwt = buildJwt(account)
    const token = await getAccessToken(jwt)
    const url = `https://bigquery.googleapis.com/bigquery/v2/projects/${encodeURIComponent(config.projectId)}/datasets/${encodeURIComponent(config.datasetId)}/tables/${encodeURIComponent(config.tableId)}?fields=id`
    const perAttempt = AbortSignal.any([signal, AbortSignal.timeout(PER_ATTEMPT_TIMEOUT_MS)])
    const response = await fetch(url, {
      headers: { Authorization: `Bearer ${token}` },
      signal: perAttempt,
    })
    if (!response.ok) {
      const text = await response.text().catch(() => '')
      throw new Error(`BigQuery probe failed (HTTP ${response.status}): ${text}`)
    }
    /** Drain the success body so undici can return the socket to the keep-alive pool. */
    await response.text().catch(() => '')
  },

  openSession({ config, credentials }) {
    const account = parseServiceAccount(credentials.serviceAccountJson)