mirror of https://github.com/Chocobozzz/PeerTube
53 lines
1.7 KiB
TypeScript
53 lines
1.7 KiB
TypeScript
import { logger, loggerTagsFactory } from '@server/helpers/logger'
|
|
import { VideoModel } from '@server/models/video/video'
|
|
import { SCHEDULER_INTERVALS_MS } from '../../initializers/constants'
|
|
import { federateVideoIfNeeded } from '../activitypub/videos'
|
|
import { Redis } from '../redis'
|
|
import { AbstractScheduler } from './abstract-scheduler'
|
|
|
|
const lTags = loggerTagsFactory('views')
|
|
|
|
export class VideoViewsBufferScheduler extends AbstractScheduler {
|
|
|
|
private static instance: AbstractScheduler
|
|
|
|
protected schedulerIntervalMs = SCHEDULER_INTERVALS_MS.VIDEO_VIEWS_BUFFER_UPDATE
|
|
|
|
private constructor () {
|
|
super()
|
|
}
|
|
|
|
protected async internalExecute () {
|
|
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)
|
|
if (!video) {
|
|
logger.debug('Video %d does not exist anymore, skipping videos view addition.', videoId, lTags())
|
|
continue
|
|
}
|
|
|
|
// If this is a remote video, the origin instance will send us an update
|
|
await VideoModel.incrementViews(videoId, views)
|
|
|
|
// Send video update
|
|
video.views += views
|
|
await federateVideoIfNeeded(video, false)
|
|
} catch (err) {
|
|
logger.error('Cannot process local video views buffer of video %d.', videoId, { err, ...lTags() })
|
|
}
|
|
}
|
|
}
|
|
|
|
static get Instance () {
|
|
return this.instance || (this.instance = new this())
|
|
}
|
|
}
|