Method AttachConsole

src/client/client.cpp:288–361

}

int Client::AttachConsole(const std::string& vm_id) const {
    auto conn = ipc::UnixSocketClient::Connect(socket_path_);
    if (!conn.IsValid()) {
        std::cerr << "failed to connect to " << socket_path_ << "\n";
        return 1;
    }

    if (!WriteJsonLine(conn, {{"type", "vm.console.attach"}, {"vm_id", vm_id}})) {
        std::cerr << "failed to send console attach request\n";
        return 1;
    }

    std::string first = conn.ReadLine();
    auto response = nlohmann::json::parse(first, nullptr, false);
    if (response.is_discarded() || !response.value("ok", false)) {
        std::cerr << (response.is_object() ? response.value("error", "console attach failed")
                                           : "console attach failed")
                  << "\n";
        return 1;
    }

    std::cerr << "Attached to " << vm_id << ". Press Ctrl-] to detach.\n";
    RawTerminal raw;

    while (true) {
        while (conn.HasBufferedLine()) {
            auto event = nlohmann::json::parse(conn.ReadLine(), nullptr, false);
            if (!event.is_discarded()) {
                if (event.value("type", "") == "console.closed") {
                    PrintDetached(raw);
                    return 0;
                }
                HandleConsoleEvent(event);
            }
        }

        pollfd fds[2] = {
            {.fd = STDIN_FILENO, .events = POLLIN, .revents = 0},
            {.fd = conn.fd(), .events = POLLIN, .revents = 0},
        };
        const int rc = ::poll(fds, 2, -1);
        if (rc <= 0) continue;

        if (fds[0].revents & POLLIN) {
            char buf[4096];
            const ssize_t n = ::read(STDIN_FILENO, buf, sizeof(buf));
            if (n <= 0) break;
            if (n == 1 && buf[0] == 0x1d) break;  // Ctrl-]
            const std::string input = StripHostTerminalResponses(buf, static_cast<size_t>(n));
            if (input.empty()) continue;
            if (!WriteJsonLine(conn, {
                    {"type", "console.input"},
                    {"vm_id", vm_id},
                    {"data_hex", BytesToHex(input.data(), input.size())},
                })) {
                break;
            }
        }