2 import * as express from 'express'
3 import { auditLoggerFactory, getAuditIdFromRes, UserAuditView } from '@server/helpers/audit-logger'
4 import { Hooks } from '@server/lib/plugins/hooks'
5 import { UserUpdateMe, UserVideoRate as FormattedUserVideoRate } from '../../../../shared'
6 import { HttpStatusCode } from '../../../../shared/core-utils/miscs/http-error-codes'
7 import { UserVideoQuota } from '../../../../shared/models/users/user-video-quota.model'
8 import { createReqFiles } from '../../../helpers/express-utils'
9 import { getFormattedObjects } from '../../../helpers/utils'
10 import { CONFIG } from '../../../initializers/config'
11 import { MIMETYPES } from '../../../initializers/constants'
12 import { sequelizeTypescript } from '../../../initializers/database'
13 import { sendUpdateActor } from '../../../lib/activitypub/send'
14 import { deleteLocalActorAvatarFile, updateLocalActorAvatarFile } from '../../../lib/avatar'
15 import { getOriginalVideoFileTotalDailyFromUser, getOriginalVideoFileTotalFromUser, sendVerifyUserEmail } from '../../../lib/user'
18 asyncRetryTransactionMiddleware,
24 usersUpdateMeValidator,
25 usersVideoRatingValidator
26 } from '../../../middlewares'
27 import { deleteMeValidator, videoImportsSortValidator, videosSortValidator } from '../../../middlewares/validators'
28 import { updateAvatarValidator } from '../../../middlewares/validators/avatar'
29 import { AccountModel } from '../../../models/account/account'
30 import { AccountVideoRateModel } from '../../../models/account/account-video-rate'
31 import { UserModel } from '../../../models/account/user'
32 import { VideoModel } from '../../../models/video/video'
33 import { VideoImportModel } from '../../../models/video/video-import'
35 const auditLogger = auditLoggerFactory('users')
37 const reqAvatarFile = createReqFiles([ 'avatarfile' ], MIMETYPES.IMAGE.MIMETYPE_EXT, { avatarfile: CONFIG.STORAGE.TMP_DIR })
39 const meRouter = express.Router()
43 asyncMiddleware(getUserInformation)
45 meRouter.delete('/me',
48 asyncMiddleware(deleteMe)
51 meRouter.get('/me/video-quota-used',
53 asyncMiddleware(getUserVideoQuotaUsed)
56 meRouter.get('/me/videos/imports',
59 videoImportsSortValidator,
62 asyncMiddleware(getUserVideoImports)
65 meRouter.get('/me/videos',
71 asyncMiddleware(getUserVideos)
74 meRouter.get('/me/videos/:videoId/rating',
76 asyncMiddleware(usersVideoRatingValidator),
77 asyncMiddleware(getUserVideoRating)
82 asyncMiddleware(usersUpdateMeValidator),
83 asyncRetryTransactionMiddleware(updateMe)
86 meRouter.post('/me/avatar/pick',
89 updateAvatarValidator,
90 asyncRetryTransactionMiddleware(updateMyAvatar)
93 meRouter.delete('/me/avatar',
95 asyncRetryTransactionMiddleware(deleteMyAvatar)
98 // ---------------------------------------------------------------------------
104 // ---------------------------------------------------------------------------
106 async function getUserVideos (req: express.Request, res: express.Response) {
107 const user = res.locals.oauth.token.User
109 const apiOptions = await Hooks.wrapObject({
110 accountId: user.Account.id,
111 start: req.query.start,
112 count: req.query.count,
113 sort: req.query.sort,
114 search: req.query.search
115 }, 'filter:api.user.me.videos.list.params')
117 const resultList = await Hooks.wrapPromiseFun(
118 VideoModel.listUserVideosForApi,
120 'filter:api.user.me.videos.list.result'
123 const additionalAttributes = {
124 waitTranscoding: true,
126 scheduledUpdate: true,
129 return res.json(getFormattedObjects(resultList.data, resultList.total, { additionalAttributes }))
132 async function getUserVideoImports (req: express.Request, res: express.Response) {
133 const user = res.locals.oauth.token.User
134 const resultList = await VideoImportModel.listUserVideoImportsForApi(
136 req.query.start as number,
137 req.query.count as number,
141 return res.json(getFormattedObjects(resultList.data, resultList.total))
144 async function getUserInformation (req: express.Request, res: express.Response) {
145 // We did not load channels in res.locals.user
146 const user = await UserModel.loadForMeAPI(res.locals.oauth.token.user.id)
148 return res.json(user.toMeFormattedJSON())
151 async function getUserVideoQuotaUsed (req: express.Request, res: express.Response) {
152 const user = res.locals.oauth.token.user
153 const videoQuotaUsed = await getOriginalVideoFileTotalFromUser(user)
154 const videoQuotaUsedDaily = await getOriginalVideoFileTotalDailyFromUser(user)
156 const data: UserVideoQuota = {
160 return res.json(data)
163 async function getUserVideoRating (req: express.Request, res: express.Response) {
164 const videoId = res.locals.videoId.id
165 const accountId = +res.locals.oauth.token.User.Account.id
167 const ratingObj = await AccountVideoRateModel.load(accountId, videoId, null)
168 const rating = ratingObj ? ratingObj.type : 'none'
170 const json: FormattedUserVideoRate = {
174 return res.json(json)
177 async function deleteMe (req: express.Request, res: express.Response) {
178 const user = await UserModel.loadByIdWithChannels(res.locals.oauth.token.User.id)
180 auditLogger.delete(getAuditIdFromRes(res), new UserAuditView(user.toFormattedJSON()))
184 return res.sendStatus(HttpStatusCode.NO_CONTENT_204)
187 async function updateMe (req: express.Request, res: express.Response) {
188 const body: UserUpdateMe = req.body
189 let sendVerificationEmail = false
191 const user = res.locals.oauth.token.user
193 if (body.password !== undefined) user.password = body.password
194 if (body.nsfwPolicy !== undefined) user.nsfwPolicy = body.nsfwPolicy
195 if (body.webTorrentEnabled !== undefined) user.webTorrentEnabled = body.webTorrentEnabled
196 if (body.autoPlayVideo !== undefined) user.autoPlayVideo = body.autoPlayVideo
197 if (body.autoPlayNextVideo !== undefined) user.autoPlayNextVideo = body.autoPlayNextVideo
198 if (body.autoPlayNextVideoPlaylist !== undefined) user.autoPlayNextVideoPlaylist = body.autoPlayNextVideoPlaylist
199 if (body.videosHistoryEnabled !== undefined) user.videosHistoryEnabled = body.videosHistoryEnabled
200 if (body.videoLanguages !== undefined) user.videoLanguages = body.videoLanguages
201 if (body.theme !== undefined) user.theme = body.theme
202 if (body.noInstanceConfigWarningModal !== undefined) user.noInstanceConfigWarningModal = body.noInstanceConfigWarningModal
203 if (body.noWelcomeModal !== undefined) user.noWelcomeModal = body.noWelcomeModal
205 if (body.email !== undefined) {
206 if (CONFIG.SIGNUP.REQUIRES_EMAIL_VERIFICATION) {
207 user.pendingEmail = body.email
208 sendVerificationEmail = true
210 user.email = body.email
214 await sequelizeTypescript.transaction(async t => {
215 await user.save({ transaction: t })
217 if (body.displayName !== undefined || body.description !== undefined) {
218 const userAccount = await AccountModel.load(user.Account.id, t)
220 if (body.displayName !== undefined) userAccount.name = body.displayName
221 if (body.description !== undefined) userAccount.description = body.description
222 await userAccount.save({ transaction: t })
224 await sendUpdateActor(userAccount, t)
228 if (sendVerificationEmail === true) {
229 await sendVerifyUserEmail(user, true)
232 return res.sendStatus(HttpStatusCode.NO_CONTENT_204)
235 async function updateMyAvatar (req: express.Request, res: express.Response) {
236 const avatarPhysicalFile = req.files['avatarfile'][0]
237 const user = res.locals.oauth.token.user
239 const userAccount = await AccountModel.load(user.Account.id)
241 const avatar = await updateLocalActorAvatarFile(userAccount, avatarPhysicalFile)
243 return res.json({ avatar: avatar.toFormattedJSON() })
246 async function deleteMyAvatar (req: express.Request, res: express.Response) {
247 const user = res.locals.oauth.token.user
249 const userAccount = await AccountModel.load(user.Account.id)
250 await deleteLocalActorAvatarFile(userAccount)
252 return res.sendStatus(HttpStatusCode.NO_CONTENT_204)