fix(scanner): decode rg/git output as utf-8 with replacement

dsgai_scanner_tool/cli/dsgai_scan.py

@@ -90,7 +90,7 @@ def find_rg():
 
 def rg_supports_pcre2(rg):
     try:
-        out = subprocess.run([rg, "--pcre2-version"], capture_output=True, text=True)
+        out = subprocess.run([rg, "--pcre2-version"], capture_output=True, text=True, encoding="utf-8", errors="replace")
         return out.returncode == 0
     except Exception:
         return False
@@ -156,13 +156,13 @@ def _sensitive_walk_files(target):
 def _git_files(target):
     try:
         top = subprocess.run(["git", "-C", target, "rev-parse", "--show-toplevel"],
-                             capture_output=True, text=True)
+                             capture_output=True, text=True, encoding="utf-8", errors="replace")
         if top.returncode != 0:
             return None
         res = subprocess.run(
             ["git", "-C", target, "ls-files", "--cached", "--others",
              "--exclude-standard", "-z", "--", "."],
-            capture_output=True, text=True)
+            capture_output=True, text=True, encoding="utf-8", errors="replace")
         if res.returncode != 0:
             return None
         rels = [p for p in res.stdout.split("\0") if p]
@@ -225,7 +225,7 @@ def _run_rg(rg, base_cmd, files, scan_root, rid):
     for batch in _batches(files):
         cmd = base_cmd + [f[0] for f in batch]
         try:
-            proc = subprocess.run(cmd, capture_output=True, text=True, cwd=scan_root)
+            proc = subprocess.run(cmd, capture_output=True, text=True, encoding="utf-8", errors="replace", cwd=scan_root)
         except OSError as exc:  # e.g. arg list too long on a pathological path
             raise RuntimeError(f"rg invocation failed for {rid}: {exc}")
         if proc.returncode >= 2:
@@ -384,7 +384,7 @@ def now_iso():
 def git_commit(target):
     try:
         r = subprocess.run(["git", "-C", os.path.abspath(target), "rev-parse", "HEAD"],
-                           capture_output=True, text=True)
+                           capture_output=True, text=True, encoding="utf-8", errors="replace")
         return r.stdout.strip() if r.returncode == 0 else None
     except Exception:
         return None
@@ -437,7 +437,7 @@ def checkpoint_is_valid(cp, target, current_ruleset_version):
         return False
     try:
         r = subprocess.run(["git", "-C", os.path.abspath(target), "status", "--porcelain"],
-                           capture_output=True, text=True)
+                           capture_output=True, text=True, encoding="utf-8", errors="replace")
         if r.returncode != 0 or r.stdout.strip():
             return False  # dirty working tree
     except Exception:
@@ -565,7 +565,7 @@ def diff_files(target, ref):
     """Return the set of rel paths changed vs `ref` (git). None if unavailable."""
     try:
         r = subprocess.run(["git", "-C", os.path.abspath(target), "diff",
-                            "--name-only", ref], capture_output=True, text=True)
+                            "--name-only", ref], capture_output=True, text=True, encoding="utf-8", errors="replace")
         if r.returncode != 0:
             return None
         return {p.strip().replace("/", os.sep) for p in r.stdout.splitlines() if p.strip()}
@@ -709,7 +709,7 @@ def cmd_doctor(args):
     rg = find_rg()
     print(f"ripgrep: {'found at ' + rg if rg else 'NOT FOUND'}")
     if rg:
-        v = subprocess.run([rg, "--version"], capture_output=True, text=True)
+        v = subprocess.run([rg, "--version"], capture_output=True, text=True, encoding="utf-8", errors="replace")
         print("  " + v.stdout.splitlines()[0])
         pcre = rg_supports_pcre2(rg)
         print(f"  PCRE2 support: {'yes' if pcre else 'NO'}")

dsgai_scanner_tool/tests/test_runner.py

@@ -408,6 +408,23 @@ def test_report_no_path_leak_on_filemap_miss(tmp_path):
     assert "<script>" not in rendered               # line escaped
 
 
+@requires_rg
+def test_scan_survives_non_utf8_bytes(tmp_path):
+    """A repo file with bytes not decodable as the platform default must not
+    crash the scanner (found by the benchmark; the ASCII fixture never hit it)."""
+    repo = tmp_path / "r"
+    repo.mkdir()
+    # P13.3 (host ... 0.0.0.0) matches this line; -o will emit the 0x8f byte.
+    (repo / "x.py").write_bytes(b'host = "\x8f\x9f-bad-bytes" 0.0.0.0\n')
+    out = tmp_path / "s.json"
+    proc = subprocess.run([sys.executable, CLI, "scan", str(repo), "--no-cve",
+                           "--json-out", str(out), "--format", "none"],
+                          capture_output=True, text=True, encoding="utf-8",
+                          errors="replace")
+    assert proc.returncode in (0, 1), f"scanner crashed on non-UTF-8 input: {proc.stderr}"
+    assert out.exists()
+
+
 def test_rules_json_in_sync():
     from_yaml = yaml.safe_load(open(RULES_YAML, encoding="utf-8"))
     rebuilt = json.dumps(from_yaml, indent=2, sort_keys=True, ensure_ascii=False) + "\n"