feat: add GET /healthz endpoint to cluster HTTP server

src/cluster/cluster-http-server.test.ts

@@ -0,0 +1,79 @@
+// Licensed under the Hungry Ghost Hive License. See LICENSE.
+
+import { createServer } from 'net';
+import { afterEach, beforeEach, describe, expect, it, vi } from 'vitest';
+import type { ClusterConfig } from '../config/schema.js';
+import { ClusterHttpServer, type ClusterHttpHandlers } from './cluster-http-server.js';
+
+async function getFreePort(): Promise<number> {
+  return new Promise((resolve, reject) => {
+    const srv = createServer();
+    srv.listen(0, '127.0.0.1', () => {
+      const addr = srv.address();
+      srv.close(() => {
+        if (addr && typeof addr === 'object') resolve(addr.port);
+        else reject(new Error('Could not get free port'));
+      });
+    });
+  });
+}
+
+function makeHandlers(): ClusterHttpHandlers {
+  return {
+    getStatus: vi.fn().mockReturnValue({ role: 'leader' }),
+    handleVoteRequest: vi.fn().mockReturnValue({}),
+    handleHeartbeat: vi.fn().mockReturnValue({}),
+    getDeltaFromCache: vi.fn().mockReturnValue([]),
+    getVersionVectorCache: vi.fn().mockReturnValue({}),
+    getReplicationLag: vi.fn().mockReturnValue({}),
+    getFencingToken: vi.fn().mockReturnValue(1),
+    validateFencingToken: vi.fn().mockReturnValue(true),
+    isLeaderLeaseValid: vi.fn().mockReturnValue(true),
+    handleMembershipJoin: vi.fn().mockReturnValue({ success: true, leader_id: null, leader_url: null, peers: [], term: 1 }),
+    handleMembershipLeave: vi.fn().mockReturnValue({ success: true, peers: [] }),
+    getSnapshot: vi.fn().mockReturnValue({}),
+  };
+}
+
+describe('ClusterHttpServer /healthz', () => {
+  let server: ClusterHttpServer;
+  let port: number;
+
+  beforeEach(async () => {
+    port = await getFreePort();
+    const config: ClusterConfig = {
+      enabled: true,
+      node_id: 'test-node',
+      listen_host: '127.0.0.1',
+      listen_port: port,
+      public_url: `http://127.0.0.1:${port}`,
+      peers: [],
+      heartbeat_interval_ms: 100,
+      election_timeout_min_ms: 150,
+      election_timeout_max_ms: 250,
+      sync_interval_ms: 200,
+      request_timeout_ms: 500,
+      story_similarity_threshold: 0.92,
+      auth_token: 'secret',
+    };
+    server = new ClusterHttpServer(config, makeHandlers());
+    await server.startServer();
+  });
+
+  afterEach(async () => {
+    await server.stopServer();
+  });
+
+  it('returns 200 with status ok and timestamp without auth', async () => {
+    const before = Date.now();
+    const res = await fetch(`http://127.0.0.1:${port}/healthz`);
+    const after = Date.now();
+
+    expect(res.status).toBe(200);
+    const body = (await res.json()) as { status: string; timestamp: number };
+    expect(body.status).toBe('ok');
+    expect(typeof body.timestamp).toBe('number');
+    expect(body.timestamp).toBeGreaterThanOrEqual(before);
+    expect(body.timestamp).toBeLessThanOrEqual(after);
+  });
+});

src/cluster/cluster-http-server.ts

@@ -91,14 +91,19 @@ export class ClusterHttpServer {
 
   private async handleHttpRequest(req: IncomingMessage, res: ServerResponse): Promise<void> {
     try {
+      const method = req.method || 'GET';
+      const path = req.url?.split('?')[0] || '/';
+
+      if (method === 'GET' && path === '/healthz') {
+        sendJson(res, 200, { status: 'ok', timestamp: Date.now() });
+        return;
+      }
+
       if (!this.authorize(req)) {
         sendJson(res, 401, { error: 'Unauthorized' });
         return;
       }
 
-      const method = req.method || 'GET';
-      const path = req.url?.split('?')[0] || '/';
-
       if (method === 'GET' && path === '/cluster/v1/status') {
         sendJson(res, 200, this.handlers.getStatus());
         return;