const eventService = require('./events'); const scriptService = require('./script'); const treeService = require('./tree'); const log = require('./log'); const repository = require('./repository'); const Attribute = require('../entities/attribute'); function runAttachedRelations(note, relationName, originEntity) { // same script note can get here with multiple ways, but execute only once const notesToRun = new Set( note.getRelations(relationName) .map(relation => relation.getTargetNote()) .filter(note => !!note) ); for (const noteToRun of notesToRun) { scriptService.executeNoteNoException(noteToRun, { originEntity }); } } eventService.subscribe(eventService.NOTE_TITLE_CHANGED, note => { runAttachedRelations(note, 'runOnNoteTitleChange', note); if (!note.isRoot()) { const parents = note.getParentNotes(); for (const parent of parents) { if (parent.hasOwnedLabel("sorted")) { treeService.sortNotesAlphabetically(parent.noteId); } } } }); eventService.subscribe([ eventService.ENTITY_CHANGED, eventService.ENTITY_DELETED ], ({ entityName, entity }) => { if (entityName === 'attributes') { runAttachedRelations(entity.getNote(), 'runOnAttributeChange', entity); } else if (entityName === 'notes') { runAttachedRelations(entity, 'runOnNoteChange', entity); } }); eventService.subscribe(eventService.ENTITY_CREATED, ({ entityName, entity }) => { if (entityName === 'attributes') { runAttachedRelations(entity.getNote(), 'runOnAttributeCreation', entity); if (entity.type === 'relation' && entity.name === 'template') { const note = repository.getNote(entity.noteId); if (!note.isStringNote()) { return; } const content = note.getContent(); if (content && content.trim().length > 0) { return; } const targetNote = repository.getNote(entity.value); if (!targetNote || !targetNote.isStringNote()) { return; } const targetNoteContent = targetNote.getContent(); if (targetNoteContent) { note.setContent(targetNoteContent); } } else if (entity.type === 'label' && entity.name === 'sorted') { treeService.sortNotesAlphabetically(entity.noteId); } } else if (entityName === 'notes') { runAttachedRelations(entity, 'runOnNoteCreation', entity); } }); eventService.subscribe(eventService.CHILD_NOTE_CREATED, ({ parentNote, childNote }) => { runAttachedRelations(parentNote, 'runOnChildNoteCreation', childNote); }); function processInverseRelations(entityName, entity, handler) { if (entityName === 'attributes' && entity.type === 'relation') { const note = entity.getNote(); const attributes = (note.getOwnedAttributes(entity.name)).filter(relation => relation.type === 'relation-definition'); for (const attribute of attributes) { const definition = attribute.value; if (definition.inverseRelation && definition.inverseRelation.trim()) { const targetNote = entity.getTargetNote(); handler(definition, note, targetNote); } } } } eventService.subscribe(eventService.ENTITY_CHANGED, ({ entityName, entity }) => { processInverseRelations(entityName, entity, (definition, note, targetNote) => { // we need to make sure that also target's inverse attribute exists and if note, then create it // inverse attribute has to target our note as well const hasInverseAttribute = (targetNote.getRelations(definition.inverseRelation)) .some(attr => attr.value === note.noteId); if (!hasInverseAttribute) { new Attribute({ noteId: targetNote.noteId, type: 'relation', name: definition.inverseRelation, value: note.noteId, isInheritable: entity.isInheritable }).save(); targetNote.invalidateAttributeCache(); } }); }); eventService.subscribe(eventService.ENTITY_DELETED, ({ entityName, entity }) => { processInverseRelations(entityName, entity, (definition, note, targetNote) => { // if one inverse attribute is deleted then the other should be deleted as well const relations = targetNote.getOwnedRelations(definition.inverseRelation); let deletedSomething = false; for (const relation of relations) { if (relation.value === note.noteId) { relation.isDeleted = true; relation.save(); deletedSomething = true; } } if (deletedSomething) { targetNote.invalidateAttributeCache(); } }); });