6 files changed, 0 insertions, 183 deletions

diff --git a/packages/peertube-runner/shared/ipc/index.ts b/packages/peertube-runner/shared/ipc/index.ts
deleted file mode 100644
index ad4590281..000000000
--- a/packages/peertube-runner/shared/ipc/index.ts
+++ /dev/null
@@ -1,2 +0,0 @@
-export * from './ipc-client'
-export * from './ipc-server'
diff --git a/packages/peertube-runner/shared/ipc/ipc-client.ts b/packages/peertube-runner/shared/ipc/ipc-client.ts
deleted file mode 100644
index f8e72f97f..000000000
--- a/packages/peertube-runner/shared/ipc/ipc-client.ts
+++ /dev/null
@@ -1,88 +0,0 @@
-import CliTable3 from 'cli-table3'
-import { ensureDir } from 'fs-extra'
-import { Client as NetIPC } from 'net-ipc'
-import { ConfigManager } from '../config-manager'
-import { IPCReponse, IPCReponseData, IPCRequest } from './shared'
-
-export class IPCClient {
-  private netIPC: NetIPC
-
-  async run () {
-    await ensureDir(ConfigManager.Instance.getSocketDirectory())
-
-    const socketPath = ConfigManager.Instance.getSocketPath()
-
-    this.netIPC = new NetIPC({ path: socketPath })
-
-    try {
-      await this.netIPC.connect()
-    } catch (err) {
-      if (err.code === 'ECONNREFUSED') {
-        throw new Error(
-          'This runner is not currently running in server mode on this system. ' +
-          'Please run it using the `server` command first (in another terminal for example) and then retry your command.'
-        )
-      }
-
-      throw err
-    }
-  }
-
-  async askRegister (options: {
-    url: string
-    registrationToken: string
-    runnerName: string
-    runnerDescription?: string
-  }) {
-    const req: IPCRequest = {
-      type: 'register',
-      ...options
-    }
-
-    const { success, error } = await this.netIPC.request(req) as IPCReponse
-
-    if (success) console.log('PeerTube instance registered')
-    else console.error('Could not register PeerTube instance on runner server side', error)
-  }
-
-  async askUnregister (options: {
-    url: string
-    runnerName: string
-  }) {
-    const req: IPCRequest = {
-      type: 'unregister',
-      ...options
-    }
-
-    const { success, error } = await this.netIPC.request(req) as IPCReponse
-
-    if (success) console.log('PeerTube instance unregistered')
-    else console.error('Could not unregister PeerTube instance on runner server side', error)
-  }
-
-  async askListRegistered () {
-    const req: IPCRequest = {
-      type: 'list-registered'
-    }
-
-    const { success, error, data } = await this.netIPC.request(req) as IPCReponse<IPCReponseData>
-    if (!success) {
-      console.error('Could not list registered PeerTube instances', error)
-      return
-    }
-
-    const table = new CliTable3({
-      head: [ 'instance', 'runner name', 'runner description' ]
-    })
-
-    for (const server of data.servers) {
-      table.push([ server.url, server.runnerName, server.runnerDescription ])
-    }
-
-    console.log(table.toString())
-  }
-
-  stop () {
-    this.netIPC.destroy()
-  }
-}
diff --git a/packages/peertube-runner/shared/ipc/ipc-server.ts b/packages/peertube-runner/shared/ipc/ipc-server.ts
deleted file mode 100644
index 4b67d01ae..000000000
--- a/packages/peertube-runner/shared/ipc/ipc-server.ts
+++ /dev/null
@@ -1,61 +0,0 @@
-import { ensureDir } from 'fs-extra'
-import { Server as NetIPC } from 'net-ipc'
-import { pick } from '@shared/core-utils'
-import { RunnerServer } from '../../server'
-import { ConfigManager } from '../config-manager'
-import { logger } from '../logger'
-import { IPCReponse, IPCReponseData, IPCRequest } from './shared'
-
-export class IPCServer {
-  private netIPC: NetIPC
-  private runnerServer: RunnerServer
-
-  async run (runnerServer: RunnerServer) {
-    this.runnerServer = runnerServer
-
-    await ensureDir(ConfigManager.Instance.getSocketDirectory())
-
-    const socketPath = ConfigManager.Instance.getSocketPath()
-    this.netIPC = new NetIPC({ path: socketPath })
-    await this.netIPC.start()
-
-    logger.info(`IPC socket created on ${socketPath}`)
-
-    this.netIPC.on('request', async (req: IPCRequest, res) => {
-      try {
-        const data = await this.process(req)
-
-        this.sendReponse(res, { success: true, data })
-      } catch (err) {
-        logger.error('Cannot execute RPC call', err)
-        this.sendReponse(res, { success: false, error: err.message })
-      }
-    })
-  }
-
-  private async process (req: IPCRequest) {
-    switch (req.type) {
-      case 'register':
-        await this.runnerServer.registerRunner(pick(req, [ 'url', 'registrationToken', 'runnerName', 'runnerDescription' ]))
-        return undefined
-
-      case 'unregister':
-        await this.runnerServer.unregisterRunner(pick(req, [ 'url', 'runnerName' ]))
-        return undefined
-
-      case 'list-registered':
-        return Promise.resolve(this.runnerServer.listRegistered())
-
-      default:
-        throw new Error('Unknown RPC call ' + (req as any).type)
-    }
-  }
-
-  private sendReponse <T extends IPCReponseData> (
-    response: (data: any) => Promise<void>,
-    body: IPCReponse<T>
-  ) {
-    response(body)
-      .catch(err => logger.error('Cannot send response after IPC request', err))
-  }
-}
diff --git a/packages/peertube-runner/shared/ipc/shared/index.ts b/packages/peertube-runner/shared/ipc/shared/index.ts
deleted file mode 100644
index deaaa152e..000000000
--- a/packages/peertube-runner/shared/ipc/shared/index.ts
+++ /dev/null
@@ -1,2 +0,0 @@
-export * from './ipc-request.model'
-export * from './ipc-response.model'
diff --git a/packages/peertube-runner/shared/ipc/shared/ipc-request.model.ts b/packages/peertube-runner/shared/ipc/shared/ipc-request.model.ts
deleted file mode 100644
index 352808c74..000000000
--- a/packages/peertube-runner/shared/ipc/shared/ipc-request.model.ts
+++ /dev/null
@@ -1,15 +0,0 @@
-export type IPCRequest =
-  IPCRequestRegister |
-  IPCRequestUnregister |
-  IPCRequestListRegistered
-
-export type IPCRequestRegister = {
-  type: 'register'
-  url: string
-  registrationToken: string
-  runnerName: string
-  runnerDescription?: string
-}
-
-export type IPCRequestUnregister = { type: 'unregister', url: string, runnerName: string }
-export type IPCRequestListRegistered = { type: 'list-registered' }
diff --git a/packages/peertube-runner/shared/ipc/shared/ipc-response.model.ts b/packages/peertube-runner/shared/ipc/shared/ipc-response.model.ts
deleted file mode 100644
index 689d6e09a..000000000
--- a/packages/peertube-runner/shared/ipc/shared/ipc-response.model.ts
+++ /dev/null
@@ -1,15 +0,0 @@
-export type IPCReponse <T extends IPCReponseData = undefined> = {
-  success: boolean
-  error?: string
-  data?: T
-}
-
-export type IPCReponseData =
-  // list registered
-  {
-    servers: {
-      runnerName: string
-      runnerDescription: string
-      url: string
-    }[]
-  }