aboutsummaryrefslogtreecommitdiff
path: root/internal
diff options
context:
space:
mode:
Diffstat (limited to '')
-rw-r--r--internal/feed/cache.go2
-rw-r--r--internal/feed/cache_v1.go4
-rw-r--r--internal/feed/parse.go6
3 files changed, 8 insertions, 4 deletions
diff --git a/internal/feed/cache.go b/internal/feed/cache.go
index 0b2f905..f1dfb77 100644
--- a/internal/feed/cache.go
+++ b/internal/feed/cache.go
@@ -25,7 +25,7 @@ type Cache interface {
type CachedFeed interface {
Checked(withFailure bool)
- Failures() uint
+ Failures() int
Last() time.Time
filterItems(items []feeditem, ignoreHash bool, alwaysNew bool) []feeditem
Commit()
diff --git a/internal/feed/cache_v1.go b/internal/feed/cache_v1.go
index 37a4773..5f8c8f4 100644
--- a/internal/feed/cache_v1.go
+++ b/internal/feed/cache_v1.go
@@ -25,7 +25,7 @@ type v1Cache struct {
type cachedFeed struct {
LastCheck time.Time
currentCheck time.Time
- NumFailures uint // can't be named `Failures` b/c it'll collide with the interface
+ NumFailures int // can't be named `Failures` b/c it'll collide with the interface
Items []cachedItem
newItems []cachedItem
}
@@ -67,7 +67,7 @@ func (cf *cachedFeed) Commit() {
cf.LastCheck = cf.currentCheck
}
-func (cf *cachedFeed) Failures() uint {
+func (cf *cachedFeed) Failures() int {
return cf.NumFailures
}
diff --git a/internal/feed/parse.go b/internal/feed/parse.go
index fe3374a..1ce6cda 100644
--- a/internal/feed/parse.go
+++ b/internal/feed/parse.go
@@ -65,6 +65,10 @@ func handleFeed(feed *Feed) {
err := parseFeed(feed)
if err != nil {
- log.Error(err)
+ if feed.cached.Failures() >= feed.Global.MaxFailures {
+ log.Error(err)
+ } else {
+ log.Print(err)
+ }
}
}