worker: fix updated time

dhcmrlchtdj · Nov 3, 2024 · ec8f6be · ec8f6be
1 parent 1477599
commit ec8f6be
Showing 1 changed file with 4 additions and 1 deletion.
diff --git a/worker/worker.go b/worker/worker.go
@@ -117,12 +117,15 @@ func parseFeed(ctx context.Context, done *sync.WaitGroup, qFeedFetched <-chan *f
 
 	qFeedParsed := make(chan *feedItem)
 
+	now := time.Now()
 	worker := func(feed *feedItem) {
 		updated := getLatestUpdated(feed.fetched)
 		if updated == nil {
 			err := errors.WithMessage(errors.New("can't parse date field"), feed.feed.URL)
 			logger.Warn().Str("module", "worker").Stack().Err(err).Send()
-			now := time.Now()
+			updated = &now
+		}
+		if updated.Compare(now) > 0 {
 			updated = &now
 		}