diff options
Diffstat (limited to 'packages/peertube-runner/shared/ipc')
-rw-r--r-- | packages/peertube-runner/shared/ipc/ipc-client.ts | 1 | ||||
-rw-r--r-- | packages/peertube-runner/shared/ipc/ipc-server.ts | 2 | ||||
-rw-r--r-- | packages/peertube-runner/shared/ipc/shared/ipc-request.model.ts | 2 |
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 | ||
14 | export type IPCRequestUnregister = { type: 'unregister', url: string } | 14 | export type IPCRequestUnregister = { type: 'unregister', url: string, runnerName: string } |
15 | export type IPCRequestListRegistered = { type: 'list-registered' } | 15 | export type IPCRequestListRegistered = { type: 'list-registered' } |