Fix evt test
This commit is contained in:
parent
ce65c622cb
commit
6593fc4413
|
@ -1,7 +1,7 @@
|
||||||
const db = global.db;
|
const db = global.db;
|
||||||
const { EventEmitter } = require('events');
|
const { EventEmitter } = require('events');
|
||||||
const log = require("./logger");
|
const log = require("./logger");
|
||||||
require("dotenv").config({quiet:true});
|
require("dotenv").config({ quiet: true });
|
||||||
|
|
||||||
log.info("Starting event watcher...");
|
log.info("Starting event watcher...");
|
||||||
|
|
||||||
|
@ -92,12 +92,21 @@ dataTypes = {
|
||||||
}
|
}
|
||||||
|
|
||||||
const validEvents = {
|
const validEvents = {
|
||||||
1: [1,2,3,6,7],
|
1: [1, 2, 3, 6, 7],
|
||||||
2: [25],
|
2: [25],
|
||||||
3: [23,24,28,37,38,39,40,41,42,43,44,45]
|
3: [23, 24, 28, 37, 38, 39, 40, 41, 42, 43, 44, 45]
|
||||||
}
|
}
|
||||||
|
|
||||||
if (process.env.EVENT_TESTING == true) {
|
if (process.env.EVENT_TESTING == true) {
|
||||||
|
|
||||||
|
}
|
||||||
|
|
||||||
|
(async () => {
|
||||||
|
await getLastEventIndex();
|
||||||
|
await fetchEvents();
|
||||||
|
})();
|
||||||
|
test = true
|
||||||
|
if (test == true) {
|
||||||
log.warn("EVENT_TESTING is enabled - generating test events");
|
log.warn("EVENT_TESTING is enabled - generating test events");
|
||||||
setInterval(() => {
|
setInterval(() => {
|
||||||
const eventTypes = Object.keys(validEvents);
|
const eventTypes = Object.keys(validEvents);
|
||||||
|
@ -119,12 +128,7 @@ if (process.env.EVENT_TESTING == true) {
|
||||||
}
|
}
|
||||||
log.info(`Generated test event: ${JSON.stringify(testEvent)}`);
|
log.info(`Generated test event: ${JSON.stringify(testEvent)}`);
|
||||||
emitter.emit('event', testEvent);
|
emitter.emit('event', testEvent);
|
||||||
}, 1000);
|
}, 1000);
|
||||||
}
|
}
|
||||||
|
|
||||||
(async () => {
|
|
||||||
await getLastEventIndex();
|
|
||||||
await fetchEvents();
|
|
||||||
})();
|
|
||||||
|
|
||||||
module.exports = emitter;
|
module.exports = emitter;
|
Loading…
Reference in a new issue