From 7bc29171456ffa91c7ec8dc77e892c7dca359989 Mon Sep 17 00:00:00 2001 From: Chocobozzz Date: Thu, 11 Jan 2018 11:40:18 +0100 Subject: [PATCH] Add tests to handle down server --- server/controllers/api/server/follows.ts | 4 +- server/initializers/constants.ts | 4 +- .../lib/activitypub/process/process-accept.ts | 8 +- .../lib/activitypub/process/process-create.ts | 4 +- .../activitypub-http-job-scheduler.ts | 1 - .../activitypub-http-unicast-handler.ts | 4 +- server/models/activitypub/actor.ts | 4 +- server/tests/api/index-slow.ts | 1 + server/tests/api/server/handle-down.ts | 136 ++++++++++++++++-- server/tests/api/videos/video-channels.ts | 16 +-- server/tests/utils/server/servers.ts | 10 +- server/tests/utils/videos/videos.ts | 3 +- 12 files changed, 161 insertions(+), 34 deletions(-) diff --git a/server/controllers/api/server/follows.ts b/server/controllers/api/server/follows.ts index c87107197..b93d8a816 100644 --- a/server/controllers/api/server/follows.ts +++ b/server/controllers/api/server/follows.ts @@ -124,9 +124,7 @@ function follow (fromActor: ActorModel, targetActor: ActorModel) { actorFollow.ActorFollower = fromActor // Send a notification to remote server - if (actorFollow.state === 'pending') { - await sendFollow(actorFollow, t) - } + await sendFollow(actorFollow, t) }) } diff --git a/server/initializers/constants.ts b/server/initializers/constants.ts index 0c139912c..a3c128d1f 100644 --- a/server/initializers/constants.ts +++ b/server/initializers/constants.ts @@ -283,7 +283,7 @@ const ACTIVITY_PUB = { MAGNET: [ 'application/x-bittorrent;x-scheme-handler/magnet' ] }, MAX_RECURSION_COMMENTS: 100, - ACTOR_REFRESH_INTERVAL: 3600 * 24 // 1 day + ACTOR_REFRESH_INTERVAL: 3600 * 24 * 1000 // 1 day } const ACTIVITY_PUB_ACTOR_TYPES: { [ id: string ]: ActivityPubActorType } = { @@ -355,7 +355,7 @@ if (isTestInstance() === true) { REMOTE_SCHEME.WS = 'ws' STATIC_MAX_AGE = '0' ACTIVITY_PUB.COLLECTION_ITEMS_PER_PAGE = 2 - ACTIVITY_PUB.ACTOR_REFRESH_INTERVAL = 60 // 1 minute + ACTIVITY_PUB.ACTOR_REFRESH_INTERVAL = 10 * 1000 // 10 seconds CONSTRAINTS_FIELDS.ACTORS.AVATAR.FILE_SIZE.max = 100 * 1024 // 100KB SCHEDULER_INTERVAL = 10000 } diff --git a/server/lib/activitypub/process/process-accept.ts b/server/lib/activitypub/process/process-accept.ts index b9d906ec9..551f09ea7 100644 --- a/server/lib/activitypub/process/process-accept.ts +++ b/server/lib/activitypub/process/process-accept.ts @@ -23,7 +23,9 @@ async function processAccept (actor: ActorModel, targetActor: ActorModel) { const follow = await ActorFollowModel.loadByActorAndTarget(actor.id, targetActor.id) if (!follow) throw new Error('Cannot find associated follow.') - follow.set('state', 'accepted') - await follow.save() - await addFetchOutboxJob(targetActor, undefined) + if (follow.state !== 'accepted') { + follow.set('state', 'accepted') + await follow.save() + await addFetchOutboxJob(targetActor, undefined) + } } diff --git a/server/lib/activitypub/process/process-create.ts b/server/lib/activitypub/process/process-create.ts index 08d61996a..442cd5c0b 100644 --- a/server/lib/activitypub/process/process-create.ts +++ b/server/lib/activitypub/process/process-create.ts @@ -147,8 +147,8 @@ async function processCreateView (byActor: ActorModel, activity: ActivityCreate) const { video } = await getOrCreateAccountAndVideoAndChannel(view.object) - const account = await ActorModel.loadByUrl(view.actor) - if (!account) throw new Error('Unknown account ' + view.actor) + const actor = await ActorModel.loadByUrl(view.actor) + if (!actor) throw new Error('Unknown actor ' + view.actor) await video.increment('views') diff --git a/server/lib/jobs/activitypub-http-job-scheduler/activitypub-http-job-scheduler.ts b/server/lib/jobs/activitypub-http-job-scheduler/activitypub-http-job-scheduler.ts index 884ede5a3..10423a7df 100644 --- a/server/lib/jobs/activitypub-http-job-scheduler/activitypub-http-job-scheduler.ts +++ b/server/lib/jobs/activitypub-http-job-scheduler/activitypub-http-job-scheduler.ts @@ -4,7 +4,6 @@ import { logger } from '../../../helpers/logger' import { getServerActor } from '../../../helpers/utils' import { ACTIVITY_PUB } from '../../../initializers' import { ActorModel } from '../../../models/activitypub/actor' -import { ActorFollowModel } from '../../../models/activitypub/actor-follow' import { JobHandler, JobScheduler } from '../job-scheduler' import * as activitypubHttpBroadcastHandler from './activitypub-http-broadcast-handler' diff --git a/server/lib/jobs/activitypub-http-job-scheduler/activitypub-http-unicast-handler.ts b/server/lib/jobs/activitypub-http-job-scheduler/activitypub-http-unicast-handler.ts index e02bd698e..deedf8402 100644 --- a/server/lib/jobs/activitypub-http-job-scheduler/activitypub-http-unicast-handler.ts +++ b/server/lib/jobs/activitypub-http-job-scheduler/activitypub-http-unicast-handler.ts @@ -19,11 +19,11 @@ async function process (payload: ActivityPubHttpPayload, jobId: number) { try { await doRequest(options) - await ActorFollowModel.updateActorFollowsScoreAndRemoveBadOnes([ uri ], [], undefined) + ActorFollowModel.updateActorFollowsScoreAndRemoveBadOnes([ uri ], [], undefined) } catch (err) { const isRetryingLater = await maybeRetryRequestLater(err, payload, uri) if (isRetryingLater === false) { - await ActorFollowModel.updateActorFollowsScoreAndRemoveBadOnes([], [ uri ], undefined) + ActorFollowModel.updateActorFollowsScoreAndRemoveBadOnes([], [ uri ], undefined) } throw err diff --git a/server/models/activitypub/actor.ts b/server/models/activitypub/actor.ts index 912d8d748..6c74aa61b 100644 --- a/server/models/activitypub/actor.ts +++ b/server/models/activitypub/actor.ts @@ -41,11 +41,11 @@ enum ScopeNames { [ScopeNames.FULL]: { include: [ { - model: () => AccountModel, + model: () => AccountModel.unscoped(), required: false }, { - model: () => VideoChannelModel, + model: () => VideoChannelModel.unscoped(), required: false }, { diff --git a/server/tests/api/index-slow.ts b/server/tests/api/index-slow.ts index fe86fc018..0082bcb56 100644 --- a/server/tests/api/index-slow.ts +++ b/server/tests/api/index-slow.ts @@ -6,3 +6,4 @@ import './server/follows' import './server/jobs' import './videos/video-comments' import './users/users-multiple-servers' +import './server/handle-down' diff --git a/server/tests/api/server/handle-down.ts b/server/tests/api/server/handle-down.ts index f8ba8bd66..cc1ff9a9f 100644 --- a/server/tests/api/server/handle-down.ts +++ b/server/tests/api/server/handle-down.ts @@ -3,7 +3,8 @@ import * as chai from 'chai' import 'mocha' import { VideoPrivacy } from '../../../../shared/models/videos' -import { completeVideoCheck, runServer, viewVideo } from '../../utils' +import { VideoCommentThreadTree } from '../../../../shared/models/videos/video-comment.model' +import { completeVideoCheck, getVideo, immutableAssign, reRunServer, viewVideo } from '../../utils' import { flushAndRunMultipleServers, flushTests, getVideosList, killallServers, ServerInfo, setAccessTokensToServers, uploadVideo, @@ -11,11 +12,20 @@ import { } from '../../utils/index' import { follow, getFollowersListPaginationAndSort } from '../../utils/server/follows' import { getJobsListPaginationAndSort } from '../../utils/server/jobs' +import { + addVideoCommentReply, addVideoCommentThread, getVideoCommentThreads, + getVideoThreadComments +} from '../../utils/videos/video-comments' const expect = chai.expect describe('Test handle downs', function () { let servers: ServerInfo[] = [] + const videos = [] + let threadIdServer1: number + let threadIdServer2: number + let commentIdServer1: number + let commentIdServer2: number const videoAttributes = { name: 'my super name for server 1', @@ -23,11 +33,16 @@ describe('Test handle downs', function () { licence: 4, language: 9, nsfw: true, + privacy: VideoPrivacy.PUBLIC, description: 'my super description for server 1', tags: [ 'tag1p1', 'tag2p1' ], fixture: 'video_short1.webm' } + const unlistedVideoAttributes = immutableAssign(videoAttributes, { + privacy: VideoPrivacy.UNLISTED + }) + const checkAttributes = { name: 'my super name for server 1', category: 5, @@ -56,6 +71,10 @@ describe('Test handle downs', function () { ] } + const unlistedCheckAttributes = immutableAssign(checkAttributes, { + privacy: VideoPrivacy.UNLISTED + }) + before(async function () { this.timeout(20000) @@ -85,9 +104,27 @@ describe('Test handle downs', function () { // Kill server 1 killallServers([ servers[1] ]) + let resVideo = await uploadVideo(servers[ 0 ].url, servers[ 0 ].accessToken, unlistedVideoAttributes) + videos.push(resVideo.body.video) + // Remove server 2 follower for (let i = 0; i < 10; i++) { - await uploadVideo(servers[ 0 ].url, servers[ 0 ].accessToken, videoAttributes) + resVideo = await uploadVideo(servers[ 0 ].url, servers[ 0 ].accessToken, videoAttributes) + videos.push(resVideo.body.video) + } + + // Add comments to video 2 + { + const text = 'thread 1' + let resComment = await addVideoCommentThread(servers[0].url, servers[0].accessToken, videos[1].uuid, text) + let comment = resComment.body.comment + threadIdServer1 = comment.id + + resComment = await addVideoCommentReply(servers[0].url, servers[0].accessToken, videos[1].uuid, comment.id, 'comment 1-1') + comment = resComment.body.comment + + resComment = await addVideoCommentReply(servers[0].url, servers[0].accessToken, videos[1].uuid, comment.id, 'comment 1-2') + commentIdServer1 = resComment.body.comment.id } await wait(10000) @@ -108,7 +145,9 @@ describe('Test handle downs', function () { }) it('Should follow server 1', async function () { - servers[1] = await runServer(2) + this.timeout(15000) + + await reRunServer(servers[1]) await follow(servers[1].url, [ servers[0].url ], servers[1].accessToken) @@ -120,19 +159,98 @@ describe('Test handle downs', function () { }) it('Should send a view to server 2, and automatically fetch the video', async function () { - const resVideo = await getVideosList(servers[0].url) - const videoServer1 = resVideo.body.data[0] + this.timeout(15000) - await viewVideo(servers[0].url, videoServer1.uuid) + await viewVideo(servers[0].url, videos[0].uuid) await wait(5000) const res = await getVideosList(servers[1].url) - const videoServer2 = res.body.data.find(v => v.url === videoServer1.url) + expect(res.body.data).to.be.an('array') + // Video is unlisted + expect(res.body.data).to.have.lengthOf(1) - expect(videoServer2).not.to.be.undefined + const resVideo = await getVideo(servers[1].url, videos[0].uuid) + expect(resVideo.body).not.to.be.undefined - await completeVideoCheck(servers[1].url, videoServer2, checkAttributes) + await completeVideoCheck(servers[1].url, resVideo.body, unlistedCheckAttributes) + }) + + it('Should send comments on a video to server 2, and automatically fetch the video', async function () { + this.timeout(25000) + + await addVideoCommentReply(servers[0].url, servers[0].accessToken, videos[1].uuid, commentIdServer1, 'comment 1-3') + + await wait(5000) + + const res = await getVideosList(servers[1].url) + expect(res.body.data).to.be.an('array') + expect(res.body.data).to.have.lengthOf(2) + + const resVideo = await getVideo(servers[1].url, videos[0].uuid) + expect(resVideo.body).not.to.be.undefined + + await completeVideoCheck(servers[1].url, resVideo.body, unlistedCheckAttributes) + + { + let resComment = await getVideoCommentThreads(servers[1].url, videos[1].uuid, 0, 5) + expect(resComment.body.data).to.be.an('array') + expect(resComment.body.data).to.have.lengthOf(1) + + threadIdServer2 = resComment.body.data[0].id + + resComment = await getVideoThreadComments(servers[1].url, videos[1].uuid, threadIdServer2) + + const tree: VideoCommentThreadTree = resComment.body + expect(tree.comment.text).equal('thread 1') + expect(tree.children).to.have.lengthOf(1) + + const firstChild = tree.children[0] + expect(firstChild.comment.text).to.equal('comment 1-1') + expect(firstChild.children).to.have.lengthOf(1) + + const childOfFirstChild = firstChild.children[0] + expect(childOfFirstChild.comment.text).to.equal('comment 1-2') + expect(childOfFirstChild.children).to.have.lengthOf(1) + + const childOfChildFirstChild = childOfFirstChild.children[0] + expect(childOfChildFirstChild.comment.text).to.equal('comment 1-3') + expect(childOfChildFirstChild.children).to.have.lengthOf(0) + + commentIdServer2 = childOfChildFirstChild.comment.id + } + }) + + it('Should correctly reply to the comment', async function () { + this.timeout(15000) + + await addVideoCommentReply(servers[1].url, servers[1].accessToken, videos[1].uuid, commentIdServer2, 'comment 1-4') + + await wait(5000) + + { + const resComment = await getVideoThreadComments(servers[0].url, videos[1].uuid, threadIdServer1) + + const tree: VideoCommentThreadTree = resComment.body + expect(tree.comment.text).equal('thread 1') + expect(tree.children).to.have.lengthOf(1) + + const firstChild = tree.children[0] + expect(firstChild.comment.text).to.equal('comment 1-1') + expect(firstChild.children).to.have.lengthOf(1) + + const childOfFirstChild = firstChild.children[0] + expect(childOfFirstChild.comment.text).to.equal('comment 1-2') + expect(childOfFirstChild.children).to.have.lengthOf(1) + + const childOfChildFirstChild = childOfFirstChild.children[0] + expect(childOfChildFirstChild.comment.text).to.equal('comment 1-3') + expect(childOfChildFirstChild.children).to.have.lengthOf(1) + + const childOfChildOfChildOfFirstChild = childOfChildFirstChild.children[0] + expect(childOfChildOfChildOfFirstChild.comment.text).to.equal('comment 1-4') + expect(childOfChildOfChildOfFirstChild.children).to.have.lengthOf(0) + } }) after(async function () { diff --git a/server/tests/api/videos/video-channels.ts b/server/tests/api/videos/video-channels.ts index 454a96da6..8d33c6025 100644 --- a/server/tests/api/videos/video-channels.ts +++ b/server/tests/api/videos/video-channels.ts @@ -59,8 +59,8 @@ describe('Test a video channels', function () { expect(userInfo.videoChannels).to.have.lengthOf(2) const videoChannels = userInfo.videoChannels - expect(videoChannels[0].name).to.equal('Default root channel') - expect(videoChannels[1].name).to.equal('second video channel') + expect(videoChannels[0].displayName).to.equal('Default root channel') + expect(videoChannels[1].displayName).to.equal('second video channel') expect(videoChannels[1].description).to.equal('super video channel description') }) @@ -72,8 +72,8 @@ describe('Test a video channels', function () { expect(res.body.data).to.have.lengthOf(2) const videoChannels = res.body.data - expect(videoChannels[0].name).to.equal('Default root channel') - expect(videoChannels[1].name).to.equal('second video channel') + expect(videoChannels[0].displayName).to.equal('Default root channel') + expect(videoChannels[1].displayName).to.equal('second video channel') expect(videoChannels[1].description).to.equal('super video channel description') videoChannelId = videoChannels[1].id @@ -85,7 +85,7 @@ describe('Test a video channels', function () { expect(res.body.total).to.equal(2) expect(res.body.data).to.be.an('array') expect(res.body.data).to.have.lengthOf(1) - expect(res.body.data[0].name).to.equal('Default root channel') + expect(res.body.data[0].displayName).to.equal('Default root channel') }) it('Should update video channel', async () => { @@ -103,7 +103,7 @@ describe('Test a video channels', function () { expect(res.body.total).to.equal(2) expect(res.body.data).to.be.an('array') expect(res.body.data).to.have.lengthOf(1) - expect(res.body.data[0].name).to.equal('video channel updated') + expect(res.body.data[0].displayName).to.equal('video channel updated') expect(res.body.data[0].description).to.equal('video channel description updated') }) @@ -111,7 +111,7 @@ describe('Test a video channels', function () { const res = await getVideoChannel(server.url, videoChannelId) const videoChannel = res.body - expect(videoChannel.name).to.equal('video channel updated') + expect(videoChannel.displayName).to.equal('video channel updated') expect(videoChannel.description).to.equal('video channel description updated') }) @@ -125,7 +125,7 @@ describe('Test a video channels', function () { expect(res.body.total).to.equal(1) expect(res.body.data).to.be.an('array') expect(res.body.data).to.have.lengthOf(1) - expect(res.body.data[0].name).to.equal('Default root channel') + expect(res.body.data[0].displayName).to.equal('Default root channel') }) after(async function () { diff --git a/server/tests/utils/server/servers.ts b/server/tests/utils/server/servers.ts index 4add2f69a..878efe91a 100644 --- a/server/tests/utils/server/servers.ts +++ b/server/tests/utils/server/servers.ts @@ -145,6 +145,13 @@ function runServer (serverNumber: number, configOverride?: Object) { }) } +async function reRunServer (server: ServerInfo) { + const newServer = await runServer(server.serverNumber) + server.app = newServer.app + + return server +} + function killallServers (servers: ServerInfo[]) { for (const server of servers) { process.kill(-server.app.pid) @@ -158,5 +165,6 @@ export { flushAndRunMultipleServers, flushTests, runServer, - killallServers + killallServers, + reRunServer } diff --git a/server/tests/utils/videos/videos.ts b/server/tests/utils/videos/videos.ts index c437c21b2..dc1327215 100644 --- a/server/tests/utils/videos/videos.ts +++ b/server/tests/utils/videos/videos.ts @@ -383,7 +383,8 @@ async function completeVideoCheck ( expect(videoDetails.account.name).to.equal(attributes.account) expect(videoDetails.commentsEnabled).to.equal(attributes.commentsEnabled) - expect(videoDetails.channel.name).to.equal(attributes.channel.name) + expect(videoDetails.channel.displayName).to.equal(attributes.channel.name) + expect(videoDetails.channel.name).to.have.lengthOf(36) expect(videoDetails.channel.isLocal).to.equal(attributes.channel.isLocal) expect(dateIsValid(videoDetails.channel.createdAt)).to.be.true expect(dateIsValid(videoDetails.channel.updatedAt)).to.be.true