PeerTube/server/tests/api/server/stats.ts

183 lines
5.6 KiB
TypeScript
Raw Normal View History

2020-01-31 09:56:52 -06:00
/* eslint-disable @typescript-eslint/no-unused-expressions,@typescript-eslint/require-await */
2018-02-28 11:04:46 -06:00
import 'mocha'
2020-11-10 01:07:21 -06:00
import * as chai from 'chai'
2018-02-28 11:04:46 -06:00
import {
2019-04-24 08:10:37 -05:00
cleanupTests,
2018-02-28 11:04:46 -06:00
createUser,
doubleFollow,
flushAndRunMultipleServers,
follow,
2020-11-10 01:07:21 -06:00
ServerInfo,
unfollow,
updateCustomSubConfig,
2018-02-28 11:04:46 -06:00
uploadVideo,
2020-11-10 01:07:21 -06:00
userLogin,
2018-02-28 11:04:46 -06:00
viewVideo,
2020-11-10 01:07:21 -06:00
wait
} from '../../../../shared/extra-utils'
2020-01-31 09:56:52 -06:00
import { setAccessTokensToServers } from '../../../../shared/extra-utils/index'
2020-11-10 01:07:21 -06:00
import { waitJobs } from '../../../../shared/extra-utils/server/jobs'
import { getStats } from '../../../../shared/extra-utils/server/stats'
import { addVideoCommentThread } from '../../../../shared/extra-utils/videos/video-comments'
2020-11-10 01:07:21 -06:00
import { ServerStats } from '../../../../shared/models/server/server-stats.model'
2018-02-28 11:04:46 -06:00
const expect = chai.expect
2018-09-14 07:57:59 -05:00
describe('Test stats (excluding redundancy)', function () {
2018-02-28 11:04:46 -06:00
let servers: ServerInfo[] = []
2020-05-07 03:39:09 -05:00
const user = {
username: 'user1',
password: 'super_password'
}
2018-02-28 11:04:46 -06:00
before(async function () {
this.timeout(60000)
2020-11-10 01:07:21 -06:00
2018-02-28 11:04:46 -06:00
servers = await flushAndRunMultipleServers(3)
2020-11-10 01:07:21 -06:00
2018-02-28 11:04:46 -06:00
await setAccessTokensToServers(servers)
await doubleFollow(servers[0], servers[1])
2020-01-31 09:56:52 -06:00
await createUser({ url: servers[0].url, accessToken: servers[0].accessToken, username: user.username, password: user.password })
2018-02-28 11:04:46 -06:00
2019-01-15 02:45:54 -06:00
const resVideo = await uploadVideo(servers[0].url, servers[0].accessToken, { fixture: 'video_short.webm' })
2018-02-28 11:04:46 -06:00
const videoUUID = resVideo.body.video.uuid
await addVideoCommentThread(servers[0].url, servers[0].accessToken, videoUUID, 'comment')
await viewVideo(servers[0].url, videoUUID)
2018-08-29 09:26:25 -05:00
// Wait the video views repeatable job
await wait(8000)
2018-02-28 11:04:46 -06:00
await follow(servers[2].url, [ servers[0].url ], servers[2].accessToken)
await waitJobs(servers)
2018-02-28 11:04:46 -06:00
})
it('Should have the correct stats on instance 1', async function () {
const res = await getStats(servers[0].url)
const data: ServerStats = res.body
expect(data.totalLocalVideoComments).to.equal(1)
expect(data.totalLocalVideos).to.equal(1)
expect(data.totalLocalVideoViews).to.equal(1)
2019-01-15 02:45:54 -06:00
expect(data.totalLocalVideoFilesSize).to.equal(218910)
2018-02-28 11:04:46 -06:00
expect(data.totalUsers).to.equal(2)
expect(data.totalVideoComments).to.equal(1)
expect(data.totalVideos).to.equal(1)
expect(data.totalInstanceFollowers).to.equal(2)
expect(data.totalInstanceFollowing).to.equal(1)
})
it('Should have the correct stats on instance 2', async function () {
const res = await getStats(servers[1].url)
const data: ServerStats = res.body
expect(data.totalLocalVideoComments).to.equal(0)
expect(data.totalLocalVideos).to.equal(0)
expect(data.totalLocalVideoViews).to.equal(0)
expect(data.totalLocalVideoFilesSize).to.equal(0)
2018-02-28 11:04:46 -06:00
expect(data.totalUsers).to.equal(1)
expect(data.totalVideoComments).to.equal(1)
expect(data.totalVideos).to.equal(1)
expect(data.totalInstanceFollowers).to.equal(1)
expect(data.totalInstanceFollowing).to.equal(1)
})
it('Should have the correct stats on instance 3', async function () {
const res = await getStats(servers[2].url)
const data: ServerStats = res.body
expect(data.totalLocalVideoComments).to.equal(0)
expect(data.totalLocalVideos).to.equal(0)
expect(data.totalLocalVideoViews).to.equal(0)
expect(data.totalUsers).to.equal(1)
expect(data.totalVideoComments).to.equal(1)
expect(data.totalVideos).to.equal(1)
expect(data.totalInstanceFollowing).to.equal(1)
expect(data.totalInstanceFollowers).to.equal(0)
})
2020-03-13 07:43:26 -05:00
it('Should have the correct total videos stats after an unfollow', async function () {
2020-05-07 03:39:09 -05:00
this.timeout(15000)
2020-03-13 07:43:26 -05:00
await unfollow(servers[2].url, servers[2].accessToken, servers[0])
await waitJobs(servers)
const res = await getStats(servers[2].url)
const data: ServerStats = res.body
expect(data.totalVideos).to.equal(0)
})
2020-05-07 03:39:09 -05:00
it('Should have the correct active users stats', async function () {
const server = servers[0]
{
const res = await getStats(server.url)
const data: ServerStats = res.body
expect(data.totalDailyActiveUsers).to.equal(1)
expect(data.totalWeeklyActiveUsers).to.equal(1)
expect(data.totalMonthlyActiveUsers).to.equal(1)
}
{
await userLogin(server, user)
const res = await getStats(server.url)
const data: ServerStats = res.body
expect(data.totalDailyActiveUsers).to.equal(2)
expect(data.totalWeeklyActiveUsers).to.equal(2)
expect(data.totalMonthlyActiveUsers).to.equal(2)
}
})
2020-11-10 01:07:21 -06:00
it('Should correctly count video file sizes if transcoding is enabled', async function () {
this.timeout(20000)
await updateCustomSubConfig(servers[0].url, servers[0].accessToken, {
transcoding: {
enabled: true,
webtorrent: {
enabled: true
},
hls: {
enabled: true
},
resolutions: {
'0p': false,
'240p': false,
'360p': false,
'480p': false,
'720p': false,
'1080p': false,
'2160p': false
}
}
})
await uploadVideo(servers[0].url, servers[0].accessToken, { name: 'video', fixture: 'video_short.webm' })
await waitJobs(servers)
{
const res = await getStats(servers[1].url)
const data: ServerStats = res.body
expect(data.totalLocalVideoFilesSize).to.equal(0)
}
{
const res = await getStats(servers[0].url)
const data: ServerStats = res.body
expect(data.totalLocalVideoFilesSize).to.be.greaterThan(300000)
expect(data.totalLocalVideoFilesSize).to.be.lessThan(400000)
}
})
2019-04-24 08:10:37 -05:00
after(async function () {
await cleanupTests(servers)
2018-02-28 11:04:46 -06:00
})
})