budibase/packages/standard-components/src/fetchData.js

76 lines
2.1 KiB
JavaScript
Raw Normal View History

import api from "./api"
export default async function fetchData(datasource, store) {
2020-10-09 13:24:18 +02:00
const { type, name } = datasource
if (name) {
let rows = []
if (type === "table") {
rows = await fetchTableData()
2020-10-09 13:24:18 +02:00
} else if (type === "view") {
rows = await fetchViewData()
2020-10-09 13:24:18 +02:00
} else if (type === "link") {
rows = await fetchLinkedRowsData()
2020-10-09 13:24:18 +02:00
}
// Fetch table schema so we can check for linked rows
if (rows && rows.length) {
const table = await fetchTable(rows[0].tableId)
const keys = Object.keys(table.schema)
rows.forEach(row => {
for (let key of keys) {
if (table.schema[key].type === "link") {
row[`${key}_count`] = Array.isArray(row[key])
? row[key].length
: 0
}
}
})
}
return rows
}
async function fetchTable(id) {
const FETCH_TABLE_URL = `/api/tables/${id}`
const response = await api.get(FETCH_TABLE_URL)
return await response.json()
}
async function fetchTableData() {
if (!name.startsWith("all_")) {
throw new Error("Incorrect table convention - must begin with all_")
}
const tablesResponse = await api.get(`/api/views/${name}`)
return await tablesResponse.json()
}
async function fetchViewData() {
const { field, groupBy } = datasource
const params = new URLSearchParams()
if (field) {
params.set("field", field)
params.set("stats", true)
}
if (groupBy) params.set("group", groupBy)
let QUERY_VIEW_URL = field
? `/api/views/${name}?${params}`
: `/api/views/${name}`
const response = await api.get(QUERY_VIEW_URL)
return await response.json()
}
2020-10-09 13:24:18 +02:00
async function fetchLinkedRowsData() {
if (!store || !store.data || !store.data._id) {
2020-10-09 13:24:18 +02:00
return []
}
const QUERY_URL = `/api/${store.data.tableId}/${store.data._id}/enrich`
2020-10-09 13:24:18 +02:00
const response = await api.get(QUERY_URL)
const row = await response.json()
return row[datasource.fieldName]
2020-10-09 13:24:18 +02:00
}
}