prehistoric-systems/omnivore
1
0
Fork 0
mirror of https://github.com/omnivore-app/omnivore.git synced 2026-03-11 08:54:26 +00:00
Code Issues Projects Releases Packages Wiki Activity Actions

update logs

Browse source
This commit is contained in:
Hongbo Wu 2024-01-24 13:30:57 +08:00
parent 9d378d3f46
commit 86c4bbabee
1 changed files with 13 additions and 4 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

17
packages/api/src/jobs/rss/refreshFeed.ts
View file

@ -637,10 +637,12 @@ export const _refreshFeed = async (request: RefreshFeedRequest) => {
const fetchContentTasks = new Map<string, FetchContentTask>() // 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, {