X-Git-Url: https://git.immae.eu/?a=blobdiff_plain;f=server%2Flib%2Frequest%2Frequest-video-event-scheduler.ts;h=5f21287f02adb7de483af505bc5741142fe4a480;hb=f5028693a896a3076dd286ac0030e3d8f78f5ebf;hp=68023273299f5c7c5cf6c783c86a14a8b76e72ef;hpb=eb08047657e739bcd9e592d76307befa3998482b;p=github%2FChocobozzz%2FPeerTube.git diff --git a/server/lib/request/request-video-event-scheduler.ts b/server/lib/request/request-video-event-scheduler.ts index 680232732..5f21287f0 100644 --- a/server/lib/request/request-video-event-scheduler.ts +++ b/server/lib/request/request-video-event-scheduler.ts @@ -59,8 +59,8 @@ class RequestVideoEventScheduler extends AbstractRequestScheduler { - eventRequests[toPodId].forEach(eventToProcess => { + for (const toPodId of Object.keys(eventRequests)) { + for (const eventToProcess of eventRequests[toPodId]) { if (!eventsPerVideoPerPod[toPodId]) eventsPerVideoPerPod[toPodId] = {} if (!requestsToMakeGrouped[toPodId]) { @@ -81,17 +81,17 @@ class RequestVideoEventScheduler extends AbstractRequestScheduler { + for (const toPodId of Object.keys(eventsPerVideoPerPod)) { const eventsForPod = eventsPerVideoPerPod[toPodId] - Object.keys(eventsForPod).forEach(uuid => { + for (const uuid of Object.keys(eventsForPod)) { const eventsForVideo = eventsForPod[uuid] - Object.keys(eventsForVideo).forEach(eventType => { + for (const eventType of Object.keys(eventsForVideo)) { requestsToMakeGrouped[toPodId].datas.push({ data: { uuid, @@ -99,9 +99,9 @@ class RequestVideoEventScheduler extends AbstractRequestScheduler