import { getStats } from '../../../../shared/extra-utils/server/stats'
import { addVideoCommentThread } from '../../../../shared/extra-utils/videos/video-comments'
import { ServerStats } from '../../../../shared/models/server/server-stats.model'
+import { ActivityType } from '@shared/models'
const expect = chai.expect
})
it('Should correctly count video file sizes if transcoding is enabled', async function () {
- this.timeout(20000)
+ this.timeout(60000)
await updateCustomSubConfig(servers[0].url, servers[0].accessToken, {
transcoding: {
'480p': false,
'720p': false,
'1080p': false,
+ '1440p': false,
'2160p': false
}
}
it('Should have the correct AP stats', async function () {
this.timeout(60000)
- for (let i = 0; i < 10; i++) {
- await uploadVideo(servers[0].url, servers[0].accessToken, { name: 'video' })
- }
+ await updateCustomSubConfig(servers[0].url, servers[0].accessToken, {
+ transcoding: {
+ enabled: false
+ }
+ })
const res1 = await getStats(servers[1].url)
const first = res1.body as ServerStats
+ for (let i = 0; i < 10; i++) {
+ await uploadVideo(servers[0].url, servers[0].accessToken, { name: 'video' })
+ }
+
await waitJobs(servers)
+ await wait(6000)
+
const res2 = await getStats(servers[1].url)
const second: ServerStats = res2.body
- expect(second.totalActivityPubMessagesWaiting).to.equal(0)
expect(second.totalActivityPubMessagesProcessed).to.be.greaterThan(first.totalActivityPubMessagesProcessed)
+ const apTypes: ActivityType[] = [
+ 'Create', 'Update', 'Delete', 'Follow', 'Accept', 'Announce', 'Undo', 'Like', 'Reject', 'View', 'Dislike', 'Flag'
+ ]
+
+ const processed = apTypes.reduce(
+ (previous, type) => previous + second['totalActivityPub' + type + 'MessagesSuccesses'],
+ 0
+ )
+ expect(second.totalActivityPubMessagesProcessed).to.equal(processed)
+ expect(second.totalActivityPubMessagesSuccesses).to.equal(processed)
+
+ expect(second.totalActivityPubMessagesErrors).to.equal(0)
+
+ for (const apType of apTypes) {
+ expect(second['totalActivityPub' + apType + 'MessagesErrors']).to.equal(0)
+ }
- await wait(5000)
+ await wait(6000)
const res3 = await getStats(servers[1].url)
const third: ServerStats = res3.body
+ expect(third.totalActivityPubMessagesWaiting).to.equal(0)
expect(third.activityPubMessagesProcessedPerSecond).to.be.lessThan(second.activityPubMessagesProcessedPerSecond)
})