Make the health behave like the ready

Author: IvanUkhov

README.md

@@ -11,8 +11,8 @@ npm install @thetypefounders/container-well-being --save
 ## Usage
 
 ```javascript
-import express from 'express';
 import { Status } from '@thetypefounders/container-well-being';
+import express from 'express';
 
 const status = new Status({
   // The host to bind to.

package-lock.json

@@ -1,6 +1,6 @@
 {
   "name": "@thetypefounders/container-well-being",
-  "version": "1.0.0",
+  "version": "1.0.1",
   "license": "Apache-2.0",
   "author": "Ivan Ukhov <ivan.ukhov@gmail.com>",
   "description": "Standard checks and probes for containers on Kubernetes",
@@ -15,11 +15,11 @@
     "express": "^4.21.2"
   },
   "devDependencies": {
-    "@trivago/prettier-plugin-sort-imports": "^5.2.1",
+    "@trivago/prettier-plugin-sort-imports": "^5.2.2",
     "@types/express": "^5.0.0",
-    "@types/node": "^22.13.2",
-    "prettier": "^3.4.2",
-    "typescript": "^5.7.3"
+    "@types/node": "^22.13.9",
+    "prettier": "^3.5.3",
+    "typescript": "^5.8.2"
   },
   "scripts": {
     "build": "tsc",

package.json

@@ -38,33 +38,17 @@ export class Status {
 
     const app = express();
 
-    app.get(
-      '/health',
-      (request: express.Request, response: express.Response) => {
-        response
-          .status(self.options.successCode!)
-          .send(self.options.successBody);
-      }
-    );
+    app.get('/health', (request, response) => {
+      self.onReady(request, response);
+    });
 
-    app.get('/live', (request: express.Request, response: express.Response) => {
-      response.status(self.options.successCode!).send(self.options.successBody);
+    app.get('/live', (request, response) => {
+      self.onLive(request, response);
     });
 
-    app.get(
-      '/ready',
-      (request: express.Request, response: express.Response) => {
-        if (!self.started || self.stopped) {
-          response
-            .status(self.options.failureCode!)
-            .send(self.options.failureBody);
-        } else {
-          response
-            .status(self.options.successCode!)
-            .send(self.options.successBody);
-        }
-      }
-    );
+    app.get('/ready', (request, response) => {
+      self.onReady(request, response);
+    });
 
     process.on('SIGTERM', () => {
       self.stop();
@@ -78,6 +62,7 @@ export class Status {
   }
 
   start(): void {
+    this.options.logger?.info('Starting to pass the readiness probe...');
     this.started = true;
   }
 
@@ -88,6 +73,7 @@ export class Status {
       `Sleeping for ${self.options.graceBeforeSeconds} seconds...`
     );
     setTimeout(() => {
+      self.options.logger?.info('Starting to fail the readiness probe...');
       self.stopped = true;
       self.options.logger?.info(
         `Sleeping for ${self.options.graceAfterSeconds} seconds...`
@@ -98,4 +84,16 @@ export class Status {
       }, 1000 * self.options.graceAfterSeconds!);
     }, 1000 * self.options.graceBeforeSeconds!);
   }
+
+  private onLive(request: express.Request, response: express.Response): void {
+    response.status(this.options.successCode!).send(this.options.successBody);
+  }
+
+  private onReady(request: express.Request, response: express.Response): void {
+    if (!this.started || this.stopped) {
+      response.status(this.options.failureCode!).send(this.options.failureBody);
+    } else {
+      response.status(this.options.successCode!).send(this.options.successBody);
+    }
+  }
 }