Method HandleClient

src/daemon/rpc_server.cpp:146–180

}

void RpcServer::HandleClient(ipc::UnixSocketConnection client) {
    pthread_setname_np(pthread_self(), "rpc-handler");
    const std::string line = client.ReadLine();
    if (line.empty()) return;
    auto request = nlohmann::json::parse(line, nullptr, false);
    if (request.is_discarded()) {
        auto response = Error("bad_json", "request is not valid JSON").dump() + "\n";
        (void)client.Send(response);
        return;
    }

    if (request.value("type", "") == "vm.console.attach") {
        std::string error;
        if (!runtime_manager_.AttachConsole(request.value("vm_id", ""), &client, &error)) {
            auto response = Error("console_attach_failed", error).dump() + "\n";
            (void)client.Send(response);
            return;
        }
        return;
    }

    if (request.value("type", "") == "vm.logs.follow") {
        std::string error;
        if (!runtime_manager_.AttachLogFollower(request.value("vm_id", ""), &client, &error)) {
            auto response = Error("logs_follow_failed", error).dump() + "\n";
            (void)client.Send(response);
            return;
        }
        return;
    }

    auto response = HandleRequest(request).dump();
    response.push_back('\n');
    (void)client.Send(response);
}

nlohmann::json RpcServer::HandleRequest(const nlohmann::json& request) {
    const std::string type = request.value("type", "");