eventstore 4.0.0

Official EventStoreDB gRPC client
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

use tracing::debug;

async fn test_with_valid_root_certificate(port: u16) -> eyre::Result<()> {
    let root_cert = "certs/ca/ca.crt";

    let setts = format!(
        "esdb://admin:changeit@localhost:{}?tlsVerifyCert=true&tls=true&tlsCaFile={}",
        port, root_cert
    )
    .parse()?;
    let client = eventstore::Client::new(setts)?;

    let mut streams = client.read_all(&Default::default()).await?;

    streams.next().await?;

    Ok(())
}

async fn test_with_invalid_certificate(port: u16) -> eyre::Result<()> {
    // invalid root certificate
    let root_cert = "certs/node1/node.crt";

    let setts = format!(
        "esdb://admin:changeit@localhost:{}?tlsVerifyCert=true&tls=true&tlsCaFile={}",
        port, root_cert
    )
    .parse()?;
    let client = eventstore::Client::new(setts)?;

    let result = client.read_all(&Default::default()).await;

    assert!(
        result.is_err(),
        "Expected an error due to invalid certificate"
    );

    Ok(())
}

pub async fn tests(port: u16) -> eyre::Result<()> {
    debug!("Before test_with_valid_root_certificate…");
    test_with_valid_root_certificate(port).await?;
    debug!("Complete");

    debug!("Before test_with_invalid_certificate…");
    test_with_invalid_certificate(port).await?;
    debug!("Complete");

    Ok(())
}