3a4992633e
Sorry for the very big commit that may lead to git log issues and merge
conflicts, but it's a major step forward:
* Server can be faster at startup because imports() are async and we can
easily lazy import big modules
* Angular doesn't seem to support ES import (with .js extension), so we
had to correctly organize peertube into a monorepo:
* Use yarn workspace feature
* Use typescript reference projects for dependencies
* Shared projects have been moved into "packages", each one is now a
node module (with a dedicated package.json/tsconfig.json)
* server/tools have been moved into apps/ and is now a dedicated app
bundled and published on NPM so users don't have to build peertube
cli tools manually
* server/tests have been moved into packages/ so we don't compile
them every time we want to run the server
* Use isolatedModule option:
* Had to move from const enum to const
(https://www.typescriptlang.org/docs/handbook/enums.html#objects-vs-enums)
* Had to explictely specify "type" imports when used in decorators
* Prefer tsx (that uses esbuild under the hood) instead of ts-node to
load typescript files (tests with mocha or scripts):
* To reduce test complexity as esbuild doesn't support decorator
metadata, we only test server files that do not import server
models
* We still build tests files into js files for a faster CI
* Remove unmaintained peertube CLI import script
* Removed some barrels to speed up execution (less imports)
91 lines
2 KiB
TypeScript
91 lines
2 KiB
TypeScript
import Bluebird from 'bluebird'
|
|
import { wait } from '@peertube/peertube-core-utils'
|
|
import {
|
|
createSingleServer,
|
|
doubleFollow,
|
|
killallServers,
|
|
PeerTubeServer,
|
|
setAccessTokensToServers,
|
|
waitJobs
|
|
} from '@peertube/peertube-server-commands'
|
|
|
|
let servers: PeerTubeServer[]
|
|
const viewers: { xForwardedFor: string }[] = []
|
|
let videoId: string
|
|
|
|
run()
|
|
.then(() => process.exit(0))
|
|
.catch(err => console.error(err))
|
|
.finally(() => killallServers(servers))
|
|
|
|
async function run () {
|
|
await prepare()
|
|
|
|
while (true) {
|
|
await runViewers()
|
|
}
|
|
}
|
|
|
|
async function prepare () {
|
|
console.log('Preparing servers...')
|
|
|
|
const config = {
|
|
log: {
|
|
level: 'info'
|
|
},
|
|
rates_limit: {
|
|
api: {
|
|
max: 5_000_000
|
|
}
|
|
},
|
|
views: {
|
|
videos: {
|
|
local_buffer_update_interval: '30 minutes',
|
|
ip_view_expiration: '1 hour'
|
|
}
|
|
}
|
|
}
|
|
|
|
const env = { PRODUCTION_CONSTANTS: 'true' }
|
|
|
|
servers = await Promise.all([
|
|
createSingleServer(1, config, { env, nodeArgs: [ '--inspect' ] }),
|
|
createSingleServer(2, config, { env }),
|
|
createSingleServer(3, config, { env })
|
|
])
|
|
|
|
await setAccessTokensToServers(servers)
|
|
await doubleFollow(servers[0], servers[1])
|
|
await doubleFollow(servers[0], servers[2])
|
|
|
|
const { uuid } = await servers[0].videos.quickUpload({ name: 'video' })
|
|
videoId = uuid
|
|
|
|
await waitJobs(servers)
|
|
|
|
const THOUSAND_VIEWERS = 2
|
|
|
|
for (let i = 2; i < 252; i++) {
|
|
for (let j = 2; j < 6; j++) {
|
|
for (let k = 2; k < THOUSAND_VIEWERS + 2; k++) {
|
|
viewers.push({ xForwardedFor: `0.${k}.${j}.${i},127.0.0.1` })
|
|
}
|
|
}
|
|
}
|
|
|
|
console.log('Servers preparation finished.')
|
|
}
|
|
|
|
async function runViewers () {
|
|
console.log('Will run views of %d viewers.', viewers.length)
|
|
|
|
const before = new Date().getTime()
|
|
|
|
await Bluebird.map(viewers, viewer => {
|
|
return servers[0].views.simulateView({ id: videoId, xForwardedFor: viewer.xForwardedFor })
|
|
}, { concurrency: 500 })
|
|
|
|
console.log('Finished to run views in %d seconds.', (new Date().getTime() - before) / 1000)
|
|
|
|
await wait(5000)
|
|
}
|