X-Git-Url: https://git.immae.eu/?a=blobdiff_plain;f=server%2Finitializers%2Fmigrations%2F0100-activitypub.ts;h=05fd37406874a4c2eb0d85969631ee53d2810e95;hb=fb7194043d0486ce0a6a40b2ffbdf32878c33a6f;hp=50a0adc143e86233d1b5e03d6a4765b5af636a7f;hpb=74bb2cb8348d6794ed3a0e2ec94c8c9abdde82cf;p=github%2FChocobozzz%2FPeerTube.git diff --git a/server/initializers/migrations/0100-activitypub.ts b/server/initializers/migrations/0100-activitypub.ts index 50a0adc14..05fd37406 100644 --- a/server/initializers/migrations/0100-activitypub.ts +++ b/server/initializers/migrations/0100-activitypub.ts @@ -1,17 +1,16 @@ -import { values } from 'lodash' import * as Sequelize from 'sequelize' import { createPrivateAndPublicKeys } from '../../helpers/peertube-crypto' -import { shareVideoByServer } from '../../lib/activitypub/share' +import { shareVideoByServerAndChannel } from '../../lib/activitypub/share' import { getVideoActivityPubUrl, getVideoChannelActivityPubUrl } from '../../lib/activitypub/url' import { createLocalAccountWithoutKeys } from '../../lib/user' -import { JOB_CATEGORIES, SERVER_ACCOUNT_NAME } from '../constants' -import { PeerTubeDatabase } from '../database' +import { ApplicationModel } from '../../models/application/application' +import { SERVER_ACTOR_NAME } from '../constants' async function up (utils: { - transaction: Sequelize.Transaction, - queryInterface: Sequelize.QueryInterface, - sequelize: Sequelize.Sequelize, - db: PeerTubeDatabase + transaction: Sequelize.Transaction + queryInterface: Sequelize.QueryInterface + sequelize: Sequelize.Sequelize + db: any }): Promise { const q = utils.queryInterface const db = utils.db @@ -22,7 +21,7 @@ async function up (utils: { const options = { type: Sequelize.QueryTypes.SELECT } - const res = await utils.sequelize.query(query, options) + const res = await utils.sequelize.query(query, options) as any if (!res[0] || res[0].total !== 0) { throw new Error('You need to quit friends.') @@ -65,12 +64,17 @@ async function up (utils: { // Create application account { - const applicationInstance = await db.Application.findOne() - const accountCreated = await createLocalAccountWithoutKeys(SERVER_ACCOUNT_NAME, null, applicationInstance.id, undefined) + const applicationInstance = await ApplicationModel.findOne() + const accountCreated = await createLocalAccountWithoutKeys({ + name: SERVER_ACTOR_NAME, + userId: null, + applicationId: applicationInstance.id, + t: undefined + }) const { publicKey, privateKey } = await createPrivateAndPublicKeys() - accountCreated.set('publicKey', publicKey) - accountCreated.set('privateKey', privateKey) + accountCreated.Actor.publicKey = publicKey + accountCreated.Actor.privateKey = privateKey await accountCreated.save() } @@ -84,11 +88,11 @@ async function up (utils: { // Recreate accounts for each user const users = await db.User.findAll() for (const user of users) { - const account = await createLocalAccountWithoutKeys(user.username, user.id, null, undefined) + const account = await createLocalAccountWithoutKeys({ name: user.username, userId: user.id, applicationId: null, t: undefined }) const { publicKey, privateKey } = await createPrivateAndPublicKeys() - account.set('publicKey', publicKey) - account.set('privateKey', privateKey) + account.Actor.publicKey = publicKey + account.Actor.privateKey = privateKey await account.save() } @@ -161,7 +165,7 @@ async function up (utils: { { const data = { - type: Sequelize.ENUM(values(JOB_CATEGORIES)), + type: Sequelize.ENUM('transcoding', 'activitypub-http'), defaultValue: 'transcoding', allowNull: false } @@ -197,7 +201,7 @@ async function up (utils: { }) for (const video of videos) { - await shareVideoByServer(video, undefined) + await shareVideoByServerAndChannel(video, undefined) } } }