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(analyze-stock): catch cachedFetchJson timeout to prevent 500

Browse Source 
cachedFetchJson re-throws fetcher errors after logging. A timeout in
the Yahoo history, news search, or LLM call propagated up as an
unhandled error causing random 500s. Wrap in try-catch so any fetcher
failure falls through to buildEmptyAnalysisResponse (200 with empty data).
This commit is contained in:
Elie Habib
2026-03-27 15:14:55 +04:00
parent b57fdd7e33
commit 2647afc0f1
1 changed files with 26 additions and 21 deletions
Download Patch File Download Diff File Expand all files Collapse all files

47
server/worldmonitor/market/v1/analyze-stock.ts
View File

@@ -831,29 +831,34 @@ export async function analyzeStock(
const nameSuffix = name !== symbol ? `:${name.replace(/[^a-zA-Z0-9]/g, '').slice(0, 30).toLowerCase()}` : '';
const cacheKey = `market:analyze-stock:v1:${symbol}:${includeNews ? 'news' : 'no-news'}${nameSuffix}`;
const cached = await cachedFetchJson<AnalyzeStockResponse>(cacheKey, CACHE_TTL_SECONDS, async () => {
const history = await fetchYahooHistory(symbol);
if (!history) return null;
let cached: AnalyzeStockResponse | null = null;
try {
cached = await cachedFetchJson<AnalyzeStockResponse>(cacheKey, CACHE_TTL_SECONDS, async () => {
const history = await fetchYahooHistory(symbol);
if (!history) return null;
const technical = buildTechnicalSnapshot(history.candles);
technical.currency = history.currency || 'USD';
const headlines = includeNews ? (await searchRecentStockHeadlines(symbol, name, NEWS_LIMIT)).headlines : [];
const overlay = await buildAiOverlay(symbol, name, technical, headlines);
const analysisAt = history.candles[history.candles.length - 1]?.timestamp || Date.now();
const response = buildAnalysisResponse({
symbol,
name,
currency: history.currency || 'USD',
technical,
headlines,
overlay,
includeNews,
analysisAt,
generatedAt: new Date().toISOString(),
const technical = buildTechnicalSnapshot(history.candles);
technical.currency = history.currency || 'USD';
const headlines = includeNews ? (await searchRecentStockHeadlines(symbol, name, NEWS_LIMIT)).headlines : [];
const overlay = await buildAiOverlay(symbol, name, technical, headlines);
const analysisAt = history.candles[history.candles.length - 1]?.timestamp || Date.now();
const response = buildAnalysisResponse({
symbol,
name,
currency: history.currency || 'USD',
technical,
headlines,
overlay,
includeNews,
analysisAt,
generatedAt: new Date().toISOString(),
});
await storeStockAnalysisSnapshot(response, includeNews);
return response;
});
await storeStockAnalysisSnapshot(response, includeNews);
return response;
});
} catch {
// fetcher timed out or threw — fall through to empty response
}
if (cached) return cached;