remove the run_command

Author: joyguoguo

fuzz/build_fuzz.py

@@ -36,46 +36,6 @@
 from errors import BuildError, CommandError, PathError, ConfigError
 from command_util import run_command_build_fuzz as run_command
 
-
-
-# ========================================================================================
-# Helper Functions
-# ========================================================================================
-def run_command(
-    cmd: str,
-    oss_fuzz_dir: Path,
-    project: str = "",
-    allowed_exit_codes: Maybe[list[int]] = Maybe.empty,
-    skip_yes: bool = False
-) -> int:
-    """Execute a command and return the exit code (no stdout/stderr capture)"""
-    allowed_codes = allowed_exit_codes.value_or([0])
-    cmd_str = f"yes | {cmd}" if not skip_yes else cmd
-    logging.debug(f"Executing command [{project}]: {cmd_str}")
-
-    try:
-        process = subprocess.Popen(
-            cmd_str,
-            shell=True,
-            cwd=str(oss_fuzz_dir)
-        )
-        exit_code = process.wait()
-
-        if exit_code in allowed_codes:
-            return exit_code
-
-        error_msg = f"Command failed (exit code: {exit_code})"
-        if project:
-            error_msg += f" for project: {project}"
-        raise CommandError(error_msg, project=project, exit_code=exit_code)
-
-    except FileNotFoundError as e:
-        raise CommandError(f"Command not found: {cmd.split()[0]}", project=project) from e
-    except OSError as e:
-        raise CommandError(f"System error: {e}", project=project) from e
-    except subprocess.SubprocessError as e:
-        raise CommandError(f"Subprocess error: {e}", project=project) from e
-
 # ========================================================================================
 # Build Functions
 # ========================================================================================

fuzz/run_fuzz_all_targets_print1.py

@@ -29,76 +29,6 @@
 
 
 
-
-def run_command(
-    cmd: str,
-    log_msg: str,
-    logger: logging.Logger,
-    allowed_exit_codes: Maybe[list[int]] = Nothing,
-    timeout: int = 3600  # Default 1-hour timeout
-) -> bool:
-    """Execute commands with real-time logging and precise error handling"""
-    allowed_codes = allowed_exit_codes.value_or([])
-    logger.info(f"▶️ {log_msg}...")
-    logger.debug(f"   $ {cmd}")
-
-    process = None
-    try:
-        process = subprocess.Popen(
-            cmd,
-            shell=True,
-            stdout=subprocess.PIPE,
-            stderr=subprocess.STDOUT,
-            text=True,
-            encoding="utf-8",
-            errors="replace"
-        )
-
-        start_time = time.time()
-        while process.poll() is None:
-            if time.time() - start_time > timeout:
-                logger.error(f"⌛ Command timed out after {timeout} seconds")
-                process.terminate()
-                try:
-                    process.wait(timeout=5)
-                except subprocess.TimeoutExpired:
-                    process.kill()
-                return False
-
-            if process.stdout:
-                line = process.stdout.readline()
-                if line:
-                    logger.debug(line.strip())
-            else:
-                time.sleep(0.1)
-
-        exit_code = process.returncode
-        if exit_code not in [0, *allowed_codes]:
-            logger.error(f"❌ Command execution failed, exit code: {exit_code}")
-            return False
-        return True
-
-    except FileNotFoundError:
-        logger.error(f"🔍 Command not found: {cmd.split()[0]}")
-        return False
-    except PermissionError:
-        logger.error(f"🔒 Insufficient permissions to execute command: {cmd}")
-        return False
-    except subprocess.SubprocessError as e:
-        logger.exception(f"💥 Subprocess error: {e}")
-        return False
-    except OSError as e:
-        logger.exception(f"💥 Operating system error during command execution: {e}")
-        return False
-    finally:
-        if process and process.poll() is None:
-            try:
-                process.terminate()
-                process.wait(timeout=5)
-            except Exception:
-                pass
-
-
 def discover_targets(project_name: str, oss_fuzz_dir: Path, logger: logging.Logger) -> list[str]:
     """Discover fuzz targets for a project (starting with 'fuzz_', ending with 'print1', no extension, and executable)"""
     out_dir = oss_fuzz_dir / "build" / "out" / project_name