|
|
|
|
@ -1,46 +1,9 @@
|
|
|
|
|
"use strict";
|
|
|
|
|
|
|
|
|
|
const sql = require('../../services/sql');
|
|
|
|
|
const utils = require('../../services/utils');
|
|
|
|
|
const syncTable = require('../../services/sync_table');
|
|
|
|
|
const log = require('../../services/log');
|
|
|
|
|
const repository = require('../../services/repository');
|
|
|
|
|
|
|
|
|
|
async function cleanupSoftDeletedItems() {
|
|
|
|
|
const noteIdsToDelete = await sql.getColumn("SELECT noteId FROM notes WHERE isDeleted = 1");
|
|
|
|
|
const noteIdsSql = noteIdsToDelete
|
|
|
|
|
.map(noteId => "'" + utils.sanitizeSql(noteId) + "'")
|
|
|
|
|
.join(', ');
|
|
|
|
|
|
|
|
|
|
await sql.execute(`DELETE FROM event_log WHERE noteId IN (${noteIdsSql})`);
|
|
|
|
|
|
|
|
|
|
await sql.execute(`DELETE FROM note_revisions WHERE noteId IN (${noteIdsSql})`);
|
|
|
|
|
|
|
|
|
|
await sql.execute(`DELETE FROM note_images WHERE noteId IN (${noteIdsSql})`);
|
|
|
|
|
|
|
|
|
|
await sql.execute(`DELETE FROM labels WHERE noteId IN (${noteIdsSql})`);
|
|
|
|
|
|
|
|
|
|
await sql.execute("DELETE FROM branches WHERE isDeleted = 1");
|
|
|
|
|
|
|
|
|
|
await sql.execute("DELETE FROM note_images WHERE isDeleted = 1");
|
|
|
|
|
|
|
|
|
|
await sql.execute("DELETE FROM images WHERE isDeleted = 1");
|
|
|
|
|
|
|
|
|
|
await sql.execute("DELETE FROM notes WHERE isDeleted = 1");
|
|
|
|
|
|
|
|
|
|
await sql.execute("DELETE FROM recent_notes");
|
|
|
|
|
|
|
|
|
|
await syncTable.cleanupSyncRowsForMissingEntities("notes", "noteId");
|
|
|
|
|
await syncTable.cleanupSyncRowsForMissingEntities("branches", "branchId");
|
|
|
|
|
await syncTable.cleanupSyncRowsForMissingEntities("note_revisions", "noteRevisionId");
|
|
|
|
|
await syncTable.cleanupSyncRowsForMissingEntities("recent_notes", "branchId");
|
|
|
|
|
await syncTable.cleanupSyncRowsForMissingEntities("images", "imageId");
|
|
|
|
|
await syncTable.cleanupSyncRowsForMissingEntities("note_images", "noteImageId");
|
|
|
|
|
await syncTable.cleanupSyncRowsForMissingEntities("labels", "labelId");
|
|
|
|
|
|
|
|
|
|
log.info("Following notes has been completely cleaned from database: " + noteIdsSql);
|
|
|
|
|
}
|
|
|
|
|
|
|
|
|
|
async function cleanupUnusedImages() {
|
|
|
|
|
const unusedImageIds = await sql.getColumn(`
|
|
|
|
|
SELECT images.imageId
|
|
|
|
|
@ -67,7 +30,6 @@ async function vacuumDatabase() {
|
|
|
|
|
}
|
|
|
|
|
|
|
|
|
|
module.exports = {
|
|
|
|
|
cleanupSoftDeletedItems,
|
|
|
|
|
cleanupUnusedImages,
|
|
|
|
|
vacuumDatabase
|
|
|
|
|
};
|