Moved out thread deduplication

2 files changed, 2 insertions, 1 deletions

diff --git a/fetchers/app.bsky.feed.go b/fetchers/app.bsky.feed.go
index 1083256..a0eaeb2 100644
--- a/fetchers/app.bsky.feed.go
+++ b/fetchers/app.bsky.feed.go
@@ -177,7 +177,7 @@ func parseAppBskyFeedPostCollection(conf *Config, session *auth.OAuthState, reco
 		posts = append(posts, *note)
 	}
 
-	return notes.DeduplicateThreads(posts), nil
+	return posts, nil
 }
 
 func FetchParents(conf *Config, replyToURI string, session *auth.OAuthState, maxDepth int) ([]notes.Note, error) {
diff --git a/main.go b/main.go
index e9a871e..85c8712 100644
--- a/main.go
+++ b/main.go
@@ -369,6 +369,7 @@ func postsHandler(w http.ResponseWriter, r *http.Request) {
 			http.Error(w, err.Error(), http.StatusInternalServerError)
 			return
 		}
+		posts = notes.DeduplicateThreads(posts)
 	}
 	config.Logger.Debug("posts ready", "count", len(posts))