aboutsummaryrefslogtreecommitdiffhomepage
path: root/server/tests/real-world
diff options
context:
space:
mode:
Diffstat (limited to 'server/tests/real-world')
-rw-r--r--server/tests/real-world/real-world.ts743
1 files changed, 371 insertions, 372 deletions
diff --git a/server/tests/real-world/real-world.ts b/server/tests/real-world/real-world.ts
index 1afa55267..e41203351 100644
--- a/server/tests/real-world/real-world.ts
+++ b/server/tests/real-world/real-world.ts
@@ -1,372 +1,371 @@
1// // /!\ Before imports /!\ 1// /!\ Before imports /!\
2// process.env.NODE_ENV = 'test' 2process.env.NODE_ENV = 'test'
3// 3
4// import * as program from 'commander' 4import * as program from 'commander'
5// import { Video, VideoFile, VideoRateType } from '../../../shared' 5import { Video, VideoFile, VideoRateType } from '../../../shared'
6// import { 6import {
7// flushAndRunMultipleServers, 7 flushAndRunMultipleServers,
8// flushTests, 8 flushTests, follow,
9// getAllVideosListBy, 9 getVideo,
10// getVideo, 10 getVideosList, getVideosListPagination,
11// getVideosList, 11 killallServers,
12// killallServers, 12 removeVideo,
13// removeVideo, 13 ServerInfo as DefaultServerInfo,
14// ServerInfo as DefaultServerInfo, 14 setAccessTokensToServers,
15// setAccessTokensToServers, 15 updateVideo,
16// updateVideo, 16 uploadVideo, viewVideo,
17// uploadVideo, 17 wait
18// wait 18} from '../utils'
19// } from '../utils' 19import { getJobsListPaginationAndSort } from '../utils/server/jobs'
20// import { follow } from '../utils/follows' 20
21// 21interface ServerInfo extends DefaultServerInfo {
22// interface ServerInfo extends DefaultServerInfo { 22 requestsNumber: number
23// requestsNumber: number 23}
24// } 24
25// 25program
26// program 26 .option('-c, --create [weight]', 'Weight for creating videos')
27// .option('-c, --create [weight]', 'Weight for creating videos') 27 .option('-r, --remove [weight]', 'Weight for removing videos')
28// .option('-r, --remove [weight]', 'Weight for removing videos') 28 .option('-u, --update [weight]', 'Weight for updating videos')
29// .option('-u, --update [weight]', 'Weight for updating videos') 29 .option('-v, --view [weight]', 'Weight for viewing videos')
30// .option('-v, --view [weight]', 'Weight for viewing videos') 30 .option('-l, --like [weight]', 'Weight for liking videos')
31// .option('-l, --like [weight]', 'Weight for liking videos') 31 .option('-s, --dislike [weight]', 'Weight for disliking videos')
32// .option('-s, --dislike [weight]', 'Weight for disliking videos') 32 .option('-p, --servers [n]', 'Number of servers to run (3 or 6)', /^3|6$/, 3)
33// .option('-p, --servers [n]', 'Number of servers to run (3 or 6)', /^3|6$/, 3) 33 .option('-i, --interval-action [interval]', 'Interval in ms for an action')
34// .option('-i, --interval-action [interval]', 'Interval in ms for an action') 34 .option('-I, --interval-integrity [interval]', 'Interval in ms for an integrity check')
35// .option('-I, --interval-integrity [interval]', 'Interval in ms for an integrity check') 35 .option('-f, --flush', 'Flush data on exit')
36// .option('-f, --flush', 'Flush datas on exit') 36 .option('-d, --difference', 'Display difference if integrity is not okay')
37// .option('-d, --difference', 'Display difference if integrity is not okay') 37 .parse(process.argv)
38// .parse(process.argv) 38
39// 39const createWeight = program['create'] !== undefined ? parseInt(program['create'], 10) : 5
40// const createWeight = program['create'] !== undefined ? parseInt(program['create'], 10) : 5 40const removeWeight = program['remove'] !== undefined ? parseInt(program['remove'], 10) : 4
41// const removeWeight = program['remove'] !== undefined ? parseInt(program['remove'], 10) : 4 41const updateWeight = program['update'] !== undefined ? parseInt(program['update'], 10) : 4
42// const updateWeight = program['update'] !== undefined ? parseInt(program['update'], 10) : 4 42const viewWeight = program['view'] !== undefined ? parseInt(program['view'], 10) : 4
43// const viewWeight = program['view'] !== undefined ? parseInt(program['view'], 10) : 4 43const likeWeight = program['like'] !== undefined ? parseInt(program['like'], 10) : 4
44// const likeWeight = program['like'] !== undefined ? parseInt(program['like'], 10) : 4 44const dislikeWeight = program['dislike'] !== undefined ? parseInt(program['dislike'], 10) : 4
45// const dislikeWeight = program['dislike'] !== undefined ? parseInt(program['dislike'], 10) : 4 45const flushAtExit = program['flush'] || false
46// const flushAtExit = program['flush'] || false 46const actionInterval = program['intervalAction'] !== undefined ? parseInt(program['intervalAction'], 10) : 500
47// const actionInterval = program['intervalAction'] !== undefined ? parseInt(program['intervalAction'], 10) : 500 47const integrityInterval = program['intervalIntegrity'] !== undefined ? parseInt(program['intervalIntegrity'], 10) : 60000
48// const integrityInterval = program['intervalIntegrity'] !== undefined ? parseInt(program['intervalIntegrity'], 10) : 60000 48const displayDiffOnFail = program['difference'] || false
49// const displayDiffOnFail = program['difference'] || false 49
50// 50const numberOfServers = 6
51// const numberOfServers = 6 51
52// 52console.log(
53// console.log( 53 'Create weight: %d, update weight: %d, remove weight: %d, view weight: %d, like weight: %d, dislike weight: %d.',
54// 'Create weight: %d, update weight: %d, remove weight: %d, view weight: %d, like weight: %d, dislike weight: %d.', 54 createWeight, updateWeight, removeWeight, viewWeight, likeWeight, dislikeWeight
55// createWeight, updateWeight, removeWeight, viewWeight, likeWeight, dislikeWeight 55)
56// ) 56
57// 57if (flushAtExit) {
58// if (flushAtExit) { 58 console.log('Program will flush data on exit.')
59// console.log('Program will flush data on exit.') 59} else {
60// } else { 60 console.log('Program will not flush data on exit.')
61// console.log('Program will not flush data on exit.') 61}
62// } 62if (displayDiffOnFail) {
63// if (displayDiffOnFail) { 63 console.log('Program will display diff on failure.')
64// console.log('Program will display diff on failure.') 64} else {
65// } else { 65 console.log('Program will not display diff on failure')
66// console.log('Program will not display diff on failure') 66}
67// } 67console.log('Interval in ms for each action: %d.', actionInterval)
68// console.log('Interval in ms for each action: %d.', actionInterval) 68console.log('Interval in ms for each integrity check: %d.', integrityInterval)
69// console.log('Interval in ms for each integrity check: %d.', integrityInterval) 69
70// 70console.log('Run servers...')
71// console.log('Run servers...') 71
72// 72start()
73// start() 73
74// 74// ----------------------------------------------------------------------------
75// // ---------------------------------------------------------------------------- 75
76// 76async function start () {
77// async function start () { 77 const servers = await runServers(numberOfServers)
78// const servers = await runServers(numberOfServers) 78
79// 79 process.on('exit', async () => {
80// process.on('exit', async () => { 80 await exitServers(servers, flushAtExit)
81// await exitServers(servers, flushAtExit) 81
82// 82 return
83// return 83 })
84// }) 84 process.on('SIGINT', goodbye)
85// process.on('SIGINT', goodbye) 85 process.on('SIGTERM', goodbye)
86// process.on('SIGTERM', goodbye) 86
87// 87 console.log('Servers ran')
88// console.log('Servers ran') 88 initializeRequestsPerServer(servers)
89// initializeRequestsPerServer(servers) 89
90// 90 let checking = false
91// let checking = false 91
92// 92 setInterval(async () => {
93// setInterval(async () => { 93 if (checking === true) return
94// if (checking === true) return 94
95// 95 const rand = getRandomInt(0, createWeight + updateWeight + removeWeight + viewWeight + likeWeight + dislikeWeight)
96// const rand = getRandomInt(0, createWeight + updateWeight + removeWeight + viewWeight + likeWeight + dislikeWeight) 96
97// 97 const numServer = getRandomNumServer(servers)
98// const numServer = getRandomNumServer(servers) 98 servers[numServer].requestsNumber++
99// servers[numServer].requestsNumber++ 99
100// 100 if (rand < createWeight) {
101// if (rand < createWeight) { 101 await upload(servers, numServer)
102// await upload(servers, numServer) 102 } else if (rand < createWeight + updateWeight) {
103// } else if (rand < createWeight + updateWeight) { 103 await update(servers, numServer)
104// await update(servers, numServer) 104 } else if (rand < createWeight + updateWeight + removeWeight) {
105// } else if (rand < createWeight + updateWeight + removeWeight) { 105 await remove(servers, numServer)
106// await remove(servers, numServer) 106 } else if (rand < createWeight + updateWeight + removeWeight + viewWeight) {
107// } else if (rand < createWeight + updateWeight + removeWeight + viewWeight) { 107 await view(servers, numServer)
108// await view(servers, numServer) 108 } else if (rand < createWeight + updateWeight + removeWeight + viewWeight + likeWeight) {
109// } else if (rand < createWeight + updateWeight + removeWeight + viewWeight + likeWeight) { 109 await like(servers, numServer)
110// await like(servers, numServer) 110 } else {
111// } else { 111 await dislike(servers, numServer)
112// await dislike(servers, numServer) 112 }
113// } 113 }, actionInterval)
114// }, actionInterval) 114
115// 115 // The function will check the consistency between servers (should have the same videos with same attributes...)
116// // The function will check the consistency between servers (should have the same videos with same attributes...) 116 setInterval(function () {
117// setInterval(function () { 117 if (checking === true) return
118// if (checking === true) return 118
119// 119 console.log('Checking integrity...')
120// console.log('Checking integrity...') 120 checking = true
121// checking = true 121
122// 122 const waitingInterval = setInterval(async () => {
123// const waitingInterval = setInterval(async () => { 123 const pendingRequests = await isTherePendingRequests(servers)
124// const pendingRequests = await isTherePendingRequests(servers) 124 if (pendingRequests === true) {
125// if (pendingRequests === true) { 125 console.log('A server has pending requests, waiting...')
126// console.log('A server has pending requests, waiting...') 126 return
127// return 127 }
128// } 128
129// 129 // Even if there are no pending request, wait some potential processes
130// // Even if there are no pending request, wait some potential processes 130 await wait(2000)
131// await wait(2000) 131 await checkIntegrity(servers)
132// await checkIntegrity(servers) 132
133// 133 initializeRequestsPerServer(servers)
134// initializeRequestsPerServer(servers) 134 checking = false
135// checking = false 135 clearInterval(waitingInterval)
136// clearInterval(waitingInterval) 136 }, 10000)
137// }, 10000) 137 }, integrityInterval)
138// }, integrityInterval) 138}
139// } 139
140// 140function initializeRequestsPerServer (servers: ServerInfo[]) {
141// function initializeRequestsPerServer (servers: ServerInfo[]) { 141 servers.forEach(server => server.requestsNumber = 0)
142// servers.forEach(server => server.requestsNumber = 0) 142}
143// } 143
144// 144function getRandomInt (min, max) {
145// function getRandomInt (min, max) { 145 return Math.floor(Math.random() * (max - min)) + min
146// return Math.floor(Math.random() * (max - min)) + min 146}
147// } 147
148// 148function getRandomNumServer (servers) {
149// function getRandomNumServer (servers) { 149 return getRandomInt(0, servers.length)
150// return getRandomInt(0, servers.length) 150}
151// } 151
152// 152async function runServers (numberOfServers: number) {
153// async function runServers (numberOfServers: number) { 153 const servers: ServerInfo[] = (await flushAndRunMultipleServers(numberOfServers))
154// const servers: ServerInfo[] = (await flushAndRunMultipleServers(numberOfServers)) 154 .map(s => Object.assign({ requestsNumber: 0 }, s))
155// .map(s => Object.assign({ requestsNumber: 0 }, s)) 155
156// 156 // Get the access tokens
157// // Get the access tokens 157 await setAccessTokensToServers(servers)
158// await setAccessTokensToServers(servers) 158
159// 159 for (let i = 0; i < numberOfServers; i++) {
160// for (let i = 0; i < numberOfServers; i++) { 160 for (let j = 0; j < numberOfServers; j++) {
161// for (let j = 0; j < numberOfServers; j++) { 161 if (i === j) continue
162// if (i === j) continue 162
163// 163 await follow(servers[i].url, [ servers[j].url ], servers[i].accessToken)
164// await follow(servers[i].url, [ servers[j].url ], servers[i].accessToken) 164 }
165// } 165 }
166// } 166
167// 167 return servers
168// return servers 168}
169// } 169
170// 170async function exitServers (servers: ServerInfo[], flushAtExit: boolean) {
171// async function exitServers (servers: ServerInfo[], flushAtExit: boolean) { 171 killallServers(servers)
172// killallServers(servers) 172
173// 173 if (flushAtExit) await flushTests()
174// if (flushAtExit) await flushTests() 174}
175// } 175
176// 176function upload (servers: ServerInfo[], numServer: number) {
177// function upload (servers: ServerInfo[], numServer: number) { 177 console.log('Uploading video to server ' + numServer)
178// console.log('Uploading video to server ' + numServer) 178
179// 179 const videoAttributes = {
180// const videoAttributes = { 180 name: Date.now() + ' name',
181// name: Date.now() + ' name', 181 category: 4,
182// category: 4, 182 nsfw: false,
183// nsfw: false, 183 licence: 2,
184// licence: 2, 184 language: 1,
185// language: 1, 185 description: Date.now() + ' description',
186// description: Date.now() + ' description', 186 tags: [ Date.now().toString().substring(0, 5) + 't1', Date.now().toString().substring(0, 5) + 't2' ],
187// tags: [ Date.now().toString().substring(0, 5) + 't1', Date.now().toString().substring(0, 5) + 't2' ], 187 fixture: 'video_short1.webm'
188// fixture: 'video_short1.webm' 188 }
189// } 189 return uploadVideo(servers[numServer].url, servers[numServer].accessToken, videoAttributes)
190// return uploadVideo(servers[numServer].url, servers[numServer].accessToken, videoAttributes) 190}
191// } 191
192// 192async function update (servers: ServerInfo[], numServer: number) {
193// async function update (servers: ServerInfo[], numServer: number) { 193 const res = await getVideosList(servers[numServer].url)
194// const res = await getVideosList(servers[numServer].url) 194
195// 195 const videos = res.body.data.filter(video => video.isLocal === true)
196// const videos = res.body.data.filter(video => video.isLocal === true) 196 if (videos.length === 0) return undefined
197// if (videos.length === 0) return undefined 197
198// 198 const toUpdate = videos[getRandomInt(0, videos.length)].id
199// const toUpdate = videos[getRandomInt(0, videos.length)].id 199 const attributes = {
200// const attributes = { 200 name: Date.now() + ' name',
201// name: Date.now() + ' name', 201 description: Date.now() + ' description',
202// description: Date.now() + ' description', 202 tags: [ Date.now().toString().substring(0, 5) + 't1', Date.now().toString().substring(0, 5) + 't2' ]
203// tags: [ Date.now().toString().substring(0, 5) + 't1', Date.now().toString().substring(0, 5) + 't2' ] 203 }
204// } 204
205// 205 console.log('Updating video of server ' + numServer)
206// console.log('Updating video of server ' + numServer) 206
207// 207 return updateVideo(servers[numServer].url, servers[numServer].accessToken, toUpdate, attributes)
208// return updateVideo(servers[numServer].url, servers[numServer].accessToken, toUpdate, attributes) 208}
209// } 209
210// 210async function remove (servers: ServerInfo[], numServer: number) {
211// async function remove (servers: ServerInfo[], numServer: number) { 211 const res = await getVideosList(servers[numServer].url)
212// const res = await getVideosList(servers[numServer].url) 212 const videos = res.body.data.filter(video => video.isLocal === true)
213// const videos = res.body.data.filter(video => video.isLocal === true) 213 if (videos.length === 0) return undefined
214// if (videos.length === 0) return undefined 214
215// 215 const toRemove = videos[getRandomInt(0, videos.length)].id
216// const toRemove = videos[getRandomInt(0, videos.length)].id 216
217// 217 console.log('Removing video from server ' + numServer)
218// console.log('Removing video from server ' + numServer) 218 return removeVideo(servers[numServer].url, servers[numServer].accessToken, toRemove)
219// return removeVideo(servers[numServer].url, servers[numServer].accessToken, toRemove) 219}
220// } 220
221// 221async function view (servers: ServerInfo[], numServer: number) {
222// async function view (servers: ServerInfo[], numServer: number) { 222 const res = await getVideosList(servers[numServer].url)
223// const res = await getVideosList(servers[numServer].url) 223
224// 224 const videos = res.body.data
225// const videos = res.body.data 225 if (videos.length === 0) return undefined
226// if (videos.length === 0) return undefined 226
227// 227 const toView = videos[getRandomInt(0, videos.length)].id
228// const toView = videos[getRandomInt(0, videos.length)].id 228
229// 229 console.log('Viewing video from server ' + numServer)
230// console.log('Viewing video from server ' + numServer) 230 return viewVideo(servers[numServer].url, toView)
231// return getVideo(servers[numServer].url, toView) 231}
232// } 232
233// 233function like (servers: ServerInfo[], numServer: number) {
234// function like (servers: ServerInfo[], numServer: number) { 234 return rate(servers, numServer, 'like')
235// return rate(servers, numServer, 'like') 235}
236// } 236
237// 237function dislike (servers: ServerInfo[], numServer: number) {
238// function dislike (servers: ServerInfo[], numServer: number) { 238 return rate(servers, numServer, 'dislike')
239// return rate(servers, numServer, 'dislike') 239}
240// } 240
241// 241async function rate (servers: ServerInfo[], numServer: number, rating: VideoRateType) {
242// async function rate (servers: ServerInfo[], numServer: number, rating: VideoRateType) { 242 const res = await getVideosList(servers[numServer].url)
243// const res = await getVideosList(servers[numServer].url) 243
244// 244 const videos = res.body.data
245// const videos = res.body.data 245 if (videos.length === 0) return undefined
246// if (videos.length === 0) return undefined 246
247// 247 const toRate = videos[getRandomInt(0, videos.length)].id
248// const toRate = videos[getRandomInt(0, videos.length)].id 248
249// 249 console.log('Rating (%s) video from server %d', rating, numServer)
250// console.log('Rating (%s) video from server %d', rating, numServer) 250 return getVideo(servers[numServer].url, toRate)
251// return getVideo(servers[numServer].url, toRate) 251}
252// } 252
253// 253async function checkIntegrity (servers: ServerInfo[]) {
254// async function checkIntegrity (servers: ServerInfo[]) { 254 const videos: Video[][] = []
255// const videos: Video[][] = [] 255 const tasks: Promise<any>[] = []
256// const tasks: Promise<any>[] = [] 256
257// 257 // Fetch all videos and remove some fields that can differ between servers
258// // Fetch all videos and remove some fields that can differ between servers 258 for (const server of servers) {
259// for (const server of servers) { 259 const p = getVideosListPagination(server.url, 0, 1000000, '-createdAt')
260// const p = getAllVideosListBy(server.url).then(res => videos.push(res.body.data)) 260 .then(res => videos.push(res.body.data))
261// tasks.push(p) 261 tasks.push(p)
262// } 262 }
263// 263
264// await Promise.all(tasks) 264 await Promise.all(tasks)
265// 265
266// let i = 0 266 let i = 0
267// for (const video of videos) { 267 for (const video of videos) {
268// const differences = areDifferences(video, videos[0]) 268 const differences = areDifferences(video, videos[0])
269// if (differences !== undefined) { 269 if (differences !== undefined) {
270// console.error('Integrity not ok with server %d!', i + 1) 270 console.error('Integrity not ok with server %d!', i + 1)
271// 271
272// if (displayDiffOnFail) { 272 if (displayDiffOnFail) {
273// console.log(differences) 273 console.log(differences)
274// } 274 }
275// 275
276// process.exit(-1) 276 process.exit(-1)
277// } 277 }
278// 278
279// i++ 279 i++
280// } 280 }
281// 281
282// console.log('Integrity ok.') 282 console.log('Integrity ok.')
283// } 283}
284// 284
285// function areDifferences (videos1: Video[], videos2: Video[]) { 285function areDifferences (videos1: Video[], videos2: Video[]) {
286// // Remove some keys we don't want to compare 286 // Remove some keys we don't want to compare
287// videos1.concat(videos2).forEach(video => { 287 videos1.concat(videos2).forEach(video => {
288// delete video.id 288 delete video.id
289// delete video.isLocal 289 delete video.isLocal
290// delete video.thumbnailPath 290 delete video.thumbnailPath
291// delete video.updatedAt 291 delete video.updatedAt
292// delete video.views 292 delete video.views
293// }) 293 })
294// 294
295// if (videos1.length !== videos2.length) { 295 if (videos1.length !== videos2.length) {
296// return `Videos length are different (${videos1.length}/${videos2.length}).` 296 return `Videos length are different (${videos1.length}/${videos2.length}).`
297// } 297 }
298// 298
299// for (const video1 of videos1) { 299 for (const video1 of videos1) {
300// const video2 = videos2.find(video => video.uuid === video1.uuid) 300 const video2 = videos2.find(video => video.uuid === video1.uuid)
301// 301
302// if (!video2) return 'Video ' + video1.uuid + ' is missing.' 302 if (!video2) return 'Video ' + video1.uuid + ' is missing.'
303// 303
304// for (const videoKey of Object.keys(video1)) { 304 for (const videoKey of Object.keys(video1)) {
305// const attribute1 = video1[videoKey] 305 const attribute1 = video1[videoKey]
306// const attribute2 = video2[videoKey] 306 const attribute2 = video2[videoKey]
307// 307
308// if (videoKey === 'tags') { 308 if (videoKey === 'tags') {
309// if (attribute1.length !== attribute2.length) { 309 if (attribute1.length !== attribute2.length) {
310// return 'Tags are different.' 310 return 'Tags are different.'
311// } 311 }
312// 312
313// attribute1.forEach(tag1 => { 313 attribute1.forEach(tag1 => {
314// if (attribute2.indexOf(tag1) === -1) { 314 if (attribute2.indexOf(tag1) === -1) {
315// return 'Tag ' + tag1 + ' is missing.' 315 return 'Tag ' + tag1 + ' is missing.'
316// } 316 }
317// }) 317 })
318// } else if (videoKey === 'files') { 318 } else if (videoKey === 'files') {
319// if (attribute1.length !== attribute2.length) { 319 if (attribute1.length !== attribute2.length) {
320// return 'Video files are different.' 320 return 'Video files are different.'
321// } 321 }
322// 322
323// attribute1.forEach((videoFile1: VideoFile) => { 323 attribute1.forEach((videoFile1: VideoFile) => {
324// const videoFile2: VideoFile = attribute2.find(videoFile => videoFile.magnetUri === videoFile1.magnetUri) 324 const videoFile2: VideoFile = attribute2.find(videoFile => videoFile.magnetUri === videoFile1.magnetUri)
325// if (!videoFile2) { 325 if (!videoFile2) {
326// return `Video ${video1.uuid} has missing video file ${videoFile1.magnetUri}.` 326 return `Video ${video1.uuid} has missing video file ${videoFile1.magnetUri}.`
327// } 327 }
328// 328
329// if (videoFile1.size !== videoFile2.size || videoFile1.resolutionLabel !== videoFile2.resolutionLabel) { 329 if (videoFile1.size !== videoFile2.size || videoFile1.resolutionLabel !== videoFile2.resolutionLabel) {
330// return `Video ${video1.uuid} has different video file ${videoFile1.magnetUri}.` 330 return `Video ${video1.uuid} has different video file ${videoFile1.magnetUri}.`
331// } 331 }
332// }) 332 })
333// } else { 333 } else {
334// if (attribute1 !== attribute2) { 334 if (attribute1 !== attribute2) {
335// return `Video ${video1.uuid} has different value for attribute ${videoKey}.` 335 return `Video ${video1.uuid} has different value for attribute ${videoKey}.`
336// } 336 }
337// } 337 }
338// } 338 }
339// } 339 }
340// 340
341// return undefined 341 return undefined
342// } 342}
343// 343
344// function goodbye () { 344function goodbye () {
345// return process.exit(-1) 345 return process.exit(-1)
346// } 346}
347// 347
348// async function isTherePendingRequests (servers: ServerInfo[]) { 348async function isTherePendingRequests (servers: ServerInfo[]) {
349// const tasks: Promise<any>[] = [] 349 const tasks: Promise<any>[] = []
350// let pendingRequests = false 350 let pendingRequests = false
351// 351
352// // Check if each server has pending request 352 // Check if each server has pending request
353// for (const server of servers) { 353 for (const server of servers) {
354// const p = getRequestsStats(server).then(res => { 354 const p = getJobsListPaginationAndSort(server.url, server.accessToken, 0, 10, '-createdAt')
355// const stats = res.body 355 .then(res => {
356// 356 const jobs = res.body.data
357// if ( 357
358// stats.requestScheduler.totalRequests !== 0 || 358 for (const job of jobs) {
359// stats.requestVideoEventScheduler.totalRequests !== 0 || 359 if (job.state === 'pending' || job.state === 'processing') {
360// stats.requestVideoQaduScheduler.totalRequests !== 0 360 pendingRequests = true
361// ) { 361 }
362// pendingRequests = true 362 }
363// } 363 })
364// }) 364
365// 365 tasks.push(p)
366// tasks.push(p) 366 }
367// } 367
368// 368 await Promise.all(tasks)
369// await Promise.all(tasks) 369
370// 370 return pendingRequests
371// return pendingRequests 371}
372// }
generated by cgit v1.2.3 (git 2.25.1) at 2024-11-15 06:29:03 +0000