X-Git-Url: https://git.immae.eu/?a=blobdiff_plain;f=server%2Flib%2Fuser.ts;h=56995cca33f5b527a2d8b6a489f3357e8b1feafa;hb=5a05c14573ca3c0d16b77bef78d845f96c8c6497;hp=f4ffae0e4178fa088d2e98fb3428d64189101977;hpb=ba2684ceddf9b76312635b9cddc6bf6975ce436a;p=github%2FChocobozzz%2FPeerTube.git diff --git a/server/lib/user.ts b/server/lib/user.ts index f4ffae0e4..56995cca3 100644 --- a/server/lib/user.ts +++ b/server/lib/user.ts @@ -3,21 +3,19 @@ import { logger } from '@server/helpers/logger' import { CONFIG } from '@server/initializers/config' import { UserModel } from '@server/models/user/user' import { MActorDefault } from '@server/types/models/actor' -import { buildUUID } from '@shared/extra-utils' import { ActivityPubActorType } from '../../shared/models/activitypub' import { UserAdminFlag, UserNotificationSetting, UserNotificationSettingValue, UserRole } from '../../shared/models/users' import { SERVER_ACTOR_NAME, WEBSERVER } from '../initializers/constants' import { sequelizeTypescript } from '../initializers/database' import { AccountModel } from '../models/account/account' -import { ActorModel } from '../models/actor/actor' import { UserNotificationSettingModel } from '../models/user/user-notification-setting' import { MAccountDefault, MChannelActor } from '../types/models' -import { MUser, MUserDefault, MUserId } from '../types/models/user' +import { MRegistration, MUser, MUserDefault, MUserId } from '../types/models/user' import { generateAndSaveActorKeys } from './activitypub/actors' import { getLocalAccountActivityPubUrl } from './activitypub/url' import { Emailer } from './emailer' import { LiveQuotaStore } from './live/live-quota-store' -import { buildActorInstance } from './local-actor' +import { buildActorInstance, findAvailableLocalActorName } from './local-actor' import { Redis } from './redis' import { createLocalVideoChannel } from './video-channel' import { createWatchLaterPlaylist } from './video-playlist' @@ -58,6 +56,8 @@ function buildUser (options: { nsfwPolicy: CONFIG.INSTANCE.DEFAULT_NSFW_POLICY, p2pEnabled: CONFIG.DEFAULTS.P2P.WEBAPP.ENABLED, + videosHistoryEnabled: CONFIG.USER.HISTORY.VIDEOS.ENABLED, + autoPlayVideo: true, role, @@ -71,6 +71,8 @@ function buildUser (options: { }) } +// --------------------------------------------------------------------------- + async function createUserAccountAndChannelAndPlaylist (parameters: { userToCreate: MUser userDisplayName?: string @@ -97,7 +99,7 @@ async function createUserAccountAndChannelAndPlaylist (parameters: { }) userCreated.Account = accountCreated - const channelAttributes = await buildChannelAttributes(userCreated, t, channelNames) + const channelAttributes = await buildChannelAttributes({ user: userCreated, transaction: t, channelNames }) const videoChannel = await createLocalVideoChannel(channelAttributes, accountCreated, t) const videoPlaylist = await createWatchLaterPlaylist(accountCreated, t) @@ -157,18 +159,35 @@ async function createApplicationActor (applicationId: number) { return accountCreated } +// --------------------------------------------------------------------------- + async function sendVerifyUserEmail (user: MUser, isPendingEmail = false) { - const verificationString = await Redis.Instance.setVerifyEmailVerificationString(user.id) - let url = WEBSERVER.URL + '/verify-account/email?userId=' + user.id + '&verificationString=' + verificationString + const verificationString = await Redis.Instance.setUserVerifyEmailVerificationString(user.id) + let verifyEmailUrl = `${WEBSERVER.URL}/verify-account/email?userId=${user.id}&verificationString=${verificationString}` - if (isPendingEmail) url += '&isPendingEmail=true' + if (isPendingEmail) verifyEmailUrl += '&isPendingEmail=true' + + const to = isPendingEmail + ? user.pendingEmail + : user.email - const email = isPendingEmail ? user.pendingEmail : user.email const username = user.username - Emailer.Instance.addVerifyEmailJob(username, email, url) + Emailer.Instance.addVerifyEmailJob({ username, to, verifyEmailUrl, isRegistrationRequest: false }) +} + +async function sendVerifyRegistrationEmail (registration: MRegistration) { + const verificationString = await Redis.Instance.setRegistrationVerifyEmailVerificationString(registration.id) + const verifyEmailUrl = `${WEBSERVER.URL}/verify-account/email?registrationId=${registration.id}&verificationString=${verificationString}` + + const to = registration.email + const username = registration.username + + Emailer.Instance.addVerifyEmailJob({ username, to, verifyEmailUrl, isRegistrationRequest: true }) } +// --------------------------------------------------------------------------- + async function getOriginalVideoFileTotalFromUser (user: MUserId) { // Don't use sequelize because we need to use a sub query const query = UserModel.generateUserQuotaBaseSQL({ @@ -228,7 +247,10 @@ export { createApplicationActor, createUserAccountAndChannelAndPlaylist, createLocalAccountWithoutKeys, + sendVerifyUserEmail, + sendVerifyRegistrationEmail, + isAbleToUploadVideo, buildUser } @@ -260,15 +282,16 @@ function createDefaultUserNotificationSettings (user: MUserId, t: Transaction | return UserNotificationSettingModel.create(values, { transaction: t }) } -async function buildChannelAttributes (user: MUser, transaction?: Transaction, channelNames?: ChannelNames) { - if (channelNames) return channelNames - - let channelName = user.username + '_channel' +async function buildChannelAttributes (options: { + user: MUser + transaction?: Transaction + channelNames?: ChannelNames +}) { + const { user, transaction, channelNames } = options - // Conflict, generate uuid instead - const actor = await ActorModel.loadLocalByName(channelName, transaction) - if (actor) channelName = buildUUID() + if (channelNames) return channelNames + const channelName = await findAvailableLocalActorName(user.username + '_channel', transaction) const videoChannelDisplayName = `Main ${user.username} channel` return {