Junit functional upload

client/pyproject.toml

@@ -27,6 +27,7 @@ dependencies = [
     "couchbase==4.3.4",
     "cryptography==44.0.0",
     "deepdiff==8.6.1",
+    "junitparser==4.0.2",
     "netifaces==0.11.0",
     "opentelemetry-api==1.29.0",
     "opentelemetry-exporter-otlp-proto-common==1.29.0",
@@ -69,3 +70,7 @@ packages = [
 
 [tool.pytest.ini_options]
 asyncio_default_fixture_loop_scope = "session"
+# Always emit a JUnit XML next to the test invocation so the greenboard
+# fixture can read pass/fail counts from it at session-finish. Users can
+# override the path with `--junitxml=...` on the CLI; last-wins.
+addopts = "--junitxml=junit_result.xml"

client/src/cbltest/greenboarduploader.py

@@ -9,11 +9,64 @@
 from couchbase.auth import PasswordAuthenticator
 from couchbase.cluster import Cluster
 from couchbase.options import ClusterOptions
+from junitparser import JUnitXml, TestSuite
+from pydantic import BaseModel, ConfigDict, Field
 
 from cbltest.api.syncgateway import CouchbaseVersion
 from cbltest.logging import cbl_info, cbl_warning
 
 
+def count_from_junit_xml(xml_path: Path) -> tuple[int, int] | None:
+    """Return ``(passed, failed)`` summed across every ``<testsuite>`` in
+    a JUnit XML file at ``xml_path``, or ``None`` if the file is missing or
+    can't be parsed.
+
+    ``passed = tests - failures - errors - skipped``; ``failed`` lumps
+    failures and errors together (the greenboard doc only carries a single
+    fail bucket). Used by the greenboard pytest fixture to derive upload
+    counts from pytest's ``--junitxml`` output instead of in-process
+    hook-driven counters.
+    """
+    xml_path = Path(xml_path)
+    if not xml_path.is_file():
+        return None
+    try:
+        xml = JUnitXml.fromfile(str(xml_path))
+    except Exception as e:
+        cbl_warning(f"Failed to parse JUnit XML {xml_path}: {e}")
+        return None
+
+    total_pass = 0
+    total_fail = 0
+    suites = list(xml) if isinstance(xml, JUnitXml) else [xml]
+    for suite in suites:
+        if not isinstance(suite, TestSuite):
+            continue
+        tests = suite.tests or 0
+        failures = suite.failures or 0
+        errors = suite.errors or 0
+        skipped = suite.skipped or 0
+        total_pass += max(0, tests - failures - errors - skipped)
+        total_fail += failures + errors
+    return total_pass, total_fail
+
+
+class RunResult(BaseModel):
+    """
+    Store the information for a test run in greenboard
+    """
+
+    model_config = ConfigDict(populate_by_name=True)
+
+    build: int  # build number of CBL build
+    version: str  # major.minor.patch version of CBL
+    sgw_version: str = Field(alias="sgwVersion")  # Sync Gateway version, optional
+    fail_count: int = Field(alias="failCount")  # number of failing tests
+    pass_count: int = Field(alias="passCount")  # number of passing tests
+    platform: str  # CBL platform
+    os: str  # Operating system for CBL
+
+
 class GreenboardUploader:
     """
     A class for uploading results to a specified greenboard server bucket.
@@ -75,6 +128,9 @@ def upload(
         os_name: str,
         version: str,
         sgw_version: CouchbaseVersion | None,
+        *,
+        pass_count: int | None = None,
+        fail_count: int | None = None,
     ):
         """
         Uploads the results using the specified platform and version.  The reason that they
@@ -84,11 +140,21 @@ def upload(
         :param platform: The platform name (e.g. couchbase-lite-net) as specified by the test server
         :param version: The version string (e.g. 3.2.0-b0136, etc) as specified by the test server
         :param sgw_version: The parsed SGW CouchbaseVersion object, or None if unavailable
+        :param pass_count: Optional override for the pass count. When ``None``
+            (default), uses the in-process counter populated by
+            :py:meth:`pytest_runtest_makereport`. When provided (e.g. the
+            greenboard fixture derived counts from a JUnit XML), the supplied
+            value is used instead.
+        :param fail_count: Optional override for the fail count. Same
+            semantics as ``pass_count``.
         """
         if self.__overall_fail:
             cbl_warning("Overall result is failure, skipping upload...")
             return
 
+        resolved_pass = pass_count if pass_count is not None else self.__pass_count
+        resolved_fail = fail_count if fail_count is not None else self.__fail_count
+
         parsed_version = "0.0.0"
         parsed_build = 0
         sgw_version_str = "n/a"
@@ -122,15 +188,15 @@ def upload(
                     cbl_warning(f"Could not parse build number from '{version}'")
 
         self._upload_document(
-            {
-                "build": parsed_build,
-                "version": parsed_version,
-                "sgwVersion": sgw_version_str,
-                "failCount": self.__fail_count,
-                "passCount": self.__pass_count,
-                "platform": platform,
-                "os": os_name,
-            }
+            RunResult(
+                build=parsed_build,
+                version=parsed_version,
+                sgwVersion=sgw_version_str,
+                failCount=resolved_fail,
+                passCount=resolved_pass,
+                platform=platform,
+                os=os_name,
+            )
         )
 
     def record_upgrade_step(
@@ -288,7 +354,7 @@ def upload_upgrade_batch(self, results_file: str) -> None:
             # `build` fields preserve what was actually running at each step.
             target_build = 0
 
-        self._upload_document(
+        self._upsert(
             {
                 "build": target_build,
                 "version": target_version,
@@ -306,13 +372,17 @@ def upload_upgrade_batch(self, results_file: str) -> None:
             f"failedAt={failed_at}"
         )
 
-    def _upload_document(self, doc: dict) -> None:
-        """Upload a document to the greenboard bucket with common fields added."""
+    def _upload_document(self, test_run: RunResult) -> None:
+        self._upsert(test_run.model_dump(by_alias=True))
+
+    def _upsert(self, doc: dict) -> None:
+        """Add timestamp fields and write one document to the greenboard bucket."""
         now = datetime.now(timezone.utc)
         unix_timestamp = (
             now - datetime(1970, 1, 1, tzinfo=timezone.utc)
         ).total_seconds()
 
+        # Do not add to RunResult since this code will go away shortly
         doc["uploaded"] = unix_timestamp
         doc["date"] = now.strftime("%Y-%m-%d")
 

client/src/cbltest/plugins/greenboard_fixture.py

@@ -1,10 +1,11 @@
 import os
+from pathlib import Path
 
 import pytest
 import pytest_asyncio
 from cbltest import CBLPyTest
 from cbltest.api.syncgateway import CouchbaseVersion
-from cbltest.greenboarduploader import GreenboardUploader
+from cbltest.greenboarduploader import GreenboardUploader, count_from_junit_xml
 from cbltest.logging import cbl_info, cbl_warning
 
 # This plugin provides an automatic (i.e. not used directly by tests)
@@ -97,7 +98,39 @@ async def greenboard(cblpytest: CBLPyTest, pytestconfig: pytest.Config):
                     os_name = test_server_info.device["systemName"]
             if len(cblpytest.sync_gateways) > 0:
                 sgw_version = await cblpytest.sync_gateways[0].get_version()
-            uploader.upload(test_platform, os_name, library_version, sgw_version)
+
+            # Prefer JUnit XML for pass/fail counts when pytest wrote one
+            # (--junitxml is set by default via pyproject.toml's addopts).
+            # If the XML is missing or unparseable, fall through to the
+            # in-process counter populated by the uploader's
+            # pytest_runtest_makereport hook.
+            xmlpath = getattr(pytestconfig.option, "xmlpath", None)
+            counts = count_from_junit_xml(Path(xmlpath)) if xmlpath else None
+
+            if counts is not None:
+                junit_pass, junit_fail = counts
+                if junit_pass + junit_fail == 0:
+                    cbl_info(
+                        "Greenboard: JUnit XML reports zero tests; skipping upload"
+                    )
+                    return
+                if junit_pass == 0:
+                    cbl_info(
+                        f"Greenboard: all tests failed (failCount={junit_fail}); "
+                        "skipping upload per policy"
+                    )
+                    return
+                uploader.upload(
+                    test_platform,
+                    os_name,
+                    library_version,
+                    sgw_version,
+                    pass_count=junit_pass,
+                    fail_count=junit_fail,
+                )
+            else:
+                # No usable JUnit XML — fall back to the in-process counter.
+                uploader.upload(test_platform, os_name, library_version, sgw_version)
     except Exception as e:
         cbl_warning(f"Failed to upload results to Greenboard: {e}")
     finally: