diff options
Diffstat (limited to 'internal/reader/processor/processor.go')
| -rw-r--r-- | internal/reader/processor/processor.go | 27 |
1 files changed, 0 insertions, 27 deletions
diff --git a/internal/reader/processor/processor.go b/internal/reader/processor/processor.go index 4dec59f0..d56d4289 100644 --- a/internal/reader/processor/processor.go +++ b/internal/reader/processor/processor.go @@ -13,8 +13,6 @@ import ( "time" "unicode/utf8" - "miniflux.app/v2/internal/integration" - "miniflux.app/v2/internal/config" "miniflux.app/v2/internal/http/client" "miniflux.app/v2/internal/logger" @@ -41,9 +39,6 @@ var ( func ProcessFeedEntries(store *storage.Storage, feed *model.Feed, user *model.User, forceRefresh bool) { var filteredEntries model.Entries - // array used for bulk push - entriesToPush := model.Entries{} - // Process older entries first for i := len(feed.Entries) - 1; i >= 0; i-- { entry := feed.Entries[i] @@ -90,32 +85,10 @@ func ProcessFeedEntries(store *storage.Storage, feed *model.Feed, user *model.Us // The sanitizer should always run at the end of the process to make sure unsafe HTML is filtered. entry.Content = sanitizer.Sanitize(url, entry.Content) - if entryIsNew { - intg, err := store.Integration(feed.UserID) - if err != nil { - logger.Error("[Processor] Get integrations for user %d failed: %v; the refresh process will go on, but no integrations will run this time.", feed.UserID, err) - } else if intg != nil { - localEntry := entry - go func() { - integration.PushEntry(localEntry, feed, intg) - }() - entriesToPush = append(entriesToPush, localEntry) - } - } - updateEntryReadingTime(store, feed, entry, entryIsNew, user) filteredEntries = append(filteredEntries, entry) } - intg, err := store.Integration(feed.UserID) - if err != nil { - logger.Error("[Processor] Get integrations for user %d failed: %v; the refresh process will go on, but no integrations will run this time.", feed.UserID, err) - } else if intg != nil && len(entriesToPush) > 0 { - go func() { - integration.PushEntries(entriesToPush, intg) - }() - } - feed.Entries = filteredEntries } |