relay-knowledge 1.1.17

Graph-database-based knowledge graph project.
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

use crate::storage::{KnowledgeStoreFactoryFuture, StorageTopologySnapshot};

use super::*;

struct FailingFactory;

impl KnowledgeStoreFactory for FailingFactory {
    fn open(&self) -> KnowledgeStoreFactoryFuture<'_, Arc<dyn KnowledgeStore>> {
        Box::pin(async { Err(StorageError::InvalidInput("factory-open-failed".to_owned())) })
    }

    fn topology_snapshot(&self) -> KnowledgeStoreFactoryFuture<'_, StorageTopologySnapshot> {
        Box::pin(async { Ok(StorageTopologySnapshot::default()) })
    }
}

#[tokio::test]
async fn lazy_provider_preserves_factory_errors_without_partial_initialization() {
    let provider = StorageProvider::configured(Arc::new(FailingFactory));

    let error = match provider.get().await {
        Ok(_) => panic!("factory should fail"),
        Err(error) => error,
    };

    assert_eq!(
        error.to_string(),
        "invalid storage input: factory-open-failed"
    );
    assert!(provider.ready_store().is_none());
}