Update logic to conform OSV 0.8 format used now

thoth-station · Sep 14, 2021 · d8887b1 · d8887b1
1 parent 7cc59c9
commit d8887b1
Showing 1 changed file with 41 additions and 35 deletions.
diff --git a/app.py b/app.py
@@ -95,44 +95,50 @@ def _record_vulnerability(
     """Record the given vulnerability in the database."""
     _LOGGER.info("Creating CVE entries for %r...", vulnerability["id"])
 
-    if not vulnerability["affects"].get("versions"):
-        _LOGGER.warning("No versions found for CVE %r", vulnerability["id"])
-        return 0
-
-    package_name = vulnerability["package"]["name"]
     cve_id = vulnerability["id"]
-    for package_version in vulnerability["affects"]["versions"]:
-        existed = graph.create_python_cve_record(
-            package_name,
-            package_version,
-            "https://pypi.org/simple",
-            cve_id=cve_id,
-            details=vulnerability["details"],
-        )
-
-        if existed:
+    for affected in vulnerability.get("affected") or []:
+        if affected["package"]["ecosystem"] != "PyPI":
+            _LOGGER.info(
+                "Skipping affected package %r from ecosystem %r",
+                affected["package"]["name"],
+                affected["package"]["ecosystem"],
+            )
             continue
 
-        _LOGGER.info(
-            "Created new CVE %r entry for package %r in version %r",
-            cve_id,
-            package_name,
-            package_version,
-        )
-
-        publish_to_topic(
-            _PRODUCER,
-            cve_provided_message,
-            CVEProvidedMessageContent(
-                component_name=_COMPONENT_NAME,
-                service_version=__component_version__,
-                package_name=package_name,
-                package_version=package_version,
-                index_url="https://pypi.org/simple",
-            ),
-        )
-
-        cve_messages_sent += 1
+        package_name = affected["package"]["name"]
+
+        for package_version in affected.get("versions") or []:
+            existed = graph.create_python_cve_record(
+                package_name,
+                package_version,
+                "https://pypi.org/simple",
+                cve_id=cve_id,
+                details=vulnerability["details"],
+            )
+
+            if existed:
+                continue
+
+            _LOGGER.info(
+                "Created new CVE %r entry for package %r in version %r",
+                cve_id,
+                package_name,
+                package_version,
+            )
+
+            publish_to_topic(
+                _PRODUCER,
+                cve_provided_message,
+                CVEProvidedMessageContent(
+                    component_name=_COMPONENT_NAME,
+                    service_version=__component_version__,
+                    package_name=package_name,
+                    package_version=package_version,
+                    index_url="https://pypi.org/simple",
+                ),
+            )
+
+            cve_messages_sent += 1
 
     return cve_messages_sent