darkredis 0.1.2

Async Redis client using std::future
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
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66

#![feature(async_await)]

use futures::stream::{self, StreamExt};
use darkredis::Connection;

async fn add_comment(mut connection: Connection, post: usize, text: &str) {
    let key = format!("posts.{}.comments", post);
    connection.rpush(&key, text).await.unwrap();
}

async fn add_post(mut connection: Connection, postid: usize, text: &str) {
    let key = "posts";
    connection
        .rpush(&key, format!("{}\n{}", postid, text))
        .await
        .unwrap();
}

async fn show_posts(mut connection: Connection) {
    let posts = connection.lrange("posts", 0, 10).await.unwrap().unwrap();

    for post in posts {
        let post = String::from_utf8_lossy(&post);
        let id = (&post[0..1]).parse::<usize>().unwrap();
        let comment_key = format!("posts.{}.comments", id);
        println!("Post #{}: {}", id, &post[2..]);
        let comments = connection
            .lrange(&comment_key, 0, 10)
            .await
            .unwrap()
            .unwrap();

        for (number, comment) in comments.iter().enumerate() {
            println!("Comment #{}: {}", number, String::from_utf8_lossy(comment));
        }

        connection.del(comment_key).await.unwrap();

        println!();
    }

    connection.del("posts").await.unwrap();
}

#[runtime::main]
async fn main() {
    let connection = Connection::connect("127.0.0.1:6379").await.unwrap();

    //Write some posts
    let first_post = "My first ever blog post!";
    add_post(connection.clone(), 1, first_post).await;
    stream::iter(vec!["Cool!", "Nice!", "I'm excited!"])
        .for_each(|comment| add_comment(connection.clone(), 1, comment))
        .await;

    let second_post = "Blogging is hard work!";
    add_post(connection.clone(), 2, second_post).await;

    let last_post = "My last ever blog post...";
    add_post(connection.clone(), 3, last_post).await;
    stream::iter(vec!["Sad to see you go, you were good.", "It's not fair!"])
        .for_each(|comment| add_comment(connection.clone(), 3, comment))
        .await;

    show_posts(connection).await;
}