1 import express from 'express'
2 import { Hooks } from '@server/lib/plugins/hooks'
3 import { VideoViewsManager } from '@server/lib/views/video-views-manager'
4 import { MVideoId } from '@server/types/models'
5 import { HttpStatusCode, VideoView } from '@shared/models'
6 import { asyncMiddleware, methodsValidator, openapiOperationDoc, optionalAuthenticate, videoViewValidator } from '../../../middlewares'
7 import { UserVideoHistoryModel } from '../../../models/user/user-video-history'
9 const viewRouter = express.Router()
12 [ '/:videoId/views', '/:videoId/watching' ],
13 openapiOperationDoc({ operationId: 'addView' }),
14 methodsValidator([ 'PUT', 'POST' ]),
16 asyncMiddleware(videoViewValidator),
17 asyncMiddleware(viewVideo)
20 // ---------------------------------------------------------------------------
26 // ---------------------------------------------------------------------------
28 async function viewVideo (req: express.Request, res: express.Response) {
29 const video = res.locals.onlyImmutableVideo
31 const body = req.body as VideoView
34 const { successView } = await VideoViewsManager.Instance.processLocalView({
37 currentTime: body.currentTime,
38 viewEvent: body.viewEvent
42 Hooks.runAction('action:api.video.viewed', { video, ip, req, res })
45 await updateUserHistoryIfNeeded(body, video, res)
47 return res.status(HttpStatusCode.NO_CONTENT_204).end()
50 async function updateUserHistoryIfNeeded (body: VideoView, video: MVideoId, res: express.Response) {
51 const user = res.locals.oauth?.token.User
53 if (user.videosHistoryEnabled !== true) return
55 await UserVideoHistoryModel.upsert({
58 currentTime: body.currentTime