Move for loop into paginate() function

Author: verhovsky

components/zoho_desk/actions/list-articles/list-articles.mjs

@@ -77,16 +77,13 @@ export default {
       tag,
     };
 
-    const articles = [];
-    const stream = this.zohoDesk.listKnowledgeBaseArticlesStream({
-      params,
+    const articles = await this.zohoDesk.paginate({
+      resourceFn: this.zohoDesk.listKnowledgeBaseArticles,
+      resourceFnArgs: {
+        params,
+      },
+      max: maxResults,
     });
-    for await (const article of stream) {
-      articles.push(article);
-      if (maxResults && articles.length >= maxResults) {
-        break;
-      }
-    }
 
     $.export("$summary", `Retrieved ${articles.length} article${articles.length === 1
       ? ""

components/zoho_desk/actions/list-root-categories/list-root-categories.mjs

@@ -89,16 +89,13 @@ export default {
       hasArticles,
     };
 
-    const categories = [];
-    const stream = this.zohoDesk.listKnowledgeBaseRootCategoriesStream({
-      params,
+    const categories = await this.zohoDesk.paginate({
+      resourceFn: this.zohoDesk.listKnowledgeBaseRootCategories,
+      resourceFnArgs: {
+        params,
+      },
+      max: maxResults,
     });
-    for await (const category of stream) {
-      categories.push(category);
-      if (maxResults && categories.length >= maxResults) {
-        break;
-      }
-    }
 
     $.export("$summary", `Retrieved ${categories.length} root categor${categories.length === 1
       ? "y"

components/zoho_desk/actions/search-articles/search-articles.mjs

@@ -92,16 +92,13 @@ export default {
       searchKeyWordMatch,
     };
 
-    const articles = [];
-    const stream = this.zohoDesk.searchKnowledgeBaseArticlesStream({
-      params,
+    const articles = await this.zohoDesk.paginate({
+      resourceFn: this.zohoDesk.searchKnowledgeBaseArticles,
+      resourceFnArgs: {
+        params,
+      },
+      max: maxResults,
     });
-    for await (const article of stream) {
-      articles.push(article);
-      if (maxResults && articles.length >= maxResults) {
-        break;
-      }
-    }
 
     $.export("$summary", `Found ${articles.length} article${articles.length === 1
       ? ""

components/zoho_desk/zoho_desk.app.mjs

@@ -483,5 +483,23 @@ export default {
         }
       }
     },
+    async paginate({
+      resourceFn,
+      resourceFnArgs,
+      max,
+    } = {}) {
+      const resources = [];
+      const stream = this.getResourcesStream({
+        resourceFn,
+        resourceFnArgs,
+      });
+      for await (const resource of stream) {
+        resources.push(resource);
+        if (max && resources.length >= max) {
+            break;
+        }
+      }
+      return resources;
+    },
   },
 };