"use strict"; const Entity = require('./entity'); const Attribute = require('./attribute'); const protectedSessionService = require('../services/protected_session'); const repository = require('../services/repository'); const sql = require('../services/sql'); const utils = require('../services/utils'); const dateUtils = require('../services/date_utils'); const noteFulltextService = require('../services/note_fulltext'); const syncTableService = require('../services/sync_table'); const LABEL = 'label'; const LABEL_DEFINITION = 'label-definition'; const RELATION = 'relation'; const RELATION_DEFINITION = 'relation-definition'; const STRING_MIME_TYPES = ["application/x-javascript"]; /** * This represents a Note which is a central object in the Trilium Notes project. * * @property {string} noteId - primary key * @property {string} type - one of "text", "code", "file" or "render" * @property {string} mime - MIME type, e.g. "text/html" * @property {string} title - note title * @property {boolean} isProtected - true if note is protected * @property {boolean} isDeleted - true if note is deleted * @property {string} dateCreated - local date time (with offset) * @property {string} dateModified - local date time (with offset) * @property {string} utcDateCreated * @property {string} utcDateModified * * @extends Entity */ class Note extends Entity { static get entityName() { return "notes"; } static get primaryKeyName() { return "noteId"; } static get hashedProperties() { return ["noteId", "title", "type", "isProtected", "isDeleted"]; } /** * @param row - object containing database row from "notes" table */ constructor(row) { super(row); this.isProtected = !!this.isProtected; /* true if content (meaning any kind of potentially encrypted content) is either not encrypted * or encrypted, but with available protected session (so effectively decrypted) */ this.isContentAvailable = true; // check if there's noteId, otherwise this is a new entity which wasn't encrypted yet if (this.isProtected && this.noteId) { this.isContentAvailable = protectedSessionService.isProtectedSessionAvailable(); if (this.isContentAvailable) { protectedSessionService.decryptNote(this); } else { this.title = "[protected]"; } } } /* * Note content has quite special handling - it's not a separate entity, but a lazily loaded * part of Note entity with it's own sync. Reasons behind this hybrid design has been: * * - content can be quite large and it's not necessary to load it / fill memory for any note access even if we don't need a content, especially for bulk operations like search * - changes in the note metadata or title should not trigger note content sync (so we keep separate utcDateModified and sync rows) * - but to the user note content and title changes are one and the same - single dateModified (so all changes must go through Note and content is not a separate entity) */ /** @returns {Promise<*>} */ async getContent() { if (this.content === undefined) { this.content = await sql.getValue(`SELECT content FROM note_contents WHERE noteId = ?`, [this.noteId]); if (this.isProtected) { if (this.isContentAvailable) { protectedSessionService.decryptNoteContent(this); } else { this.content = ""; } } if (this.isStringNote()) { this.content = this.content === null ? "" : this.content.toString("UTF-8"); } } return this.content; } /** @returns {Promise<*>} */ async getJsonContent() { const content = await this.getContent(); return JSON.parse(content); } /** @returns {Promise} */ async setContent(content) { this.content = content; const pojo = { noteId: this.noteId, content: content, utcDateModified: dateUtils.utcNowDateTime(), hash: utils.hash(this.noteId + "|" + content) }; if (this.isProtected) { if (this.isContentAvailable) { protectedSessionService.encryptNoteContent(pojo); } else { throw new Error(`Cannot update content of noteId=${this.noteId} since we're out of protected session.`); } } await sql.upsert("note_contents", "noteId", pojo); await syncTableService.addNoteContentSync(this.noteId); this.forcedChange = true; await this.save(); } /** @returns {Promise} */ async setJsonContent(content) { await this.setContent(JSON.stringify(content, null, '\t')); } /** @returns {boolean} true if this note is the root of the note tree. Root note has "root" noteId */ isRoot() { return this.noteId === 'root'; } /** @returns {boolean} true if this note is of application/json content type */ isJson() { return this.mime === "application/json"; } /** @returns {boolean} true if this note is JavaScript (code or attachment) */ isJavaScript() { return (this.type === "code" || this.type === "file") && (this.mime.startsWith("application/javascript") || this.mime === "application/x-javascript" || this.mime === "text/javascript"); } /** @returns {boolean} true if this note is HTML */ isHtml() { return (this.type === "code" || this.type === "file" || this.type === "render") && this.mime === "text/html"; } /** @returns {boolean} true if the note has string content (not binary) */ isStringNote() { return ["text", "code", "relation-map", "search"].includes(this.type) || this.mime.startsWith('text/') || STRING_MIME_TYPES.includes(this.mime); } /** @returns {string} JS script environment - either "frontend" or "backend" */ getScriptEnv() { if (this.isHtml() || (this.isJavaScript() && this.mime.endsWith('env=frontend'))) { return "frontend"; } if (this.type === 'render') { return "frontend"; } if (this.isJavaScript() && this.mime.endsWith('env=backend')) { return "backend"; } return null; } /** * @returns {Promise} attributes belonging to this specific note (excludes inherited attributes) */ async getOwnedAttributes() { return await repository.getEntities(`SELECT * FROM attributes WHERE isDeleted = 0 AND noteId = ?`, [this.noteId]); } /** * @returns {Promise} relations targetting this specific note */ async getTargetRelations() { return await repository.getEntities("SELECT * FROM attributes WHERE type = 'relation' AND isDeleted = 0 AND value = ?", [this.noteId]); } /** * @param {string} [name] - attribute name to filter * @returns {Promise} all note's attributes, including inherited ones */ async getAttributes(name) { if (!this.__attributeCache) { await this.loadAttributesToCache(); } if (name) { return this.__attributeCache.filter(attr => attr.name === name); } else { return this.__attributeCache; } } /** * @param {string} [name] - label name to filter * @returns {Promise} all note's labels (attributes with type label), including inherited ones */ async getLabels(name) { return (await this.getAttributes(name)).filter(attr => attr.type === LABEL); } /** * @param {string} [name] - label name to filter * @returns {Promise} all note's label definitions, including inherited ones */ async getLabelDefinitions(name) { return (await this.getAttributes(name)).filter(attr => attr.type === LABEL_DEFINITION); } /** * @param {string} [name] - relation name to filter * @returns {Promise} all note's relations (attributes with type relation), including inherited ones */ async getRelations(name) { return (await this.getAttributes(name)).filter(attr => attr.type === RELATION); } /** * @param {string} [name] - relation name to filter * @returns {Promise} all note's relation definitions including inherited ones */ async getRelationDefinitions(name) { return (await this.getAttributes(name)).filter(attr => attr.type === RELATION_DEFINITION); } /** * Clear note's attributes cache to force fresh reload for next attribute request. * Cache is note instance scoped. */ invalidateAttributeCache() { this.__attributeCache = null; } /** @returns {Promise} */ async loadAttributesToCache() { const attributes = await repository.getEntities(` WITH RECURSIVE tree(noteId, level) AS ( SELECT ?, 0 UNION SELECT branches.parentNoteId, tree.level + 1 FROM branches JOIN tree ON branches.noteId = tree.noteId JOIN notes ON notes.noteId = branches.parentNoteId WHERE notes.isDeleted = 0 AND branches.isDeleted = 0 ), treeWithAttrs(noteId, level) AS ( SELECT * FROM tree UNION SELECT attributes.value, treeWithAttrs.level + 1 FROM attributes JOIN treeWithAttrs ON treeWithAttrs.noteId = attributes.noteId WHERE attributes.isDeleted = 0 AND attributes.type = 'relation' AND attributes.name = 'template' AND (attributes.noteId = ? OR attributes.isInheritable = 1) ) SELECT attributes.* FROM attributes JOIN treeWithAttrs ON attributes.noteId = treeWithAttrs.noteId WHERE attributes.isDeleted = 0 AND (attributes.isInheritable = 1 OR attributes.noteId = ?) ORDER BY level, noteId, position`, [this.noteId, this.noteId, this.noteId]); // attributes are ordered so that "closest" attributes are first // we order by noteId so that attributes from same note stay together. Actual noteId ordering doesn't matter. const filteredAttributes = attributes.filter((attr, index) => { if (attr.isDefinition()) { const firstDefinitionIndex = attributes.findIndex(el => el.type === attr.type && el.name === attr.name); // keep only if this element is the first definition for this type & name return firstDefinitionIndex === index; } else { const definitionAttr = attributes.find(el => el.type === attr.type + '-definition' && el.name === attr.name); if (!definitionAttr) { return true; } const definition = definitionAttr.value; if (definition.multiplicityType === 'multivalue') { return true; } else { const firstAttrIndex = attributes.findIndex(el => el.type === attr.type && el.name === attr.name); // in case of single-valued attribute we'll keep it only if it's first (closest) return firstAttrIndex === index; } } }); for (const attr of filteredAttributes) { attr.isOwned = attr.noteId === this.noteId; } this.__attributeCache = filteredAttributes; } /** * @param {string} type - attribute type (label, relation, etc.) * @param {string} name - attribute name * @returns {Promise} true if note has an attribute with given type and name (including inherited) */ async hasAttribute(type, name) { return !!await this.getAttribute(type, name); } /** * @param {string} type - attribute type (label, relation, etc.) * @param {string} name - attribute name * @returns {Promise} attribute of given type and name. If there's more such attributes, first is returned. Returns null if there's no such attribute belonging to this note. */ async getAttribute(type, name) { const attributes = await this.getAttributes(); return attributes.find(attr => attr.type === type && attr.name === name); } /** * @param {string} type - attribute type (label, relation, etc.) * @param {string} name - attribute name * @returns {Promise} attribute value of given type and name or null if no such attribute exists. */ async getAttributeValue(type, name) { const attr = await this.getAttribute(type, name); return attr ? attr.value : null; } /** * Based on enabled, attribute is either set or removed. * * @param {string} type - attribute type ('relation', 'label' etc.) * @param {boolean} enabled - toggle On or Off * @param {string} name - attribute name * @param {string} [value] - attribute value (optional) * @returns {Promise} */ async toggleAttribute(type, enabled, name, value) { if (enabled) { await this.setAttribute(type, name, value); } else { await this.removeAttribute(type, name, value); } } /** * Creates given attribute name-value pair if it doesn't exist. * * @param {string} type - attribute type (label, relation, etc.) * @param {string} name - attribute name * @param {string} [value] - attribute value (optional) * @returns {Promise} */ async setAttribute(type, name, value) { const attributes = await this.getOwnedAttributes(); let attr = attributes.find(attr => attr.type === type && (value === undefined || attr.value === value)); if (!attr) { attr = new Attribute({ noteId: this.noteId, type: type, name: name, value: value !== undefined ? value : "" }); await attr.save(); this.invalidateAttributeCache(); } } /** * Removes given attribute name-value pair if it exists. * * @param {string} type - attribute type (label, relation, etc.) * @param {string} name - attribute name * @param {string} [value] - attribute value (optional) * @returns {Promise} */ async removeAttribute(type, name, value) { const attributes = await this.getOwnedAttributes(); for (const attribute of attributes) { if (attribute.type === type && (value === undefined || value === attribute.value)) { attribute.isDeleted = true; await attribute.save(); this.invalidateAttributeCache(); } } } /** * @param {string} name - label name * @returns {Promise} true if label exists (including inherited) */ async hasLabel(name) { return await this.hasAttribute(LABEL, name); } /** * @param {string} name - relation name * @returns {Promise} true if relation exists (including inherited) */ async hasRelation(name) { return await this.hasAttribute(RELATION, name); } /** * @param {string} name - label name * @returns {Promise} label if it exists, null otherwise */ async getLabel(name) { return await this.getAttribute(LABEL, name); } /** * @param {string} name - relation name * @returns {Promise} relation if it exists, null otherwise */ async getRelation(name) { return await this.getAttribute(RELATION, name); } /** * @param {string} name - label name * @returns {Promise} label value if label exists, null otherwise */ async getLabelValue(name) { return await this.getAttributeValue(LABEL, name); } /** * @param {string} name - relation name * @returns {Promise} relation value if relation exists, null otherwise */ async getRelationValue(name) { return await this.getAttributeValue(RELATION, name); } /** * @param {string} name * @returns {Promise|null} target note of the relation or null (if target is empty or note was not found) */ async getRelationTarget(name) { const relation = await this.getRelation(name); return relation ? await repository.getNote(relation.value) : null; } /** * Based on enabled, label is either set or removed. * * @param {boolean} enabled - toggle On or Off * @param {string} name - label name * @param {string} [value] - label value (optional) * @returns {Promise} */ async toggleLabel(enabled, name, value) { return await this.toggleAttribute(LABEL, enabled, name, value); } /** * Based on enabled, relation is either set or removed. * * @param {boolean} enabled - toggle On or Off * @param {string} name - relation name * @param {string} [value] - relation value (noteId) * @returns {Promise} */ async toggleRelation(enabled, name, value) { return await this.toggleAttribute(RELATION, enabled, name, value); } /** * Create label name-value pair if it doesn't exist yet. * * @param {string} name - label name * @param {string} [value] - label value * @returns {Promise} */ async setLabel(name, value) { return await this.setAttribute(LABEL, name, value); } /** * Create relation name-value pair if it doesn't exist yet. * * @param {string} name - relation name * @param {string} [value] - relation value (noteId) * @returns {Promise} */ async setRelation(name, value) { return await this.setAttribute(RELATION, name, value); } /** * Remove label name-value pair, if it exists. * * @param {string} name - label name * @param {string} [value] - label value * @returns {Promise} */ async removeLabel(name, value) { return await this.removeAttribute(LABEL, name, value); } /** * Remove relation name-value pair, if it exists. * * @param {string} name - relation name * @param {string} [value] - relation value (noteId) * @returns {Promise} */ async removeRelation(name, value) { return await this.removeAttribute(RELATION, name, value); } /** * @return {Promise} return list of all descendant noteIds of this note. Returning just noteIds because number of notes can be huge. Includes also this note's noteId */ async getDescendantNoteIds() { return await sql.getColumn(` WITH RECURSIVE tree(noteId) AS ( SELECT ? UNION SELECT branches.noteId FROM branches JOIN tree ON branches.parentNoteId = tree.noteId JOIN notes ON notes.noteId = branches.noteId WHERE notes.isDeleted = 0 AND branches.isDeleted = 0 ) SELECT noteId FROM tree`, [this.noteId]); } /** * Finds descendant notes with given attribute name and value. Only own attributes are considered, not inherited ones * * @param {string} type - attribute type (label, relation, etc.) * @param {string} name - attribute name * @param {string} [value] - attribute value * @returns {Promise} */ async getDescendantNotesWithAttribute(type, name, value) { const params = [this.noteId, name]; let valueCondition = ""; if (value !== undefined) { params.push(value); valueCondition = " AND attributes.value = ?"; } const notes = await repository.getEntities(` WITH RECURSIVE tree(noteId) AS ( SELECT ? UNION SELECT branches.noteId FROM branches JOIN tree ON branches.parentNoteId = tree.noteId JOIN notes ON notes.noteId = branches.noteId WHERE notes.isDeleted = 0 AND branches.isDeleted = 0 ) SELECT notes.* FROM notes JOIN tree ON tree.noteId = notes.noteId JOIN attributes ON attributes.noteId = notes.noteId WHERE attributes.isDeleted = 0 AND attributes.name = ? ${valueCondition} ORDER BY noteId, position`, params); return notes; } /** * Finds descendant notes with given label name and value. Only own labels are considered, not inherited ones * * @param {string} name - label name * @param {string} [value] - label value * @returns {Promise} */ async getDescendantNotesWithLabel(name, value) { return await this.getDescendantNotesWithAttribute(LABEL, name, value); } /** * Finds descendant notes with given relation name and value. Only own relations are considered, not inherited ones * * @param {string} name - relation name * @param {string} [value] - relation value * @returns {Promise} */ async getDescendantNotesWithRelation(name, value) { return await this.getDescendantNotesWithAttribute(RELATION, name, value); } /** * Returns note revisions of this note. * * @returns {Promise} */ async getRevisions() { return await repository.getEntities("SELECT * FROM note_revisions WHERE noteId = ?", [this.noteId]); } /** * Get list of links coming out of this note. * * @returns {Promise} */ async getLinks() { return await repository.getEntities("SELECT * FROM links WHERE noteId = ? AND isDeleted = 0", [this.noteId]); } /** * Get list of links targetting this note. * * @returns {Promise} */ async getTargetLinks() { return await repository.getEntities("SELECT * FROM links WHERE targetNoteId = ? AND isDeleted = 0", [this.noteId]); } /** * Return all links from this note, including deleted ones. * * @returns {Promise} */ async getLinksWithDeleted() { return await repository.getEntities("SELECT * FROM links WHERE noteId = ?", [this.noteId]); } /** * @returns {Promise} */ async getBranches() { return await repository.getEntities("SELECT * FROM branches WHERE isDeleted = 0 AND noteId = ?", [this.noteId]); } /** * @returns {boolean} - true if note has children */ async hasChildren() { return (await this.getChildNotes()).length > 0; } /** * @returns {Promise} child notes of this note */ async getChildNotes() { return await repository.getEntities(` SELECT notes.* FROM branches JOIN notes USING(noteId) WHERE notes.isDeleted = 0 AND branches.isDeleted = 0 AND branches.parentNoteId = ? ORDER BY branches.notePosition`, [this.noteId]); } /** * @returns {Promise} child branches of this note */ async getChildBranches() { return await repository.getEntities(` SELECT branches.* FROM branches WHERE branches.isDeleted = 0 AND branches.parentNoteId = ? ORDER BY branches.notePosition`, [this.noteId]); } /** * @returns {Promise} parent notes of this note (note can have multiple parents because of cloning) */ async getParentNotes() { return await repository.getEntities(` SELECT parent_notes.* FROM branches AS child_tree JOIN notes AS parent_notes ON parent_notes.noteId = child_tree.parentNoteId WHERE child_tree.noteId = ? AND child_tree.isDeleted = 0 AND parent_notes.isDeleted = 0`, [this.noteId]); } beforeSaving() { if (!this.isDeleted) { this.isDeleted = false; } if (!this.dateCreated) { this.dateCreated = dateUtils.localNowDateTime(); } if (!this.utcDateCreated) { this.utcDateCreated = dateUtils.utcNowDateTime(); } super.beforeSaving(); if (this.isChanged) { this.dateModified = dateUtils.localNowDateTime(); this.utcDateModified = dateUtils.utcNowDateTime(); } } // cannot be static! updatePojo(pojo) { if (pojo.isProtected) { if (this.isContentAvailable) { protectedSessionService.encryptNote(pojo); } else { // updating protected note outside of protected session means we will keep original ciphertexts delete pojo.title; } } delete pojo.isContentAvailable; delete pojo.__attributeCache; delete pojo.content; } async afterSaving() { noteFulltextService.triggerNoteFulltextUpdate(this.noteId); } } module.exports = Note;