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