datasources 0.1.5

Async datasource interfaces, middleware, registry, and test doubles
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

use crate::{create, default, register, reset, Datasource, DatasourceError, MockDriver};
use std::collections::HashMap;

fn clear_env() {
    reset();
    for key in [
        "INSTALLED_PROVIDERS",
        "DATASOURCE_URL",
        "PROVIDER",
    ] {
        std::env::remove_var(key);
    }
}

#[test]
fn default_from_environment() {
    let _guard = super::env_lock();
    clear_env();
    register("sqlite", MockDriver::arc());
    std::env::set_var("PROVIDER", "sqlite");
    let ds = default().expect("default");
    assert_eq!(Datasource::provider(&*ds), "sqlite");
}

#[test]
fn missing_provider_throws() {
    let _guard = super::env_lock();
    reset();
    assert!(matches!(
        create(Some(&HashMap::from([("PROVIDER".into(), "missing".into())]))),
        Err(DatasourceError::ProviderNotInstalled(name)) if name == "missing"
    ));
}