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, setAsyncActorKeys } from './activitypub/actor'
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 '../types/models'
16 import { MUser, MUserDefault, MUserId } from '../types/models/user'
17 import { getAccountActivityPubUrl } from './activitypub/url'
19 type ChannelNames = { name: string, displayName: string }
21 async function createUserAccountAndChannelAndPlaylist (parameters: {
23 userDisplayName?: string
24 channelNames?: ChannelNames
25 validateUser?: boolean
26 }): Promise<{ user: MUserDefault, account: MAccountDefault, videoChannel: MChannelActor }> {
27 const { userToCreate, userDisplayName, channelNames, validateUser = true } = parameters
29 const { user, account, videoChannel } = await sequelizeTypescript.transaction(async t => {
32 validate: validateUser
35 const userCreated: MUserDefault = await userToCreate.save(userOptions)
36 userCreated.NotificationSetting = await createDefaultUserNotificationSettings(userCreated, t)
38 const accountCreated = await createLocalAccountWithoutKeys({
39 name: userCreated.username,
40 displayName: userDisplayName,
41 userId: userCreated.id,
45 userCreated.Account = accountCreated
47 const channelAttributes = await buildChannelAttributes(userCreated, channelNames)
48 const videoChannel = await createLocalVideoChannel(channelAttributes, accountCreated, t)
50 const videoPlaylist = await createWatchLaterPlaylist(accountCreated, t)
52 return { user: userCreated, account: accountCreated, videoChannel, videoPlaylist }
55 const [ accountActorWithKeys, channelActorWithKeys ] = await Promise.all([
56 setAsyncActorKeys(account.Actor),
57 setAsyncActorKeys(videoChannel.Actor)
60 account.Actor = accountActorWithKeys
61 videoChannel.Actor = channelActorWithKeys
63 return { user, account, videoChannel }
66 async function createLocalAccountWithoutKeys (parameters: {
70 applicationId: number | null
71 t: Transaction | undefined
72 type?: ActivityPubActorType
74 const { name, displayName, userId, applicationId, t, type = 'Person' } = parameters
75 const url = getAccountActivityPubUrl(name)
77 const actorInstance = buildActorInstance(type, url, name)
78 const actorInstanceCreated: MActorDefault = await actorInstance.save({ transaction: t })
80 const accountInstance = new AccountModel({
81 name: displayName || name,
84 actorId: actorInstanceCreated.id
87 const accountInstanceCreated: MAccountDefault = await accountInstance.save({ transaction: t })
88 accountInstanceCreated.Actor = actorInstanceCreated
90 return accountInstanceCreated
93 async function createApplicationActor (applicationId: number) {
94 const accountCreated = await createLocalAccountWithoutKeys({
95 name: SERVER_ACTOR_NAME,
97 applicationId: applicationId,
102 accountCreated.Actor = await setAsyncActorKeys(accountCreated.Actor)
104 return accountCreated
107 async function sendVerifyUserEmail (user: MUser, isPendingEmail = false) {
108 const verificationString = await Redis.Instance.setVerifyEmailVerificationString(user.id)
109 let url = WEBSERVER.URL + '/verify-account/email?userId=' + user.id + '&verificationString=' + verificationString
111 if (isPendingEmail) url += '&isPendingEmail=true'
113 const email = isPendingEmail ? user.pendingEmail : user.email
114 const username = user.username
116 await Emailer.Instance.addVerifyEmailJob(username, email, url)
119 // ---------------------------------------------------------------------------
122 createApplicationActor,
123 createUserAccountAndChannelAndPlaylist,
124 createLocalAccountWithoutKeys,
128 // ---------------------------------------------------------------------------
130 function createDefaultUserNotificationSettings (user: MUserId, t: Transaction | undefined) {
131 const values: UserNotificationSetting & { userId: number } = {
133 newVideoFromSubscription: UserNotificationSettingValue.WEB,
134 newCommentOnMyVideo: UserNotificationSettingValue.WEB,
135 myVideoImportFinished: UserNotificationSettingValue.WEB,
136 myVideoPublished: UserNotificationSettingValue.WEB,
137 abuseAsModerator: UserNotificationSettingValue.WEB | UserNotificationSettingValue.EMAIL,
138 videoAutoBlacklistAsModerator: UserNotificationSettingValue.WEB | UserNotificationSettingValue.EMAIL,
139 blacklistOnMyVideo: UserNotificationSettingValue.WEB | UserNotificationSettingValue.EMAIL,
140 newUserRegistration: UserNotificationSettingValue.WEB,
141 commentMention: UserNotificationSettingValue.WEB,
142 newFollow: UserNotificationSettingValue.WEB,
143 newInstanceFollower: UserNotificationSettingValue.WEB,
144 abuseNewMessage: UserNotificationSettingValue.WEB | UserNotificationSettingValue.EMAIL,
145 abuseStateChange: UserNotificationSettingValue.WEB | UserNotificationSettingValue.EMAIL,
146 autoInstanceFollowing: UserNotificationSettingValue.WEB
149 return UserNotificationSettingModel.create(values, { transaction: t })
152 async function buildChannelAttributes (user: MUser, channelNames?: ChannelNames) {
153 if (channelNames) return channelNames
155 let channelName = user.username + '_channel'
157 // Conflict, generate uuid instead
158 const actor = await ActorModel.loadLocalByName(channelName)
159 if (actor) channelName = uuidv4()
161 const videoChannelDisplayName = `Main ${user.username} channel`
165 displayName: videoChannelDisplayName