--- /dev/null
+import Bluebird from 'bluebird'
+import { wait } from '@shared/core-utils'
+import { createSingleServer, doubleFollow, PeerTubeServer, setAccessTokensToServers, waitJobs } from '@shared/server-commands'
+
+let servers: PeerTubeServer[]
+const viewers: { xForwardedFor: string }[] = []
+let videoId: string
+
+run()
+ .then(() => process.exit(0))
+ .catch(err => console.error(err))
+
+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'
+ }
+ }
+ }
+
+ servers = await Promise.all([
+ createSingleServer(1, config, { nodeArgs: [ '--inspect' ] }),
+ createSingleServer(2, config),
+ createSingleServer(3, config)
+ ])
+
+ 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)
+
+ await Bluebird.map(viewers, viewer => {
+ return servers[0].views.simulateView({ id: videoId, xForwardedFor: viewer.xForwardedFor })
+ }, { concurrency: 100 })
+
+ await wait(5000)
+}