5bf815b304
Adds the minimum ops surface area for a production broker without
over-engineering. All new config knobs are env-var driven with sane
defaults.
New modules:
- logger.ts: structured JSON logs (one line, stderr, ready for
Loki/Datadog ingestion without preprocessing)
- metrics.ts: in-process Prometheus counters + gauges, exposed at
GET /metrics. Tracks connections, messages, queue depth, TTL
sweeps, hook requests, DB health.
- rate-limit.ts: token-bucket rate limiter keyed by (pid, cwd).
Applied to POST /hook/set-status at 30/min default.
- db-health.ts: Postgres ping loop with exponential-backoff retry.
GET /health returns 503 while DB is down.
- build-info.ts: version + gitSha (from GIT_SHA env or `git rev-parse`
fallback) + uptime, surfaced on /health.
Behavior changes:
- Connection caps: MAX_CONNECTIONS_PER_MESH (default 100). Exceed →
close(1008, "capacity") + metric increment.
- Message size: MAX_MESSAGE_BYTES (default 65536). WS applies it via
`ws.maxPayload`. Hook POST bodies cap out with 413.
- Structured logs everywhere replacing the old `log()` helper.
- Env validation stricter: DATABASE_URL required + regex-checked for
postgres:// prefix.
New endpoints:
- GET /health → {status, db, version, gitSha, uptime}. 503 if DB down.
- GET /metrics → Prometheus text format.
Verified: 21/21 tests still pass. Hit /health + /metrics live —
gitSha resolves correctly via `git rev-parse --short HEAD` in dev.
Co-Authored-By: Claude Opus 4.6 (1M context) <noreply@anthropic.com>
46 lines
1002 B
TypeScript
46 lines
1002 B
TypeScript
/**
|
|
* Build info surfaced on /health.
|
|
*
|
|
* gitSha is resolved lazily:
|
|
* 1. GIT_SHA env var (preferred — baked in at image build time)
|
|
* 2. `git rev-parse --short HEAD` (dev)
|
|
* 3. "unknown" if neither works
|
|
*/
|
|
|
|
const VERSION = "0.1.0";
|
|
const startedAt = Date.now();
|
|
|
|
let cachedSha: string | null = null;
|
|
|
|
function resolveGitSha(): string {
|
|
if (cachedSha !== null) return cachedSha;
|
|
if (process.env.GIT_SHA) {
|
|
cachedSha = process.env.GIT_SHA;
|
|
return cachedSha;
|
|
}
|
|
try {
|
|
const proc = Bun.spawnSync(["git", "rev-parse", "--short", "HEAD"], {
|
|
stderr: "ignore",
|
|
});
|
|
const sha = new TextDecoder().decode(proc.stdout).trim();
|
|
cachedSha = sha || "unknown";
|
|
} catch {
|
|
cachedSha = "unknown";
|
|
}
|
|
return cachedSha;
|
|
}
|
|
|
|
export function buildInfo(): {
|
|
version: string;
|
|
gitSha: string;
|
|
uptime: number;
|
|
} {
|
|
return {
|
|
version: VERSION,
|
|
gitSha: resolveGitSha(),
|
|
uptime: Math.floor((Date.now() - startedAt) / 1000),
|
|
};
|
|
}
|
|
|
|
export { VERSION };
|