[claude] Connect API to real Lightning node (#12) (#64)

Co-authored-by: Claude (Opus 4.6) <claude@hermes.local>
Co-committed-by: Claude (Opus 4.6) <claude@hermes.local>
This commit was merged in pull request #64.
This commit is contained in:
2026-03-23 20:54:48 +00:00
committed by rockachopa
parent 677c79bd14
commit 5b935a83e3
3 changed files with 85 additions and 2 deletions

View File

@@ -6,6 +6,7 @@ import { timmyIdentityService } from "./lib/timmy-identity.js";
import { startEngagementEngine } from "./lib/engagement.js";
import { relayAccountService } from "./lib/relay-accounts.js";
import { moderationService } from "./lib/moderation.js";
import { lnbitsService } from "./lib/lnbits.js";
const rawPort = process.env["PORT"];
@@ -25,6 +26,16 @@ attachWebSocketServer(server);
server.listen(port, () => {
rootLogger.info("server started", { port });
rootLogger.info("timmy identity", { npub: timmyIdentityService.npub });
// Warn loudly in production if Lightning is not connected.
if (lnbitsService.stubMode && process.env["NODE_ENV"] === "production") {
rootLogger.warn(
"LNBITS_URL / LNBITS_API_KEY not set — running in STUB mode. " +
"Invoices are simulated in-memory. Set these env vars to connect to a real Lightning node. " +
"See infrastructure/lnd-init.sh for setup instructions.",
{ lnbits_stub: true },
);
}
const domain = process.env["REPLIT_DEV_DOMAIN"];
if (domain) {
rootLogger.info("public url", { url: `https://${domain}/api/ui` });

View File

@@ -2,6 +2,7 @@ import { Router, type IRouter, type Request, type Response } from "express";
import { db, jobs } from "@workspace/db";
import { sql } from "drizzle-orm";
import { makeLogger } from "../lib/logger.js";
import { lnbitsService } from "../lib/lnbits.js";
const router: IRouter = Router();
const logger = makeLogger("health");
@@ -13,12 +14,24 @@ router.get("/healthz", async (_req: Request, res: Response) => {
const rows = await db.select({ total: sql<number>`cast(count(*) as int)` }).from(jobs);
const jobsTotal = Number(rows[0]?.total ?? 0);
const uptimeS = Math.floor((Date.now() - START_TIME) / 1000);
res.json({ status: "ok", uptime_s: uptimeS, jobs_total: jobsTotal });
res.json({
status: "ok",
uptime_s: uptimeS,
jobs_total: jobsTotal,
lnbits_stub: lnbitsService.stubMode,
lnbits_url: lnbitsService.stubMode ? null : process.env["LNBITS_URL"] ?? null,
});
} catch (err) {
const message = err instanceof Error ? err.message : "Health check failed";
logger.error("healthz db query failed", { error: message });
const uptimeS = Math.floor((Date.now() - START_TIME) / 1000);
res.status(503).json({ status: "error", uptime_s: uptimeS, error: message });
res.status(503).json({
status: "error",
uptime_s: uptimeS,
error: message,
lnbits_stub: lnbitsService.stubMode,
lnbits_url: lnbitsService.stubMode ? null : process.env["LNBITS_URL"] ?? null,
});
}
});