airtable

pnpm add @cbcruk/airtable effect

import { Effect } from 'effect'
import { fetchList, makeAirtableConfigLayer } from '@cbcruk/airtable'

// Layer 생성
const ConfigLayer = makeAirtableConfigLayer({
  apiKey: 'your-api-key',
  baseUrl: 'https://api.airtable.com/v0/your-base-id',
  pageSize: 20, // 선택사항, 기본값: 20
})

// 레코드 조회
type MyRecord = { name: string; status: string }

const program = fetchList<MyRecord>('/TableName', {
  filterByFormula: '{status} = "active"',
  sort: [{ field: 'name', direction: 'asc' }],
  fields: ['name', 'status'],
})

// 실행
Effect.runPromise(program.pipe(Effect.provide(ConfigLayer)))
  .then((result) => console.log(result.records))
  .catch((error) => console.error(error))

import {
  getLastIndex,
  releaseFormula,
  paginationFormula,
  getLastPage,
  makeAirtableConfigLayer,
} from '@cbcruk/airtable'
import { Effect } from 'effect'

const ConfigLayer = makeAirtableConfigLayer({
  apiKey: 'your-api-key',
  baseUrl: 'https://api.airtable.com/v0/your-base-id',
})

// 마지막 index 조회
const lastIndex = await Effect.runPromise(
  getLastIndex('/TableName').pipe(Effect.provide(ConfigLayer)),
)

// 포뮬라 생성 (순수 함수)
const formula = paginationFormula({ start: 1, end: 10 })
// => "AND(AND({status}, 'release'), AND({index} >= 1, {index} <= 10))"

// 마지막 페이지 계산 (순수 함수)
const lastPage = getLastPage(100, 20) // => 5

import { Effect } from 'effect'
import {
  fetchList,
  AirtableError,
  makeAirtableConfigLayer,
} from '@cbcruk/airtable'

const ConfigLayer = makeAirtableConfigLayer({
  apiKey: 'your-api-key',
  baseUrl: 'https://api.airtable.com/v0/your-base-id',
})

const program = fetchList('/TableName', {}).pipe(
  Effect.provide(ConfigLayer),
  Effect.catchTag('AirtableError', (error) => {
    console.error(`API 에러 (${error.status}): ${error.message}`)
    return Effect.succeed({ records: [], offset: undefined })
  }),
)

type AirtableRecord<TFields> = {
  id: string
  createdTime?: string
  fields: TFields
}

type AirtableResponse<TFields> = {
  records: AirtableRecord<TFields>[]
  offset?: string
}

type AirtableConfigOptions = {
  apiKey: string
  baseUrl: string
  pageSize?: number
}

class AirtableError extends Data.TaggedError('AirtableError')<{
  readonly message: string
  readonly status?: number
  readonly cause?: unknown
}>