From 0c646fe97f69cefee995b5edcfd78f7253dff506 Mon Sep 17 00:00:00 2001
From: Finn Voorhees <finnvoorhees@gmail.com>
Date: Tue, 30 Jan 2024 09:19:04 +0000
Subject: [PATCH] Handle paged responses

---
 Sources/xcc.swift | 26 ++++++++++++++++++--------
 1 file changed, 18 insertions(+), 8 deletions(-)

diff --git a/Sources/xcc.swift b/Sources/xcc.swift
index e72e8d9..41a0692 100644
--- a/Sources/xcc.swift
+++ b/Sources/xcc.swift
@@ -48,15 +48,15 @@ import SwiftTUI
         let provider = APIProvider(configuration: configuration)
 
         ActivityIndicator.start()
-        let bundleIDs = try await provider.request(
+        let bundleIDs = try await provider.requestAll(
             APIEndpoint.v1.bundleIDs.get(parameters: .init(fieldsBundleIDs: [.identifier], limit: 200))
-        ).data
+        ).flatMap(\.data)
 
-        var products = try await provider.request(
+        var products = try await provider.requestAll(
             APIEndpoint.v1.ciProducts.get(parameters: .init(
                 include: [.bundleID]
             ))
-        ).data
+        ).flatMap(\.data)
         ActivityIndicator.stop()
 
         // Some products have the internal ASC bundleID ID
@@ -79,9 +79,9 @@ import SwiftTUI
         }
 
         ActivityIndicator.start()
-        let workflows = try await provider.request(
+        let workflows = try await provider.requestAll(
             APIEndpoint.v1.ciProducts.id(selectedProduct.id).workflows.get()
-        ).data
+        ).flatMap(\.data)
         ActivityIndicator.stop()
 
         let selectedWorkflow = if let workflow {
@@ -98,9 +98,9 @@ import SwiftTUI
             APIEndpoint.v1.ciWorkflows.id(selectedWorkflow.id).repository.get()
         ).data
 
-        let gitReferences = try await provider.request(
+        let gitReferences = try await provider.requestAll(
             APIEndpoint.v1.scmRepositories.id(repository.id).gitReferences.get()
-        ).data
+        ).flatMap(\.data)
         ActivityIndicator.stop()
 
         let selectedGitReference = if let reference {
@@ -197,3 +197,13 @@ extension ScmGitReference: CustomStringConvertible {
         }
     }
 }
+
+extension APIProvider {
+    func requestAll<T: Decodable>(_ endpoint: Request<T>) async throws -> [T] {
+        var results: [T] = []
+        for try await pagedResult in paged(endpoint) {
+            results.append(pagedResult)
+        }
+        return results
+    }
+}