138 lines
3.3 KiB
JavaScript
138 lines
3.3 KiB
JavaScript
const internal = require("./internal")
|
|
const external = require("./external")
|
|
const { isExternalTable } = require("../../../integrations/utils")
|
|
|
|
function pickApi(tableId) {
|
|
if (isExternalTable(tableId)) {
|
|
return external
|
|
}
|
|
return internal
|
|
}
|
|
|
|
function getTableId(ctx) {
|
|
if (ctx.request.body && ctx.request.body.tableId) {
|
|
return ctx.request.body.tableId
|
|
}
|
|
if (ctx.params && ctx.params.tableId) {
|
|
return ctx.params.tableId
|
|
}
|
|
if (ctx.params && ctx.params.viewName) {
|
|
return ctx.params.viewName
|
|
}
|
|
}
|
|
|
|
exports.patch = async ctx => {
|
|
const appId = ctx.appId
|
|
const tableId = getTableId(ctx)
|
|
const body = ctx.request.body
|
|
// if it doesn't have an _id then its save
|
|
if (body && !body._id) {
|
|
return exports.save(ctx)
|
|
}
|
|
try {
|
|
const { row, table } = await pickApi(tableId).patch(ctx)
|
|
ctx.status = 200
|
|
ctx.eventEmitter &&
|
|
ctx.eventEmitter.emitRow(`row:update`, appId, row, table)
|
|
ctx.message = `${table.name} updated successfully.`
|
|
ctx.body = row
|
|
} catch (err) {
|
|
ctx.throw(400, err)
|
|
}
|
|
}
|
|
|
|
exports.save = async function (ctx) {
|
|
const appId = ctx.appId
|
|
const tableId = getTableId(ctx)
|
|
const body = ctx.request.body
|
|
// if it has an ID already then its a patch
|
|
if (body && body._id) {
|
|
return exports.patch(ctx)
|
|
}
|
|
try {
|
|
const { row, table } = await pickApi(tableId).save(ctx)
|
|
ctx.status = 200
|
|
ctx.eventEmitter && ctx.eventEmitter.emitRow(`row:save`, appId, row, table)
|
|
ctx.message = `${table.name} saved successfully`
|
|
ctx.body = row
|
|
} catch (err) {
|
|
ctx.throw(400, err)
|
|
}
|
|
}
|
|
|
|
exports.fetchView = async function (ctx) {
|
|
const tableId = getTableId(ctx)
|
|
try {
|
|
ctx.body = await pickApi(tableId).fetchView(ctx)
|
|
} catch (err) {
|
|
ctx.throw(400, err)
|
|
}
|
|
}
|
|
|
|
exports.fetch = async function (ctx) {
|
|
const tableId = getTableId(ctx)
|
|
try {
|
|
ctx.body = await pickApi(tableId).fetch(ctx)
|
|
} catch (err) {
|
|
ctx.throw(400, err)
|
|
}
|
|
}
|
|
|
|
exports.find = async function (ctx) {
|
|
const tableId = getTableId(ctx)
|
|
try {
|
|
ctx.body = await pickApi(tableId).find(ctx)
|
|
} catch (err) {
|
|
ctx.throw(400, err)
|
|
}
|
|
}
|
|
|
|
exports.destroy = async function (ctx) {
|
|
const appId = ctx.appId
|
|
const inputs = ctx.request.body
|
|
const tableId = getTableId(ctx)
|
|
let response, row
|
|
if (inputs.rows) {
|
|
let { rows } = await pickApi(tableId).bulkDestroy(ctx)
|
|
response = rows
|
|
for (let row of rows) {
|
|
ctx.eventEmitter && ctx.eventEmitter.emitRow(`row:delete`, appId, row)
|
|
}
|
|
} else {
|
|
let resp = await pickApi(tableId).destroy(ctx)
|
|
response = resp.response
|
|
row = resp.row
|
|
ctx.eventEmitter && ctx.eventEmitter.emitRow(`row:delete`, appId, row)
|
|
}
|
|
ctx.status = 200
|
|
// for automations include the row that was deleted
|
|
ctx.row = row || {}
|
|
ctx.body = response
|
|
}
|
|
|
|
exports.search = async ctx => {
|
|
const tableId = getTableId(ctx)
|
|
try {
|
|
ctx.body = await pickApi(tableId).search(ctx)
|
|
} catch (err) {
|
|
ctx.throw(400, err)
|
|
}
|
|
}
|
|
|
|
exports.validate = async function (ctx) {
|
|
const tableId = getTableId(ctx)
|
|
try {
|
|
ctx.body = await pickApi(tableId).validate(ctx)
|
|
} catch (err) {
|
|
ctx.throw(400, err)
|
|
}
|
|
}
|
|
|
|
exports.fetchEnrichedRow = async function (ctx) {
|
|
const tableId = getTableId(ctx)
|
|
try {
|
|
ctx.body = await pickApi(tableId).fetchEnrichedRow(ctx)
|
|
} catch (err) {
|
|
ctx.throw(400, err)
|
|
}
|
|
}
|