rubin 0.4.0

In-memory key-value store with the option for persistence
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

#[cfg(test)]
mod net_integration_tests {
    use rubin::net::client::RubinClient;
    use rubin::net::server::start;

    async fn sleep(duration: u64) {
        tokio::time::sleep(tokio::time::Duration::from_millis(duration)).await;
    }

    #[tokio::test]
    async fn connects_to_server_and_performs_successful_request() {
        let server = tokio::spawn(start("127.0.0.1", 9876));
        sleep(1000).await;

        let client = RubinClient::new("127.0.0.1", 9876);
        let response = client.insert_string("user:1000", "value1").await.unwrap();
        assert!(&response == "OK");

        server.abort();
    }

    #[tokio::test]
    async fn gets_value_from_the_server() {
        let server = tokio::spawn(start("127.0.0.1", 9877));
        sleep(1000).await;

        let client = RubinClient::new("127.0.0.1", 9877);
        client.insert_string("user:1000", "value1").await.unwrap();

        sleep(500).await;
        let response = client.get_string("user:1000").await.unwrap();
        assert_eq!(&response, "value1");

        server.abort();
    }

    #[tokio::test]
    async fn gets_an_error_from_the_server() {
        let server = tokio::spawn(start("127.0.0.1", 9878));
        sleep(1000).await;

        let client = RubinClient::new("127.0.0.1", 9878);
        let response = client.insert_string("user:1000", "").await.unwrap();

        assert_eq!(&response, "message failed validation");

        server.abort();
    }
}