Method saveModule

src/Interpreters/WasmModuleManager.cpp:157–192

WasmModuleManager::~WasmModuleManager() = default;

void WasmModuleManager::saveModule(std::string_view module_name, std::string_view wasm_code, UInt256 expected_hash)
{
    if (auto res = checkValidWasmCode(module_name, wasm_code); !res)
        throw Exception(std::move(res.error()), ErrorCodes::INCORRECT_DATA);

    UInt256 actual_hash = calculateHash(wasm_code);
    if (expected_hash && actual_hash != expected_hash)
        throw Exception(ErrorCodes::INCORRECT_DATA,
            "Hash mismatch for WebAssembly module '{}', expected {}, got {}",
            module_name, hashToHex(expected_hash), hashToHex(actual_hash));

    UniqueLock lock(modules_mutex);
    auto it = modules.find(module_name);
    if (it != modules.end())
    {
        UInt256 existing_hash = it->second.hash;
        if (!existing_hash)
        {
            existing_hash = calculateHash(loadModuleImpl(module_name));
            it->second.hash = existing_hash;
        }

        if (existing_hash == actual_hash)
        {
            LOG_DEBUG(log, "WebAssembly module '{}' with the same hash already exists, skipping saving", module_name);
            return;
        }
        throw Exception(ErrorCodes::FILE_ALREADY_EXISTS, "WebAssembly module '{}' already exists", module_name);
    }

    auto out_buf = user_scripts_disk->writeFile(getFilePath(module_name), DBMS_DEFAULT_BUFFER_SIZE, WriteMode::Rewrite, {});
    out_buf->write(wasm_code.data(), wasm_code.size());
    out_buf->finalize();

    modules.emplace(String(module_name), ModuleRef{{}, actual_hash});
}


static void linkHostFunctions(WasmModule & module)