+++ /dev/null
-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)
- }
-}