Creepso/pstream-backend
1
0
Fork 0
mirror of https://github.com/p-stream/backend.git synced 2026-03-11 17:55:35 +00:00
Code Issues Projects Releases Packages Wiki Activity Actions

re init metrics after clearing

Browse source
This commit is contained in:
Pas 2025-12-14 21:12:54 -07:00
parent 9e79b3fd15
commit 9120767784
3 changed files with 42 additions and 6 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

16
server/routes/metrics/daily.ts
View file

@ -1,13 +1,25 @@
import { getRegistry } from '../../utils/metrics'; import { getRegistry, initializeAllMetrics } from '../../utils/metrics';
import { scopedLogger } from '../../utils/logger'; import { scopedLogger } from '../../utils/logger';
const log = scopedLogger('metrics-daily-endpoint'); const log = scopedLogger('metrics-daily-endpoint');
let isInitialized = false;
async function ensureMetricsInitialized() {
if (!isInitialized) {
log.info('Initializing metrics from daily endpoint...', { evt: 'init_start' });
await initializeAllMetrics();
isInitialized = true;
log.info('Metrics initialized from daily endpoint', { evt: 'init_complete' });
}
}
export default defineEventHandler(async event => { export default defineEventHandler(async event => {
try { try {
await ensureMetricsInitialized();
// Get the daily registry // Get the daily registry
const dailyRegistry = getRegistry('daily'); const dailyRegistry = getRegistry('daily');
const metrics = await dailyRegistry.metrics(); const metrics = await dailyRegistry.metrics();
event.node.res.setHeader('Content-Type', dailyRegistry.contentType); event.node.res.setHeader('Content-Type', dailyRegistry.contentType);
return metrics; return metrics;

16
server/routes/metrics/monthly.ts
View file

@ -1,13 +1,25 @@
import { getRegistry } from '../../utils/metrics'; import { getRegistry, initializeAllMetrics } from '../../utils/metrics';
import { scopedLogger } from '../../utils/logger'; import { scopedLogger } from '../../utils/logger';
const log = scopedLogger('metrics-monthly-endpoint'); const log = scopedLogger('metrics-monthly-endpoint');
let isInitialized = false;
async function ensureMetricsInitialized() {
if (!isInitialized) {
log.info('Initializing metrics from monthly endpoint...', { evt: 'init_start' });
await initializeAllMetrics();
isInitialized = true;
log.info('Metrics initialized from monthly endpoint', { evt: 'init_complete' });
}
}
export default defineEventHandler(async event => { export default defineEventHandler(async event => {
try { try {
await ensureMetricsInitialized();
// Get the monthly registry // Get the monthly registry
const monthlyRegistry = getRegistry('monthly'); const monthlyRegistry = getRegistry('monthly');
const metrics = await monthlyRegistry.metrics(); const metrics = await monthlyRegistry.metrics();
event.node.res.setHeader('Content-Type', monthlyRegistry.contentType); event.node.res.setHeader('Content-Type', monthlyRegistry.contentType);
return metrics; return metrics;

16
server/routes/metrics/weekly.ts
View file

@ -1,13 +1,25 @@
import { getRegistry } from '../../utils/metrics'; import { getRegistry, initializeAllMetrics } from '../../utils/metrics';
import { scopedLogger } from '../../utils/logger'; import { scopedLogger } from '../../utils/logger';
const log = scopedLogger('metrics-weekly-endpoint'); const log = scopedLogger('metrics-weekly-endpoint');
let isInitialized = false;
async function ensureMetricsInitialized() {
if (!isInitialized) {
log.info('Initializing metrics from weekly endpoint...', { evt: 'init_start' });
await initializeAllMetrics();
isInitialized = true;
log.info('Metrics initialized from weekly endpoint', { evt: 'init_complete' });
}
}
export default defineEventHandler(async event => { export default defineEventHandler(async event => {
try { try {
await ensureMetricsInitialized();
// Get the weekly registry // Get the weekly registry
const weeklyRegistry = getRegistry('weekly'); const weeklyRegistry = getRegistry('weekly');
const metrics = await weeklyRegistry.metrics(); const metrics = await weeklyRegistry.metrics();
event.node.res.setHeader('Content-Type', weeklyRegistry.contentType); event.node.res.setHeader('Content-Type', weeklyRegistry.contentType);
return metrics; return metrics;