Merge branch 'main' into claude/js-sdk-audit-6x115l-c3-paginator-cursor

Co-Authored-By: Claude <noreply@anthropic.com>
Claude-Session: https://claude.ai/code/session_01B8xeJm2Hd923k8uo6eoFd2

Author: claude

src/lib/seam-paginator.ts

@@ -145,10 +145,7 @@ export class SeamPaginator<
     EnsureReadonlyArray<TResponse[TResponseKey]>
   > {
     const items = [] as EnsureMutableArray<TResponse[TResponseKey]>
-    let [current, pagination] = await this.firstPage()
-    items.push(...current)
-    while (pagination.hasNextPage) {
-      ;[current, pagination] = await this.nextPage(pagination.nextPageCursor)
+    for await (const [current] of this.#walk()) {
       items.push(...current)
     }
     return items as EnsureReadonlyArray<TResponse[TResponseKey]>
@@ -158,12 +155,7 @@ export class SeamPaginator<
    * Yields each item across all pages, fetching the next page as needed.
    */
   async *flatten(): AsyncGenerator<ElementOfArray<TResponse[TResponseKey]>> {
-    let [current, pagination] = await this.firstPage()
-    for (const item of current) {
-      yield item
-    }
-    while (pagination.hasNextPage) {
-      ;[current, pagination] = await this.nextPage(pagination.nextPageCursor)
+    for await (const [current] of this.#walk()) {
       for (const item of current) {
         yield item
       }
@@ -176,13 +168,25 @@ export class SeamPaginator<
   async *[Symbol.asyncIterator](): AsyncGenerator<
     EnsureReadonlyArray<TResponse[TResponseKey]>
   > {
-    let [current, pagination] = await this.firstPage()
-    yield current
-    while (pagination.hasNextPage) {
-      ;[current, pagination] = await this.nextPage(pagination.nextPageCursor)
+    for await (const [current] of this.#walk()) {
       yield current
     }
   }
+
+  async *#walk(): AsyncGenerator<
+    [EnsureReadonlyArray<TResponse[TResponseKey]>, Pagination]
+  > {
+    const seenCursors = new Set<SeamPageCursor>()
+    let page = await this.firstPage()
+    yield page
+    while (page[1].hasNextPage) {
+      const cursor = page[1].nextPageCursor
+      if (cursor == null || seenCursors.has(cursor)) return
+      seenCursors.add(cursor)
+      page = await this.nextPage(cursor)
+      yield page
+    }
+  }
 }
 
 const usesParams = (method: string): boolean =>

test/seam/connect/seam-paginator.test.ts

@@ -130,6 +130,68 @@ test('SeamPaginator: sends the page cursor when the request has no parameters',
   )
 })
 
+test('SeamPaginator: stops iterating when the page cursor repeats', async (t) => {
+  const { seed, endpoint } = await getTestServer(t)
+  const seam = SeamHttp.fromApiKey(seed.seam_apikey1_token, { endpoint })
+
+  nock(endpoint)
+    .get('/devices/list')
+    .query({ limit: '1', _strict: 'true' })
+    .reply(200, {
+      devices: [{ device_id: 'device-1' }],
+      pagination: {
+        has_next_page: true,
+        next_page_cursor: 'repeated-cursor',
+        next_page_url: null,
+      },
+    })
+    .get('/devices/list')
+    .query({ limit: '1', page_cursor: 'repeated-cursor', _strict: 'true' })
+    .reply(200, {
+      devices: [{ device_id: 'device-2' }],
+      pagination: {
+        has_next_page: true,
+        next_page_cursor: 'repeated-cursor',
+        next_page_url: null,
+      },
+    })
+
+  const pages = seam.createPaginator(seam.devices.list({ limit: 1 }))
+  const devices = await pages.flattenToArray()
+
+  t.deepEqual(
+    devices.map(({ device_id: deviceId }) => deviceId),
+    ['device-1', 'device-2'],
+  )
+})
+
+test('SeamPaginator: stops iterating when there is a next page without a cursor', async (t) => {
+  const { seed, endpoint } = await getTestServer(t)
+  const seam = SeamHttp.fromApiKey(seed.seam_apikey1_token, { endpoint })
+
+  nock(endpoint)
+    .get('/devices/list')
+    .query({ limit: '1', _strict: 'true' })
+    .reply(200, {
+      devices: [{ device_id: 'device-1' }],
+      pagination: {
+        has_next_page: true,
+        next_page_cursor: null,
+        next_page_url: null,
+      },
+    })
+
+  const pages = seam.createPaginator(seam.devices.list({ limit: 1 }))
+
+  const seenPages = []
+  for await (const page of pages) {
+    seenPages.push(page)
+  }
+
+  t.is(seenPages.length, 1)
+  t.is(seenPages[0]?.[0]?.device_id, 'device-1')
+})
+
 test('SeamPaginator: instance allows iteration over all pages', async (t) => {
   const { seed, endpoint } = await getTestServer(t)
   const seam = SeamHttp.fromApiKey(seed.seam_apikey1_token, { endpoint })