Draft: Run AUNIT for GCTS repository

sap/adt/core.py

@@ -93,7 +93,8 @@ class Connection:
     """
 
     # pylint: disable=too-many-arguments
-    def __init__(self, host, client, user, password, port=None, ssl=True, verify=True):
+    def __init__(self, host, client, user, password=None, port=None, ssl=True, verify=True,
+                 auth=None):
         """Parameters:
             - host: string host name
             - client: string SAP client
@@ -124,7 +125,7 @@ def __init__(self, host, client, user, password, port=None, ssl=True, verify=Tru
         self._base_url = f'{protocol}://{host}:{port}/{self._adt_uri}'
         self._query_args = f'sap-client={client}&saml2=disabled'
         self._user = user
-        self._auth = HTTPBasicAuth(user, password)
+        self._auth = auth if auth else HTTPBasicAuth(user, password)
         self._session = None
         self._collection_types = None
         self._timeout = config_get('http_timeout')

sap/adt/object_factory.py

@@ -20,7 +20,11 @@ def __init__(self, connection: sap.adt.core.Connection, builders: Optional[ADTOb
         if builders:
             self._builders = builders
         else:
-            self._builders = cast(ADTObjectBuilderDictType, {})
+            self._builders = cast(ADTObjectBuilderDictType, {
+                'CLAS': sap.adt.Class,
+                'FUGR': sap.adt.FunctionGroup,
+                'PROG': sap.adt.Program,
+            })
 
     def register(self, typ: str, producer: ADTObjectBuilderType, overwrite: bool = False) -> None:
         """Registers ADT object builder"""

sap/cli/gcts.py

@@ -358,6 +358,40 @@ def install_parser(self, arg_parser):
         self.branch_grp.install_parser(branch_parser)
 
 
+@RepoCommandGroup.argument('package')
+@RepoCommandGroup.command('run-aunit')
+def run_aunit(connection, args):
+    """Run AUNIT for GCTS repository"""
+
+    adt_connection = connection.get_adt_connection()
+    repo = get_repository(connection, args.package)
+    objects = repo.list_objects()
+    # remove object type DEVC, because it is already included in scope packages
+    # also if you run ATC Checks for DEVC together with other object types, ATC checks will run only for DEVC
+    # SUSH is removed because this type is not supported yet
+    objects = [obj for obj in objects if obj['type'] != 'DEVC' and obj['type'] != 'SUSH']
+    objfactory = sap.adt.object_factory.ADTObjectFactory(adt_connection)
+
+    sets = sap.adt.objects.ADTObjectSets()
+
+    for obj in objects:
+        objname = obj['object']
+        objtype = obj['type']
+        try:
+            sets.include(objfactory.make(objtype, objname))
+        except SAPCliError as ex:
+            sap.cli.core.printerr(str(ex))
+            return 1
+
+    aunit = sap.adt.AUnit(adt_connection)
+    aunit_response = aunit.execute(sets)
+    if aunit_response.status_code != 200:
+        print('AUNIT fail:', aunit_response.text)
+        return 1
+
+    return 0
+
+
 @RepoCommandGroup.argument('url')
 @RepoCommandGroup.argument('package')
 @RepoCommandGroup.command('set-url')

sap/rest/connection.py

@@ -8,6 +8,7 @@
 import requests
 from requests.auth import HTTPBasicAuth
 
+import sap.adt.core
 from sap import get_logger, config_get
 from sap.rest.errors import (
     HTTPRequestError,
@@ -93,6 +94,7 @@ def __init__(self, icf_path, login_path, host, client, user, password, port=None
         self._session = None
         self._login_path = login_path
         self._timeout = config_get('http_timeout')
+        self._client = client
 
     @property
     def user(self):
@@ -242,3 +244,10 @@ def delete_json(self, uri_path, params=None):
 
         response = self.execute('DELETE', uri_path, accept='application/json', params=params)
         return response.json()
+
+    def get_adt_connection(self):
+        """Build ADT Connection from this connection.
+        """
+
+        return sap.adt.core.Connection(self._host, self._client, self._user, port=self._port, ssl=self._ssl,
+                                       verify=self._ssl_verify, auth=self._auth)

sap/rest/gcts/remote_repo.py

@@ -545,3 +545,10 @@ def list_branches(self):
             raise SAPCliError("gCTS response does not contain 'branches'")
 
         return branches
+
+    def list_objects(self):
+        """List ADT objects of repository"""
+
+        response = self._http.get_json('objects')
+
+        return response['objects']