1 import * as express from 'express'
5 asyncRetryTransactionMiddleware,
10 userNotificationsSortValidator
11 } from '../../../middlewares'
12 import { UserModel } from '../../../models/account/user'
13 import { getFormattedObjects } from '../../../helpers/utils'
14 import { UserNotificationModel } from '../../../models/account/user-notification'
15 import { meRouter } from './me'
17 markAsReadUserNotificationsValidator,
18 updateNotificationSettingsValidator
19 } from '../../../middlewares/validators/user-notifications'
20 import { UserNotificationSetting } from '../../../../shared/models/users'
21 import { UserNotificationSettingModel } from '../../../models/account/user-notification-setting'
23 const myNotificationsRouter = express.Router()
25 meRouter.put('/me/notification-settings',
27 updateNotificationSettingsValidator,
28 asyncRetryTransactionMiddleware(updateNotificationSettings)
31 myNotificationsRouter.get('/me/notifications',
34 userNotificationsSortValidator,
37 asyncMiddleware(listUserNotifications)
40 myNotificationsRouter.post('/me/notifications/read',
42 markAsReadUserNotificationsValidator,
43 asyncMiddleware(markAsReadUserNotifications)
50 // ---------------------------------------------------------------------------
52 async function updateNotificationSettings (req: express.Request, res: express.Response) {
53 const user: UserModel = res.locals.oauth.token.User
54 const body: UserNotificationSetting = req.body
62 await UserNotificationSettingModel.update({
63 newVideoFromSubscription: body.newVideoFromSubscription,
64 newCommentOnMyVideo: body.newCommentOnMyVideo
67 return res.status(204).end()
70 async function listUserNotifications (req: express.Request, res: express.Response) {
71 const user: UserModel = res.locals.oauth.token.User
73 const resultList = await UserNotificationModel.listForApi(user.id, req.query.start, req.query.count, req.query.sort)
75 return res.json(getFormattedObjects(resultList.data, resultList.total))
78 async function markAsReadUserNotifications (req: express.Request, res: express.Response) {
79 const user: UserModel = res.locals.oauth.token.User
81 await UserNotificationModel.markAsRead(user.id, req.body.ids)
83 return res.status(204).end()