Move health endpoints to dedicated router

Author: max-lt

README.md

@@ -157,25 +157,3 @@ console.log(users[0], users.count);
 - Token-based access control per database
 - Same API works from workers (OpenWorkers runtime)
 
-## Status
-
-### Implemented
-
-- [x] Auth routes (GitHub OAuth, refresh)
-- [x] Users routes (profile)
-- [x] Workers routes (CRUD + name uniqueness check)
-- [x] Databases routes (CRUD + token management via Postgate)
-- [x] Environments routes (CRUD + values management)
-- [x] Domains routes (CRUD)
-- [x] Crons routes (CRUD)
-- [x] Zod input/output validation
-- [x] JWT authentication middleware
-- [x] Standalone binary compilation
-- [x] Postgate integration (HTTP-based Postgres access)
-
-### TODO
-
-- [ ] Error handling middleware (standardized error responses)
-- [ ] Rate limiting
-- [ ] Tests (unit + integration)
-- [ ] API documentation (OpenAPI/Swagger)

src/index.ts

@@ -1,6 +1,7 @@
 import { Hono } from 'hono';
 import { cors } from 'hono/cors';
 import { logger } from 'hono/logger';
+
 import { nodeEnv, port } from './config';
 import { createAuthMiddleware, extractUser, errorHandler } from './middlewares/auth';
 import authRoutes from './routes/auth';
@@ -15,9 +16,8 @@ import kv from './routes/kv';
 import storage from './routes/storage';
 import ai from './routes/ai';
 import apiKeys from './routes/api-keys';
+import health from './routes/health';
 import pkg from '../package.json';
-import { sql } from './services/db/client';
-import { WasmCron } from '@openworkers/croner-wasm';
 
 export const app = new Hono();
 
@@ -32,38 +32,8 @@ if (nodeEnv === 'development') {
 // API routes (no version prefix for health checks)
 const api = new Hono();
 
-// Health check (no auth required)
-api.get('/health', (c) => {
-  return c.json({ status: 'ok', timestamp: new Date().toISOString() });
-});
-
-// Postgate connection test (no auth required)
-api.get('/postgate', async (c) => {
-  try {
-    const result = await sql<{ result: number }>('SELECT 1 + 1 AS result');
-    return c.json({ status: 'ok', result: result[0]?.result });
-  } catch (error) {
-    return c.json({ status: 'error', error: String(error) }, 500);
-  }
-});
-
-// Cron WASM test (no auth required)
-api.get('/cron-test', (c) => {
-  const pattern = c.req.query('pattern') || '*/5 * * * *';
-  try {
-    const cron = new WasmCron(pattern);
-    return c.json({
-      status: 'ok',
-      wasm: true,
-      pattern: cron.pattern(),
-      description: cron.describe(),
-      nextRun: cron.nextRun()?.toISOString() ?? null,
-      nextRuns: cron.nextRuns(5).map((d: Date) => d.toISOString())
-    });
-  } catch (error) {
-    return c.json({ status: 'error', wasm: true, error: String(error) }, 400);
-  }
-});
+// Health endpoints (no auth required)
+api.route('/health', health);
 
 // API v1 routes
 const v1 = new Hono();

src/routes/health.ts

@@ -0,0 +1,65 @@
+import { Hono } from 'hono';
+
+import { sql } from '../services/db/client';
+import { WasmCron } from '@openworkers/croner-wasm';
+
+const health = new Hono();
+
+// Liveness check
+health.get('/', (c) => {
+  return c.json({ status: 'ok', timestamp: new Date().toISOString() });
+});
+
+// Database connection test
+health.get('/database', async (c) => {
+  try {
+    const result = await sql<{ result: number }>('SELECT 1 + 1 AS result');
+    return c.json({ status: 'ok', result: result[0]?.result });
+  } catch (error) {
+    return c.json({ status: 'error', error: String(error) }, 500);
+  }
+});
+
+// Cron WASM test
+health.get('/cron', (c) => {
+  const pattern = c.req.query('pattern') || '*/5 * * * *';
+
+  try {
+    const cron = new WasmCron(pattern);
+    return c.json({
+      status: 'ok',
+      wasm: true,
+      pattern: cron.pattern(),
+      description: cron.describe(),
+      nextRun: cron.nextRun()?.toISOString() ?? null,
+      nextRuns: cron.nextRuns(5).map((d: Date) => d.toISOString())
+    });
+  } catch (error) {
+    return c.json({ status: 'error', wasm: true, error: String(error) }, 400);
+  }
+});
+
+// --- Latency endpoints (used by CLI test-latency) ---
+
+// API latency: measures request round-trip through all layers above
+health.get('/latency/api', (c) => {
+  return c.json({ status: 'ok', timestamp: new Date().toISOString() });
+});
+
+// Database latency: measures API + DB round-trip
+health.get('/latency/database', async (c) => {
+  try {
+    const result = await sql<{ now: string }>('SELECT NOW() AS now');
+    return c.json({ status: 'ok', timestamp: result[0]?.now });
+  } catch (error) {
+    return c.json({ status: 'error', error: String(error) }, 500);
+  }
+});
+
+// Proxy latency: should be intercepted by Nginx before reaching API
+// If the CLI receives 418, it means Nginx is not intercepting this path
+health.get('/latency/proxy', (c) => {
+  return c.json({ status: 'not_intercepted', layer: 'proxy' }, 418);
+});
+
+export default health;