1 import { v4 as uuidv4 } from 'uuid'
2 import { ActivityPubActorType } from '../../shared/models/activitypub'
3 import { SERVER_ACTOR_NAME, WEBSERVER } from '../initializers/constants'
4 import { AccountModel } from '../models/account/account'
5 import { buildActorInstance, getAccountActivityPubUrl, setAsyncActorKeys } from './activitypub'
6 import { createLocalVideoChannel } from './video-channel'
7 import { ActorModel } from '../models/activitypub/actor'
8 import { UserNotificationSettingModel } from '../models/account/user-notification-setting'
9 import { UserNotificationSetting, UserNotificationSettingValue } from '../../shared/models/users'
10 import { createWatchLaterPlaylist } from './video-playlist'
11 import { sequelizeTypescript } from '../initializers/database'
12 import { Transaction } from 'sequelize/types'
13 import { Redis } from './redis'
14 import { Emailer } from './emailer'
15 import { MAccountDefault, MActorDefault, MChannelActor } from '../typings/models'
16 import { MUser, MUserDefault, MUserId } from '../typings/models/user'
18 type ChannelNames = { name: string, displayName: string }
20 async function createUserAccountAndChannelAndPlaylist (parameters: {
22 userDisplayName?: string
23 channelNames?: ChannelNames
24 validateUser?: boolean
25 }): Promise<{ user: MUserDefault, account: MAccountDefault, videoChannel: MChannelActor }> {
26 const { userToCreate, userDisplayName, channelNames, validateUser = true } = parameters
28 const { user, account, videoChannel } = await sequelizeTypescript.transaction(async t => {
31 validate: validateUser
34 const userCreated: MUserDefault = await userToCreate.save(userOptions)
35 userCreated.NotificationSetting = await createDefaultUserNotificationSettings(userCreated, t)
37 const accountCreated = await createLocalAccountWithoutKeys({
38 name: userCreated.username,
39 displayName: userDisplayName,
40 userId: userCreated.id,
44 userCreated.Account = accountCreated
46 const channelAttributes = await buildChannelAttributes(userCreated, channelNames)
47 const videoChannel = await createLocalVideoChannel(channelAttributes, accountCreated, t)
49 const videoPlaylist = await createWatchLaterPlaylist(accountCreated, t)
51 return { user: userCreated, account: accountCreated, videoChannel, videoPlaylist }
54 const [ accountActorWithKeys, channelActorWithKeys ] = await Promise.all([
55 setAsyncActorKeys(account.Actor),
56 setAsyncActorKeys(videoChannel.Actor)
59 account.Actor = accountActorWithKeys
60 videoChannel.Actor = channelActorWithKeys
62 return { user, account, videoChannel }
65 async function createLocalAccountWithoutKeys (parameters: {
69 applicationId: number | null
70 t: Transaction | undefined
71 type?: ActivityPubActorType
73 const { name, displayName, userId, applicationId, t, type = 'Person' } = parameters
74 const url = getAccountActivityPubUrl(name)
76 const actorInstance = buildActorInstance(type, url, name)
77 const actorInstanceCreated: MActorDefault = await actorInstance.save({ transaction: t })
79 const accountInstance = new AccountModel({
80 name: displayName || name,
83 actorId: actorInstanceCreated.id
86 const accountInstanceCreated: MAccountDefault = await accountInstance.save({ transaction: t })
87 accountInstanceCreated.Actor = actorInstanceCreated
89 return accountInstanceCreated
92 async function createApplicationActor (applicationId: number) {
93 const accountCreated = await createLocalAccountWithoutKeys({
94 name: SERVER_ACTOR_NAME,
96 applicationId: applicationId,
101 accountCreated.Actor = await setAsyncActorKeys(accountCreated.Actor)
103 return accountCreated
106 async function sendVerifyUserEmail (user: MUser, isPendingEmail = false) {
107 const verificationString = await Redis.Instance.setVerifyEmailVerificationString(user.id)
108 let url = WEBSERVER.URL + '/verify-account/email?userId=' + user.id + '&verificationString=' + verificationString
110 if (isPendingEmail) url += '&isPendingEmail=true'
112 const email = isPendingEmail ? user.pendingEmail : user.email
114 await Emailer.Instance.addVerifyEmailJob(email, url)
117 // ---------------------------------------------------------------------------
120 createApplicationActor,
121 createUserAccountAndChannelAndPlaylist,
122 createLocalAccountWithoutKeys,
126 // ---------------------------------------------------------------------------
128 function createDefaultUserNotificationSettings (user: MUserId, t: Transaction | undefined) {
129 const values: UserNotificationSetting & { userId: number } = {
131 newVideoFromSubscription: UserNotificationSettingValue.WEB,
132 newCommentOnMyVideo: UserNotificationSettingValue.WEB,
133 myVideoImportFinished: UserNotificationSettingValue.WEB,
134 myVideoPublished: UserNotificationSettingValue.WEB,
135 videoAbuseAsModerator: UserNotificationSettingValue.WEB | UserNotificationSettingValue.EMAIL,
136 videoAutoBlacklistAsModerator: UserNotificationSettingValue.WEB | UserNotificationSettingValue.EMAIL,
137 blacklistOnMyVideo: UserNotificationSettingValue.WEB | UserNotificationSettingValue.EMAIL,
138 newUserRegistration: UserNotificationSettingValue.WEB,
139 commentMention: UserNotificationSettingValue.WEB,
140 newFollow: UserNotificationSettingValue.WEB,
141 newInstanceFollower: UserNotificationSettingValue.WEB,
142 autoInstanceFollowing: UserNotificationSettingValue.WEB
145 return UserNotificationSettingModel.create(values, { transaction: t })
148 async function buildChannelAttributes (user: MUser, channelNames?: ChannelNames) {
149 if (channelNames) return channelNames
151 let channelName = user.username + '_channel'
153 // Conflict, generate uuid instead
154 const actor = await ActorModel.loadLocalByName(channelName)
155 if (actor) channelName = uuidv4()
157 const videoChannelDisplayName = `Main ${user.username} channel`
161 displayName: videoChannelDisplayName