Merge pull request #279 from strideynet/kev-hide-old-imported-posts

Hide posts with created_at older than 7 days
strideynet · Nov 18, 2024 · 9e999cf · 9e999cf
2 parents 094ee0e + 8015d63
commit 9e999cf
Show file tree

Hide file tree

Showing 5 changed files with 9 additions and 0 deletions.
diff --git a/feed/feed_test.go b/feed/feed_test.go
@@ -134,6 +134,9 @@ func TestGenerator(t *testing.T) {
 		if opts.IndexedAt.IsZero() {
 			opts.IndexedAt = now
 		}
+		if opts.CreatedAt.IsZero() {
+			opts.CreatedAt = now
+		}
 		require.NoError(t, harness.Store.CreatePost(ctx, opts))
 	}
 

diff --git a/store/gen/candidate_posts.sql.go b/store/gen/candidate_posts.sql.go
diff --git a/store/migrations/000024_add_post_created_at_index.down.sql b/store/migrations/000024_add_post_created_at_index.down.sql
@@ -0,0 +1 @@
+DROP INDEX candidate_posts_created_at_idx;
diff --git a/store/migrations/000024_add_post_created_at_index.up.sql b/store/migrations/000024_add_post_created_at_index.up.sql
@@ -0,0 +1 @@
+CREATE INDEX candidate_posts_created_at_idx ON public.candidate_posts (created_at);
diff --git a/store/queries/candidate_posts.sql b/store/queries/candidate_posts.sql
@@ -84,6 +84,7 @@ WHERE
     -- Remove posts newer than the cursor timestamp
     AND (cp.indexed_at < sqlc.arg(cursor_timestamp))
     AND cp.indexed_at > NOW() - INTERVAL '7 day'
+    AND cp.created_at > NOW() - INTERVAL '7 day'
 ORDER BY
     cp.indexed_at DESC
 LIMIT sqlc.arg(_limit);
@@ -156,6 +157,7 @@ WHERE
         < ROW((sqlc.arg(after_score))::REAL, (sqlc.arg(after_uri))::TEXT)
     )
     AND cp.indexed_at > NOW() - INTERVAL '7 day'
+    AND cp.created_at > NOW() - INTERVAL '7 day'
 ORDER BY
     ph.score DESC, ph.uri DESC
 LIMIT sqlc.arg(_limit);
Original file line number	Diff line number	Diff line change
		@@ -0,0 +1 @@
		CREATE INDEX candidate_posts_created_at_idx ON public.candidate_posts (created_at);