Filter test collection based on files changed in upstream PRs (Satell…

…iteQE#14931)

conf/github_repos.yaml.template

@@ -0,0 +1,17 @@
+# Upstream GitHub repos and test collection rules
+GITHUB_REPOS:
+  BASE_MARKER:
+  FOREMAN:
+    ORG: theforeman
+    REPO: foreman
+    RULES:
+     - PATH:
+       MARKER:
+       MARKER_ARG:
+  KATELLO:
+    ORG: Katello
+    REPO: katello
+    RULES:
+      - PATH:
+        MARKER:
+        MARKER_ARG:

conftest.py

@@ -25,6 +25,7 @@
     'pytest_plugins.jira_comments',
     'pytest_plugins.select_random_tests',
     'pytest_plugins.capsule_n-minus',
+    'pytest_plugins.upstream_pr',
     # Fixtures
     'pytest_fixtures.core.broker',
     'pytest_fixtures.core.sat_cap_factory',

pytest_plugins/upstream_pr.py

@@ -0,0 +1,95 @@
+from github import Github
+
+from robottelo.config import settings
+from robottelo.logging import collection_logger as logger
+
+
+def rule_match(item, rules):
+    """Return True if `item` has a marker matching one of the `rules`.
+
+    In order for a rule to match:
+    1. If `settings.github_repos.base_marker` exists, then `item` has a marker with the given value
+    as its `name` attribute.
+    2. `item` has a marker with the name given in `rule.marker`.
+    3. If `rule.marker_arg` exists, then the item's marker must also have the given value in marker's
+    `args` attribute.
+    """
+    base_marker = settings.github_repos.get('base_marker')
+    return (
+        not base_marker or any(base_marker == marker.name for marker in item.iter_markers())
+    ) and any(
+        rule.marker == marker.name
+        and (not rule.get('marker_arg') or rule.get('marker_arg') in marker.args)
+        for marker in item.iter_markers()
+        for rule in rules
+    )
+
+
+def pytest_addoption(parser):
+    """Add CLI option to specify upstream GitHub PRs.
+
+    Add --upstream-pr option for filtering tests based on the files modified by upstream
+    PRs.
+    """
+    parser.addoption(
+        "--upstream-pr",
+        help=(
+            "Comma separated list of upstream PRs to filter test collection based on files modified in upstream.\n"
+            "Usage: `pytest tests/foreman --upstream-pr foreman/10146`"
+        ),
+    )
+
+
+def pytest_collection_modifyitems(session, items, config):
+    """Filter tests based on upstream PRs.
+    1. Get the list of modified files in the upstream PRs.
+    2. Map each file to at most one marker.
+    3. Filter the collected tests to include only those with matching markers.
+
+    If no rules were matched above, all tests will be deselected.
+    Filenames that did not match any rules are ignored.
+    """
+    if not (
+        upstream_prs := [
+            pr_info for pr_info in (config.getoption('upstream_pr') or '').split(',') if pr_info != ''
+        ]
+    ):
+        return
+
+    matched_rules = []
+
+    for pr_info in upstream_prs:
+        repo_key, pr_id = pr_info.split('/')
+        if not (repo_config := settings.github_repos.get(repo_key)):
+            raise Exception(f"Key {repo_key} not found in settings file.")
+
+        # Get list of filenames modified by this PR
+        pr = Github().get_repo(f"{repo_config.org}/{repo_config.repo}").get_pull(int(pr_id))
+        pr_filenames = {file.filename for file in pr.get_files()}
+
+        # Get list of matching rules
+        unprocessed_filenames = pr_filenames.copy()
+        for rule in repo_config.rules:
+            if matched_filenames := {
+                filename for filename in unprocessed_filenames if filename.startswith(rule.path)
+            }:
+                matched_rules.append(rule)
+                unprocessed_filenames.difference_update(matched_filenames)
+
+    # If no rules were matched above, deselect all tests.
+    # Filenames that didn't match any rules are ignored.
+    selected = []
+    deselected = []
+    for item in items:
+        if matched_rules:
+            if rule_match(item, matched_rules):
+                selected.append(item)
+            else:
+                logger.debug(f'Deselected test {item.nodeid} due to PR filter {upstream_prs}')
+                deselected.append(item)
+        else:
+            logger.debug(f'Deselected test {item.nodeid} due to PR filter {upstream_prs}')
+            deselected.append(item)
+
+    config.hook.pytest_deselected(items=deselected)
+    items[:] = selected

requirements.txt

@@ -11,6 +11,7 @@ jinja2==3.1.4
 manifester==0.2.5
 navmazing==1.2.2
 productmd==1.38
+PyGithub==2.3.0
 pyotp==2.9.0
 python-box==7.2.0
 pytest==8.2.2

robottelo/config/validators.py

@@ -151,6 +151,15 @@
             must_exist=True,
         ),
     ],
+    github_repos=[
+        Validator('github_repos.base_marker', default=None),
+        Validator('github_repos.foreman.org', default='theforeman'),
+        Validator('github_repos.foreman.repo', default='foreman'),
+        Validator('github_repos.foreman.rules', default=[], is_type_of=list),
+        Validator('github_repos.katello.org', default='Katello'),
+        Validator('github_repos.katello.repo', default='katello'),
+        Validator('github_repos.katello.rules', default=[], is_type_of=list),
+    ],
     http_proxy=[
         Validator(
             'http_proxy.un_auth_proxy_url',