X-Git-Url: https://git.immae.eu/?a=blobdiff_plain;f=server%2Flib%2Fuser.ts;h=2ea7481e8152b09ce9fc11ff75bd178951ed9e89;hb=81e504b34e71e91633442c8021e05f9cd52a49c6;hp=a92f4777bbdfa74ab4e56165f6d3827de8b3ce3a;hpb=f5028693a896a3076dd286ac0030e3d8f78f5ebf;p=github%2FChocobozzz%2FPeerTube.git diff --git a/server/lib/user.ts b/server/lib/user.ts index a92f4777b..2ea7481e8 100644 --- a/server/lib/user.ts +++ b/server/lib/user.ts @@ -1,42 +1,73 @@ -import { database as db } from '../initializers' -import { UserInstance } from '../models' -import { addVideoAuthorToFriends } from './friends' +import * as Sequelize from 'sequelize' +import { ActivityPubActorType } from '../../shared/models/activitypub' +import { sequelizeTypescript, SERVER_ACTOR_NAME } from '../initializers' +import { AccountModel } from '../models/account/account' +import { UserModel } from '../models/account/user' +import { buildActorInstance, getAccountActivityPubUrl, setAsyncActorKeys } from './activitypub' import { createVideoChannel } from './video-channel' -async function createUserAuthorAndChannel (user: UserInstance, validateUser = true) { - const res = await db.sequelize.transaction(async t => { +async function createUserAccountAndChannel (userToCreate: UserModel, validateUser = true) { + const { user, account, videoChannel } = await sequelizeTypescript.transaction(async t => { const userOptions = { transaction: t, validate: validateUser } - const userCreated = await user.save(userOptions) - const authorInstance = db.Author.build({ - name: userCreated.username, - podId: null, // It is our pod - userId: userCreated.id - }) + const userCreated = await userToCreate.save(userOptions) + const accountCreated = await createLocalAccountWithoutKeys(userToCreate.username, userToCreate.id, null, t) - const authorCreated = await authorInstance.save({ transaction: t }) + const videoChannelName = `Default ${userCreated.username} channel` + const videoChannelInfo = { + name: videoChannelName + } + const videoChannel = await createVideoChannel(videoChannelInfo, accountCreated, t) - const remoteVideoAuthor = authorCreated.toAddRemoteJSON() + return { user: userCreated, account: accountCreated, videoChannel } + }) - // Now we'll add the video channel's meta data to our friends - const author = await addVideoAuthorToFriends(remoteVideoAuthor, t) + account.Actor = await setAsyncActorKeys(account.Actor) + videoChannel.Actor = await setAsyncActorKeys(videoChannel.Actor) - const videoChannelInfo = { - name: `Default ${userCreated.username} channel` - } - const videoChannel = await createVideoChannel(videoChannelInfo, authorCreated, t) + return { user, account, videoChannel } +} + +async function createLocalAccountWithoutKeys ( + name: string, + userId: number, + applicationId: number, + t: Sequelize.Transaction, + type: ActivityPubActorType= 'Person' +) { + const url = getAccountActivityPubUrl(name) - return { author, videoChannel } + const actorInstance = buildActorInstance(type, url, name) + const actorInstanceCreated = await actorInstance.save({ transaction: t }) + + const accountInstance = new AccountModel({ + name, + userId, + applicationId, + actorId: actorInstanceCreated.id }) - return res + const accountInstanceCreated = await accountInstance.save({ transaction: t }) + accountInstanceCreated.Actor = actorInstanceCreated + + return accountInstanceCreated +} + +async function createApplicationActor (applicationId: number) { + const accountCreated = await createLocalAccountWithoutKeys(SERVER_ACTOR_NAME, null, applicationId, undefined, 'Application') + + accountCreated.Actor = await setAsyncActorKeys(accountCreated.Actor) + + return accountCreated } // --------------------------------------------------------------------------- export { - createUserAuthorAndChannel + createApplicationActor, + createUserAccountAndChannel, + createLocalAccountWithoutKeys }