123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109 |
- import 'multer'
- import express from 'express'
- import { HttpStatusCode, UserNotificationSetting } from '@peertube/peertube-models'
- import { getFormattedObjects } from '@server/helpers/utils.js'
- import { UserNotificationModel } from '@server/models/user/user-notification.js'
- import {
- asyncMiddleware,
- asyncRetryTransactionMiddleware,
- authenticate,
- paginationValidator,
- setDefaultPagination,
- setDefaultSort,
- userNotificationsSortValidator
- } from '../../../middlewares/index.js'
- import {
- listUserNotificationsValidator,
- markAsReadUserNotificationsValidator,
- updateNotificationSettingsValidator
- } from '../../../middlewares/validators/users/user-notifications.js'
- import { UserNotificationSettingModel } from '../../../models/user/user-notification-setting.js'
- import { meRouter } from './me.js'
- const myNotificationsRouter = express.Router()
- meRouter.put('/me/notification-settings',
- authenticate,
- updateNotificationSettingsValidator,
- asyncRetryTransactionMiddleware(updateNotificationSettings)
- )
- myNotificationsRouter.get('/me/notifications',
- authenticate,
- paginationValidator,
- userNotificationsSortValidator,
- setDefaultSort,
- setDefaultPagination,
- listUserNotificationsValidator,
- asyncMiddleware(listUserNotifications)
- )
- myNotificationsRouter.post('/me/notifications/read',
- authenticate,
- markAsReadUserNotificationsValidator,
- asyncMiddleware(markAsReadUserNotifications)
- )
- myNotificationsRouter.post('/me/notifications/read-all',
- authenticate,
- asyncMiddleware(markAsReadAllUserNotifications)
- )
- export {
- myNotificationsRouter
- }
- // ---------------------------------------------------------------------------
- async function updateNotificationSettings (req: express.Request, res: express.Response) {
- const user = res.locals.oauth.token.User
- const body = req.body as UserNotificationSetting
- const values: UserNotificationSetting = {
- newVideoFromSubscription: body.newVideoFromSubscription,
- newCommentOnMyVideo: body.newCommentOnMyVideo,
- abuseAsModerator: body.abuseAsModerator,
- videoAutoBlacklistAsModerator: body.videoAutoBlacklistAsModerator,
- blacklistOnMyVideo: body.blacklistOnMyVideo,
- myVideoPublished: body.myVideoPublished,
- myVideoImportFinished: body.myVideoImportFinished,
- newFollow: body.newFollow,
- newUserRegistration: body.newUserRegistration,
- commentMention: body.commentMention,
- newInstanceFollower: body.newInstanceFollower,
- autoInstanceFollowing: body.autoInstanceFollowing,
- abuseNewMessage: body.abuseNewMessage,
- abuseStateChange: body.abuseStateChange,
- newPeerTubeVersion: body.newPeerTubeVersion,
- newPluginVersion: body.newPluginVersion,
- myVideoStudioEditionFinished: body.myVideoStudioEditionFinished
- }
- await UserNotificationSettingModel.updateUserSettings(values, user.id)
- return res.sendStatus(HttpStatusCode.NO_CONTENT_204)
- }
- async function listUserNotifications (req: express.Request, res: express.Response) {
- const user = res.locals.oauth.token.User
- const resultList = await UserNotificationModel.listForApi(user.id, req.query.start, req.query.count, req.query.sort, req.query.unread)
- return res.json(getFormattedObjects(resultList.data, resultList.total))
- }
- async function markAsReadUserNotifications (req: express.Request, res: express.Response) {
- const user = res.locals.oauth.token.User
- await UserNotificationModel.markAsRead(user.id, req.body.ids)
- return res.sendStatus(HttpStatusCode.NO_CONTENT_204)
- }
- async function markAsReadAllUserNotifications (req: express.Request, res: express.Response) {
- const user = res.locals.oauth.token.User
- await UserNotificationModel.markAllAsRead(user.id)
- return res.sendStatus(HttpStatusCode.NO_CONTENT_204)
- }
|