feat: propagate staleCursor to GraphQL PageInfo and add tests

- Update connectionFromNodes to extract staleCursor from FeedResponse
  and include it in PageInfo
- Add tests for FeedClient parsing staleCursor from feed service response
- Add tests for connectionFromNodes propagating staleCursor to PageInfo

Co-Authored-By: Claude Opus 4.5 <[email protected]>

Author: pnvasanth

__tests__/integrations/feed.ts

@@ -6,6 +6,10 @@ import {
   FeedPreferencesConfigGenerator,
   FeedResponse,
 } from '../../src/integrations/feed';
+import {
+  connectionFromNodes,
+  feedCursorPageGenerator,
+} from '../../src/schema/common';
 import { MockContext, saveFixtures } from '../helpers';
 import { deleteKeysByPattern } from '../../src/redis';
 import createOrGetConnection from '../../src/db';
@@ -128,6 +132,112 @@ describe('FeedClient', () => {
       ],
     });
   });
+
+  it('should parse staleCursor from feed service response', async () => {
+    const responseWithStaleCursor = {
+      ...rawFeedResponse,
+      cursor: 'abc123',
+      stale_cursor: true,
+    };
+
+    nock(url)
+      // eslint-disable-next-line @typescript-eslint/no-explicit-any
+      .post('', config as any)
+      .reply(200, responseWithStaleCursor);
+
+    const feedClient = new FeedClient(url);
+    const feed = await feedClient.fetchFeed(ctx, 'id', config);
+    expect(feed).toMatchObject({
+      cursor: 'abc123',
+      staleCursor: true,
+    });
+  });
+
+  it('should not include staleCursor when not present in response', async () => {
+    nock(url)
+      // eslint-disable-next-line @typescript-eslint/no-explicit-any
+      .post('', config as any)
+      .reply(200, rawFeedResponse);
+
+    const feedClient = new FeedClient(url);
+    const feed = await feedClient.fetchFeed(ctx, 'id', config);
+    expect(feed.staleCursor).toBeUndefined();
+  });
+});
+
+describe('connectionFromNodes with staleCursor', () => {
+  const pageGenerator = feedCursorPageGenerator<{ id: string }>(30, 50);
+
+  it('should include staleCursor in pageInfo when present in queryParams', () => {
+    const nodes = [{ id: '1' }, { id: '2' }];
+    const page = { limit: 30 };
+    const queryParams: FeedResponse = {
+      data: [
+        ['1', null],
+        ['2', null],
+      ],
+      cursor: 'next-cursor',
+      staleCursor: true,
+    };
+
+    const result = connectionFromNodes(
+      {},
+      nodes,
+      undefined,
+      page,
+      pageGenerator,
+      undefined,
+      queryParams,
+    );
+
+    expect(result.pageInfo.staleCursor).toBe(true);
+  });
+
+  it('should have undefined staleCursor in pageInfo when not present in queryParams', () => {
+    const nodes = [{ id: '1' }, { id: '2' }];
+    const page = { limit: 30 };
+    const queryParams: FeedResponse = {
+      data: [
+        ['1', null],
+        ['2', null],
+      ],
+      cursor: 'next-cursor',
+    };
+
+    const result = connectionFromNodes(
+      {},
+      nodes,
+      undefined,
+      page,
+      pageGenerator,
+      undefined,
+      queryParams,
+    );
+
+    expect(result.pageInfo.staleCursor).toBeUndefined();
+  });
+
+  it('should include staleCursor in pageInfo even when nodes are empty', () => {
+    const nodes: { id: string }[] = [];
+    const page = { limit: 30 };
+    const queryParams: FeedResponse = {
+      data: [],
+      staleCursor: true,
+    };
+
+    const result = connectionFromNodes(
+      {},
+      nodes,
+      undefined,
+      page,
+      pageGenerator,
+      undefined,
+      queryParams,
+    );
+
+    expect(result.pageInfo.staleCursor).toBe(true);
+    expect(result.edges).toHaveLength(0);
+  });
 });
 
 describe('FeedPreferencesConfigGenerator', () => {

src/schema/common.ts

@@ -345,13 +345,22 @@ export function connectionFromNodes<
   queryParams?: TParams,
 ): Connection<TReturn> & TExtra {
   const transformedNodes = pageGenerator.transformNodes?.(page, nodes) ?? nodes;
+  // Extract staleCursor from queryParams if it's a FeedResponse
+  const staleCursor =
+    queryParams &&
+    typeof queryParams === 'object' &&
+    'staleCursor' in queryParams
+      ? (queryParams as FeedResponse).staleCursor
+      : undefined;
+
   if (!transformedNodes.length) {
     return {
       pageInfo: {
         startCursor: null,
         endCursor: null,
         hasNextPage: false,
         hasPreviousPage: false,
+        staleCursor,
       },
       edges: [],
       ...extra,
@@ -370,6 +379,7 @@ export function connectionFromNodes<
       endCursor: edges[edges.length - 1].cursor,
       hasNextPage: pageGenerator.hasNextPage(page, nodes.length, total),
       hasPreviousPage: pageGenerator.hasPreviousPage(page, nodes.length, total),
+      staleCursor,
     },
     edges,
     ...extra,