fix trigger delay calculation

This commit is contained in:
Gernot Pansy 2019-10-21 09:39:42 +02:00
parent cbf2a6e39d
commit e7e0f78742

View file

@ -138,10 +138,10 @@ async function run() {
} }
} }
sqlQry = sqlQry.where(column, '<=', new Date(currentTs - trigger.seconds)); sqlQry = sqlQry.where(column, '<=', new Date(currentTs - trigger.seconds * 1000));
if (trigger.last_check !== null) { if (trigger.last_check !== null) {
sqlQry = sqlQry.where(column, '>', trigger.last_check); sqlQry = sqlQry.where(column, '>', new Date(trigger.last_check - trigger.seconds * 1000));
} }
const subscribers = await sqlQry; const subscribers = await sqlQry;