mudhorn/n8n
1
0
Fork 0
mirror of https://github.com/n8n-io/n8n.git synced 2024-12-24 20:24:05 -08:00
Code Issues Actions 1 Packages Projects Releases Wiki Activity

fix(Supabase Node): Pagination for get all rows (#8311)

Browse source
This commit is contained in:
Michael Kret 2024-01-12 15:14:10 +02:00 committed by GitHub
parent 1a0e285553
commit e0804768e8
No known key found for this signature in database
GPG key ID: 4AEE18F83AFDEB23
1 changed files with 9 additions and 3 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

12
packages/nodes-base/nodes/Supabase/Supabase.node.ts
View file

@ -310,12 +310,18 @@ export class Supabase implements INodeType {
qs.limit = this.getNodeParameter('limit', 0); qs.limit = this.getNodeParameter('limit', 0);
} }
let rows; let rows: IDataObject[] = [];
try { try {
rows = await supabaseApiRequest.call(this, 'GET', endpoint, {}, qs); let responseLength = 0;
do {
const newRows = await supabaseApiRequest.call(this, 'GET', endpoint, {}, qs);
responseLength = newRows.length;
rows = rows.concat(newRows);
qs.offset = rows.length;
} while (responseLength >= 1000);
const executionData = this.helpers.constructExecutionMetaData( const executionData = this.helpers.constructExecutionMetaData(
this.helpers.returnJsonArray(rows as IDataObject[]), this.helpers.returnJsonArray(rows),
{ itemData: { item: i } }, { itemData: { item: i } },
); );
returnData.push(...executionData); returnData.push(...executionData);