X-Git-Url: https://git.immae.eu/?a=blobdiff_plain;f=server%2Flib%2Fschedulers%2Fvideo-views-buffer-scheduler.ts;h=244a88b14ce087d92cad187278d201761861857f;hb=0b6f531653a7a24f82ad65564479a70a9326301a;hp=c0e72c4615c82913c55d215e0a7f2d33096dc206;hpb=51353d9a035fb6b81f903a8b5f391292841649fd;p=github%2FChocobozzz%2FPeerTube.git diff --git a/server/lib/schedulers/video-views-buffer-scheduler.ts b/server/lib/schedulers/video-views-buffer-scheduler.ts index c0e72c461..244a88b14 100644 --- a/server/lib/schedulers/video-views-buffer-scheduler.ts +++ b/server/lib/schedulers/video-views-buffer-scheduler.ts @@ -21,19 +21,19 @@ export class VideoViewsBufferScheduler extends AbstractScheduler { const videoIds = await Redis.Instance.listLocalVideosViewed() if (videoIds.length === 0) return - logger.info('Processing local video views buffer.', { videoIds, ...lTags() }) - for (const videoId of videoIds) { try { const views = await Redis.Instance.getLocalVideoViews(videoId) await Redis.Instance.deleteLocalVideoViews(videoId) - const video = await VideoModel.loadAndPopulateAccountAndServerAndTags(videoId) + const video = await VideoModel.loadFull(videoId) if (!video) { logger.debug('Video %d does not exist anymore, skipping videos view addition.', videoId, lTags()) continue } + logger.info('Processing local video %s views buffer.', video.uuid, lTags(video.uuid)) + // If this is a remote video, the origin instance will send us an update await VideoModel.incrementViews(videoId, views)