keket 0.20.3

Database-like Asset management on top of ECS storage
Documentation 
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57

use keket::{
    database::{AssetDatabase, events::AssetEventBindings},
    fetch::file::FileAssetFetch,
    protocol::{
        bundle::BundleAssetProtocol, bytes::BytesAssetProtocol, group::GroupAssetProtocol,
        text::TextAssetProtocol,
    },
};
use serde_json::Value;
use std::{error::Error, sync::mpsc::channel};

fn main() -> Result<(), Box<dyn Error>> {
    let mut database = AssetDatabase::default()
        .with_protocol(TextAssetProtocol)
        .with_protocol(BytesAssetProtocol)
        .with_protocol(BundleAssetProtocol::new("json", |bytes: Vec<u8>| {
            let asset = serde_json::from_slice::<Value>(&bytes)?;
            Ok((asset,).into())
        }))
        .with_protocol(GroupAssetProtocol)
        .with_fetch(FileAssetFetch::default().with_root("resources"));

    /* ANCHOR: events */
    // We can bind closures to asset event bindings for any asset progression tracking.
    database.events.bind(|event| {
        println!("Asset closure event: {event:#?}");
        Ok(())
    });

    // Create channel for asset events communication.
    let (tx, rx) = channel();

    // Start loading asset and its dependencies.
    let group = database.ensure("group://group.txt")?;
    // We can also bind sender to asset event bindings.
    group.ensure::<AssetEventBindings>(&mut database)?.bind(tx);

    while database.is_busy() {
        database.maintain()?;
    }

    // Read sent events from receiver.
    while let Ok(event) = rx.try_recv() {
        println!("Group channel event: {event:#?}");
    }
    /* ANCHOR_END: events */

    println!(
        "Lorem Ipsum: {}",
        database
            .find("text://lorem.txt")
            .unwrap()
            .access::<&String>(&database)
    );

    Ok(())
}