feat(daily): only return digest posts for last 24 hours

Author: capJavert

__tests__/highlights.ts

@@ -376,6 +376,9 @@ describe('query dailyHeadlines', () => {
       status,
     });
 
+  const hoursAgo = (hours: number): Date =>
+    new Date(Date.now() - hours * 60 * 60 * 1000);
+
   beforeEach(async () => {
     await saveFixtures(con, User, usersFixture);
     await saveFixtures(con, Feed, [{ id: '1', userId: '1' }]);
@@ -405,26 +408,21 @@ describe('query dailyHeadlines', () => {
       'bd-old',
       'backend_digest',
       'Backend old',
-      new Date('2026-06-19T08:00:00.000Z'),
+      hoursAgo(20),
     );
     await saveDigestPost(
       'bd-new',
       'backend_digest',
       'Backend latest',
-      new Date('2026-06-19T12:00:00.000Z'),
+      hoursAgo(2),
     );
     await saveDigestPost(
       'career-d',
       'career_digest',
       'Career latest',
-      new Date('2026-06-19T10:00:00.000Z'),
-    );
-    await saveDigestPost(
-      'bdb-d',
-      'backend_digest_b',
-      'Blocked',
-      new Date('2026-06-19T13:00:00.000Z'),
+      hoursAgo(5),
     );
+    await saveDigestPost('bdb-d', 'backend_digest_b', 'Blocked', hoursAgo(1));
 
     const res = await client.query(DAILY_HEADLINES_QUERY);
 
@@ -447,6 +445,20 @@ describe('query dailyHeadlines', () => {
     expect(res.errors).toBeFalsy();
     expect(res.data.dailyHeadlines.edges).toEqual([]);
   });
+
+  it('should exclude digest posts older than 24 hours', async () => {
+    loggedUser = '1';
+
+    await saveDigestSource('backend_digest');
+    await saveChannelDigest('backend', 'backend_digest', 'backend');
+    await followDigest('backend_digest');
+    await saveDigestPost('bd-stale', 'backend_digest', 'Stale', hoursAgo(30));
+
+    const res = await client.query(DAILY_HEADLINES_QUERY);
+
+    expect(res.errors).toBeFalsy();
+    expect(res.data.dailyHeadlines.edges).toEqual([]);
+  });
 });
 
 describe('query channelDigestConfigurations', () => {

src/schema/highlights.ts

@@ -22,6 +22,7 @@ import { ContentPreferenceSource } from '../entity/contentPreference/ContentPref
 import { ContentPreferenceStatus } from '../entity/contentPreference/types';
 import { queryReadReplica } from '../common/queryReadReplica';
 import { Post, PostType } from '../entity/posts/Post';
+import { ONE_DAY_IN_SECONDS } from '../common/constants';
 
 type GQLChannelDigestConfiguration = {
   frequency: string;
@@ -125,8 +126,8 @@ export const typeDefs = /* GraphQL */ `
     ): PostHighlightConnection!
 
     """
-    Get the latest digest post for each channel digest whose source the current
-    user follows, one per channel, ordered by recency.
+    Get the latest digest post from the last 24 hours for each channel digest
+    whose source the current user follows, one per channel, ordered by recency.
     """
     dailyHeadlines(first: Int, after: String): PostConnection! @auth
   }
@@ -283,6 +284,7 @@ export const resolvers: IResolvers<unknown, BaseContext> = {
       ctx: AuthContext,
       info,
     ) => {
+      const since = new Date(Date.now() - ONE_DAY_IN_SECONDS * 1000);
       const latestDigestPerChannel = await queryReadReplica(
         ctx.con,
         ({ queryRunner }) =>
@@ -298,8 +300,8 @@ export const resolvers: IResolvers<unknown, BaseContext> = {
             .innerJoin(
               Post,
               'p',
-              'p."sourceId" = cd."sourceId" AND p.type = :postType AND p.visible = true AND p.deleted = false',
-              { postType: PostType.Freeform },
+              'p."sourceId" = cd."sourceId" AND p.type = :postType AND p.visible = true AND p.deleted = false AND p."createdAt" >= :since',
+              { postType: PostType.Freeform, since },
             )
             .where('cp."userId" = :userId AND cp."feedId" = :userId', {
               userId: ctx.userId,