Added ability to pause specific subscriptions

This commit is contained in:
Isaac Abadi
2020-12-19 04:12:27 -05:00
parent 441a470990
commit e75b56ad3f
5 changed files with 14 additions and 9 deletions

View File

@@ -701,12 +701,14 @@ async function watchSubscriptions() {
if (!subscriptions) return;
let subscriptions_amount = subscriptions.length;
const valid_subscriptions = subscriptions.filter(sub => !sub.paused);
let subscriptions_amount = valid_subscriptions.length;
let delay_interval = calculateSubcriptionRetrievalDelay(subscriptions_amount);
let current_delay = 0;
for (let i = 0; i < subscriptions.length; i++) {
let sub = subscriptions[i];
for (let i = 0; i < valid_subscriptions.length; i++) {
let sub = valid_subscriptions[i];
// don't check the sub if the last check for the same subscription has not completed
if (subscription_timeouts[sub.id]) {