keket 0.20.3

Database-like Asset management on top of ECS storage
Documentation
use crate::{
    database::path::{AssetPath, AssetPathStatic},
    fetch::AssetFetch,
};
use anput::{bundle::DynamicBundle, world::World};
use std::error::Error;

/// A wrapper for `AssetFetch` implementations that provides fallback assets
/// to use when fetching primary assets fails.
pub struct FallbackAssetFetch<Fetch: AssetFetch> {
    fetch: Fetch,
    /// A list of fallback asset paths to try if the primary fetch fails.
    pub assets: Vec<AssetPathStatic>,
}

impl<Fetch: AssetFetch> FallbackAssetFetch<Fetch> {
    /// Creates a new `FallbackAssetFetch` with the given fetch implementation.
    ///
    /// # Arguments
    /// - `fetch`: The primary `AssetFetch` implementation to use.
    ///
    /// # Returns
    /// - A new `FallbackAssetFetch` instance.
    pub fn new(fetch: Fetch) -> Self {
        Self {
            fetch,
            assets: Default::default(),
        }
    }

    /// Adds a fallback asset path to the list of paths to try.
    ///
    /// # Arguments
    /// - `path`: The asset path to add as a fallback.
    ///
    /// # Returns
    /// - The updated `FallbackAssetFetch` instance.
    pub fn path(mut self, path: impl Into<AssetPathStatic>) -> Self {
        self.assets.push(path.into());
        self
    }
}

impl<Fetch: AssetFetch> AssetFetch for FallbackAssetFetch<Fetch> {
    fn load_bytes(&self, path: AssetPath) -> Result<DynamicBundle, Box<dyn Error>> {
        let mut status = self.fetch.load_bytes(path.clone());
        if status.is_err() {
            for asset in &self.assets {
                if asset.protocol() == path.protocol() {
                    status = self.fetch.load_bytes(asset.clone());
                    if status.is_ok() {
                        break;
                    }
                }
            }
        }
        status
    }

    fn maintain(&mut self, storage: &mut World) -> Result<(), Box<dyn Error>> {
        self.fetch.maintain(storage)
    }
}