Creepso/pstream-backend
1
0
Fork 0
mirror of https://github.com/p-stream/backend.git synced 2026-01-11 20:10:33 +00:00
Code Issues Projects Releases Packages Wiki Activity Actions

update metric to fix maybe?

Browse source
This commit is contained in:
Pas 2025-08-20 13:49:19 -06:00
parent fa64d49f25
commit 3d17e32338
2 changed files with 41 additions and 4 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

19
server/plugins/metrics.ts Normal file
View file

@ -0,0 +1,19 @@
import { defineNitroPlugin } from '#imports';
import { initializeAllMetrics } from '../utils/metrics';
import { scopedLogger } from '../utils/logger';
const log = scopedLogger('metrics-plugin');
export default defineNitroPlugin(async () => {
try {
log.info('Initializing metrics at startup...');
await initializeAllMetrics();
log.info('Metrics initialized.');
} catch (error) {
log.error('Failed to initialize metrics at startup', {
error: error instanceof Error ? error.message : String(error),
});
}
});

26
server/utils/metrics.ts
View file

@ -280,9 +280,17 @@ export async function setupMetrics(interval: 'default' | 'daily' | 'weekly' | 'm
});
}
// Initialize metrics with current data
// Initialize metrics with current data (best-effort; don't fail if DB is unavailable)
log.info(`Syncing up ${interval} metrics...`, { evt: 'sync', interval });
await updateMetrics(interval);
try {
await updateMetrics(interval);
} catch (err) {
log.warn(`Skipping ${interval} DB-backed metric sync due to error`, {
evt: 'sync_skipped',
interval,
error: err instanceof Error ? err.message : String(err),
});
}
log.info(`${interval} metrics initialized!`, { evt: 'end', interval });
// Save initial state
@ -293,7 +301,8 @@ export async function setupMetrics(interval: 'default' | 'daily' | 'weekly' | 'm
interval,
error: error instanceof Error ? error.message : String(error),
});
throw error;
// Do not rethrow so callers can keep running (e.g., allow HTTP metrics recording without DB)
return;
}
}
@ -407,6 +416,15 @@ export function recordCaptchaMetrics(success: boolean) {
// Initialize all metrics registries on startup
export async function initializeAllMetrics() {
for (const interval of Object.keys(registries) as Array<'default' | 'daily' | 'weekly' | 'monthly'>) {
await setupMetrics(interval);
try {
await setupMetrics(interval);
} catch (error) {
log.error(`initializeAllMetrics: failed to setup ${interval}`, {
evt: 'init_interval_error',
interval,
error: error instanceof Error ? error.message : String(error),
});
// Continue initializing other intervals
}
}
}