Support cursor pagination for fetching requestIdentifiers

package.json

@@ -2,7 +2,7 @@
   "author": "Transcend Inc.",
   "name": "@transcend-io/cli",
   "description": "A command line interface for programmatic operations across Transcend.",
-  "version": "8.38.0",
+  "version": "8.39.0",
   "homepage": "https://github.com/transcend-io/cli",
   "repository": {
     "type": "git",

src/lib/graphql/fetchAllRequestIdentifierMetadata.ts

@@ -11,7 +11,7 @@ export interface RequestIdentifierMetadata {
   isVerifiedAtLeastOnce: boolean;
 }
 
-const PAGE_SIZE = 50;
+const PAGE_SIZE = 2000;
 
 /**
  * Fetch all request identifier metadata for a particular request
@@ -41,31 +41,38 @@ export async function fetchAllRequestIdentifierMetadata(
   const resolvedRequestIds =
     requestIds ?? (requestId ? [requestId] : undefined);
   const requestIdentifiers: RequestIdentifierMetadata[] = [];
-  let offset = 0;
+  let cursor: string | undefined;
 
   // Paginate
   let shouldContinue = false;
   do {
     const {
-      requestIdentifiers: { nodes },
+      requestIdentifiers: { nodes, pageInfo },
     } = await makeGraphQLRequest<{
       /** Request Identifiers */
       requestIdentifiers: {
         /** List */
         nodes: RequestIdentifierMetadata[];
+        /** Pagination info */
+        pageInfo: {
+          /** Cursor for the last item */
+          endCursor: string | null;
+          /** Whether more pages exist */
+          hasNextPage: boolean;
+        };
       };
     }>(client, REQUEST_IDENTIFIERS, {
       first: PAGE_SIZE,
-      offset,
+      after: cursor,
       requestIds: resolvedRequestIds,
       updatedAtBefore: updatedAtBefore
         ? updatedAtBefore.toISOString()
         : undefined,
       updatedAtAfter: updatedAtAfter ? updatedAtAfter.toISOString() : undefined,
     });
     requestIdentifiers.push(...nodes);
-    offset += PAGE_SIZE;
-    shouldContinue = nodes.length === PAGE_SIZE;
+    cursor = pageInfo.endCursor ?? undefined;
+    shouldContinue = pageInfo.hasNextPage;
   } while (shouldContinue);
 
   return requestIdentifiers;

src/lib/graphql/fetchAllRequestIdentifiers.ts

@@ -24,10 +24,16 @@ const RequestIdentifier = t.type({
 /** Type override */
 export type RequestIdentifier = t.TypeOf<typeof RequestIdentifier>;
 
-const PAGE_SIZE = 50;
+const PAGE_SIZE = 100;
+
+const PageInfo = t.type({
+  endCursor: t.union([t.string, t.null]),
+  hasNextPage: t.boolean,
+});
 
 export const RequestIdentifiersResponse = t.type({
   identifiers: t.array(RequestIdentifier),
+  pageInfo: PageInfo,
 });
 
 /**
@@ -45,11 +51,11 @@ export async function fetchAllRequestIdentifiers(
     requestId,
   }: {
     /** ID of request to filter on */
-    requestId: string;
-  },
+    requestId?: string;
+  } = {},
 ): Promise<RequestIdentifier[]> {
   const requestIdentifiers: RequestIdentifier[] = [];
-  let offset = 0;
+  let cursor: string | undefined;
   let shouldContinue = false;
 
   // determine sombra version
@@ -81,10 +87,12 @@ export async function fetchAllRequestIdentifiers(
         .post<{
           /** Decrypted identifiers */
           identifiers: RequestIdentifier[];
+          /** Pagination info */
+          pageInfo: { endCursor: string | null; hasNextPage: boolean };
         }>('v1/request-identifiers', {
           json: {
             first: PAGE_SIZE,
-            offset,
+            after: cursor,
             requestId,
           },
         })
@@ -97,15 +105,15 @@ export async function fetchAllRequestIdentifiers(
       );
     }
 
-    const { identifiers: nodes } = decodeCodec(
+    const { identifiers: nodes, pageInfo } = decodeCodec(
       RequestIdentifiersResponse,
       response,
     );
 
     requestIdentifiers.push(...nodes);
 
-    offset += PAGE_SIZE;
-    shouldContinue = nodes.length === PAGE_SIZE;
+    cursor = pageInfo.endCursor ?? undefined;
+    shouldContinue = pageInfo.hasNextPage;
   } while (shouldContinue);
 
   return requestIdentifiers;

src/lib/graphql/gqls/RequestIdentifier.ts

@@ -15,19 +15,19 @@ export const REMOVE_REQUEST_IDENTIFIERS = gql`
 export const REQUEST_IDENTIFIERS = gql`
   query TranscendCliRequestIdentifiers(
     $first: Int!
-    $offset: Int!
+    $after: String
     $requestIds: [ID!]
     $updatedAtBefore: Date
     $updatedAtAfter: Date
   ) {
     requestIdentifiers(
-      input: {
-        requestIds: $requestIds
+      input: { requestIds: $requestIds }
+      filterBy: {
         updatedAtBefore: $updatedAtBefore
         updatedAtAfter: $updatedAtAfter
       }
       first: $first
-      offset: $offset
+      after: $after
       useMaster: false
       orderBy: [
         { field: createdAt, direction: ASC }
@@ -40,6 +40,10 @@ export const REQUEST_IDENTIFIERS = gql`
         isVerifiedAtLeastOnce
       }
       totalCount
+      pageInfo {
+        endCursor
+        hasNextPage
+      }
     }
   }
 `;