1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
|
import { ChildProcess, fork, ForkOptions } from 'child_process'
import execa from 'execa'
import { join } from 'path'
import { root } from '@peertube/peertube-node-utils'
import { PeerTubeServer } from '@peertube/peertube-server-commands'
export class PeerTubeRunnerProcess {
private app?: ChildProcess
constructor (private readonly server: PeerTubeServer) {
}
runServer (options: {
hideLogs?: boolean // default true
} = {}) {
const { hideLogs = true } = options
return new Promise<void>((res, rej) => {
const args = [ 'server', '--verbose', ...this.buildIdArg() ]
const forkOptions: ForkOptions = {
detached: false,
silent: true,
execArgv: [] // Don't inject parent node options
}
this.app = fork(this.getRunnerPath(), args, forkOptions)
this.app.stdout.on('data', data => {
const str = data.toString() as string
if (!hideLogs) {
console.log(str)
}
})
res()
})
}
registerPeerTubeInstance (options: {
registrationToken: string
runnerName: string
runnerDescription?: string
}) {
const { registrationToken, runnerName, runnerDescription } = options
const args = [
'register',
'--url', this.server.url,
'--registration-token', registrationToken,
'--runner-name', runnerName,
...this.buildIdArg()
]
if (runnerDescription) {
args.push('--runner-description')
args.push(runnerDescription)
}
return this.runCommand(this.getRunnerPath(), args)
}
unregisterPeerTubeInstance (options: {
runnerName: string
}) {
const { runnerName } = options
const args = [ 'unregister', '--url', this.server.url, '--runner-name', runnerName, ...this.buildIdArg() ]
return this.runCommand(this.getRunnerPath(), args)
}
async listRegisteredPeerTubeInstances () {
const args = [ 'list-registered', ...this.buildIdArg() ]
const { stdout } = await this.runCommand(this.getRunnerPath(), args)
return stdout
}
kill () {
if (!this.app) return
process.kill(this.app.pid)
this.app = null
}
getId () {
return 'test-' + this.server.internalServerNumber
}
private getRunnerPath () {
return join(root(), 'apps', 'peertube-runner', 'dist', 'peertube-runner.js')
}
private buildIdArg () {
return [ '--id', this.getId() ]
}
private runCommand (path: string, args: string[]) {
return execa.node(path, args, { env: { ...process.env, NODE_OPTIONS: '' } })
}
}
|
