server-ts: Convert services/scheduler

src/services/scheduler.ts

@@ -0,0 +1,54 @@
+import scriptService = require('./script');
+import cls = require('./cls');
+import sqlInit = require('./sql_init');
+import config = require('./config');
+import log = require('./log');
+import attributeService = require('../services/attributes');
+import protectedSessionService = require('../services/protected_session');
+import hiddenSubtreeService = require('./hidden_subtree');
+import BNote = require('../becca/entities/bnote');
+
+function getRunAtHours(note: BNote): number[] {
+    try {
+        return note.getLabelValues('runAtHour').map(hour => parseInt(hour));
+    } catch (e: any) {
+        log.error(`Could not parse runAtHour for note ${note.noteId}: ${e.message}`);
+
+        return [];
+    }
+}
+
+function runNotesWithLabel(runAttrValue: string) {
+    const instanceName = config.General ? config.General.instanceName : null;
+    const currentHours = new Date().getHours();
+    const notes = attributeService.getNotesWithLabel('run', runAttrValue);
+
+    for (const note of notes) {
+        const runOnInstances = note.getLabelValues('runOnInstance');
+        const runAtHours = getRunAtHours(note);
+
+        if ((runOnInstances.length === 0 || runOnInstances.includes(instanceName))
+            && (runAtHours.length === 0 || runAtHours.includes(currentHours))
+        ) {
+            scriptService.executeNoteNoException(note, { originEntity: note });
+        }
+    }
+}
+
+sqlInit.dbReady.then(() => {
+    cls.init(() => {
+        hiddenSubtreeService.checkHiddenSubtree();
+    });
+
+    if (!process.env.TRILIUM_SAFE_MODE) {
+        setTimeout(cls.wrap(() => runNotesWithLabel('backendStartup')), 10 * 1000);
+
+        setInterval(cls.wrap(() => runNotesWithLabel('hourly')), 3600 * 1000);
+
+        setInterval(cls.wrap(() => runNotesWithLabel('daily')), 24 * 3600 * 1000);
+
+        setInterval(cls.wrap(() => hiddenSubtreeService.checkHiddenSubtree()), 7 * 3600 * 1000);
+    }
+
+    setInterval(() => protectedSessionService.checkProtectedSessionExpiration(), 30000);
+});