trilium/src/services/blob.js

const becca = require('../becca/becca.js');
const NotFoundError = require('../errors/not_found_error.js');
const protectedSessionService = require('./protected_session.js');
const utils = require('./utils.js');

function getBlobPojo(entityName, entityId) {
    const entity = becca.getEntity(entityName, entityId);
    if (!entity) {
        throw new NotFoundError(`Entity ${entityName} '${entityId}' was not found.`);
    }

    const blob = becca.getBlob(entity);
    if (!blob) {
        throw new NotFoundError(`Blob ${entity.blobId} for ${entityName} '${entityId}' was not found.`);
    }

    const pojo = blob.getPojo();

    if (!entity.hasStringContent()) {
        pojo.content = null;
    } else {
        pojo.content = processContent(pojo.content, entity.isProtected, true);
    }

    return pojo;
}

function processContent(content, isProtected, isStringContent) {
    if (isProtected) {
        if (protectedSessionService.isProtectedSessionAvailable()) {
            content = content === null ? null : protectedSessionService.decrypt(content);
        } else {
            content = "";
        }
    }

    if (isStringContent) {
        return content === null ? "" : content.toString("utf-8");
    } else {
        // see https://github.com/zadam/trilium/issues/3523
        // IIRC a zero-sized buffer can be returned as null from the database
        if (content === null) {
            // this will force de/encryption
            content = Buffer.alloc(0);
        }

        return content;
    }
}

function calculateContentHash({blobId, content}) {
    return utils.hash(`${blobId}|${content.toString()}`);
}

module.exports = {
    getBlobPojo,
    processContent,
    calculateContentHash
};