fix: 404ing list results should return empty iterators, not throw (#189)

Co-authored-by: Sean Roberts <sean.roberts@netlify.com>

Author: sean-roberts

src/list.test.ts

@@ -762,4 +762,58 @@ describe('list', () => {
     expect(directories).toEqual([])
     expect(mockStore.fulfilled).toBeTruthy()
   })
+
+  test('Handles missing content automatic pagination', async () => {
+    const mockStore = new MockFetch().get({
+      headers: { authorization: `Bearer ${edgeToken}` },
+      response: new Response('<not_found>', { status: 404 }),
+      url: `${edgeURL}/${siteID}/site:${storeName}?prefix=group%2F`,
+    })
+
+    globalThis.fetch = mockStore.fetch
+
+    const store = getStore({
+      edgeURL,
+      name: storeName,
+      token: edgeToken,
+      siteID,
+    })
+
+    const { blobs } = await store.list({
+      prefix: 'group/',
+    })
+
+    expect(blobs).toEqual([])
+    expect(mockStore.fulfilled).toBeTruthy()
+  })
+
+  test('Handles missing content manual pagination', async () => {
+    const mockStore = new MockFetch().get({
+      headers: { authorization: `Bearer ${edgeToken}` },
+      response: new Response('<not_found>', { status: 404 }),
+      url: `${edgeURL}/${siteID}/site:${storeName}`,
+    })
+
+    globalThis.fetch = mockStore.fetch
+
+    const store = getStore({
+      edgeURL,
+      name: storeName,
+      token: edgeToken,
+      siteID,
+    })
+    const result: ListResult = {
+      blobs: [],
+      directories: [],
+    }
+
+    for await (const entry of store.list({ paginate: true })) {
+      result.blobs.push(...entry.blobs)
+      result.directories.push(...entry.directories)
+    }
+
+    expect(result.blobs).toEqual([])
+    expect(result.directories).toEqual([])
+    expect(mockStore.fulfilled).toBeTruthy()
+  })
 })

src/store.ts

@@ -409,21 +409,34 @@ export class Store {
               parameters: nextParameters,
               storeName,
             })
-            const page = (await res.json()) as ListResponse
 
-            if (page.next_cursor) {
-              currentCursor = page.next_cursor
-            } else {
-              done = true
+            let blobs: ListResponseBlob[] = []
+            let directories: string[] = []
+
+            if (![200, 204, 404].includes(res.status)) {
+              throw new BlobsInternalError(res)
             }
 
-            const blobs = (page.blobs ?? []).map(Store.formatListResultBlob).filter(Boolean) as ListResponseBlob[]
+            if (res.status === 404) {
+              done = true
+            } else {
+              const page = (await res.json()) as ListResponse
+
+              if (page.next_cursor) {
+                currentCursor = page.next_cursor
+              } else {
+                done = true
+              }
+
+              blobs = (page.blobs ?? []).map(Store.formatListResultBlob).filter(Boolean) as ListResponseBlob[]
+              directories = page.directories ?? []
+            }
 
             return {
               done: false,
               value: {
                 blobs,
-                directories: page.directories ?? [],
+                directories,
               },
             }
           },

src/store_list.test.ts

@@ -136,6 +136,45 @@ describe('listStores', () => {
     })
   })
 
+  test('Handles missing content for auto pagination', async () => {
+    const mockStore = new MockFetch().get({
+      headers: { authorization: `Bearer ${apiToken}` },
+      response: new Response('<not found>', { status: 404 }),
+      url: `https://api.netlify.com/api/v1/blobs/${siteID}?prefix=site%3A`,
+    })
+
+    globalThis.fetch = mockStore.fetch
+
+    const { stores } = await listStores({
+      token: apiToken,
+      siteID,
+    })
+
+    expect(stores).toStrictEqual([])
+    expect(mockStore.fulfilled).toBeTruthy()
+  })
+
+  test('Handles missing content with manual pagination', async () => {
+    const mockStore = new MockFetch().get({
+      headers: { authorization: `Bearer ${apiToken}` },
+      response: new Response('<not found>', { status: 404 }),
+      url: `https://api.netlify.com/api/v1/blobs/${siteID}?prefix=site%3A`,
+    })
+
+    globalThis.fetch = mockStore.fetch
+
+    const result: ListStoresResponse = {
+      stores: [],
+    }
+
+    for await (const entry of listStores({ token: apiToken, siteID, paginate: true })) {
+      result.stores.push(...entry.stores)
+    }
+
+    expect(result.stores).toStrictEqual([])
+    expect(mockStore.fulfilled).toBeTruthy()
+  })
+
   describe('With edge credentials', () => {
     test('Lists site stores', async () => {
       const mockStore = new MockFetch().get({

src/store_list.ts

@@ -56,6 +56,11 @@ const getListIterator = (client: Client, prefix: string): AsyncIterable<ListStor
             method: HTTPMethod.GET,
             parameters: nextParameters,
           })
+
+          if (res.status === 404) {
+            return { done: true, value: undefined }
+          }
+
           const page = (await res.json()) as ListStoresResponse
 
           if (page.next_cursor) {