idb 0.6.5

A futures based crate for interacting with IndexedDB on browsers using webassembly
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

use idb::Factory;
use tokio::sync::oneshot;
use wasm_bindgen_test::wasm_bindgen_test;

#[wasm_bindgen_test]
async fn test_open_request_upgrade_needed() {
    let factory = Factory::new().unwrap();
    factory.delete("test").unwrap().await.unwrap();

    let mut open_request = factory.open("test", Some(1)).unwrap();

    let (sender, receiver) = oneshot::channel();
    open_request.on_upgrade_needed(move |event| {
        sender.send(event).expect("channel send");
    });

    let database = open_request.await.unwrap();

    let event = receiver.await.unwrap();

    assert_eq!(event.old_version(), Ok(0));
    assert_eq!(event.new_version(), Ok(Some(1)));

    database.close();
    factory.delete("test").unwrap().await.unwrap();
}

#[wasm_bindgen_test]
async fn test_open_request_blocked() {
    let factory = Factory::new().unwrap();
    factory.delete("test").unwrap().await.unwrap();

    let open_request = factory.open("test", Some(1)).unwrap();
    let database = open_request.await.unwrap();

    let mut blocking_open_request = factory.open("test", Some(2)).unwrap();

    let (sender, receiver) = oneshot::channel();
    blocking_open_request.on_blocked(move |event| {
        sender.send(event).expect("channel send");
    });

    let event = receiver.await.unwrap();

    assert_eq!(event.old_version(), Ok(1));
    assert_eq!(event.new_version(), Ok(Some(2)));

    database.close();

    let database = blocking_open_request.await.unwrap();
    assert_eq!(database.version(), Ok(2));

    database.close();
    factory.delete("test").unwrap().await.unwrap();
}