Function TEST

tests/test_pytorch_install_proof.cpp:18–166

This test proves UV output streams correctly with a REAL large package Run with: ./build/tests/lichtfeld_tests --gtest_filter='*PyTorchInstall*'

// This test proves UV output streams correctly with a REAL large package
// Run with: ./build/tests/lichtfeld_tests --gtest_filter='*PyTorchInstall*'
TEST(PyTorchInstallProof, StreamingOutputWhileUIResponsive) {
    auto& pm = PackageManager::instance();

    if (!pm.is_uv_available()) {
        GTEST_SKIP() << "UV not available";
    }

    ASSERT_TRUE(pm.ensure_venv()) << "Failed to create venv";

    std::cout << "\n";
    std::cout << "╔════════════════════════════════════════════════════════════════╗\n";
    std::cout << "║  PROOF: Real PyTorch Installation with Streaming Output        ║\n";
    std::cout << "║  This demonstrates:                                            ║\n";
    std::cout << "║    1) Output streams in real-time (not buffered until end)     ║\n";
    std::cout << "║    2) UI remains responsive (60 FPS simulation)                ║\n";
    std::cout << "║    3) Progress bars and download status are visible            ║\n";
    std::cout << "╚════════════════════════════════════════════════════════════════╝\n";
    std::cout << std::endl;

    auto start = steady_clock::now();
    std::atomic<int> frame_count{0};
    std::atomic<int> line_count{0};
    std::atomic<bool> done{false};
    std::atomic<bool> success{false};

    // Track when each line arrives to prove streaming
    std::vector<std::pair<long, std::string>> timestamped_output;
    std::mutex output_mutex;

    bool started = pm.install_torch_async(
        "auto", "",
        [&](const std::string& line, bool is_error, bool is_line_update) {
            auto elapsed = duration_cast<milliseconds>(steady_clock::now() - start).count();
            line_count++;

            {
                std::lock_guard<std::mutex> lock(output_mutex);
                timestamped_output.emplace_back(elapsed, line);
            }

            // Format output nicely
            if (is_line_update) {
                std::cout << "\r\033[K"; // Clear line for progress updates
            }
            std::cout << "\033[36m[" << std::setw(6) << elapsed << "ms]\033[0m ";
            if (is_error) {
                std::cout << "\033[31m" << line << "\033[0m";
            } else {
                // Highlight download progress
                if (line.find("Downloading") != std::string::npos ||
                    line.find("━") != std::string::npos) {
                    std::cout << "\033[33m" << line << "\033[0m";
                } else if (line.find("Installed") != std::string::npos ||
                           line.find("+") != std::string::npos) {
                    std::cout << "\033[32m" << line << "\033[0m";
                } else {
                    std::cout << line;
                }