aboutsummaryrefslogblamecommitdiffhomepage
path: root/server/lib/job-queue/handlers/video-views-stats.ts
blob: c9aa218e54a48723eead0de8c846d9df897a8837 (plain) (tree)
1
2
3
4
5
6
7
8
9
10
                                                               
                                                                 

                                                        
                                   
 
                                           


                                                                                                                 
                                                                        



                                                  
 
                                                                      

                                   
                                                                        

                                   
         

                                                                          
 
                  
                                                                                           
 
             
                                                      
                       
                                                                                                 


                    
                                       

                                           



                       
                                                                                                          

         
                   
                                                                                                     
     





                                                                              
                         
 
import { VideoViewModel } from '@server/models/view/video-view'
import { isTestOrDevInstance } from '../../../helpers/core-utils'
import { logger } from '../../../helpers/logger'
import { VideoModel } from '../../../models/video/video'
import { Redis } from '../../redis'

async function processVideosViewsStats () {
  const lastHour = new Date()

  // In test mode, we run this function multiple times per hour, so we don't want the values of the previous hour
  if (!isTestOrDevInstance()) lastHour.setHours(lastHour.getHours() - 1)

  const hour = lastHour.getHours()
  const startDate = lastHour.setMinutes(0, 0, 0)
  const endDate = lastHour.setMinutes(59, 59, 999)

  const videoIds = await Redis.Instance.listVideosViewedForStats(hour)
  if (videoIds.length === 0) return

  logger.info('Processing videos views stats in job for hour %d.', hour)

  for (const videoId of videoIds) {
    try {
      const views = await Redis.Instance.getVideoViewsStats(videoId, hour)
      await Redis.Instance.deleteVideoViewsStats(videoId, hour)

      if (views) {
        logger.debug('Adding %d views to video %d stats in hour %d.', views, videoId, hour)

        try {
          const video = await VideoModel.load(videoId)
          if (!video) {
            logger.debug('Video %d does not exist anymore, skipping videos view stats.', videoId)
            continue
          }

          await VideoViewModel.create({
            startDate: new Date(startDate),
            endDate: new Date(endDate),
            views,
            videoId
          })
        } catch (err) {
          logger.error('Cannot create video views stats for video %d in hour %d.', videoId, hour, { err })
        }
      }
    } catch (err) {
      logger.error('Cannot update video views stats of video %d in hour %d.', videoId, hour, { err })
    }
  }
}

// ---------------------------------------------------------------------------

export {
  processVideosViewsStats
}