2020-05-07 21:53:34 +12:00
|
|
|
const CouchDB = require("../../db")
|
2020-05-15 02:12:30 +12:00
|
|
|
const uuid = require("uuid")
|
2020-04-09 03:57:27 +12:00
|
|
|
|
2020-04-13 22:47:53 +12:00
|
|
|
exports.fetch = async function(ctx) {
|
2020-05-07 21:53:34 +12:00
|
|
|
const db = new CouchDB(ctx.params.instanceId)
|
|
|
|
const body = await db.query("database/by_type", {
|
2020-04-13 22:47:53 +12:00
|
|
|
include_docs: true,
|
2020-05-07 21:53:34 +12:00
|
|
|
key: ["model"],
|
|
|
|
})
|
|
|
|
ctx.body = body.rows.map(row => row.doc)
|
2020-04-13 22:47:53 +12:00
|
|
|
}
|
|
|
|
|
2020-04-10 03:53:48 +12:00
|
|
|
exports.create = async function(ctx) {
|
2020-05-07 21:53:34 +12:00
|
|
|
const db = new CouchDB(ctx.params.instanceId)
|
2020-05-15 02:12:30 +12:00
|
|
|
const newModel = {
|
2020-04-21 03:17:11 +12:00
|
|
|
type: "model",
|
2020-05-07 21:53:34 +12:00
|
|
|
...ctx.request.body,
|
2020-05-15 02:12:30 +12:00
|
|
|
_id: uuid.v4().replace(/-/g, ""),
|
|
|
|
}
|
|
|
|
|
|
|
|
const result = await db.post(newModel)
|
|
|
|
newModel._rev = result.rev
|
2020-04-15 02:14:57 +12:00
|
|
|
|
2020-05-07 21:53:34 +12:00
|
|
|
const designDoc = await db.get("_design/database")
|
2020-04-13 22:47:53 +12:00
|
|
|
designDoc.views = {
|
|
|
|
...designDoc.views,
|
2020-05-15 02:12:30 +12:00
|
|
|
[`all_${newModel._id}`]: {
|
2020-04-21 03:17:11 +12:00
|
|
|
map: `function(doc) {
|
2020-05-15 02:12:30 +12:00
|
|
|
if (doc.modelId === "${newModel._id}") {
|
2020-04-21 03:17:11 +12:00
|
|
|
emit(doc[doc.key], doc._id);
|
|
|
|
}
|
2020-05-07 21:53:34 +12:00
|
|
|
}`,
|
|
|
|
},
|
|
|
|
}
|
|
|
|
await db.put(designDoc)
|
2020-04-15 02:14:57 +12:00
|
|
|
|
2020-05-15 02:12:30 +12:00
|
|
|
ctx.status = 200
|
|
|
|
ctx.message = `Model ${ctx.request.body.name} created successfully.`
|
|
|
|
ctx.body = newModel
|
2020-04-09 03:57:27 +12:00
|
|
|
}
|
|
|
|
|
2020-05-18 22:18:31 +12:00
|
|
|
exports.update = async function() {}
|
2020-04-10 03:53:48 +12:00
|
|
|
|
|
|
|
exports.destroy = async function(ctx) {
|
2020-04-25 04:28:32 +12:00
|
|
|
const db = new CouchDB(ctx.params.instanceId)
|
2020-04-14 04:04:51 +12:00
|
|
|
|
2020-05-15 02:12:30 +12:00
|
|
|
await db.remove(ctx.params.modelId, ctx.params.revId)
|
|
|
|
const modelViewId = `all_${ctx.params.modelId}`
|
2020-04-14 04:04:51 +12:00
|
|
|
|
|
|
|
// Delete all records for that model
|
2020-05-07 21:53:34 +12:00
|
|
|
const records = await db.query(`database/${modelViewId}`)
|
2020-04-24 01:37:08 +12:00
|
|
|
await db.bulkDocs(
|
|
|
|
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
|
|
|
|
|
|
|
// delete the "all" view
|
2020-05-07 21:53:34 +12:00
|
|
|
const designDoc = await db.get("_design/database")
|
|
|
|
delete designDoc.views[modelViewId]
|
|
|
|
await db.put(designDoc)
|
2020-04-14 04:04:51 +12:00
|
|
|
|
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
|
|
|
}
|