testcontainers-modules 0.15.0

Community maintained modules for Testcontainers for Rust
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

use async_nats::connect;
use futures::StreamExt;
use testcontainers_modules::{
    nats::{Nats, NatsServerCmd},
    testcontainers::{runners::AsyncRunner, ImageExt},
};

#[tokio::main]
async fn main() -> Result<(), Box<dyn std::error::Error + 'static>> {
    // optional: customize command, here we enable jetstream
    let nats_cmd = NatsServerCmd::default().with_jetstream();

    // startup the module
    let node = Nats::default().with_cmd(&nats_cmd).start().await?;

    // default docker username/password
    let default_username = "ruser";
    let default_password = "T0pS3cr3t";
    let topic = "foo";
    let port = node.get_host_port_ipv4(4222).await.unwrap();

    // prepare connection string
    let connection_url = &format!(
        "nats://{}:{}@127.0.0.1:{}",
        default_username, default_password, port,
    );

    let subscriber = connect(connection_url).await.unwrap();
    let publisher = connect(connection_url).await.unwrap();

    let mut subscription = subscriber.subscribe(topic).await.unwrap();

    println!("sending message");
    publisher.publish(topic, "Hello".into()).await.unwrap();
    publisher.publish(topic, "world".into()).await.unwrap();

    let mut messages = Vec::new();
    while let Some(message) = subscription.next().await {
        messages.push(message.clone());
        println!("Received message: {:?}", message);
        if messages.len() == 2 {
            break;
        }
    }

    assert_eq!(messages.len(), 2);
    println!("Received {} messages", messages.len());
    Ok(())
}