feat(node-utils): add option to deactivate route handlers

Author: mroz22

packages/node-utils/src/http.ts

@@ -73,6 +73,7 @@ type Route = {
     pathname: string;
     params: string[];
     handler: AnyRequestHandler[];
+    isActive: boolean;
 };
 /**
  * Events that may be emitted or listened to by HttpServer
@@ -219,6 +220,7 @@ export class HttpServer<T extends EventMap> extends TypedEmitter<T & BaseEvents>
             pathname: `/${basePathname}`,
             params: paramsSegments,
             handler,
+            isActive: true,
         });
     }
 
@@ -244,9 +246,24 @@ export class HttpServer<T extends EventMap> extends TypedEmitter<T & BaseEvents>
             pathname: '*',
             handler,
             params: [],
+            isActive: true,
         });
     }
 
+    public activateRoute(pathname: string) {
+        const route = this.routes.find(r => r.pathname === pathname);
+        if (route) {
+            route.isActive = true;
+        }
+    }
+
+    public deactivateRoute(pathname: string) {
+        const route = this.routes.find(r => r.pathname === pathname);
+        if (route) {
+            route.isActive = false;
+        }
+    }
+
     /**
      * pathname could be /a/b/c/d
      * return route with highest number of matching segments
@@ -329,6 +346,13 @@ export class HttpServer<T extends EventMap> extends TypedEmitter<T & BaseEvents>
 
             return;
         }
+
+        if (!route.isActive) {
+            response.statusCode = 404;
+            response.end();
+            return;
+        }
+
         const paramsSegments = pathname
             .replace(route.pathname, '')
             .split('/')

packages/node-utils/src/tests/http.test.ts

@@ -391,4 +391,25 @@ describe('HttpServer', () => {
         );
         expect(res.status).toEqual(403);
     });
+
+    test('any registered route is active  by default and can be deactivated', async () => {
+        const handler = jest.fn((_request, response) => {
+            response.end('ok');
+        });
+        server.get('/foo', [handler]);
+        server.get('/bar', [handler]);
+        await server.start();
+        const address = server.getServerAddress();
+        expect(address).toBeDefined();
+        let res = await fetch(`http://${address.address}:${address.port}/foo`);
+        expect(res.status).toEqual(200);
+        res = await fetch(`http://${address.address}:${address.port}/bar`);
+        expect(res.status).toEqual(200);
+
+        server.deactivateRoute('/foo');
+        res = await fetch(`http://${address.address}:${address.port}/foo`);
+        expect(res.status).toEqual(404);
+        res = await fetch(`http://${address.address}:${address.port}/bar`);
+        expect(res.status).toEqual(200);
+    });
 });