use redis::{AsyncCommands, Client, ErrorKind, RedisError, RedisResult};
use redis_macros::{FromRedisValue, ToRedisArgs};
use serde::{Deserialize, Serialize};
#[derive(Debug, PartialEq, Serialize, Deserialize)]
enum Address {
Street(String),
Road(String),
}
#[derive(Debug, PartialEq, Serialize, Deserialize, FromRedisValue, ToRedisArgs)]
struct User {
id: u32,
name: String,
addresses: Vec<Address>,
}
#[tokio::main]
async fn main() -> RedisResult<()> {
let client = Client::open("redis://localhost:6379")?;
let mut con = client
.get_multiplexed_async_connection()
.await
.map_err(|_| {
RedisError::from((
ErrorKind::InvalidClientConfig,
"Cannot connect to localhost:6379. Try starting a redis-server process or container.",
))
})?;
let user = User {
id: 1,
name: "Ziggy".to_string(),
addresses: vec![
Address::Street("Downing".to_string()),
Address::Road("Abbey".to_string()),
],
};
let _: () = con.set("user_async", &user).await?;
let stored_user: User = con.get("user_async").await?;
assert_eq!(user, stored_user);
Ok(())
}
#[test]
fn test_derive_async() {
assert_eq!(main(), Ok(()));
}