Creepso/webstreamr-github
1
0
Fork 0
Code Issues 27 Pull requests 7 Projects Releases 240 Packages Wiki Activity Actions

chore: introduce dedicated startup/ready and live endpoints

Browse source
This commit is contained in:
WebStreamr 2025-08-06 09:09:19 +00:00
parent ff538303c6
commit db21d78aff
No known key found for this signature in database
1 changed files with 15 additions and 5 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

20
src/index.ts
View file

@ -65,8 +65,16 @@ addon.get('/', (_req: Request, res: Response) => {
res.redirect('/configure');
});
let lastHealthCheckRequestsTimestamp = 0;
addon.get('/health', async (req: Request, res: Response) => {
addon.get('/startup', async (_req: Request, res: Response) => {
res.json({ status: 'ok' });
});
addon.get('/ready', async (_req: Request, res: Response) => {
res.json({ status: 'ok' });
});
let lastLiveProbeRequestsTimestamp = 0;
const liveHandler = async (req: Request, res: Response) => {
const ctx = contextFromRequestAndResponse(req, res);
const sources: Source[] = [
@ -94,9 +102,9 @@ addon.get('/health', async (req: Request, res: Response) => {
}
});
if (Date.now() - lastHealthCheckRequestsTimestamp > 60000) { // every minute
if (Date.now() - lastLiveProbeRequestsTimestamp > 60000) { // every minute
await Promise.all(fetchFactories.map(fn => fn()));
lastHealthCheckRequestsTimestamp = Date.now();
lastLiveProbeRequestsTimestamp = Date.now();
}
if (blockedCount > 0) {
@ -109,7 +117,9 @@ addon.get('/health', async (req: Request, res: Response) => {
} else {
res.json({ status: 'ok' });
}
});
};
addon.get('/live', liveHandler);
addon.get('/health', liveHandler); // for BC
const port = parseInt(envGet('PORT') || '51546');
addon.listen(port, () => {