rohit/probo
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

Paginate access review source loader in n8n node

Browse Source 
The loader fetched only the first 500 sources with no pageInfo/cursor
follow-up, so organizations with more than 500 scoped sources could
not select sources past the first page when creating or updating a
campaign. Loop over pages using pageInfo.endCursor until exhausted.

Signed-off-by: Bryan Frimin <bryan@probo.com>
This commit is contained in:
Bryan Frimin
2026-07-27 18:30:41 +02:00
parent 2ebf3c180f
commit 8bc394c54b
1 changed files with 42 additions and 10 deletions
Download Patch File Download Diff File Expand all files Collapse all files

52
packages/n8n-node/nodes/Probo/actions/accessReview/loadAccessReviewSourceOptions.ts
View File

@@ -22,16 +22,20 @@ import type { IDataObject, ILoadOptionsFunctions, INodePropertyOptions } from 'n
import { proboApiRequest } from '../../GenericFunctions';
const organizationSourcesQuery = `
query AccessReviewSources($organizationId: ID!) {
query AccessReviewSources($organizationId: ID!, $after: CursorKey) {
organization: node(id: $organizationId) {
... on Organization {
accessReviewSources(first: 500) {
accessReviewSources(first: 100, after: $after) {
edges {
node {
id
name
}
}
pageInfo {
hasNextPage
endCursor
}
}
}
}
@@ -51,10 +55,9 @@ const campaignOrganizationQuery = `
`;
function mapSources(responseData: IDataObject): INodePropertyOptions[] {
const data = responseData.data as IDataObject | undefined;
const organization = data?.organization as IDataObject | undefined;
const accessReviewSources = organization?.accessReviewSources as IDataObject | undefined;
const edges = accessReviewSources?.edges as Array<{ node: IDataObject }> | undefined;
const edges = getAccessReviewSourcesConnection(responseData)?.edges as
| Array<{ node: IDataObject }>
| undefined;
return (edges ?? [])
.map((edge) => edge.node)
@@ -65,6 +68,24 @@ function mapSources(responseData: IDataObject): INodePropertyOptions[] {
}));
}
function getAccessReviewSourcesConnection(responseData: IDataObject): IDataObject | undefined {
const data = responseData.data as IDataObject | undefined;
const organization = data?.organization as IDataObject | undefined;
return organization?.accessReviewSources as IDataObject | undefined;
}
function getPageInfo(responseData: IDataObject): { hasNextPage: boolean; endCursor?: string } {
const pageInfo = getAccessReviewSourcesConnection(responseData)?.pageInfo as
| IDataObject
| undefined;
return {
hasNextPage: pageInfo?.hasNextPage === true,
endCursor: typeof pageInfo?.endCursor === 'string' ? pageInfo.endCursor : undefined,
};
}
async function resolveOrganizationId(
this: ILoadOptionsFunctions,
): Promise<string | undefined> {
@@ -96,9 +117,20 @@ export async function getAccessReviewSources(
return [];
}
const responseData = await proboApiRequest.call(this, organizationSourcesQuery, {
organizationId,
});
const options: INodePropertyOptions[] = [];
let after: string | undefined;
return mapSources(responseData);
do {
const responseData = await proboApiRequest.call(this, organizationSourcesQuery, {
organizationId,
after,
});
options.push(...mapSources(responseData));
const pageInfo = getPageInfo(responseData);
after = pageInfo.hasNextPage ? pageInfo.endCursor : undefined;
} while (after);
return options;
}