1 import { Redis } from '../../redis'
2 import { logger } from '../../../helpers/logger'
3 import { VideoModel } from '../../../models/video/video'
4 import { VideoViewModel } from '../../../models/video/video-views'
5 import { isTestInstance } from '../../../helpers/core-utils'
7 async function processVideosViewsViews () {
8 const lastHour = new Date()
10 // In test mode, we run this function multiple times per hour, so we don't want the values of the previous hour
11 if (!isTestInstance()) lastHour.setHours(lastHour.getHours() - 1)
13 const hour = lastHour.getHours()
14 const startDate = lastHour.setMinutes(0, 0, 0)
15 const endDate = lastHour.setMinutes(59, 59, 999)
17 const videoIds = await Redis.Instance.getVideosIdViewed(hour)
18 if (videoIds.length === 0) return
20 logger.info('Processing videos views in job for hour %d.', hour)
22 for (const videoId of videoIds) {
24 const views = await Redis.Instance.getVideoViews(videoId, hour)
26 logger.error('Cannot process videos views of video %d in hour %d: views number is NaN.', videoId, hour)
28 logger.debug('Adding %d views to video %d in hour %d.', views, videoId, hour)
30 await VideoModel.incrementViews(videoId, views)
33 await VideoViewModel.create({
40 logger.debug('Cannot create video views for video %d in hour %d. Maybe the video does not exist anymore?', videoId, hour)
44 await Redis.Instance.deleteVideoViews(videoId, hour)
46 logger.error('Cannot update video views of video %d in hour %d.', videoId, hour)
51 // ---------------------------------------------------------------------------
54 processVideosViewsViews