Method loadModuleAsyncInner

valdi/src/valdi/runtime/Resources/ResourceManager.cpp:496–549

}

void ResourceManager::loadModuleAsyncInner(const StringBox& bundleName,
                                           FlatSet<StringBox>& processedModules,
                                           ResourceManagerLoadModuleType loadType,
                                           Function<void(Result<Void>)> onComplete) {
    if (processedModules.find(bundleName) != processedModules.end()) {
        onComplete(Void());
        return;
    }
    processedModules.insert(bundleName);

    auto bundle = getBundle(bundleName);
    if (!bundle->hasRemoteArchive()) {
        onComplete(Void());
        return;
    }

    auto manifest = _remoteModuleManager->getRegisteredManifest(bundleName);
    if (manifest == nullptr) {
        onComplete(Void());
        return;
    }

    auto task = Valdi::makeShared<RemoteModulePrefetchTask>();

    for (const auto& dependency : manifest->pb.dependencies()) {
        task->enter();
        loadModuleAsyncInner(StringCache::getGlobal().makeString(dependency),
                             processedModules,
                             loadType,
                             [=](auto result) { task->leave(result); });
    }

    auto includeSources = loadType == ResourceManagerLoadModuleType::Sources ||
                          loadType == ResourceManagerLoadModuleType::SourcesAndAssets;
    auto includeAssets = loadType == ResourceManagerLoadModuleType::Assets ||
                         loadType == ResourceManagerLoadModuleType::SourcesAndAssets;

    if (includeSources) {
        task->enter();
        _remoteModuleManager->loadModule(bundleName, [=](auto result) {
            if (result) {
                bundle->setLoadedArchiveIfNeeded(result.value());
            }
            task->leave(result);
        });
    }

    if (includeAssets) {
        task->enter();
        _remoteModuleManager->loadResources(bundleName, [=](auto result) { task->leave(result); });
    }

    task->notify(std::move(onComplete));
}

void ResourceManager::addListener(Valdi::IResourceManagerListener* listener) {
    std::lock_guard<Mutex> guard(_mutex);