add summary event

packages/monitoring/src/helpers/events.ts

@@ -3,15 +3,36 @@ import { EventEmitter } from "events";
 import { TextColor } from "../types";
 import { colorizeText } from "./utils";
 const events = new EventEmitter();
+type ServiceStatus = { [key: string]: boolean };
 
+const serviceStatusSummary: ServiceStatus = {};
+const ALIVE = colorizeText("Alive", TextColor.Green);
+const DOWN = colorizeText("Down", TextColor.Red);
 function logsHandler(msg) {
   console.log(msg);
 }
 
 function serviceDownHandler(serviceName: string, error: Error) {
   console.log(`${colorizeText(serviceName + " is Down", TextColor.Red)}`);
   console.log(colorizeText("* Error: " + error.message, TextColor.Gray));
+  serviceStatusSummary[serviceName] = false;
+}
+
+function addToServiceSummary(serviceName: string, serviceIsAlive: boolean) {
+  serviceStatusSummary[serviceName] = serviceIsAlive;
+}
+
+function printStatusSummary() {
+  const serviceNames = Object.keys(serviceStatusSummary);
+  const maxServiceNameLength = Math.max(...serviceNames.map(entry => entry.length));
+  console.log(colorizeText("Aliveness check summary:", TextColor.Blue));
+  for (const service in serviceStatusSummary) {
+    const padding = " ".repeat(maxServiceNameLength - service.length);
+    console.log(`\t${service}${padding}: ${serviceStatusSummary[service] ? ALIVE : DOWN}`);
+  }
 }
 events.addListener("logs", logsHandler);
 events.addListener("serviceIsDown", serviceDownHandler);
+events.addListener("storeServiceStatus", addToServiceSummary);
+events.addListener("summarize", printStatusSummary);
 export { events };

packages/monitoring/src/serviceMonitor/alivenessChecker.ts

@@ -29,11 +29,15 @@ export async function checkServiceAliveness(services: IServiceAliveness[], retri
   for (const service of services) {
     for (let retryCount = 1; retryCount <= retries; retryCount++) {
       const { alive, error } = await service.isAlive();
-      if (alive) break;
+      if (alive) {
+        events.emit("storeServiceStatus", service.ServiceName, alive);
+        break;
+      }
       if (retryCount < retries) {
         events.emit("logs", `${service.ServiceName} seems to be down; Retrying (${retryCount}/${retries})...`);
         await new Promise(resolve => setTimeout(resolve, retryInterval * 60));
       } else events.emit("serviceIsDown", service.ServiceName, error);
     }
   }
+  events.emit("summarize");
 }