2020-05-07 21:53:34 +12:00
|
|
|
const CouchDB = require("../../db")
|
2020-10-03 04:16:06 +13:00
|
|
|
const csvParser = require("../../utilities/csvParser")
|
2020-10-02 05:22:08 +13:00
|
|
|
const {
|
|
|
|
getRecordParams,
|
|
|
|
getModelParams,
|
|
|
|
generateModelID,
|
2020-10-06 07:21:51 +13:00
|
|
|
generateRecordID,
|
2020-10-02 05:22:08 +13:00
|
|
|
} = require("../../db/utils")
|
2020-04-09 03:57:27 +12:00
|
|
|
|
2020-04-13 22:47:53 +12:00
|
|
|
exports.fetch = async function(ctx) {
|
2020-06-19 03:59:31 +12:00
|
|
|
const db = new CouchDB(ctx.user.instanceId)
|
2020-10-02 05:22:08 +13:00
|
|
|
const body = await db.allDocs(
|
|
|
|
getModelParams(null, {
|
|
|
|
include_docs: true,
|
|
|
|
})
|
|
|
|
)
|
2020-05-07 21:53:34 +12:00
|
|
|
ctx.body = body.rows.map(row => row.doc)
|
2020-04-13 22:47:53 +12:00
|
|
|
}
|
|
|
|
|
2020-06-04 03:10:03 +12:00
|
|
|
exports.find = async function(ctx) {
|
2020-06-19 03:59:31 +12:00
|
|
|
const db = new CouchDB(ctx.user.instanceId)
|
2020-10-02 05:22:08 +13:00
|
|
|
ctx.body = await db.get(ctx.params.id)
|
2020-06-04 03:10:03 +12:00
|
|
|
}
|
|
|
|
|
2020-06-24 10:26:54 +12:00
|
|
|
exports.save = async function(ctx) {
|
2020-06-19 03:59:31 +12:00
|
|
|
const db = new CouchDB(ctx.user.instanceId)
|
2020-10-03 04:16:06 +13:00
|
|
|
const { dataImport, ...rest } = ctx.request.body
|
2020-06-17 07:29:18 +12:00
|
|
|
const modelToSave = {
|
2020-04-21 03:17:11 +12:00
|
|
|
type: "model",
|
2020-10-03 00:37:46 +13:00
|
|
|
_id: generateModelID(),
|
2020-08-19 04:14:26 +12:00
|
|
|
views: {},
|
2020-10-02 02:48:07 +13:00
|
|
|
...rest,
|
2020-05-15 02:12:30 +12:00
|
|
|
}
|
|
|
|
|
2020-09-15 02:41:20 +12:00
|
|
|
// rename record fields when table column is renamed
|
2020-06-26 09:34:38 +12:00
|
|
|
const { _rename } = modelToSave
|
|
|
|
if (_rename) {
|
2020-10-02 05:22:08 +13:00
|
|
|
const records = await db.allDocs(
|
|
|
|
getRecordParams(modelToSave._id, null, {
|
|
|
|
include_docs: true,
|
|
|
|
})
|
|
|
|
)
|
2020-06-26 09:34:38 +12:00
|
|
|
const docs = records.rows.map(({ doc }) => {
|
|
|
|
doc[_rename.updated] = doc[_rename.old]
|
|
|
|
delete doc[_rename.old]
|
|
|
|
return doc
|
|
|
|
})
|
|
|
|
|
|
|
|
await db.bulkDocs(docs)
|
|
|
|
delete modelToSave._rename
|
|
|
|
}
|
|
|
|
|
2020-09-15 02:41:20 +12:00
|
|
|
// update schema of non-statistics views when new columns are added
|
2020-09-15 02:40:45 +12:00
|
|
|
for (let view in modelToSave.views) {
|
|
|
|
const modelView = modelToSave.views[view]
|
|
|
|
if (!modelView) continue
|
|
|
|
|
|
|
|
if (modelView.schema.group || modelView.schema.field) continue
|
|
|
|
modelView.schema = modelToSave.schema
|
|
|
|
}
|
|
|
|
|
2020-06-17 07:29:18 +12:00
|
|
|
const result = await db.post(modelToSave)
|
|
|
|
modelToSave._rev = result.rev
|
2020-04-15 02:14:57 +12:00
|
|
|
|
2020-06-12 04:24:09 +12:00
|
|
|
const { schema } = ctx.request.body
|
2020-10-02 05:22:08 +13:00
|
|
|
for (let key of Object.keys(schema)) {
|
2020-06-12 04:24:09 +12:00
|
|
|
// model has a linked record
|
|
|
|
if (schema[key].type === "link") {
|
|
|
|
// create the link field in the other model
|
2020-06-12 04:28:19 +12:00
|
|
|
const linkedModel = await db.get(schema[key].modelId)
|
2020-06-26 07:35:03 +12:00
|
|
|
linkedModel.schema[modelToSave.name] = {
|
2020-06-23 08:30:23 +12:00
|
|
|
name: modelToSave.name,
|
2020-06-12 04:24:09 +12:00
|
|
|
type: "link",
|
2020-06-17 07:29:18 +12:00
|
|
|
modelId: modelToSave._id,
|
2020-06-12 04:24:09 +12:00
|
|
|
constraints: {
|
2020-06-12 04:28:19 +12:00
|
|
|
type: "array",
|
2020-06-26 09:43:10 +12:00
|
|
|
},
|
2020-06-12 04:24:09 +12:00
|
|
|
}
|
2020-06-12 04:28:19 +12:00
|
|
|
await db.put(linkedModel)
|
2020-06-12 04:24:09 +12:00
|
|
|
}
|
|
|
|
}
|
|
|
|
|
2020-10-03 04:16:06 +13:00
|
|
|
if (dataImport && dataImport.path) {
|
2020-10-02 02:48:07 +13:00
|
|
|
// Populate the table with records imported from CSV in a bulk update
|
2020-10-03 04:16:06 +13:00
|
|
|
const data = await csvParser.transform(dataImport)
|
|
|
|
|
2020-10-06 07:21:51 +13:00
|
|
|
for (let row of data) {
|
|
|
|
row._id = generateRecordID(modelToSave._id)
|
|
|
|
row.modelId = modelToSave._id
|
|
|
|
}
|
2020-10-03 04:16:06 +13:00
|
|
|
|
|
|
|
await db.bulkDocs(data)
|
2020-10-02 02:48:07 +13:00
|
|
|
}
|
|
|
|
|
2020-05-15 02:12:30 +12:00
|
|
|
ctx.status = 200
|
2020-06-17 07:29:18 +12:00
|
|
|
ctx.message = `Model ${ctx.request.body.name} saved successfully.`
|
|
|
|
ctx.body = modelToSave
|
2020-04-09 03:57:27 +12:00
|
|
|
}
|
|
|
|
|
2020-04-10 03:53:48 +12:00
|
|
|
exports.destroy = async function(ctx) {
|
2020-06-19 03:59:31 +12:00
|
|
|
const db = new CouchDB(ctx.user.instanceId)
|
2020-04-14 04:04:51 +12:00
|
|
|
|
2020-06-12 04:28:19 +12:00
|
|
|
const modelToDelete = await db.get(ctx.params.modelId)
|
2020-06-12 04:24:09 +12:00
|
|
|
|
|
|
|
await db.remove(modelToDelete)
|
2020-06-12 05:11:56 +12:00
|
|
|
|
2020-04-14 04:04:51 +12:00
|
|
|
// Delete all records for that model
|
2020-10-02 05:22:08 +13:00
|
|
|
const records = await db.allDocs(
|
|
|
|
getRecordParams(ctx.params.modelId, null, {
|
|
|
|
include_docs: true,
|
|
|
|
})
|
|
|
|
)
|
2020-04-24 01:37:08 +12:00
|
|
|
await db.bulkDocs(
|
2020-06-26 07:04:58 +12:00
|
|
|
records.rows.map(record => ({ _id: record.id, _deleted: true }))
|
2020-05-07 21:53:34 +12:00
|
|
|
)
|
2020-04-14 04:04:51 +12:00
|
|
|
|
2020-06-12 04:24:09 +12:00
|
|
|
// Delete linked record fields in dependent models
|
2020-10-02 05:22:08 +13:00
|
|
|
for (let key of Object.keys(modelToDelete.schema)) {
|
2020-06-12 04:28:19 +12:00
|
|
|
const { type, modelId } = modelToDelete.schema[key]
|
2020-06-12 04:24:09 +12:00
|
|
|
if (type === "link") {
|
2020-06-12 04:28:19 +12:00
|
|
|
const linkedModel = await db.get(modelId)
|
2020-06-12 04:24:09 +12:00
|
|
|
delete linkedModel.schema[modelToDelete.name]
|
|
|
|
await db.put(linkedModel)
|
|
|
|
}
|
|
|
|
}
|
|
|
|
|
2020-05-15 02:12:30 +12:00
|
|
|
ctx.status = 200
|
|
|
|
ctx.message = `Model ${ctx.params.modelId} deleted.`
|
2020-04-10 03:53:48 +12:00
|
|
|
}
|
2020-10-03 04:16:06 +13:00
|
|
|
|
|
|
|
exports.validateCSVSchema = async function(ctx) {
|
|
|
|
const { file, schema = {} } = ctx.request.body
|
|
|
|
const result = await csvParser.parse(file.path, schema)
|
|
|
|
ctx.body = {
|
|
|
|
schema: result,
|
|
|
|
path: file.path,
|
|
|
|
}
|
|
|
|
}
|