Function fetchFieldNames

apps/sim/connectors/airtable/airtable.ts:292–339

* Fetches the table schema to build a field ID → field name mapping.

(
  accessToken: string,
  baseId: string,
  tableIdOrName: string,
  syncContext?: Record<string, unknown>
)

 * Fetches the table schema to build a field ID → field name mapping.
 */
async function fetchFieldNames(
  accessToken: string,
  baseId: string,
  tableIdOrName: string,
  syncContext?: Record<string, unknown>
): Promise<Map<string, string>> {
  const cacheKey = `fieldNames:${baseId}/${tableIdOrName}`
  if (syncContext?.[cacheKey]) return syncContext[cacheKey] as Map<string, string>

  const fieldNames = new Map<string, string>()

  try {
    const url = `${AIRTABLE_API}/meta/bases/${baseId}/tables`
    const response = await fetchWithRetry(url, {
      method: 'GET',
      headers: {
        Authorization: `Bearer ${accessToken}`,
      },
    })

    if (!response.ok) {
      logger.warn('Failed to fetch Airtable schema, using raw field keys', {
        status: response.status,
      })
      return fieldNames
    }

    const data = (await response.json()) as {
      tables: { id: string; name: string; fields: { id: string; name: string; type: string }[] }[]
    }

    const table = data.tables.find((t) => t.id === tableIdOrName || t.name === tableIdOrName)

    if (table) {
      for (const field of table.fields) {
        fieldNames.set(field.id, field.name)
        fieldNames.set(field.name, field.name)
      }
    }
  } catch (error) {
    logger.warn('Error fetching Airtable schema', {
      error: toError(error).message,
    })
  }

  if (syncContext) syncContext[cacheKey] = fieldNames
  return fieldNames
}