diff options
author | Chocobozzz <me@florianbigard.com> | 2022-03-24 13:36:47 +0100 |
---|---|---|
committer | Chocobozzz <chocobozzz@cpy.re> | 2022-04-15 09:49:35 +0200 |
commit | b211106695bb82f6c32e53306081b5262c3d109d (patch) | |
tree | fa187de1c33b0956665f5362e29af6b0f6d8bb57 /server/lib/schedulers/video-views-buffer-scheduler.ts | |
parent | 69d48ee30c9d47cddf0c3c047dc99a99dcb6e894 (diff) | |
download | PeerTube-b211106695bb82f6c32e53306081b5262c3d109d.tar.gz PeerTube-b211106695bb82f6c32e53306081b5262c3d109d.tar.zst PeerTube-b211106695bb82f6c32e53306081b5262c3d109d.zip |
Support video views/viewers stats in server
* Add "currentTime" and "event" body params to view endpoint
* Merge watching and view endpoints
* Introduce WatchAction AP activity
* Add tables to store viewer information of local videos
* Add endpoints to fetch video views/viewers stats of local videos
* Refactor views/viewers handlers
* Support "views" and "viewers" counters for both VOD and live videos
Diffstat (limited to 'server/lib/schedulers/video-views-buffer-scheduler.ts')
-rw-r--r-- | server/lib/schedulers/video-views-buffer-scheduler.ts | 4 |
1 files changed, 2 insertions, 2 deletions
diff --git a/server/lib/schedulers/video-views-buffer-scheduler.ts b/server/lib/schedulers/video-views-buffer-scheduler.ts index c0e72c461..937764155 100644 --- a/server/lib/schedulers/video-views-buffer-scheduler.ts +++ b/server/lib/schedulers/video-views-buffer-scheduler.ts | |||
@@ -21,8 +21,6 @@ export class VideoViewsBufferScheduler extends AbstractScheduler { | |||
21 | const videoIds = await Redis.Instance.listLocalVideosViewed() | 21 | const videoIds = await Redis.Instance.listLocalVideosViewed() |
22 | if (videoIds.length === 0) return | 22 | if (videoIds.length === 0) return |
23 | 23 | ||
24 | logger.info('Processing local video views buffer.', { videoIds, ...lTags() }) | ||
25 | |||
26 | for (const videoId of videoIds) { | 24 | for (const videoId of videoIds) { |
27 | try { | 25 | try { |
28 | const views = await Redis.Instance.getLocalVideoViews(videoId) | 26 | const views = await Redis.Instance.getLocalVideoViews(videoId) |
@@ -34,6 +32,8 @@ export class VideoViewsBufferScheduler extends AbstractScheduler { | |||
34 | continue | 32 | continue |
35 | } | 33 | } |
36 | 34 | ||
35 | logger.info('Processing local video %s views buffer.', video.uuid, lTags(video.uuid)) | ||
36 | |||
37 | // If this is a remote video, the origin instance will send us an update | 37 | // If this is a remote video, the origin instance will send us an update |
38 | await VideoModel.incrementViews(videoId, views) | 38 | await VideoModel.incrementViews(videoId, views) |
39 | 39 | ||