fix(feeds): process RSS on initial run (#918)

internal/feed/rss.go

@@ -227,12 +227,6 @@ func (j *RSSJob) getFeed(ctx context.Context) (items []*gofeed.Item, err error)
 
 	//sort.Sort(feed)
 
-	bucketCount, err := j.CacheRepo.GetCountByBucket(ctx, bucketKey)
-	if err != nil {
-		j.Log.Error().Err(err).Msg("could not check if item exists")
-		return nil, err
-	}
-
 	// set ttl to 1 month
 	ttl := time.Now().AddDate(0, 1, 0)
 
@@ -264,12 +258,9 @@ func (j *RSSJob) getFeed(ctx context.Context) (items []*gofeed.Item, err error)
 			continue
 		}
 
-		// first time we fetch the feed the cached bucket count will be 0
+		// only append if we successfully added to cache
-		// only append to items if it's bigger than 0, so we get new items only
-		if bucketCount > 0 {
 		items = append(items, item)
 	}
-	}
 
 	// send to filters
 	return