feat: health and ready checks

Author: saihaj

substream-listener/src/index.mts

@@ -9,7 +9,7 @@ import {
 import { logger } from "./logger.mjs";
 import { createScheduler } from "./scheduler.mjs";
 
-const { schedule, start, stop } = createScheduler({
+const { schedule, start, stop, readiness } = createScheduler({
   queueName: "substream-sink-scheduler",
   logger: logger.child({ module: "substream-sink-scheduler" }),
   redis: {
@@ -152,6 +152,27 @@ const router = createRouter({
         message: "Webhook registered",
       });
     },
+  })
+  .route({
+    path: "/health",
+    method: "GET",
+    async handler() {
+      return Response.json({ status: "ok" }, { status: 200 });
+    },
+  })
+  .route({
+    path: "/ready",
+    method: "GET",
+    handler() {
+      const isReady = readiness();
+
+      return Response.json(
+        { status: isReady ? "ok" : "not ready" },
+        {
+          status: isReady ? 200 : 503,
+        },
+      );
+    },
   });
 
 const webhookServer = App()