Method notifyAssetConsumer

valdi/src/valdi/runtime/Resources/AssetsManager.cpp:625–659

}

void AssetsManager::notifyAssetConsumer(AssetsManagerTransaction& transaction,
                                        const AssetKey& assetKey,
                                        const Ref<ManagedAsset>& managedAsset,
                                        const Ref<AssetConsumer>& assetConsumer,
                                        const Ref<LoadedAsset>& loadedAsset,
                                        const std::optional<Error>& error) {
    auto observable = managedAsset->getObservable();
    assetConsumer->setNotified(true);
    transaction.releaseLock();

    std::optional<StringBox> errorStringBox;
    if (error) {
        auto errorString = error.value().toStringBox();
        VALDI_WARN(_logger, "Notifying error for consumer of Asset '{}': {}", assetKey, errorString);
        errorStringBox = {errorString};
    }

    // Default to sending the asset as-is
    Value assetValue = Value(loadedAsset);

    // Convert BytesAsset to ValueTypedArray for proper JavaScript marshalling
    // Only do this for assets loaded with BYTES output type
    if (loadedAsset != nullptr && assetConsumer->getOutputType() == snap::valdi_core::AssetOutputType::Bytes) {
        // This was loaded as a bytes asset, try to get bytes content
        auto bytesContentResult = loadedAsset->getBytesContent();
        if (bytesContentResult) {
            // Wrap in ValueTypedArray so JS receives a Uint8Array
            assetValue = Value(makeShared<ValueTypedArray>(TypedArrayType::Uint8Array, bytesContentResult.value()));
        }
    }

    assetConsumer->getObserver()->onLoad(observable, assetValue, errorStringBox);

    transaction.acquireLock();
}

void AssetsManager::updateConsumerRequestHandler(const Ref<AssetConsumer>& assetConsumer,
                                                 const Ref<AssetLoaderRequestHandler>& request) {