Add disableHttpServer option

base-server/index.d.ts

@@ -206,6 +206,14 @@ export interface BaseServerOptions {
    * By default it cleans `Bearer [^\s"]+`.
    */
   cleanFromLog?: RegExp
+
+  /**
+   * Disable health check endpoint, control HTTP API, {@link Server#http}.
+   *
+   * The server will process only WebSocket connection and ignore all other
+   * HTTP request (so they can be processed by other HTTP server).
+   */
+  disableHttpServer?: boolean
 }
 
 export interface AuthenticatorOptions<Headers extends object> {

base-server/index.js

@@ -382,6 +382,11 @@ export class BaseServer {
   }
 
   http(listener) {
+    if (this.options.disableHttpServer) {
+      throw new Error(
+        '`server.http()` can not be called when `disableHttpServer` enabled'
+      )
+    }
     this.httpListener = listener
   }
 

bind-control-server/index.js

@@ -17,6 +17,17 @@ function isValidBody(body) {
 }
 
 export function bindControlServer(app, custom) {
+  if (app.options.disableHttpServer) {
+    if (app.options.controlSecret) {
+      let err = new Error(
+        '`controlSecret` can be set together with `disableHttpServer` option'
+      )
+      err.logux = true
+      throw err
+    }
+    return
+  }
+
   let masks = app.options.controlMask.split(/,\s*/).map(i => ip.cidrSubnet(i))
   app.httpServer.on('request', async (req, res) => {
     let urlString = req.url

bind-control-server/index.test.ts

@@ -39,7 +39,7 @@ afterEach(async () => {
   await app.destroy()
 })
 
-function createReporter(opts = {}): {
+function createReporter(opts: Partial<BaseServerOptions> = {}): {
   names: string[]
   reports: [string, object][]
   app: BaseServer
@@ -104,15 +104,36 @@ it('has hello page', async () => {
   expect(response.body).toContain('<svg ')
 })
 
+it('disables HTTP on request', async () => {
+  app = createServer({ disableHttpServer: true })
+  await app.listen()
+  let response = false
+  let req = http.request(
+    {
+      method: 'GET',
+      host: '127.0.0.1',
+      port: app.options.port,
+      path: '/health'
+    },
+    () => {
+      response = true
+    }
+  )
+  req.on('error', () => {})
+  await delay(100)
+  expect(response).toBe(false)
+  req.destroy()
+})
+
 it('has health check', async () => {
-  app = createServer({ controlSecret: 'secret', backend: 'http://localhost/' })
+  app = createServer()
   await app.listen()
   let response = await request('GET', '/health')
   expect(response.body).toContain('OK')
 })
 
-it('has health check without control server', async () => {
-  app = createServer()
+it('has health check with control server', async () => {
+  app = createServer({ controlSecret: 'secret', backend: 'http://localhost/' })
   await app.listen()
   let response = await request('GET', '/health')
   expect(response.body).toContain('OK')
@@ -275,3 +296,27 @@ it('allows to set custom HTTP processor', async () => {
   let response = await request('GET', '/test')
   expect(response.body).toEqual('test /test')
 })
+
+it('does not allow to set custom HTTP processor on disabled HTTP', async () => {
+  app = createServer({ disableHttpServer: true })
+  expect(() => {
+    app.http((req, res) => {
+      res.statusCode = 200
+      res.end(`test ${req.url}`)
+    })
+  }).toThrow(/can not be called when `disableHttpServer` enabled/)
+})
+
+it('does not allow to have control secret on disabled HTTP', async () => {
+  app = createServer({ disableHttpServer: true, controlSecret: 'x' })
+  let err: Error | undefined
+  try {
+    await app.listen()
+  } catch (e) {
+    if (e instanceof Error) err = e
+  }
+  expect(err?.message).toBe(
+    '`controlSecret` can be set together with `disableHttpServer` option'
+  )
+})
+