Function airtableLoader

packages/airtable/src/airtable-loader.ts:23–54

({
  token = import.meta.env.AIRTABLE_TOKEN,
  base,
  table,
  queryParams,
}: AirtableLoaderOptions)

 * Loads data from an Airtable table.
 */
export function airtableLoader({
  token = import.meta.env.AIRTABLE_TOKEN,
  base,
  table,
  queryParams,
}: AirtableLoaderOptions): Loader {
  if (!token) {
    throw new AstroError(
      "Missing Airtable token. Set it in the AIRTABLE_TOKEN environment variable or pass it as an option.",
    );
  }
  const baseInstance = new Airtable({ apiKey: token }).base(base);

  return {
    name: "airtable-loader",
    load: async ({ logger, parseData, store }) => {
      logger.info(`Loading data from table "${table}"`);
      const records = await baseInstance(table).select(queryParams).all();
      for (const { id, fields } of records) {
        const data = await parseData({ id, data: fields });
        store.set({ id, data });
      }
      logger.info(`Loaded ${records.length} records from "${table}"`);
    },
    schema: () =>
      zodSchemaFromAirtableTable({
        baseID: base,
        tableIdOrName: table,
        apiKey: token,
      }),
  };
}