2020-02-01 11:15:58 +01:00
|
|
|
import utils from '../services/utils.js';
|
2020-02-12 20:07:04 +01:00
|
|
|
import Mutex from "../services/mutex.js";
|
2020-02-01 11:15:58 +01:00
|
|
|
|
2020-02-29 19:43:19 +01:00
|
|
|
/**
|
|
|
|
* Abstract class for all components in the Trilium's frontend.
|
|
|
|
*
|
|
|
|
* Contains also event implementation with following properties:
|
|
|
|
* - event / command distribution is synchronous which among others mean that events are well ordered - event
|
|
|
|
* which was sent out first will also be processed first by the component since it was added to the mutex queue
|
|
|
|
* as the first one
|
|
|
|
* - execution of the event / command is asynchronous - each component executes the event on its own without regard for
|
|
|
|
* other components.
|
|
|
|
* - although the execution is async, we are collecting all the promises and therefore it is possible to wait until the
|
|
|
|
* event / command is executed in all components - by simply awaiting the `triggerEvent()`.
|
|
|
|
*/
|
2020-01-15 21:36:01 +01:00
|
|
|
export default class Component {
|
2020-02-27 00:58:10 +01:00
|
|
|
constructor() {
|
2020-02-02 18:46:50 +01:00
|
|
|
this.componentId = `comp-${this.constructor.name}-` + utils.randomString(6);
|
2020-01-15 21:36:01 +01:00
|
|
|
/** @type Component[] */
|
|
|
|
this.children = [];
|
2020-01-18 18:01:16 +01:00
|
|
|
this.initialized = Promise.resolve();
|
2020-02-12 20:07:04 +01:00
|
|
|
this.mutex = new Mutex();
|
2020-01-15 21:36:01 +01:00
|
|
|
}
|
|
|
|
|
2020-02-27 00:58:10 +01:00
|
|
|
setParent(parent) {
|
|
|
|
/** @type Component */
|
|
|
|
this.parent = parent;
|
2020-02-27 10:03:14 +01:00
|
|
|
return this;
|
|
|
|
}
|
|
|
|
|
|
|
|
child(component) {
|
|
|
|
component.setParent(this);
|
|
|
|
|
|
|
|
this.children.push(component);
|
|
|
|
|
|
|
|
return this;
|
2020-02-27 00:58:10 +01:00
|
|
|
}
|
|
|
|
|
2020-03-16 21:16:09 +01:00
|
|
|
addChildren(components = []) {
|
|
|
|
for (const component of components) {
|
|
|
|
this.child(component);
|
|
|
|
}
|
|
|
|
|
|
|
|
return this;
|
|
|
|
}
|
|
|
|
|
2020-02-29 19:43:19 +01:00
|
|
|
/** @return {Promise} */
|
|
|
|
handleEvent(name, data) {
|
|
|
|
return Promise.all([
|
|
|
|
this.initialized.then(() => this.callMethod(this[name + 'Event'], data)),
|
|
|
|
this.handleEventInChildren(name, data)
|
|
|
|
]);
|
2020-01-15 21:36:01 +01:00
|
|
|
}
|
|
|
|
|
2020-02-29 19:43:19 +01:00
|
|
|
/** @return {Promise} */
|
|
|
|
triggerEvent(name, data) {
|
|
|
|
return this.parent.triggerEvent(name, data);
|
2020-01-15 21:36:01 +01:00
|
|
|
}
|
2020-01-24 20:15:53 +01:00
|
|
|
|
2020-02-29 19:43:19 +01:00
|
|
|
/** @return {Promise} */
|
|
|
|
handleEventInChildren(name, data) {
|
2020-02-12 20:07:04 +01:00
|
|
|
const promises = [];
|
|
|
|
|
2020-01-24 20:15:53 +01:00
|
|
|
for (const child of this.children) {
|
2020-02-16 19:21:17 +01:00
|
|
|
promises.push(child.handleEvent(name, data));
|
2020-02-12 20:07:04 +01:00
|
|
|
}
|
2020-01-24 20:15:53 +01:00
|
|
|
|
2020-02-29 19:43:19 +01:00
|
|
|
return Promise.all(promises);
|
2020-01-24 20:15:53 +01:00
|
|
|
}
|
2020-02-15 09:43:47 +01:00
|
|
|
|
2020-02-29 19:43:19 +01:00
|
|
|
/** @return {Promise} */
|
|
|
|
triggerCommand(name, data = {}) {
|
2020-02-16 19:54:11 +01:00
|
|
|
const fun = this[name + 'Command'];
|
|
|
|
|
2020-02-29 19:43:19 +01:00
|
|
|
if (fun) {
|
|
|
|
return this.callMethod(fun, data);
|
|
|
|
}
|
|
|
|
else {
|
|
|
|
return this.parent.triggerCommand(name, data);
|
|
|
|
}
|
2020-02-16 19:54:11 +01:00
|
|
|
}
|
|
|
|
|
2020-02-15 10:41:21 +01:00
|
|
|
async callMethod(fun, data) {
|
|
|
|
if (typeof fun !== 'function') {
|
|
|
|
return false;
|
|
|
|
}
|
|
|
|
|
|
|
|
let release;
|
2020-02-15 09:43:47 +01:00
|
|
|
|
2020-02-15 10:41:21 +01:00
|
|
|
try {
|
|
|
|
release = await this.mutex.acquire();
|
|
|
|
|
|
|
|
await fun.call(this, data);
|
|
|
|
|
|
|
|
return true;
|
|
|
|
} finally {
|
|
|
|
if (release) {
|
|
|
|
release();
|
|
|
|
}
|
|
|
|
}
|
2020-02-15 09:43:47 +01:00
|
|
|
}
|
2020-01-15 21:36:01 +01:00
|
|
|
}
|