2021-12-17 10:52:12 +01:00
|
|
|
import DataFetch from "./DataFetch.js"
|
2021-12-17 09:22:04 +01:00
|
|
|
import { executeQuery, fetchQueryDefinition } from "api"
|
2021-12-17 10:52:12 +01:00
|
|
|
import { cloneDeep } from "lodash/fp"
|
2021-12-17 09:22:04 +01:00
|
|
|
|
2021-12-17 10:52:12 +01:00
|
|
|
export default class ViewFetch extends DataFetch {
|
2021-12-17 09:22:04 +01:00
|
|
|
static async getSchema(datasource) {
|
|
|
|
if (!datasource?._id) {
|
|
|
|
return null
|
|
|
|
}
|
|
|
|
const definition = await fetchQueryDefinition(datasource._id)
|
|
|
|
return this.enrichSchema(definition?.schema)
|
|
|
|
}
|
|
|
|
|
|
|
|
async getData() {
|
|
|
|
const { datasource } = this.options
|
|
|
|
|
|
|
|
// Set the default query params
|
|
|
|
let parameters = cloneDeep(datasource?.queryParams || {})
|
|
|
|
for (let param of datasource?.parameters || {}) {
|
|
|
|
if (!parameters[param.name]) {
|
|
|
|
parameters[param.name] = param.default
|
|
|
|
}
|
|
|
|
}
|
|
|
|
|
|
|
|
const res = await executeQuery({ queryId: datasource?._id, parameters })
|
|
|
|
return {
|
|
|
|
rows: res || [],
|
|
|
|
}
|
|
|
|
}
|
|
|
|
}
|