"use strict"; const noteService = require('../../services/notes'); const treeService = require('../../services/tree'); const sql = require('../../services/sql'); const utils = require('../../services/utils'); const log = require('../../services/log'); const TaskContext = require('../../services/task_context'); const fs = require('fs'); const becca = require("../../becca/becca"); const ValidationError = require("../../errors/validation_error"); const NotFoundError = require("../../errors/not_found_error"); function getNote(req) { const noteId = req.params.noteId; const note = becca.getNote(noteId); if (!note) { throw new NotFoundError(`Note '${noteId}' has not been found.`); } const pojo = note.getPojo(); if (note.isStringNote()) { pojo.content = note.getContent(); if (note.type === 'file' && pojo.content.length > 10000) { pojo.content = `${pojo.content.substr(0, 10000)}\r\n\r\n... and ${pojo.content.length - 10000} more characters.`; } } const contentMetadata = note.getContentMetadata(); pojo.contentLength = contentMetadata.contentLength; pojo.combinedUtcDateModified = note.utcDateModified > contentMetadata.utcDateModified ? note.utcDateModified : contentMetadata.utcDateModified; pojo.combinedDateModified = note.utcDateModified > contentMetadata.utcDateModified ? note.dateModified : contentMetadata.dateModified; return pojo; } function createNote(req) { const params = Object.assign({}, req.body); // clone params.parentNoteId = req.params.parentNoteId; const { target, targetBranchId } = req.query; const { note, branch } = noteService.createNewNoteWithTarget(target, targetBranchId, params); return { note, branch }; } function updateNoteData(req) { const {content, attachments} = req.body; const {noteId} = req.params; return noteService.updateNoteData(noteId, content, attachments); } function deleteNote(req) { const noteId = req.params.noteId; const taskId = req.query.taskId; const eraseNotes = req.query.eraseNotes === 'true'; const last = req.query.last === 'true'; // note how deleteId is separate from taskId - single taskId produces separate deleteId for each "top level" deleted note const deleteId = utils.randomString(10); const note = becca.getNote(noteId); const taskContext = TaskContext.getInstance(taskId, 'delete-notes'); note.deleteNote(deleteId, taskContext); if (eraseNotes) { noteService.eraseNotesWithDeleteId(deleteId); } if (last) { taskContext.taskSucceeded(); } } function undeleteNote(req) { const taskContext = TaskContext.getInstance(utils.randomString(10), 'undeleteNotes'); noteService.undeleteNote(req.params.noteId, taskContext); taskContext.taskSucceeded(); } function sortChildNotes(req) { const noteId = req.params.noteId; const {sortBy, sortDirection, foldersFirst, sortNatural, sortLocale} = req.body; log.info(`Sorting '${noteId}' children with ${sortBy} ${sortDirection}, foldersFirst=${foldersFirst}, sortNatural=${sortNatural}, sortLocale=${sortLocale}`); const reverse = sortDirection === 'desc'; treeService.sortNotes(noteId, sortBy, reverse, foldersFirst, sortNatural, sortLocale); } function protectNote(req) { const noteId = req.params.noteId; const note = becca.notes[noteId]; const protect = !!parseInt(req.params.isProtected); const includingSubTree = !!parseInt(req.query.subtree); const taskContext = new TaskContext(utils.randomString(10), 'protectNotes', {protect}); noteService.protectNoteRecursively(note, protect, includingSubTree, taskContext); taskContext.taskSucceeded(); } function setNoteTypeMime(req) { // can't use [] destructuring because req.params is not iterable const {noteId} = req.params; const {type, mime} = req.body; const note = becca.getNote(noteId); note.type = type; note.mime = mime; note.save(); } function getRelationMap(req) { const {relationMapNoteId, noteIds} = req.body; const resp = { // noteId => title noteTitles: {}, relations: [], // relation name => inverse relation name inverseRelations: { 'internalLink': 'internalLink' } }; if (noteIds.length === 0) { return resp; } const questionMarks = noteIds.map(noteId => '?').join(','); const relationMapNote = becca.getNote(relationMapNoteId); const displayRelationsVal = relationMapNote.getLabelValue('displayRelations'); const displayRelations = !displayRelationsVal ? [] : displayRelationsVal .split(",") .map(token => token.trim()); const hideRelationsVal = relationMapNote.getLabelValue('hideRelations'); const hideRelations = !hideRelationsVal ? [] : hideRelationsVal .split(",") .map(token => token.trim()); const foundNoteIds = sql.getColumn(`SELECT noteId FROM notes WHERE isDeleted = 0 AND noteId IN (${questionMarks})`, noteIds); const notes = becca.getNotes(foundNoteIds); for (const note of notes) { resp.noteTitles[note.noteId] = note.title; resp.relations = resp.relations.concat(note.getRelations() .filter(relation => !relation.isAutoLink() || displayRelations.includes(relation.name)) .filter(relation => displayRelations.length > 0 ? displayRelations.includes(relation.name) : !hideRelations.includes(relation.name)) .filter(relation => noteIds.includes(relation.value)) .map(relation => ({ attributeId: relation.attributeId, sourceNoteId: relation.noteId, targetNoteId: relation.value, name: relation.name }))); for (const relationDefinition of note.getRelationDefinitions()) { const def = relationDefinition.getDefinition(); if (def.inverseRelation) { resp.inverseRelations[relationDefinition.getDefinedName()] = def.inverseRelation; resp.inverseRelations[def.inverseRelation] = relationDefinition.getDefinedName(); } } } return resp; } function changeTitle(req) { const noteId = req.params.noteId; const title = req.body.title; const note = becca.getNote(noteId); if (!note) { throw new NotFoundError(`Note '${noteId}' has not been found`); } if (!note.isContentAvailable()) { throw new ValidationError(`Note '${noteId}' is not available for change`); } const noteTitleChanged = note.title !== title; if (noteTitleChanged) { noteService.saveNoteRevisionIfNeeded(note); } note.title = title; note.save(); if (noteTitleChanged) { noteService.triggerNoteTitleChanged(note); } return note; } function duplicateSubtree(req) { const {noteId, parentNoteId} = req.params; return noteService.duplicateSubtree(noteId, parentNoteId); } function eraseDeletedNotesNow() { noteService.eraseDeletedNotesNow(); } function getDeleteNotesPreview(req) { const {branchIdsToDelete, deleteAllClones} = req.body; const noteIdsToBeDeleted = new Set(); const strongBranchCountToDelete = {}; // noteId => count (integer) function branchPreviewDeletion(branch) { if (branch.isWeak) { return; } strongBranchCountToDelete[branch.branchId] = strongBranchCountToDelete[branch.branchId] || 0; strongBranchCountToDelete[branch.branchId]++; const note = branch.getNote(); if (deleteAllClones || note.getStrongParentBranches().length <= strongBranchCountToDelete[branch.branchId]) { noteIdsToBeDeleted.add(note.noteId); for (const childBranch of note.getChildBranches()) { branchPreviewDeletion(childBranch); } } } for (const branchId of branchIdsToDelete) { const branch = becca.getBranch(branchId); if (!branch) { log.error(`Branch ${branchId} was not found and delete preview can't be calculated for this note.`); continue; } branchPreviewDeletion(branch); } let brokenRelations = []; if (noteIdsToBeDeleted.size > 0) { sql.fillParamList(noteIdsToBeDeleted); brokenRelations = sql.getRows(` SELECT attr.noteId, attr.name, attr.value FROM attributes attr JOIN param_list ON param_list.paramId = attr.value WHERE attr.isDeleted = 0 AND attr.type = 'relation'`).filter(attr => !noteIdsToBeDeleted.has(attr.noteId)); } return { noteIdsToBeDeleted: Array.from(noteIdsToBeDeleted), brokenRelations }; } function uploadModifiedFile(req) { const noteId = req.params.noteId; const {filePath} = req.body; const note = becca.getNote(noteId); if (!note) { throw new NotFoundError(`Note '${noteId}' has not been found`); } log.info(`Updating note '${noteId}' with content from ${filePath}`); note.saveNoteRevision(); const fileContent = fs.readFileSync(filePath); if (!fileContent) { throw new ValidationError(`File '${fileContent}' is empty`); } note.setContent(fileContent); } function forceSaveNoteRevision(req) { const {noteId} = req.params; const note = becca.getNote(noteId); if (!note) { throw new NotFoundError(`Note '${noteId}' not found.`); } if (!note.isContentAvailable()) { throw new ValidationError(`Note revision of a protected note cannot be created outside of a protected session.`); } note.saveNoteRevision(); } module.exports = { getNote, updateNoteData, deleteNote, undeleteNote, createNote, sortChildNotes, protectNote, setNoteTypeMime, getRelationMap, changeTitle, duplicateSubtree, eraseDeletedNotesNow, getDeleteNotesPreview, uploadModifiedFile, forceSaveNoteRevision };