OpenSource/teloxide
OpenSource/teloxide
1
0
Fork 0
mirror of https://github.com/teloxide/teloxide.git synced 2025-03-22 06:45:37 +01:00
Code Issues Projects Releases Packages Wiki Activity

Open separate connections to redis during testing

Browse source
This commit is contained in:
Temirkhan Myrzamadi 2020-07-04 20:54:47 +06:00
parent 33910864c7
commit 9eee923aad
1 changed files with 34 additions and 25 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

59
tests/redis.rs
View file

@ -10,45 +10,52 @@ use teloxide::dispatching::dialogue::{
#[tokio::test] #[tokio::test]
async fn test_redis_json() { async fn test_redis_json() {
test_redis(JSON).await; let storage = Arc::new(
RedisStorage::open("redis://127.0.0.1:7777", JSON).await.unwrap(),
);
test_redis(storage).await;
} }
#[tokio::test] #[tokio::test]
async fn test_redis_bincode() { async fn test_redis_bincode() {
test_redis(Bincode).await; let storage = Arc::new(
RedisStorage::open("redis://127.0.0.1:7778", Bincode).await.unwrap(),
);
test_redis(storage).await;
} }
#[tokio::test] #[tokio::test]
async fn test_redis_cbor() { async fn test_redis_cbor() {
test_redis(CBOR).await; let storage = Arc::new(
RedisStorage::open("redis://127.0.0.1:7779", CBOR).await.unwrap(),
);
test_redis(storage).await;
} }
type Dialogue = String; type Dialogue = String;
async fn test_redis<S>(serializer: S) async fn test_redis<S>(storage: Arc<RedisStorage<S>>)
where where
S: Send + Sync + Serializer<Dialogue> + 'static, S: Send + Sync + Serializer<Dialogue> + 'static,
<S as Serializer<Dialogue>>::Error: Debug + Display, <S as Serializer<Dialogue>>::Error: Debug + Display,
{ {
let storage = Arc::new( check_dialogue(
RedisStorage::open("redis://127.0.0.1:7777", serializer).await.unwrap(), None,
); Arc::clone(&storage).update_dialogue(1, "ABC".to_owned()),
)
.await;
check_dialogue(
None,
Arc::clone(&storage).update_dialogue(11, "DEF".to_owned()),
)
.await;
check_dialogue(
None,
Arc::clone(&storage).update_dialogue(256, "GHI".to_owned()),
)
.await;
check_dialogue( // 1 - ABC, 11 - DEF, 256 - GHI
None,
Arc::clone(&storage).update_dialogue(11, "ABC".to_owned()),
)
.await;
check_dialogue(
None,
Arc::clone(&storage).update_dialogue(256, "DEF".to_owned()),
)
.await;
check_dialogue(
None,
Arc::clone(&storage).update_dialogue(11, "GHI".to_owned()),
)
.await;
check_dialogue( check_dialogue(
"ABC", "ABC",
@ -57,13 +64,15 @@ where
.await; .await;
check_dialogue( check_dialogue(
"GHI", "GHI",
Arc::clone(&storage).update_dialogue(11, "MNO".to_owned()), Arc::clone(&storage).update_dialogue(256, "MNO".to_owned()),
) )
.await; .await;
// 1 - GKL, 11 - DEF, 256 - MNO
check_dialogue("JKL", Arc::clone(&storage).remove_dialogue(1)).await; check_dialogue("JKL", Arc::clone(&storage).remove_dialogue(1)).await;
check_dialogue("DEF", Arc::clone(&storage).remove_dialogue(256)).await; check_dialogue("DEF", Arc::clone(&storage).remove_dialogue(11)).await;
check_dialogue("MNO", Arc::clone(&storage).remove_dialogue(11)).await; check_dialogue("MNO", Arc::clone(&storage).remove_dialogue(256)).await;
} }
async fn check_dialogue<E>( async fn check_dialogue<E>(