server/controllers/api/users/my-history.ts

   1 import * as express from 'express'
   2 import {
   3   asyncMiddleware,
   4   asyncRetryTransactionMiddleware,
   5   authenticate,
   6   paginationValidator,
   7   setDefaultPagination,
   8   userHistoryRemoveValidator
   9 } from '../../../middlewares'
  10 import { UserModel } from '../../../models/account/user'
  11 import { getFormattedObjects } from '../../../helpers/utils'
  12 import { UserVideoHistoryModel } from '../../../models/account/user-video-history'
  13 import { sequelizeTypescript } from '../../../initializers'
  14
  15 const myVideosHistoryRouter = express.Router()
  16
  17 myVideosHistoryRouter.get('/me/history/videos',
  18   authenticate,
  19   paginationValidator,
  20   setDefaultPagination,
  21   asyncMiddleware(listMyVideosHistory)
  22 )
  23
  24 myVideosHistoryRouter.post('/me/history/videos/remove',
  25   authenticate,
  26   userHistoryRemoveValidator,
  27   asyncRetryTransactionMiddleware(removeUserHistory)
  28 )
  29
  30 // ---------------------------------------------------------------------------
  31
  32 export {
  33   myVideosHistoryRouter
  34 }
  35
  36 // ---------------------------------------------------------------------------
  37
  38 async function listMyVideosHistory (req: express.Request, res: express.Response) {
  39   const user = res.locals.oauth.token.User
  40
  41   const resultList = await UserVideoHistoryModel.listForApi(user, req.query.start, req.query.count)
  42
  43   return res.json(getFormattedObjects(resultList.data, resultList.total))
  44 }
  45
  46 async function removeUserHistory (req: express.Request, res: express.Response) {
  47   const user = res.locals.oauth.token.User
  48   const beforeDate = req.body.beforeDate || null
  49
  50   await sequelizeTypescript.transaction(t => {
  51     return UserVideoHistoryModel.removeHistoryBefore(user, beforeDate, t)
  52   })
  53
  54   // Do not send the delete to other instances, we delete OUR copy of this video abuse
  55
  56   return res.type('json').status(204).end()
  57 }