1 files changed, 0 insertions, 52 deletions

diff --git a/server/lib/schedulers/video-views-buffer-scheduler.ts b/server/lib/schedulers/video-views-buffer-scheduler.ts
deleted file mode 100644
index 244a88b14..000000000
--- a/server/lib/schedulers/video-views-buffer-scheduler.ts
+++ /dev/null
@@ -1,52 +0,0 @@
-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
-
-    for (const videoId of videoIds) {
-      try {
-        const views = await Redis.Instance.getLocalVideoViews(videoId)
-        await Redis.Instance.deleteLocalVideoViews(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)
-
-        // 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())
-  }
-}