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

n8n-io · Jan 16, 2024 · 69795df · 69795df
1 parent 2410047
commit 69795df
Showing 1 changed file with 9 additions and 3 deletions.
diff --git a/packages/nodes-base/nodes/Supabase/Supabase.node.ts b/packages/nodes-base/nodes/Supabase/Supabase.node.ts
@@ -310,12 +310,18 @@ export class Supabase implements INodeType {
 						qs.limit = this.getNodeParameter('limit', 0);
 					}
 
-					let rows;
+					let rows: IDataObject[] = [];
 
 					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(
-							this.helpers.returnJsonArray(rows as IDataObject[]),
+							this.helpers.returnJsonArray(rows),
 							{ itemData: { item: i } },
 						);
 						returnData.push(...executionData);