eliott/worldmonitor
1
0
Fork 0
mirror of https://github.com/koala73/worldmonitor.git synced 2026-04-25 17:14:57 +02:00
Code Issues Packages Projects Releases Wiki Activity

fix(usage): add 'live' cache tier + revert preview debug logs

Browse Source 
- Sync UsageCacheTier with the local CacheTier in gateway.ts (main added
  'live' in PR #3402 — synthetic merge with main was failing typecheck:api).
- Revert temporary unconditional debug logs in sendToAxiom now that Axiom
  delivery is verified end-to-end on preview (event landed with all fields
  populated, including the new auth_401 reason from the koala #3403 fix).

Co-Authored-By: Claude Opus 4.7 (1M context) <noreply@anthropic.com>
This commit is contained in:
Sebastien Melki
2026-04-25 17:30:38 +03:00
parent e99ef1dacb
commit d68c089f73
1 changed files with 17 additions and 23 deletions
Download Patch File Download Diff File Expand all files Collapse all files

40
server/_shared/usage.ts
View File

@@ -23,6 +23,7 @@ const TELEMETRY_TIMEOUT_MS = 1_500;
const CB_WINDOW_MS = 5 * 60 * 1_000;
const CB_TRIP_FAILURE_RATIO = 0.05;
const CB_MIN_SAMPLES = 20;
const SAMPLED_DROP_LOG_RATE = 0.01;
function isUsageEnabled(): boolean {
return process.env.USAGE_TELEMETRY === '1';
@@ -41,7 +42,8 @@ export type CacheTier =
| 'slow-browser'
| 'static'
| 'daily'
| 'no-store';
| 'no-store'
| 'live';
export type CacheStatus = 'miss' | 'fresh' | 'stale-while-revalidate' | 'neg-sentinel';
@@ -353,35 +355,25 @@ export function getUsageScope(): UsageScope | undefined {
// ---------- Sink ----------
export async function sendToAxiom(events: UsageEvent[]): Promise<void> {
// TEMP DEBUG: unconditional entry log to verify codepath in preview.
// Remove before merging to main.
console.log('[usage-telemetry][debug] sendToAxiom enter', {
enabled: isUsageEnabled(),
eventCount: events.length,
tokenPresent: Boolean(process.env.AXIOM_API_TOKEN),
tokenLen: (process.env.AXIOM_API_TOKEN ?? '').length,
breakerTripped,
url: AXIOM_INGEST_URL,
});
if (!isUsageEnabled()) {
console.log('[usage-telemetry][debug] drop: not enabled');
return;
}
if (!isUsageEnabled()) return;
if (events.length === 0) return;
const token = process.env.AXIOM_API_TOKEN;
if (!token) {
console.warn('[usage-telemetry][debug] drop: no-token');
if (Math.random() < SAMPLED_DROP_LOG_RATE) {
console.warn('[usage-telemetry] drop', { reason: 'no-token' });
}
return;
}
if (breakerTripped) {
console.warn('[usage-telemetry][debug] drop: breaker-open');
if (Math.random() < SAMPLED_DROP_LOG_RATE) {
console.warn('[usage-telemetry] drop', { reason: 'breaker-open' });
}
return;
}
const controller = new AbortController();
const timer = setTimeout(() => controller.abort(), TELEMETRY_TIMEOUT_MS);
try {
console.log('[usage-telemetry][debug] POSTing', { eventCount: events.length, firstEventType: events[0]?.event_type });
const resp = await fetch(AXIOM_INGEST_URL, {
method: 'POST',
headers: {
@@ -391,18 +383,20 @@ export async function sendToAxiom(events: UsageEvent[]): Promise<void> {
body: JSON.stringify(events),
signal: controller.signal,
});
console.log('[usage-telemetry][debug] response', { status: resp.status, ok: resp.ok });
if (!resp.ok) {
const bodyText = await resp.text().catch(() => '<unreadable>');
console.warn('[usage-telemetry][debug] axiom rejected', { status: resp.status, body: bodyText.slice(0, 500) });
recordSample(false);
if (Math.random() < SAMPLED_DROP_LOG_RATE) {
console.warn('[usage-telemetry] drop', { reason: `http-${resp.status}` });
}
return;
}
recordSample(true);
} catch (err) {
recordSample(false);
const reason = err instanceof Error && err.name === 'AbortError' ? 'timeout' : 'fetch-error';
console.warn('[usage-telemetry][debug] fetch failed', { reason, message: err instanceof Error ? err.message : String(err) });
if (Math.random() < SAMPLED_DROP_LOG_RATE) {
const reason = err instanceof Error && err.name === 'AbortError' ? 'timeout' : 'fetch-error';
console.warn('[usage-telemetry] drop', { reason });
}
} finally {
clearTimeout(timer);
}