Utilizes paging to get more Jira issues

Author: axosoft-ramint

src/plus/integrations/providers/jira.ts

@@ -11,6 +11,7 @@ import { IssueFilter, providersMetadata, toAccount, toSearchedIssue } from './mo
 
 const metadata = providersMetadata[IssueIntegrationId.Jira];
 const authProvider = Object.freeze({ id: metadata.id, scopes: metadata.scopes });
+const maxPagesPerRequest = 10;
 
 export interface JiraBaseDescriptor extends ResourceDescriptor {
 	id: string;
@@ -233,15 +234,24 @@ export class JiraIntegration extends IssueIntegration<IssueIntegrationId.Jira> {
 		const results: SearchedIssue[] = [];
 		for (const resource of myResources) {
 			const userLogin = (await this.getProviderAccountForResource(session, resource))?.username;
-			const resourceIssues = await api.getIssuesForResourceForCurrentUser(this.id, resource.id, {
-				accessToken: session.accessToken,
-			});
-			const formattedIssues = resourceIssues
-				?.map(issue => toSearchedIssue(issue, this, undefined, userLogin))
-				.filter((result): result is SearchedIssue => result != null);
-			if (formattedIssues != null) {
-				results.push(...formattedIssues);
-			}
+			let cursor = undefined;
+			let hasMore = false;
+			let requestCount = 0;
+			do {
+				const resourceIssues = await api.getIssuesForResourceForCurrentUser(this.id, resource.id, {
+					accessToken: session.accessToken,
+					cursor: cursor,
+				});
+				requestCount += 1;
+				hasMore = resourceIssues.paging?.more ?? false;
+				cursor = resourceIssues.paging?.cursor;
+				const formattedIssues = resourceIssues.values
+					.map(issue => toSearchedIssue(issue, this, undefined, userLogin))
+					.filter((result): result is SearchedIssue => result != null);
+				if (formattedIssues.length > 0) {
+					results.push(...formattedIssues);
+				}
+			} while (requestCount < maxPagesPerRequest && hasMore);
 		}
 
 		return results;

src/plus/integrations/providers/providersApi.ts

@@ -340,7 +340,7 @@ export class ProvidersApi {
 	}
 
 	async getPagedResult<T>(
-		_provider: ProviderInfo,
+		provider: ProviderInfo,
 		args: any,
 		providerFn:
 			| ((
@@ -372,27 +372,31 @@ export class ProvidersApi {
 			...cursorOrPage,
 		};
 
-		const result = await providerFn?.(input, { token: token, isPAT: usePAT });
-		if (result == null) {
-			return { values: [] };
-		}
+		try {
+			const result = await providerFn?.(input, { token: token, isPAT: usePAT });
+			if (result == null) {
+				return { values: [] };
+			}
 
-		const hasMore = result.pageInfo?.hasNextPage ?? false;
+			const hasMore = result.pageInfo?.hasNextPage ?? false;
 
-		let nextCursor = '{}';
-		if (result.pageInfo?.endCursor != null) {
-			nextCursor = JSON.stringify({ value: result.pageInfo?.endCursor, type: 'cursor' });
-		} else if (result.pageInfo?.nextPage != null) {
-			nextCursor = JSON.stringify({ value: result.pageInfo?.nextPage, type: 'page' });
-		}
+			let nextCursor = '{}';
+			if (result.pageInfo?.endCursor != null) {
+				nextCursor = JSON.stringify({ value: result.pageInfo?.endCursor, type: 'cursor' });
+			} else if (result.pageInfo?.nextPage != null) {
+				nextCursor = JSON.stringify({ value: result.pageInfo?.nextPage, type: 'page' });
+			}
 
-		return {
-			values: result.data,
-			paging: {
-				cursor: nextCursor,
-				more: hasMore,
-			},
-		};
+			return {
+				values: result.data,
+				paging: {
+					cursor: nextCursor,
+					more: hasMore,
+				},
+			};
+		} catch (e) {
+			return this.handleProviderError<PagedResult<T>>(provider.id, token, e);
+		}
 	}
 
 	async getCurrentUser(
@@ -784,24 +788,21 @@ export class ProvidersApi {
 	async getIssuesForResourceForCurrentUser(
 		providerId: IntegrationId,
 		resourceId: string,
-		options?: { accessToken?: string },
-	): Promise<ProviderIssue[] | undefined> {
+		options?: { accessToken?: string; cursor?: string },
+	): Promise<PagedResult<ProviderIssue>> {
 		const { provider, token } = await this.ensureProviderTokenAndFunction(
 			providerId,
 			'getIssuesForResourceForCurrentUserFn',
 			options?.accessToken,
 		);
 
-		try {
-			const result = await provider.getIssuesForResourceForCurrentUserFn?.(
-				{ resourceId: resourceId },
-				{ token: token },
-			);
-
-			return result?.data;
-		} catch (e) {
-			return this.handleProviderError<ProviderIssue[] | undefined>(providerId, token, e);
-		}
+		return this.getPagedResult<ProviderIssue>(
+			provider,
+			{ resourceId: resourceId },
+			provider.getIssuesForResourceForCurrentUserFn,
+			token,
+			options?.cursor,
+		);
 	}
 
 	async getIssue(