shared/ typescript types dir server-commands

9 files changed, 0 insertions, 316 deletions

diff --git a/shared/extra-utils/mock-servers/index.ts b/shared/extra-utils/mock-servers/index.ts
deleted file mode 100644
index 93c00c788..000000000
--- a/shared/extra-utils/mock-servers/index.ts
+++ /dev/null
@@ -1,5 +0,0 @@
-export * from './mock-email'
-export * from './mock-instances-index'
-export * from './mock-joinpeertube-versions'
-export * from './mock-plugin-blocklist'
-export * from './mock-object-storage'
diff --git a/shared/extra-utils/mock-servers/mock-429.ts b/shared/extra-utils/mock-servers/mock-429.ts
deleted file mode 100644
index 9e0d1281a..000000000
--- a/shared/extra-utils/mock-servers/mock-429.ts
+++ /dev/null
@@ -1,33 +0,0 @@
-import express from 'express'
-import { Server } from 'http'
-import { getPort, randomListen, terminateServer } from './utils'
-
-export class Mock429 {
-  private server: Server
-  private responseSent = false
-
-  async initialize () {
-    const app = express()
-
-    app.get('/', (req: express.Request, res: express.Response, next: express.NextFunction) => {
-
-      if (!this.responseSent) {
-        this.responseSent = true
-
-        // Retry after 5 seconds
-        res.header('retry-after', '2')
-        return res.sendStatus(429)
-      }
-
-      return res.sendStatus(200)
-    })
-
-    this.server = await randomListen(app)
-
-    return getPort(this.server)
-  }
-
-  terminate () {
-    return terminateServer(this.server)
-  }
-}
diff --git a/shared/extra-utils/mock-servers/mock-email.ts b/shared/extra-utils/mock-servers/mock-email.ts
deleted file mode 100644
index f646c1621..000000000
--- a/shared/extra-utils/mock-servers/mock-email.ts
+++ /dev/null
@@ -1,63 +0,0 @@
-import { ChildProcess } from 'child_process'
-import MailDev from '@peertube/maildev'
-import { randomInt } from '@shared/core-utils'
-import { parallelTests } from '../miscs'
-
-class MockSmtpServer {
-
-  private static instance: MockSmtpServer
-  private started = false
-  private emailChildProcess: ChildProcess
-  private emails: object[]
-
-  private constructor () { }
-
-  collectEmails (emailsCollection: object[]) {
-    return new Promise<number>((res, rej) => {
-      const port = parallelTests() ? randomInt(1000, 2000) : 1025
-      this.emails = emailsCollection
-
-      if (this.started) {
-        return res(undefined)
-      }
-
-      const maildev = new MailDev({
-        ip: '127.0.0.1',
-        smtp: port,
-        disableWeb: true,
-        silent: true
-      })
-
-      maildev.on('new', email => {
-        this.emails.push(email)
-      })
-
-      maildev.listen(err => {
-        if (err) return rej(err)
-
-        this.started = true
-
-        return res(port)
-      })
-    })
-  }
-
-  kill () {
-    if (!this.emailChildProcess) return
-
-    process.kill(this.emailChildProcess.pid)
-
-    this.emailChildProcess = null
-    MockSmtpServer.instance = null
-  }
-
-  static get Instance () {
-    return this.instance || (this.instance = new this())
-  }
-}
-
-// ---------------------------------------------------------------------------
-
-export {
-  MockSmtpServer
-}
diff --git a/shared/extra-utils/mock-servers/mock-instances-index.ts b/shared/extra-utils/mock-servers/mock-instances-index.ts
deleted file mode 100644
index 92b12d6f3..000000000
--- a/shared/extra-utils/mock-servers/mock-instances-index.ts
+++ /dev/null
@@ -1,46 +0,0 @@
-import express from 'express'
-import { Server } from 'http'
-import { getPort, randomListen, terminateServer } from './utils'
-
-export class MockInstancesIndex {
-  private server: Server
-
-  private readonly indexInstances: { host: string, createdAt: string }[] = []
-
-  async initialize () {
-    const app = express()
-
-    app.use('/', (req: express.Request, res: express.Response, next: express.NextFunction) => {
-      if (process.env.DEBUG) console.log('Receiving request on mocked server %s.', req.url)
-
-      return next()
-    })
-
-    app.get('/api/v1/instances/hosts', (req: express.Request, res: express.Response) => {
-      const since = req.query.since
-
-      const filtered = this.indexInstances.filter(i => {
-        if (!since) return true
-
-        return i.createdAt > since
-      })
-
-      return res.json({
-        total: filtered.length,
-        data: filtered
-      })
-    })
-
-    this.server = await randomListen(app)
-
-    return getPort(this.server)
-  }
-
-  addInstance (host: string) {
-    this.indexInstances.push({ host, createdAt: new Date().toISOString() })
-  }
-
-  terminate () {
-    return terminateServer(this.server)
-  }
-}
diff --git a/shared/extra-utils/mock-servers/mock-joinpeertube-versions.ts b/shared/extra-utils/mock-servers/mock-joinpeertube-versions.ts
deleted file mode 100644
index e7906ea56..000000000
--- a/shared/extra-utils/mock-servers/mock-joinpeertube-versions.ts
+++ /dev/null
@@ -1,34 +0,0 @@
-import express from 'express'
-import { Server } from 'http'
-import { getPort, randomListen } from './utils'
-
-export class MockJoinPeerTubeVersions {
-  private server: Server
-  private latestVersion: string
-
-  async initialize () {
-    const app = express()
-
-    app.use('/', (req: express.Request, res: express.Response, next: express.NextFunction) => {
-      if (process.env.DEBUG) console.log('Receiving request on mocked server %s.', req.url)
-
-      return next()
-    })
-
-    app.get('/versions.json', (req: express.Request, res: express.Response) => {
-      return res.json({
-        peertube: {
-          latestVersion: this.latestVersion
-        }
-      })
-    })
-
-    this.server = await randomListen(app)
-
-    return getPort(this.server)
-  }
-
-  setLatestVersion (latestVersion: string) {
-    this.latestVersion = latestVersion
-  }
-}
diff --git a/shared/extra-utils/mock-servers/mock-object-storage.ts b/shared/extra-utils/mock-servers/mock-object-storage.ts
deleted file mode 100644
index d135c2631..000000000
--- a/shared/extra-utils/mock-servers/mock-object-storage.ts
+++ /dev/null
@@ -1,41 +0,0 @@
-import express from 'express'
-import got, { RequestError } from 'got'
-import { Server } from 'http'
-import { pipeline } from 'stream'
-import { ObjectStorageCommand } from '../server'
-import { getPort, randomListen, terminateServer } from './utils'
-
-export class MockObjectStorage {
-  private server: Server
-
-  async initialize () {
-    const app = express()
-
-    app.get('/:bucketName/:path(*)', (req: express.Request, res: express.Response, next: express.NextFunction) => {
-      const url = `http://${req.params.bucketName}.${ObjectStorageCommand.getEndpointHost()}/${req.params.path}`
-
-      if (process.env.DEBUG) {
-        console.log('Receiving request on mocked server %s.', req.url)
-        console.log('Proxifying request to %s', url)
-      }
-
-      return pipeline(
-        got.stream(url, { throwHttpErrors: false }),
-        res,
-        (err: RequestError) => {
-          if (!err) return
-
-          console.error('Pipeline failed.', err)
-        }
-      )
-    })
-
-    this.server = await randomListen(app)
-
-    return getPort(this.server)
-  }
-
-  terminate () {
-    return terminateServer(this.server)
-  }
-}
diff --git a/shared/extra-utils/mock-servers/mock-plugin-blocklist.ts b/shared/extra-utils/mock-servers/mock-plugin-blocklist.ts
deleted file mode 100644
index f8a271cba..000000000
--- a/shared/extra-utils/mock-servers/mock-plugin-blocklist.ts
+++ /dev/null
@@ -1,36 +0,0 @@
-import express, { Request, Response } from 'express'
-import { Server } from 'http'
-import { getPort, randomListen, terminateServer } from './utils'
-
-type BlocklistResponse = {
-  data: {
-    value: string
-    action?: 'add' | 'remove'
-    updatedAt?: string
-  }[]
-}
-
-export class MockBlocklist {
-  private body: BlocklistResponse
-  private server: Server
-
-  async initialize () {
-    const app = express()
-
-    app.get('/blocklist', (req: Request, res: Response) => {
-      return res.json(this.body)
-    })
-
-    this.server = await randomListen(app)
-
-    return getPort(this.server)
-  }
-
-  replace (body: BlocklistResponse) {
-    this.body = body
-  }
-
-  terminate () {
-    return terminateServer(this.server)
-  }
-}
diff --git a/shared/extra-utils/mock-servers/mock-proxy.ts b/shared/extra-utils/mock-servers/mock-proxy.ts
deleted file mode 100644
index 75ac79055..000000000
--- a/shared/extra-utils/mock-servers/mock-proxy.ts
+++ /dev/null
@@ -1,25 +0,0 @@
-
-import { createServer, Server } from 'http'
-import proxy from 'proxy'
-import { getPort, terminateServer } from './utils'
-
-class MockProxy {
-  private server: Server
-
-  initialize () {
-    return new Promise<number>(res => {
-      this.server = proxy(createServer())
-      this.server.listen(0, () => res(getPort(this.server)))
-    })
-  }
-
-  terminate () {
-    return terminateServer(this.server)
-  }
-}
-
-// ---------------------------------------------------------------------------
-
-export {
-  MockProxy
-}
diff --git a/shared/extra-utils/mock-servers/utils.ts b/shared/extra-utils/mock-servers/utils.ts
deleted file mode 100644
index 235642439..000000000
--- a/shared/extra-utils/mock-servers/utils.ts
+++ /dev/null
@@ -1,33 +0,0 @@
-import { Express } from 'express'
-import { Server } from 'http'
-import { AddressInfo } from 'net'
-
-function randomListen (app: Express) {
-  return new Promise<Server>(res => {
-    const server = app.listen(0, () => res(server))
-  })
-}
-
-function getPort (server: Server) {
-  const address = server.address() as AddressInfo
-
-  return address.port
-}
-
-function terminateServer (server: Server) {
-  if (!server) return Promise.resolve()
-
-  return new Promise<void>((res, rej) => {
-    server.close(err => {
-      if (err) return rej(err)
-
-      return res()
-    })
-  })
-}
-
-export {
-  randomListen,
-  getPort,
-  terminateServer
-}