Merge pull request sublime247#1387 from dominiccreates/standardize-mock-assertions

feat: add readiness endpoint with dependency verification to ingest-node

Author: sublime247

ingest-node/src/index.ts

@@ -448,6 +448,39 @@ app.get("/metrics", async (_req, reply) => {
   return reply.send(await register.metrics());
 });
 
+// ---------------------------------------------------------------------------
+// Readiness endpoint – verifies underlying message queues before reporting ready
+// ---------------------------------------------------------------------------
+
+async function checkDependencies(): Promise<boolean> {
+  // Verify Redis connection if enabled
+  if (REDIS_ENABLED && redisPool) {
+    try {
+      await redisPool.executeCommand(async (client) => client.ping());
+    } catch (err) {
+      console.error('[ready] Redis ping failed', err);
+      return false;
+    }
+  }
+  // Verify NATS connection if enabled
+  if (NATS_ENABLED && nats) {
+    if (nats.isClosed()) {
+      console.error('[ready] NATS connection closed');
+      return false;
+    }
+  }
+  return true;
+}
+
+app.get("/ready", async (_req, reply) => {
+  const healthy = await checkDependencies();
+  if (healthy) {
+    return reply.status(200).send({ status: "ready" });
+  } else {
+    return reply.status(503).send({ status: "unavailable" });
+  }
+});
+
 // ---------------------------------------------------------------------------
 // Boot
 // ---------------------------------------------------------------------------