//native
export type DynSelect_base_id = string
export type DynSelect_table_id = string
// Dropdown of the bases the token can access.
export async function base_id(auth: RT.Airtable) {
const options: { value: string; label: string }[] = []
let offset: string | undefined = undefined
do {
const url = new URL("https://api.airtable.com/v0/meta/bases")
if (offset) {
url.searchParams.append("offset", offset)
}
const response = await fetch(url, {
headers: {
Authorization: `Bearer ${auth.apiKey}`,
Accept: "application/json",
},
})
if (!response.ok) {
throw new Error(`${response.status} ${await response.text()}`)
}
const page = (await response.json()) as {
bases: { id: string; name: string }[]
offset?: string
}
options.push(...page.bases.map((b) => ({ value: b.id, label: b.name })))
offset = page.offset
} while (offset)
return options
}
async function listTables(auth: RT.Airtable, base_id: string) {
if (!base_id) {
return []
}
const response = await fetch(
`https://api.airtable.com/v0/meta/bases/${base_id}/tables`,
{
headers: {
Authorization: `Bearer ${auth.apiKey}`,
Accept: "application/json",
},
}
)
if (!response.ok) {
throw new Error(`${response.status} ${await response.text()}`)
}
const { tables } = (await response.json()) as {
tables: {
id: string
name: string
fields: { id: string; name: string; type: string }[]
views: { id: string; name: string }[]
}[]
}
return tables
}
// Dropdown of the tables in the chosen base.
export async function table_id(auth: RT.Airtable, base_id: DynSelect_base_id) {
return (await listTables(auth, base_id)).map((t) => ({
value: t.id,
label: t.name,
}))
}
/**
* Create or Update Record
* Update the record with the given ID (partial update), or create a new record when record_id is empty. To match on field values instead of a record ID, use Upsert Records.
*/
export async function main(
auth: RT.Airtable,
base_id: DynSelect_base_id,
table_id: DynSelect_table_id,
record_id: string | undefined,
fields: { [key: string]: any },
typecast: boolean | undefined,
return_fields_by_field_id: boolean | undefined
) {
const update = record_id != null && record_id !== ""
const response = await fetch(
update
? `https://api.airtable.com/v0/${base_id}/${table_id}/${record_id}`
: `https://api.airtable.com/v0/${base_id}/${table_id}`,
{
method: update ? "PATCH" : "POST",
headers: {
Authorization: `Bearer ${auth.apiKey}`,
"Content-Type": "application/json",
Accept: "application/json",
},
body: JSON.stringify({
fields,
typecast: typecast === true,
returnFieldsByFieldId: return_fields_by_field_id === true,
}),
}
)
if (!response.ok) {
throw new Error(`${response.status} ${await response.text()}`)
}
return await response.json()
}
Submitted by hugo989 3 hours ago