server/controllers/api/videos/watching.ts

   1 import * as express from 'express'
   2 import { UserWatchingVideo } from '../../../../shared'
   3 import { asyncMiddleware, asyncRetryTransactionMiddleware, authenticate, videoWatchingValidator } from '../../../middlewares'
   4 import { UserVideoHistoryModel } from '../../../models/account/user-video-history'
   5 import { UserModel } from '../../../models/account/user'
   6
   7 const watchingRouter = express.Router()
   8
   9 watchingRouter.put('/:videoId/watching',
  10   authenticate,
  11   asyncMiddleware(videoWatchingValidator),
  12   asyncRetryTransactionMiddleware(userWatchVideo)
  13 )
  14
  15 // ---------------------------------------------------------------------------
  16
  17 export {
  18   watchingRouter
  19 }
  20
  21 // ---------------------------------------------------------------------------
  22
  23 async function userWatchVideo (req: express.Request, res: express.Response) {
  24   const user = res.locals.oauth.token.User
  25
  26   const body: UserWatchingVideo = req.body
  27   const { id: videoId } = res.locals.video as { id: number }
  28
  29   await UserVideoHistoryModel.upsert({
  30     videoId,
  31     userId: user.id,
  32     currentTime: body.currentTime
  33   })
  34
  35   return res.type('json').status(204).end()
  36 }