1 import { logger, loggerTagsFactory } from '@server/helpers/logger'
2 import { VideoModel } from '@server/models/video/video'
3 import { SCHEDULER_INTERVALS_MS } from '../../initializers/constants'
4 import { federateVideoIfNeeded } from '../activitypub/videos'
5 import { Redis } from '../redis'
6 import { AbstractScheduler } from './abstract-scheduler'
8 const lTags = loggerTagsFactory('views')
10 export class VideoViewsBufferScheduler extends AbstractScheduler {
12 private static instance: AbstractScheduler
14 protected schedulerIntervalMs = SCHEDULER_INTERVALS_MS.VIDEO_VIEWS_BUFFER_UPDATE
16 private constructor () {
20 protected async internalExecute () {
21 const videoIds = await Redis.Instance.listLocalVideosViewed()
22 if (videoIds.length === 0) return
24 logger.info('Processing local video views buffer.', { videoIds, ...lTags() })
26 for (const videoId of videoIds) {
28 const views = await Redis.Instance.getLocalVideoViews(videoId)
29 await Redis.Instance.deleteLocalVideoViews(videoId)
31 const video = await VideoModel.loadAndPopulateAccountAndServerAndTags(videoId)
33 logger.debug('Video %d does not exist anymore, skipping videos view addition.', videoId, lTags())
37 // If this is a remote video, the origin instance will send us an update
38 await VideoModel.incrementViews(videoId, views)
42 await federateVideoIfNeeded(video, false)
44 logger.error('Cannot process local video views buffer of video %d.', videoId, { err, ...lTags() })
49 static get Instance () {
50 return this.instance || (this.instance = new this())