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'
8 asyncRetryTransactionMiddleware,
13 userNotificationsSortValidator
14 } from '../../../middlewares'
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'
24 const myNotificationsRouter = express.Router()
26 meRouter.put('/me/notification-settings',
28 updateNotificationSettingsValidator,
29 asyncRetryTransactionMiddleware(updateNotificationSettings)
32 myNotificationsRouter.get('/me/notifications',
35 userNotificationsSortValidator,
38 listUserNotificationsValidator,
39 asyncMiddleware(listUserNotifications)
42 myNotificationsRouter.post('/me/notifications/read',
44 markAsReadUserNotificationsValidator,
45 asyncMiddleware(markAsReadUserNotifications)
48 myNotificationsRouter.post('/me/notifications/read-all',
50 asyncMiddleware(markAsReadAllUserNotifications)
57 // ---------------------------------------------------------------------------
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
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
89 await UserNotificationSettingModel.update(values, query)
91 return res.status(HttpStatusCode.NO_CONTENT_204).end()
94 async function listUserNotifications (req: express.Request, res: express.Response) {
95 const user = res.locals.oauth.token.User
97 const resultList = await UserNotificationModel.listForApi(user.id, req.query.start, req.query.count, req.query.sort, req.query.unread)
99 return res.json(getFormattedObjects(resultList.data, resultList.total))
102 async function markAsReadUserNotifications (req: express.Request, res: express.Response) {
103 const user = res.locals.oauth.token.User
105 await UserNotificationModel.markAsRead(user.id, req.body.ids)
107 return res.status(HttpStatusCode.NO_CONTENT_204).end()
110 async function markAsReadAllUserNotifications (req: express.Request, res: express.Response) {
111 const user = res.locals.oauth.token.User
113 await UserNotificationModel.markAllAsRead(user.id)
115 return res.status(HttpStatusCode.NO_CONTENT_204).end()