Method registerExistingModules

src/Interpreters/WasmModuleManager.cpp:323–349

}

void WasmModuleManager::registerExistingModules()
{
    UniqueLock lock(modules_mutex);
    LOG_DEBUG(log, "Loading WASM modules from '{}/{}' at disk '{}'", user_scripts_disk->getPath(), user_scripts_path, user_scripts_disk->getName());

    auto files_it = user_scripts_disk->iterateDirectory(user_scripts_path);
    for (; files_it->isValid(); files_it->next())
    {
        const auto & file_path = files_it->path();
        const auto & file_name = files_it->name();
        auto res = validateModuleFile(user_scripts_disk, file_path);
        if (!res)
        {
            LOG_DEBUG(log, "Ignoring file '{}' which is not a valid WASM module: {}", file_path, res.error().text);
            continue;
        }

        auto [_, inserted] = modules.insert({res.value(), {}});
        if (!inserted)
        {
            LOG_DEBUG(log, "Ignoring file '{}' with duplicate module name", file_path);
            continue;
        }
    }

    LOG_DEBUG(log, "Found {} WASM modules", modules.size());
}

std::string WasmModuleManager::getFilePath(std::string_view module_name) const
{