Cf 4994 (#47)

add support for filtering pagination and limitation for pipelines

Author: ziv-codefresh

lib/interface/cli/commands/pipeline/get.cmd.js

@@ -5,27 +5,44 @@ const _ = require('lodash');
 const { pipeline } = require('../../../../logic').api;
 const { specifyOutputForSingle, specifyOutputForArray } = require('../../helpers/get');
 const getRoot = require('../root/get.cmd');
+const DEFAULTS = require('../../defaults');
+
 
 
 const command = new Command({
-    command: 'pipelines [id|name] [repo-owner] [repo-name]',
+    command: 'pipelines [id]',
     description: 'Get pipelines',
     builder: (yargs) => {
         return yargs
             .positional('id', {
-                describe: 'Pipeline name or id',
+                describe: 'Pipeline id',
             })
-            .positional('repo-owner', {
+            .option('repo-owner', {
                 describe: 'Repository owner',
             })
-            .positional('repo-name', {
+            .option('repo-name', {
                 describe: 'Repository name',
+            })
+            .option('limit', {
+                describe: 'Limit amount of returned results',
+                default: DEFAULTS.GET_LIMIT_RESULTS,
+            })
+            .option('page', {
+                describe: 'Paginated page',
+                default: DEFAULTS.GET_PAGINATED_PAGE,
+            })
+            .option('name', {
+                describe: 'Filter results by pipeline name',
+                type: Array,
             });
     },
     handler: async (argv) => {
         const id = argv.id;
         const repoOwner = argv['repo-owner'];
         const repoName = argv['repo-name'];
+        const name = argv.name;
+        const limit = argv.limit;
+        const page = argv.page;
 
         let pipelines;
         // TODO:need to decide for one way for error handeling
@@ -34,9 +51,19 @@ const command = new Command({
         } else if (id) {
             pipelines = await pipeline.getPipelineById(id);
         } else if (repoOwner && repoName) {
-            pipelines = await pipeline.getAllByRepo(repoOwner, repoName);
+            pipelines = await pipeline.getAllByRepo({
+                repoOwner,
+                repoName,
+                name,
+                limit,
+                page,
+            });
         } else {
-            pipelines = await pipeline.getAll();
+            pipelines = await pipeline.getAll({
+                name,
+                limit,
+                page,
+            });
         }
 
         if (_.isArray(pipelines)) {

lib/logic/api/pipeline.js

@@ -13,13 +13,19 @@ const _extractFieldsForPipelineEntity = pipeline => ({
 });
 
 
-const getAll = async () => {
-    const options = {
+const getAll = async (options) => {
+    const qs = {
+        name: options.name,
+        limit: options.limit,
+        page: options.page - 1,
+    };
+    const RequestOptions = {
         url: '/api/pipelines',
+        qs,
         method: 'GET',
     };
 
-    const result = await sendHttpRequest(options);
+    const result = await sendHttpRequest(RequestOptions);
     const pipelines = [];
 
     _.forEach(result, (pipeline) => {
@@ -36,13 +42,19 @@ const getAll = async () => {
  * @param repoName
  * @returns {Promise<*>}
  */
-const getAllByRepo = async (repoOwner, repoName) => {
-    const options = {
-        url: `/api/services/${encodeURIComponent(repoOwner)}/${encodeURIComponent(repoName)}`,
+const getAllByRepo = async (options) => {
+    const qs = {
+        name: options.name,
+        limit: options.limit,
+        page: options.page - 1,
+    };
+    const RequestOptions = {
+        url: `/api/services/${encodeURIComponent(options.repoOwner)}/${encodeURIComponent(options.repoName)}`,
+        qs,
         method: 'GET',
     };
 
-    const result = await sendHttpRequest(options);
+    const result = await sendHttpRequest(RequestOptions);
     const pipelines = [];
 
     _.forEach(result, (pipeline) => {
@@ -68,7 +80,10 @@ const getAllByRepo = async (repoOwner, repoName) => {
  * @returns {Promise<*>}
  */
 const getPipelineByNameAndRepo = async (name, repoOwner, repoName) => {
-    const pipelines = await getAllByRepo(repoOwner, repoName);
+    const pipelines = await getAllByRepo({
+        repoOwner,
+        repoName,
+    });
     const currPipeline = _.find(pipelines, pipeline => pipeline.info.name.toString() === name);
 
     if (!currPipeline) {