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

   1 import 'multer'
   2 import express from 'express'
   3 import { UserNotificationModel } from '@server/models/user/user-notification'
   4 import { HttpStatusCode } from '../../../../shared/models/http/http-error-codes'
   5 import { UserNotificationSetting } from '../../../../shared/models/users'
   6 import {
   7   asyncMiddleware,
   8   asyncRetryTransactionMiddleware,
   9   authenticate,
  10   paginationValidator,
  11   setDefaultPagination,
  12   setDefaultSort,
  13   userNotificationsSortValidator
  14 } from '../../../middlewares'
  15 import {
  16   listUserNotificationsValidator,
  17   markAsReadUserNotificationsValidator,
  18   updateNotificationSettingsValidator
  19 } from '../../../middlewares/validators/user-notifications'
  20 import { UserNotificationSettingModel } from '../../../models/user/user-notification-setting'
  21 import { meRouter } from './me'
  22 import { getFormattedObjects } from '@server/helpers/utils'
  23
  24 const myNotificationsRouter = express.Router()
  25
  26 meRouter.put('/me/notification-settings',
  27   authenticate,
  28   updateNotificationSettingsValidator,
  29   asyncRetryTransactionMiddleware(updateNotificationSettings)
  30 )
  31
  32 myNotificationsRouter.get('/me/notifications',
  33   authenticate,
  34   paginationValidator,
  35   userNotificationsSortValidator,
  36   setDefaultSort,
  37   setDefaultPagination,
  38   listUserNotificationsValidator,
  39   asyncMiddleware(listUserNotifications)
  40 )
  41
  42 myNotificationsRouter.post('/me/notifications/read',
  43   authenticate,
  44   markAsReadUserNotificationsValidator,
  45   asyncMiddleware(markAsReadUserNotifications)
  46 )
  47
  48 myNotificationsRouter.post('/me/notifications/read-all',
  49   authenticate,
  50   asyncMiddleware(markAsReadAllUserNotifications)
  51 )
  52
  53 export {
  54   myNotificationsRouter
  55 }
  56
  57 // ---------------------------------------------------------------------------
  58
  59 async function updateNotificationSettings (req: express.Request, res: express.Response) {
  60   const user = res.locals.oauth.token.User
  61   const body = req.body as UserNotificationSetting
  62
  63   const query = {
  64     where: {
  65       userId: user.id
  66     }
  67   }
  68
  69   const values: UserNotificationSetting = {
  70     newVideoFromSubscription: body.newVideoFromSubscription,
  71     newCommentOnMyVideo: body.newCommentOnMyVideo,
  72     abuseAsModerator: body.abuseAsModerator,
  73     videoAutoBlacklistAsModerator: body.videoAutoBlacklistAsModerator,
  74     blacklistOnMyVideo: body.blacklistOnMyVideo,
  75     myVideoPublished: body.myVideoPublished,
  76     myVideoImportFinished: body.myVideoImportFinished,
  77     newFollow: body.newFollow,
  78     newUserRegistration: body.newUserRegistration,
  79     commentMention: body.commentMention,
  80     newInstanceFollower: body.newInstanceFollower,
  81     autoInstanceFollowing: body.autoInstanceFollowing,
  82     abuseNewMessage: body.abuseNewMessage,
  83     abuseStateChange: body.abuseStateChange,
  84     newPeerTubeVersion: body.newPeerTubeVersion,
  85     newPluginVersion: body.newPluginVersion,
  86     myVideoStudioEditionFinished: body.myVideoStudioEditionFinished
  87   }
  88
  89   await UserNotificationSettingModel.update(values, query)
  90
  91   return res.status(HttpStatusCode.NO_CONTENT_204).end()
  92 }
  93
  94 async function listUserNotifications (req: express.Request, res: express.Response) {
  95   const user = res.locals.oauth.token.User
  96
  97   const resultList = await UserNotificationModel.listForApi(user.id, req.query.start, req.query.count, req.query.sort, req.query.unread)
  98
  99   return res.json(getFormattedObjects(resultList.data, resultList.total))
 100 }
 101
 102 async function markAsReadUserNotifications (req: express.Request, res: express.Response) {
 103   const user = res.locals.oauth.token.User
 104
 105   await UserNotificationModel.markAsRead(user.id, req.body.ids)
 106
 107   return res.status(HttpStatusCode.NO_CONTENT_204).end()
 108 }
 109
 110 async function markAsReadAllUserNotifications (req: express.Request, res: express.Response) {
 111   const user = res.locals.oauth.token.User
 112
 113   await UserNotificationModel.markAllAsRead(user.id)
 114
 115   return res.status(HttpStatusCode.NO_CONTENT_204).end()
 116 }