gaschz/trilium
1
0
Fork 0
mirror of https://github.com/zadam/trilium.git synced 2025-06-06 18:08:33 +02:00
Code Issues Actions Packages Projects Releases Wiki Activity

all events are now synchronous

Browse Source
This commit is contained in:
azivner 2018-08-12 20:07:02 +02:00
parent 9fb0599c45
commit c78ddb70cb
3 changed files with 3 additions and 15 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

2
src/routes/api/login.js
View File

@ -65,7 +65,7 @@ async function loginToProtectedSession(req) {
// this is set here so that event handlers have access to the protected session // this is set here so that event handlers have access to the protected session
cls.namespace.set('protectedSessionId', protectedSessionId); cls.namespace.set('protectedSessionId', protectedSessionId);
eventService.emit(eventService.ENTER_PROTECTED_SESSION); await eventService.emit(eventService.ENTER_PROTECTED_SESSION);
return { return {
success: true, success: true,

14
src/services/events.js
View File

@ -9,18 +9,7 @@ function subscribe(eventType, listener) {
eventListeners[eventType].push(listener); eventListeners[eventType].push(listener);
} }
function emit(eventType, data) { async function emit(eventType, data) {
const listeners = eventListeners[eventType];
if (listeners) {
for (const listener of listeners) {
// not awaiting for async processing
listener(data);
}
}
}
async function syncEmit(eventType, data) {
const listeners = eventListeners[eventType]; const listeners = eventListeners[eventType];
if (listeners) { if (listeners) {
@ -33,7 +22,6 @@ async function syncEmit(eventType, data) {
module.exports = { module.exports = {
subscribe, subscribe,
emit, emit,
syncEmit,
// event types: // event types:
NOTE_TITLE_CHANGED, NOTE_TITLE_CHANGED,
ENTER_PROTECTED_SESSION, ENTER_PROTECTED_SESSION,

2
src/services/sync_table.js
View File

@ -53,7 +53,7 @@ async function addEntitySync(entityName, entityId, sourceId) {
sourceId: sourceId || cls.getSourceId() || sourceIdService.getCurrentSourceId() sourceId: sourceId || cls.getSourceId() || sourceIdService.getCurrentSourceId()
}); });
await eventService.syncEmit(eventService.ENTITY_CHANGED, { await eventService.emit(eventService.ENTITY_CHANGED, {
entityName, entityName,
entityId entityId
}); });