Implement command to validate builds

Get builds from dashboard and validate
it with maestro result.

Signed-off-by: Jeny Sadadia <[email protected]>

Author: Jeny Sadadia

kcidev/libs/maestro_common.py

@@ -62,18 +62,29 @@ def maestro_get_node(url, nodeid):
     return response.json()
 
 
-def maestro_get_nodes(url, limit, offset, filter):
+def maestro_get_nodes(url, limit, offset, filter, paginate):
     headers = {
         "Content-Type": "application/json; charset=utf-8",
     }
-    url = url + "latest/nodes/fast?limit=" + str(limit) + "&offset=" + str(offset)
-    maestro_print_api_call(url)
-    if filter:
-        for f in filter:
-            # TBD: We need to add translate filter to API
-            # if we need anything more complex than eq(=)
-            url = url + "&" + f
 
+    if paginate:
+        url = url + "latest/nodes/fast?limit=" + str(limit) + "&offset=" + str(offset)
+        if filter:
+            for f in filter:
+                # TBD: We need to add translate filter to API
+                # if we need anything more complex than eq(=)
+                url = url + "&" + f
+
+    else:
+        url = url + "latest/nodes/fast"
+        if filter:
+            url = url + "?"
+            for f in filter:
+                # TBD: We need to add translate filter to API
+                # if we need anything more complex than eq(=)
+                url = url + "&" + f
+
+    maestro_print_api_call(url)
     response = requests.get(url, headers=headers)
     try:
         response.raise_for_status()

kcidev/main.py

@@ -16,6 +16,7 @@
     results,
     testretry,
     watch,
+    validate_builds,
 )
 
 
@@ -66,6 +67,7 @@ def run():
     cli.add_command(testretry.testretry)
     cli.add_command(results.results)
     cli.add_command(watch.watch)
+    cli.add_command(validate_builds.validate_builds)
     cli()
 
 

kcidev/subcommands/maestro_results.py

@@ -44,8 +44,21 @@
     multiple=True,
     help="Print only particular field(s) from node data",
 )
+@click.option(
+    "--count",
+    is_flag=True,
+    required=False,
+    help="Print only count of nodes",
+)
+@click.option(
+    "--paginate",
+    is_flag=True,
+    required=False,
+    default=True,
+    help="Set True if pagination is required in the output. Default is True",
+)
 @click.pass_context
-def maestro_results(ctx, nodeid, nodes, limit, offset, filter, field):
+def maestro_results(ctx, nodeid, nodes, limit, offset, filter, field, count, paginate):
     config = ctx.obj.get("CFG")
     instance = ctx.obj.get("INSTANCE")
     url = config[instance]["api"]
@@ -55,7 +68,10 @@ def maestro_results(ctx, nodeid, nodes, limit, offset, filter, field):
     if nodeid:
         results = maestro_get_node(url, nodeid)
     if nodes:
-        results = maestro_get_nodes(url, limit, offset, filter)
+        results = maestro_get_nodes(url, limit, offset, filter, paginate)
+        if count:
+            print("Total nodes found: ", len(results))
+            return
     maestro_print_nodes(results, field)
 
 

kcidev/subcommands/validate_builds.py

@@ -0,0 +1,45 @@
+#!/usr/bin/env python3
+# -*- coding: utf-8 -*-
+
+import click
+from click.testing import CliRunner
+
+from kcidev.libs.common import *
+from kcidev.libs.maestro_common import *
+from .results import builds
+from .maestro_results import maestro_results
+
+
+runner = CliRunner()
+
+@click.command(help="Validate builds from dashboard and maestro")
+@click.option(
+    "--giturl",
+    help="Git URL of kernel tree ",
+)
+@click.option(
+    "--branch",
+    help="Branch to get results for",
+)
+@click.option(
+    "--commit",
+    help="Commit or tag to get results for",
+)
+@click.option("--arch", help="Filter by arch")
+@click.pass_context
+def validate_builds(ctx, giturl, branch, commit, arch):
+    print("Validate builds called----")
+    ret = ctx.forward(builds, count=True)
+    ret = ctx.invoke(maestro_results,
+                     count=True, nodes=True,
+                     filter=("kind=kbuild",
+                             "data.kernel_revision.url="+giturl,
+                             "data.kernel_revision.branch="+branch,
+                             "data.kernel_revision.commit="+commit
+                             ),
+                    paginate=False,
+                    )
+
+
+if __name__ == "__main__":
+    main_kcidev()