Moved check_docker_command to utils.py and update the pipelines.rst #1767

Signed-off-by: Chin Yeung Li <tli@nexb.com>

Author: chinyeungli

docs/built-in-pipelines.rst

@@ -273,6 +273,12 @@ Scan Maven Package
     :members:
     :member-order: bysource
 
+Scan Rust Package
+-------------------
+.. autoclass:: scanpipe.pipelines.scan_rust_package.ScanRustPackage()
+    :members:
+    :member-order: bysource
+
 Fetch Scores (addon)
 --------------------
 .. warning::

scanpipe/pipelines/scan_rust_package.py

@@ -20,7 +20,6 @@
 # ScanCode.io is a free software code scanning tool from nexB Inc. and others.
 # Visit https://github.com/aboutcode-org/scancode.io for support and download.
 
-import shutil
 import tempfile
 from pathlib import Path
 
@@ -87,9 +86,11 @@ def collect_input_info(self):
         self.collect_input_information()
 
     def check_docker_command(self):
-        """Check if the Docker command is available."""
         self.have_docker = False
-        if shutil.which("docker"):
+        """Check if the Docker command is available."""
+        if not utils.check_docker_command():
+            raise Exception("Docker is required and its daemon must be running.")
+        else:
             self.have_docker = True
 
     def get_cargo_toml(self):

scanpipe/pipes/utils.py

@@ -23,11 +23,14 @@
 import hashlib
 import logging
 import os
+import requests
+import shutil
+import subprocess
+
 from fnmatch import fnmatch
 from pathlib import Path
 from urllib.parse import urlparse
 
-import requests
 from license_expression import Licensing
 from packageurl import PackageURL
 from packageurl.contrib.purl2url import get_repo_download_url_by_package_type
@@ -519,3 +522,15 @@ def fetch_path(purl):
     except (ValueError, requests.RequestException) as e:
         logger.warning("Failed to fetch package: %s - %s", purl, e)
         return None
+
+def check_docker_command():
+    """Check if the Docker command is available and the daemon is running."""
+    docker_path = shutil.which("docker")
+    if not docker_path:
+        return False
+
+    try:
+        subprocess.run([docker_path, "info"], capture_output=True, check=True)  # noqa: S603
+        return True
+    except (subprocess.SubprocessError, FileNotFoundError):
+        return False