aboutsummaryrefslogtreecommitdiffhomepage
path: root/packages/peertube-runner/shared/ipc
diff options
context:
space:
mode:
Diffstat (limited to 'packages/peertube-runner/shared/ipc')
-rw-r--r--packages/peertube-runner/shared/ipc/ipc-client.ts1
-rw-r--r--packages/peertube-runner/shared/ipc/ipc-server.ts2
-rw-r--r--packages/peertube-runner/shared/ipc/shared/ipc-request.model.ts2
3 files changed, 3 insertions, 2 deletions
diff --git a/packages/peertube-runner/shared/ipc/ipc-client.ts b/packages/peertube-runner/shared/ipc/ipc-client.ts
index db8d7f1bf..f8e72f97f 100644
--- a/packages/peertube-runner/shared/ipc/ipc-client.ts
+++ b/packages/peertube-runner/shared/ipc/ipc-client.ts
@@ -47,6 +47,7 @@ export class IPCClient {
47 47
48 async askUnregister (options: { 48 async askUnregister (options: {
49 url: string 49 url: string
50 runnerName: string
50 }) { 51 }) {
51 const req: IPCRequest = { 52 const req: IPCRequest = {
52 type: 'unregister', 53 type: 'unregister',
diff --git a/packages/peertube-runner/shared/ipc/ipc-server.ts b/packages/peertube-runner/shared/ipc/ipc-server.ts
index 922dc93e5..4b67d01ae 100644
--- a/packages/peertube-runner/shared/ipc/ipc-server.ts
+++ b/packages/peertube-runner/shared/ipc/ipc-server.ts
@@ -40,7 +40,7 @@ export class IPCServer {
40 return undefined 40 return undefined
41 41
42 case 'unregister': 42 case 'unregister':
43 await this.runnerServer.unregisterRunner({ url: req.url }) 43 await this.runnerServer.unregisterRunner(pick(req, [ 'url', 'runnerName' ]))
44 return undefined 44 return undefined
45 45
46 case 'list-registered': 46 case 'list-registered':
diff --git a/packages/peertube-runner/shared/ipc/shared/ipc-request.model.ts b/packages/peertube-runner/shared/ipc/shared/ipc-request.model.ts
index 0f733cdfe..352808c74 100644
--- a/packages/peertube-runner/shared/ipc/shared/ipc-request.model.ts
+++ b/packages/peertube-runner/shared/ipc/shared/ipc-request.model.ts
@@ -11,5 +11,5 @@ export type IPCRequestRegister = {
11 runnerDescription?: string 11 runnerDescription?: string
12} 12}
13 13
14export type IPCRequestUnregister = { type: 'unregister', url: string } 14export type IPCRequestUnregister = { type: 'unregister', url: string, runnerName: string }
15export type IPCRequestListRegistered = { type: 'list-registered' } 15export type IPCRequestListRegistered = { type: 'list-registered' }