Function run_decode_autoresearch

ci/autoresearch/decode.py:268–363

Run decode autoresearch on a local file or URL (host-only mode). Args: decode_path: Local file path or URL to a media file. Returns: Exit code (0 = success, 1 = failure).

(decode_path: str)

async def run_decode_autoresearch(decode_path: str) -> int:
    """Run decode autoresearch on a local file or URL (host-only mode).

    Args:
        decode_path: Local file path or URL to a media file.

    Returns:
        Exit code (0 = success, 1 = failure).
    """
    print()
    print("=" * 60)
    print("DECODE AUTORESEARCH MODE")
    print("=" * 60)
    print()

    temp_download: str | None = None

    try:
        # Resolve the file
        resolved = _resolve_file(decode_path)
        file_path = resolved.file_path
        ext = resolved.extension
        temp_download = resolved.temp_download_path

        # Validate extension
        if ext not in SUPPORTED_EXTENSIONS:
            supported = ", ".join(sorted(SUPPORTED_EXTENSIONS.keys()))
            print(
                f"{Fore.RED}Error: Unsupported file extension '{ext}'{Style.RESET_ALL}"
            )
            print(f"  Supported: {supported}")
            return 1

        # Validate file exists
        if not os.path.isfile(file_path):
            print(f"{Fore.RED}Error: File not found: {file_path}{Style.RESET_ALL}")
            return 1

        codec_name = SUPPORTED_EXTENSIONS[ext]
        file_size = os.path.getsize(file_path)
        print(f"  File:  {file_path}")
        print(f"  Size:  {file_size:,} bytes")
        print(f"  Codec: {codec_name}")
        print()

        # Read file and base64-encode into JSON-RPC payload
        with open(file_path, "rb") as f:
            file_bytes = f.read()

        payload_json = _build_jsonrpc_payload(file_bytes, ext)

        # Write payload to well-known path (C++ test reads this by default)
        project_root = Path(__file__).resolve().parent.parent
        payload_file = project_root / PAYLOAD_PATH
        payload_file.parent.mkdir(parents=True, exist_ok=True)
        payload_file.write_text(payload_json, encoding="utf-8")

        b64_size = len(base64.b64encode(file_bytes))