From 14a4f2b8d49da27f3b1845845d069a8eb7702f07 Mon Sep 17 00:00:00 2001
From: glidea <740696441@qq.com>
Date: Sat, 3 May 2025 14:51:27 +0800
Subject: [PATCH] fix rewrite error handing

---
 pkg/storage/feed/feed.go | 10 ++++++----
 1 file changed, 6 insertions(+), 4 deletions(-)

diff --git a/pkg/storage/feed/feed.go b/pkg/storage/feed/feed.go
index 2fa3877..2560ec5 100644
--- a/pkg/storage/feed/feed.go
+++ b/pkg/storage/feed/feed.go
@@ -613,10 +613,12 @@ func (s *storage) rewrite(ctx context.Context, feeds []*model.Feed) ([]*model.Fe
 		}(item)
 	}
 	wg.Wait()
-	if allFailed := len(errs) == len(feeds)-int(dropped.Load()); allFailed {
-		return nil, errs[0]
-	}
-	if len(errs) > 0 {
+
+	switch len(errs) {
+	case 0:
+	case len(feeds) - int(dropped.Load()):
+		return nil, errs[0] // All failed.
+	default:
 		log.Error(ctx, errors.Wrap(errs[0], "rewrite feeds"), "error_count", len(errs))
 	}