1 files changed, 42 insertions, 0 deletions

diff --git a/shared/extra-utils/mock-servers/mock-object-storage.ts b/shared/extra-utils/mock-servers/mock-object-storage.ts
new file mode 100644
index 000000000..19ea7c87c
--- /dev/null
+++ b/shared/extra-utils/mock-servers/mock-object-storage.ts
@@ -0,0 +1,42 @@
+import * as express from 'express'
+import got, { RequestError } from 'got'
+import { Server } from 'http'
+import { pipeline } from 'stream'
+import { randomInt } from '@shared/core-utils'
+import { ObjectStorageCommand } from '../server'
+
+export class MockObjectStorage {
+  private server: Server
+
+  initialize () {
+    return new Promise<number>(res => {
+      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)
+          }
+        )
+      })
+
+      const port = 42301 + randomInt(1, 100)
+      this.server = app.listen(port, () => res(port))
+    })
+  }
+
+  terminate () {
+    if (this.server) this.server.close()
+  }
+}