From 86c4bbabee5ac64ed1e35b88672c7cbc6f09b84b Mon Sep 17 00:00:00 2001 From: Hongbo Wu Date: Wed, 24 Jan 2024 13:30:57 +0800 Subject: [PATCH] update logs --- packages/api/src/jobs/rss/refreshFeed.ts | 17 +++++++++++++---- 1 file changed, 13 insertions(+), 4 deletions(-) diff --git a/packages/api/src/jobs/rss/refreshFeed.ts b/packages/api/src/jobs/rss/refreshFeed.ts index 7da104ad5..2f50d324e 100644 --- a/packages/api/src/jobs/rss/refreshFeed.ts +++ b/packages/api/src/jobs/rss/refreshFeed.ts @@ -637,10 +637,12 @@ export const _refreshFeed = async (request: RefreshFeedRequest) => { const fetchContentTasks = new Map() // url -> FetchContentTask // process each subscription sequentially for (let i = 0; i < subscriptionIds.length; i++) { + const subscriptionId = subscriptionIds[i] + try { await processSubscription( fetchContentTasks, - subscriptionIds[i], + subscriptionId, userIds[i], feedUrl, fetchResult, @@ -652,7 +654,10 @@ export const _refreshFeed = async (request: RefreshFeedRequest) => { feed ) } catch (error) { - console.error('Error while processing subscription', error) + console.error('Error while processing subscription', { + error, + subscriptionId, + }) } } @@ -666,8 +671,12 @@ export const _refreshFeed = async (request: RefreshFeedRequest) => { } return true - } catch (e) { - console.error('Error while saving RSS feeds', e) + } catch (error) { + console.error('Error while saving RSS feeds', { + feedUrl, + subscriptionIds, + error, + }) // mark subscriptions as error if we failed to get the feed await updateSubscriptions(subscriptionIds, {