Format code according to standards. (#25)

I used `ruff` to format code, which is compatible with `black`,
Python's de facto standard formatter.

Author: blkt

resources/constants.py

@@ -1,6 +1,6 @@
 # This is not a secret, but a path to a file that contains a secret
-MINDER_OFFLINE_TOKEN_PATH = 'MINDER_OFFLINE_TOKEN_PATH'  # nosec
-MINDER_CONFIG = 'MINDER_CONFIG'  # nosec
+MINDER_OFFLINE_TOKEN_PATH = "MINDER_OFFLINE_TOKEN_PATH"  # nosec
+MINDER_CONFIG = "MINDER_CONFIG"  # nosec
 
-MINDER_API_ENDPOINT = 'api.stacklok.com:443'
-MINDER_REST_ENDPOINT = 'cloud.stacklok.com:443'
+MINDER_API_ENDPOINT = "api.stacklok.com:443"
+MINDER_REST_ENDPOINT = "cloud.stacklok.com:443"

resources/eval_history_service.py

@@ -3,7 +3,12 @@
 from robot.api.deco import keyword
 from resources.minder_restapi_lib import MinderRestApiLib
 from resources.errors import ConfigurationError, APIError
-from tenacity import retry, stop_after_attempt, wait_exponential, retry_if_exception_type
+from tenacity import (
+    retry,
+    stop_after_attempt,
+    wait_exponential,
+    retry_if_exception_type,
+)
 
 
 class EvalHistoryService:
@@ -30,14 +35,11 @@ def client_retrieves_eval_history(self):
         if not provider:
             raise ConfigurationError("MINDER_PROVIDER environment variable is not set")
 
-        params = {
-            "provider": provider,
-            "context.project": project
-        }
+        params = {"provider": provider, "context.project": project}
 
         try:
             rest_api = MinderRestApiLib()
-            self.history = rest_api.get_request('/history', params=params)
+            self.history = rest_api.get_request("/history", params=params)
         except Exception as e:
             raise APIError(f"API request failed: {str(e)}")
 
@@ -90,7 +92,7 @@ def history_is_not_empty(self):
         stop=stop_after_attempt(3),
         wait=wait_exponential(multiplier=1, min=1, max=10),
         retry=(retry_if_exception_type(APIError) | retry_if_exception_type(ValueError)),
-        reraise=True
+        reraise=True,
     )
     def client_retrieves_non_empty_eval_history(self):
         """
@@ -113,14 +115,11 @@ def client_retrieves_non_empty_eval_history(self):
         if not provider:
             raise ConfigurationError("MINDER_PROVIDER environment variable is not set")
 
-        params = {
-            "provider": provider,
-            "context.project": project
-        }
+        params = {"provider": provider, "context.project": project}
 
         try:
             rest_api = MinderRestApiLib()
-            self.history = rest_api.get_request('/history', params=params)
+            self.history = rest_api.get_request("/history", params=params)
             if not self.history or not self.history.get("data"):
                 raise ValueError("Retrieved history is empty")
         except Exception as e:
@@ -173,14 +172,11 @@ def client_retrieves_eval_history_by_id(self, history_id):
         if not provider:
             raise ConfigurationError("MINDER_PROVIDER environment variable is not set")
 
-        params = {
-            "provider": provider,
-            "context.project": project
-        }
+        params = {"provider": provider, "context.project": project}
 
         try:
             rest_api = MinderRestApiLib()
-            response = rest_api.get_request(f'/history/{history_id}', params=params)
+            response = rest_api.get_request(f"/history/{history_id}", params=params)
             return response
         except Exception as e:
             raise APIError(f"API request failed: {str(e)}")

resources/eval_results_service.py

@@ -29,14 +29,11 @@ def client_retrieves_eval_results(self):
         if not provider:
             raise ConfigurationError("MINDER_PROVIDER environment variable is not set")
 
-        params = {
-            "provider": provider,
-            "context.project": project
-        }
+        params = {"provider": provider, "context.project": project}
 
         try:
             rest_api = MinderRestApiLib()
-            self.results = rest_api.get_request('/results', params=params)
+            self.results = rest_api.get_request("/results", params=params)
         except Exception as e:
             raise APIError(f"API request failed: {str(e)}")
 

resources/github.py

@@ -7,7 +7,7 @@
 
 
 def randstring(size=6, chars=string.ascii_uppercase + string.digits):
-    return ''.join(random.choice(chars) for _ in range(size))  # nosec B311
+    return "".join(random.choice(chars) for _ in range(size))  # nosec B311
 
 
 def randint():
@@ -24,33 +24,46 @@ def random_repo_name(self, org, base_name):
 
     @keyword
     def a_copy_of_repo(self, repo_template, repo_name):
-        """Fork the given repo using base_name as name.
-
-        """
+        """Fork the given repo using base_name as name."""
         # gh repo create $repo_name --template $repo_template --public --include-all-branches
-        logger.info(gh.repo.create(repo_name, "--template", repo_template, "--public", "--include-all-branches"))
+        logger.info(
+            gh.repo.create(
+                repo_name,
+                "--template",
+                repo_template,
+                "--public",
+                "--include-all-branches",
+            )
+        )
         self.repos.append(repo_name)
 
     @keyword
     def delete_repo(self, repo_name):
-        """Delete repository from GitHub.
-
-        """
+        """Delete repository from GitHub."""
         # gh repo delete $repo_name --yes
         logger.info(gh.repo.delete(repo_name, "--yes"))
 
     @keyword
     def cleanup_github_repos(self):
-        """Deletes all created repositories.
-
-        """
+        """Deletes all created repositories."""
         for repo_name in self.repos:
             self.delete_repo(repo_name)
 
     @keyword
     def create_pr(self, repo_name, pr_title):
-        """Opens a Pull Request against repository.
-
-        """
+        """Opens a Pull Request against repository."""
         # gh pr create --base main --head $PR_TITLE --title $PR_TITLE --body $PR_TITLE
-        logger.info(gh.pr.create("--base", "main", "--head", pr_title, "--title", pr_title, "--body", pr_title, "--repo", repo_name))
+        logger.info(
+            gh.pr.create(
+                "--base",
+                "main",
+                "--head",
+                pr_title,
+                "--title",
+                pr_title,
+                "--body",
+                pr_title,
+                "--repo",
+                repo_name,
+            )
+        )

resources/helpers.py

@@ -3,27 +3,33 @@
 from sh import minder
 
 from robot.api import logger
-from resources.constants import MINDER_CONFIG, MINDER_OFFLINE_TOKEN_PATH, MINDER_API_ENDPOINT
+from resources.constants import (
+    MINDER_CONFIG,
+    MINDER_OFFLINE_TOKEN_PATH,
+    MINDER_API_ENDPOINT,
+)
 
 
 def _get_url_from_config(server_type):
     """Helper function to read config and return URL for a given server type."""
     minder_config_path = os.getenv(MINDER_CONFIG)
     if not minder_config_path:
-        raise Exception(f'{MINDER_CONFIG} environment variable is not set')
+        raise Exception(f"{MINDER_CONFIG} environment variable is not set")
 
-    with open(minder_config_path, 'r') as file:
+    with open(minder_config_path, "r") as file:
         config = yaml.safe_load(file)
 
-    host = config[f'{server_type}_server'].get('host', None)
+    host = config[f"{server_type}_server"].get("host", None)
     if not host:
-        raise Exception(f"Missing expected configuration key: {server_type}_server.host")
-    port = config[f'{server_type}_server'].get('port', None)
+        raise Exception(
+            f"Missing expected configuration key: {server_type}_server.host"
+        )
+    port = config[f"{server_type}_server"].get("port", None)
 
-    if server_type == 'http':
-        protocol = 'http://'
+    if server_type == "http":
+        protocol = "http://"
         if port == 443:
-            protocol = 'https://'
+            protocol = "https://"
         if port is None:
             return f"{protocol}{host}"
         return f"{protocol}{host}:{port}"
@@ -36,26 +42,26 @@ def _get_url_from_config(server_type):
 def get_rest_url_from_config():
     """Reads the MINDER_CONFIG environment variable, loads the YAML config, and returns the REST BASE_URL."""
     try:
-        return _get_url_from_config('http')
+        return _get_url_from_config("http")
     except FileNotFoundError:
-        return f'https://{MINDER_API_ENDPOINT}'
+        return f"https://{MINDER_API_ENDPOINT}"
 
 
 def get_grpc_url_from_config():
     """Reads the MINDER_CONFIG environment variable, loads the YAML config, and returns the gRPC BASE_URL."""
     try:
-        return _get_url_from_config('grpc')
+        return _get_url_from_config("grpc")
     except FileNotFoundError:
         return MINDER_API_ENDPOINT
 
 
 def log_into_minder():
-    logger.info('Logging into minder')
+    logger.info("Logging into minder")
     if MINDER_OFFLINE_TOKEN_PATH not in os.environ:
-        raise Exception(f'{MINDER_OFFLINE_TOKEN_PATH} env variable is not set')
+        raise Exception(f"{MINDER_OFFLINE_TOKEN_PATH} env variable is not set")
     tokenpath = os.environ[MINDER_OFFLINE_TOKEN_PATH]
     if not tokenpath:
         raise Exception("MINDER_OFFLINE_TOKEN_PATH env variable is empty")
 
-    logger.info(minder.auth('offline-token', 'use', '--file', tokenpath))
+    logger.info(minder.auth("offline-token", "use", "--file", tokenpath))
     return True

resources/minder_restapi_lib.py

@@ -28,10 +28,10 @@ def _get_bearer_token(self):
         """Extracts the Bearer token from the credentials.json file."""
         credentials_path = os.path.expanduser("~/.config/minder/credentials.json")
         try:
-            with open(credentials_path, 'r') as f:
+            with open(credentials_path, "r") as f:
                 credentials = json.load(f)
 
-            bearer_token = credentials.get('access_token')
+            bearer_token = credentials.get("access_token")
             if not bearer_token:
                 raise Exception("No access_token found in credentials file")
 
@@ -45,13 +45,15 @@ def _get_bearer_token(self):
     def _make_request(self, method, path, **kwargs):
         url = f"{self.base_url}{self.api_endpoint}{path}"
         headers = self.create_authorization_header()
-        headers.update(kwargs.pop('headers', {}))
+        headers.update(kwargs.pop("headers", {}))
 
         logger.info(f"Sending {method} request to {url}")
         try:
             logger.debug(f"Request: {kwargs}")
             response = requests.request(method, url, headers=headers, **kwargs)
-            logger.debug(f"Request ID: \'{response.headers['grpc-metadata-request-id']}\'")
+            logger.debug(
+                f"Request ID: '{response.headers['grpc-metadata-request-id']}'"
+            )
             logger.debug(f"Response: {response.json()}")
             response.raise_for_status()
             return response.json()
@@ -61,16 +63,16 @@ def _make_request(self, method, path, **kwargs):
 
     @keyword
     def get_request(self, path, **kwargs):
-        return self._make_request('GET', path, **kwargs)
+        return self._make_request("GET", path, **kwargs)
 
     @keyword
     def post_request(self, path, **kwargs):
-        return self._make_request('POST', path, **kwargs)
+        return self._make_request("POST", path, **kwargs)
 
     @keyword
     def patch_request(self, path, **kwargs):
-        return self._make_request('PATCH', path, **kwargs)
+        return self._make_request("PATCH", path, **kwargs)
 
     @keyword
     def delete_request(self, path, **kwargs):
-        return self._make_request('DELETE', path, **kwargs)
+        return self._make_request("DELETE", path, **kwargs)