|
|
@ -105,11 +105,8 @@ exports.save = async function(ctx) { |
|
|
exports.destroy = async function(ctx) { |
|
|
exports.destroy = async function(ctx) { |
|
|
const instanceId = ctx.user.instanceId |
|
|
const instanceId = ctx.user.instanceId |
|
|
const db = new CouchDB(instanceId) |
|
|
const db = new CouchDB(instanceId) |
|
|
|
|
|
|
|
|
const modelToDelete = await db.get(ctx.params.modelId) |
|
|
const modelToDelete = await db.get(ctx.params.modelId) |
|
|
|
|
|
|
|
|
await db.remove(modelToDelete) |
|
|
|
|
|
|
|
|
|
|
|
// Delete all records for that model
|
|
|
// Delete all records for that model
|
|
|
const records = await db.allDocs( |
|
|
const records = await db.allDocs( |
|
|
getRecordParams(ctx.params.modelId, null, { |
|
|
getRecordParams(ctx.params.modelId, null, { |
|
|
@ -117,7 +114,7 @@ exports.destroy = async function(ctx) { |
|
|
}) |
|
|
}) |
|
|
) |
|
|
) |
|
|
await db.bulkDocs( |
|
|
await db.bulkDocs( |
|
|
records.rows.map(record => ({ _id: record.id, _deleted: true })) |
|
|
records.rows.map(record => ({ ...record.doc, _deleted: true })) |
|
|
) |
|
|
) |
|
|
|
|
|
|
|
|
// update linked records
|
|
|
// update linked records
|
|
|
@ -127,6 +124,9 @@ exports.destroy = async function(ctx) { |
|
|
model: modelToDelete, |
|
|
model: modelToDelete, |
|
|
}) |
|
|
}) |
|
|
|
|
|
|
|
|
|
|
|
// don't remove the table itself until very end
|
|
|
|
|
|
await db.remove(modelToDelete) |
|
|
|
|
|
|
|
|
ctx.eventEmitter && |
|
|
ctx.eventEmitter && |
|
|
ctx.eventEmitter.emitModel(`model:delete`, instanceId, modelToDelete) |
|
|
ctx.eventEmitter.emitModel(`model:delete`, instanceId, modelToDelete) |
|
|
ctx.status = 200 |
|
|
ctx.status = 200 |
|
|
|