Method HandleRequest

src/daemon/rpc_server.cpp:182–302

}

nlohmann::json RpcServer::HandleRequest(const nlohmann::json& request) {
    const std::string type = request.value("type", "");
    if (type == "doctor") {
        return Ok(ToJson(RunKvmDoctor()));
    }
    if (type == "system.info") {
        return Ok({
            {"data_dir", config_.data_dir},
            {"socket_path", config_.socket_path},
            {"runtime_path", config_.runtime_path},
            {"resources", ToJson(ReadHostResources(config_.data_dir))},
            {"doctor", ToJson(RunKvmDoctor())},
        });
    }
    if (type == "vm.list") {
        nlohmann::json vms = nlohmann::json::array();
        for (const auto& vm : store_.List()) {
            auto item = ToJson(vm);
            item["resources"] = VmResources(vm);
            vms.push_back(std::move(item));
        }
        return Ok({{"vms", std::move(vms)}});
    }
    if (type == "vm.create") {
        return CreateVm(request);
    }
    if (type == "vm.edit") {
        return EditVm(request);
    }
    if (type == "vm.delete") {
        const std::string vm_id = request.value("vm_id", "");
        // Stop the runtime first so qemu/runtime stops touching the vm_dir
        // before we tear it down; otherwise the child process keeps writing
        // logs and VmStore::UpdateRuntime keeps emitting runtime_state.json,
        // racing the directory removal and resurrecting an orphan dir.
        if (auto record = store_.Get(vm_id); record &&
            (record->runtime.state == VmState::kRunning ||
             record->runtime.state == VmState::kStarting ||
             record->runtime.state == VmState::kStopping ||
             record->runtime.state == VmState::kRebooting)) {
            std::string stop_error;
            runtime_manager_.StopVm(vm_id, &stop_error);
            const auto deadline = std::chrono::steady_clock::now() + std::chrono::seconds(5);
            while (std::chrono::steady_clock::now() < deadline) {
                auto current = store_.Get(vm_id);
                if (!current || current->runtime.state == VmState::kStopped ||
                    current->runtime.state == VmState::kCrashed) {
                    break;
                }
                std::this_thread::sleep_for(std::chrono::milliseconds(50));
            }
        }
        std::string error;
        if (!store_.Remove(vm_id, &error)) return Error("vm_delete_failed", error);
        return Ok();
    }
    if (type == "vm.start") {
        const std::string vm_id = request.value("vm_id", "");