1 /* eslint-disable @typescript-eslint/no-unused-expressions,@typescript-eslint/require-await */
4 import * as chai from 'chai'
12 flushAndRunMultipleServers,
14 setAccessTokensToServers,
15 updateCustomSubConfig,
21 } from '@shared/extra-utils'
22 import { ActivityType, VideoPlaylistPrivacy } from '@shared/models'
24 const expect = chai.expect
26 describe('Test stats (excluding redundancy)', function () {
27 let servers: ServerInfo[] = []
31 password: 'super_password'
34 before(async function () {
37 servers = await flushAndRunMultipleServers(3)
39 await setAccessTokensToServers(servers)
41 await doubleFollow(servers[0], servers[1])
43 await createUser({ url: servers[0].url, accessToken: servers[0].accessToken, username: user.username, password: user.password })
45 const resVideo = await uploadVideo(servers[0].url, servers[0].accessToken, { fixture: 'video_short.webm' })
46 const videoUUID = resVideo.body.video.uuid
48 await addVideoCommentThread(servers[0].url, servers[0].accessToken, videoUUID, 'comment')
50 await viewVideo(servers[0].url, videoUUID)
52 // Wait the video views repeatable job
55 await servers[2].followsCommand.follow({ targets: [ servers[0].url ] })
56 await waitJobs(servers)
59 it('Should have the correct stats on instance 1', async function () {
60 const data = await servers[0].statsCommand.get()
62 expect(data.totalLocalVideoComments).to.equal(1)
63 expect(data.totalLocalVideos).to.equal(1)
64 expect(data.totalLocalVideoViews).to.equal(1)
65 expect(data.totalLocalVideoFilesSize).to.equal(218910)
66 expect(data.totalUsers).to.equal(2)
67 expect(data.totalVideoComments).to.equal(1)
68 expect(data.totalVideos).to.equal(1)
69 expect(data.totalInstanceFollowers).to.equal(2)
70 expect(data.totalInstanceFollowing).to.equal(1)
71 expect(data.totalLocalPlaylists).to.equal(0)
74 it('Should have the correct stats on instance 2', async function () {
75 const data = await servers[1].statsCommand.get()
77 expect(data.totalLocalVideoComments).to.equal(0)
78 expect(data.totalLocalVideos).to.equal(0)
79 expect(data.totalLocalVideoViews).to.equal(0)
80 expect(data.totalLocalVideoFilesSize).to.equal(0)
81 expect(data.totalUsers).to.equal(1)
82 expect(data.totalVideoComments).to.equal(1)
83 expect(data.totalVideos).to.equal(1)
84 expect(data.totalInstanceFollowers).to.equal(1)
85 expect(data.totalInstanceFollowing).to.equal(1)
86 expect(data.totalLocalPlaylists).to.equal(0)
89 it('Should have the correct stats on instance 3', async function () {
90 const data = await servers[2].statsCommand.get()
92 expect(data.totalLocalVideoComments).to.equal(0)
93 expect(data.totalLocalVideos).to.equal(0)
94 expect(data.totalLocalVideoViews).to.equal(0)
95 expect(data.totalUsers).to.equal(1)
96 expect(data.totalVideoComments).to.equal(1)
97 expect(data.totalVideos).to.equal(1)
98 expect(data.totalInstanceFollowing).to.equal(1)
99 expect(data.totalInstanceFollowers).to.equal(0)
100 expect(data.totalLocalPlaylists).to.equal(0)
103 it('Should have the correct total videos stats after an unfollow', async function () {
106 await servers[2].followsCommand.unfollow({ target: servers[0] })
107 await waitJobs(servers)
109 const data = await servers[2].statsCommand.get()
111 expect(data.totalVideos).to.equal(0)
114 it('Should have the correct active user stats', async function () {
115 const server = servers[0]
118 const data = await server.statsCommand.get()
120 expect(data.totalDailyActiveUsers).to.equal(1)
121 expect(data.totalWeeklyActiveUsers).to.equal(1)
122 expect(data.totalMonthlyActiveUsers).to.equal(1)
126 await userLogin(server, user)
128 const data = await server.statsCommand.get()
130 expect(data.totalDailyActiveUsers).to.equal(2)
131 expect(data.totalWeeklyActiveUsers).to.equal(2)
132 expect(data.totalMonthlyActiveUsers).to.equal(2)
136 it('Should have the correct active channel stats', async function () {
137 const server = servers[0]
140 const data = await server.statsCommand.get()
142 expect(data.totalLocalDailyActiveVideoChannels).to.equal(1)
143 expect(data.totalLocalWeeklyActiveVideoChannels).to.equal(1)
144 expect(data.totalLocalMonthlyActiveVideoChannels).to.equal(1)
148 const channelAttributes = {
149 name: 'stats_channel',
150 displayName: 'My stats channel'
152 const resChannel = await addVideoChannel(server.url, server.accessToken, channelAttributes)
153 channelId = resChannel.body.videoChannel.id
155 const data = await server.statsCommand.get()
157 expect(data.totalLocalDailyActiveVideoChannels).to.equal(1)
158 expect(data.totalLocalWeeklyActiveVideoChannels).to.equal(1)
159 expect(data.totalLocalMonthlyActiveVideoChannels).to.equal(1)
163 await uploadVideo(server.url, server.accessToken, { fixture: 'video_short.webm', channelId })
165 const data = await server.statsCommand.get()
167 expect(data.totalLocalDailyActiveVideoChannels).to.equal(2)
168 expect(data.totalLocalWeeklyActiveVideoChannels).to.equal(2)
169 expect(data.totalLocalMonthlyActiveVideoChannels).to.equal(2)
173 it('Should have the correct playlist stats', async function () {
174 const server = servers[0]
177 const data = await server.statsCommand.get()
178 expect(data.totalLocalPlaylists).to.equal(0)
182 await createVideoPlaylist({
184 token: server.accessToken,
186 displayName: 'playlist for count',
187 privacy: VideoPlaylistPrivacy.PUBLIC,
188 videoChannelId: channelId
192 const data = await server.statsCommand.get()
193 expect(data.totalLocalPlaylists).to.equal(1)
197 it('Should correctly count video file sizes if transcoding is enabled', async function () {
200 await updateCustomSubConfig(servers[0].url, servers[0].accessToken, {
222 await uploadVideo(servers[0].url, servers[0].accessToken, { name: 'video', fixture: 'video_short.webm' })
224 await waitJobs(servers)
227 const data = await servers[1].statsCommand.get()
228 expect(data.totalLocalVideoFilesSize).to.equal(0)
232 const data = await servers[0].statsCommand.get()
233 expect(data.totalLocalVideoFilesSize).to.be.greaterThan(500000)
234 expect(data.totalLocalVideoFilesSize).to.be.lessThan(600000)
238 it('Should have the correct AP stats', async function () {
241 await updateCustomSubConfig(servers[0].url, servers[0].accessToken, {
247 const first = await servers[1].statsCommand.get()
249 for (let i = 0; i < 10; i++) {
250 await uploadVideo(servers[0].url, servers[0].accessToken, { name: 'video' })
253 await waitJobs(servers)
257 const second = await servers[1].statsCommand.get()
258 expect(second.totalActivityPubMessagesProcessed).to.be.greaterThan(first.totalActivityPubMessagesProcessed)
260 const apTypes: ActivityType[] = [
261 'Create', 'Update', 'Delete', 'Follow', 'Accept', 'Announce', 'Undo', 'Like', 'Reject', 'View', 'Dislike', 'Flag'
264 const processed = apTypes.reduce(
265 (previous, type) => previous + second['totalActivityPub' + type + 'MessagesSuccesses'],
268 expect(second.totalActivityPubMessagesProcessed).to.equal(processed)
269 expect(second.totalActivityPubMessagesSuccesses).to.equal(processed)
271 expect(second.totalActivityPubMessagesErrors).to.equal(0)
273 for (const apType of apTypes) {
274 expect(second['totalActivityPub' + apType + 'MessagesErrors']).to.equal(0)
279 const third = await servers[1].statsCommand.get()
280 expect(third.totalActivityPubMessagesWaiting).to.equal(0)
281 expect(third.activityPubMessagesProcessedPerSecond).to.be.lessThan(second.activityPubMessagesProcessedPerSecond)
284 after(async function () {
285 await cleanupTests(servers)