Pass maxResults to streamers

Author: verhovsky

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

@@ -1,4 +1,5 @@
 import zohoDesk from "../../zoho_desk.app.mjs";
+import constants from "../../common/constants.mjs";
 
 export default {
   key: "zoho_desk-list-articles",
@@ -59,6 +60,7 @@ export default {
       label: "Max Results",
       description: "Maximum number of articles to return. Leave blank to return all available results.",
       optional: true,
+      default: constants.MAX_RESOURCES,
     },
   },
   async run({ $ }) {
@@ -80,12 +82,10 @@ export default {
     const articles = [];
     const stream = this.zohoDesk.listKnowledgeBaseArticlesStream({
       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

@@ -1,4 +1,5 @@
 import zohoDesk from "../../zoho_desk.app.mjs";
+import constants from "../../common/constants.mjs";
 
 export default {
   key: "zoho_desk-list-root-categories",
@@ -67,6 +68,7 @@ export default {
       label: "Max Results",
       description: "Maximum number of categories to return. Leave blank to return all available results.",
       optional: true,
+      default: constants.MAX_RESOURCES,
     },
   },
   async run({ $ }) {
@@ -89,15 +91,13 @@ export default {
       hasArticles,
     };
 
-    const categories = [];
     const stream = this.zohoDesk.listKnowledgeBaseRootCategoriesStream({
       params,
+      max: maxResults,
     });
+    const categories = [];
     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

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

@@ -1,4 +1,5 @@
 import zohoDesk from "../../zoho_desk.app.mjs";
+import constants from "../../common/constants.mjs";
 
 export default {
   key: "zoho_desk-search-articles",
@@ -72,6 +73,7 @@ export default {
       label: "Max Results",
       description: "Maximum number of articles to return. Leave blank to return all available matches.",
       optional: true,
+      default: constants.MAX_RESOURCES,
     },
   },
   async run({ $ }) {
@@ -92,15 +94,13 @@ export default {
       searchKeyWordMatch,
     };
 
-    const articles = [];
     const stream = this.zohoDesk.searchKnowledgeBaseArticlesStream({
       params,
+      max: maxResults,
     });
+    const articles = [];
     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

@@ -308,6 +308,7 @@ export default {
     },
     async *listKnowledgeBaseArticlesStream({
       params,
+      max,
       ...args
     } = {}) {
       yield* this.getResourcesStream({
@@ -316,6 +317,7 @@ export default {
           ...args,
           params,
         },
+        max,
       });
     },
     getKnowledgeBaseArticle({
@@ -337,6 +339,7 @@ export default {
     },
     async *searchKnowledgeBaseArticlesStream({
       params,
+      max,
       ...args
     } = {}) {
       yield* this.getResourcesStream({
@@ -345,6 +348,7 @@ export default {
           ...args,
           params,
         },
+        max,
       });
     },
     listKnowledgeBaseRootCategories(args = {}) {
@@ -356,6 +360,7 @@ export default {
     },
     async *listKnowledgeBaseRootCategoriesStream({
       params,
+      max,
       ...args
     } = {}) {
       yield* this.getResourcesStream({
@@ -364,6 +369,7 @@ export default {
           ...args,
           params,
         },
+        max,
       });
     },
     sendReply({