From 6aed9609b9568e2f838860cf9d1e91fb9caeafe6 Mon Sep 17 00:00:00 2001 From: Bartosz Sypytkowski Date: Mon, 4 Nov 2024 09:21:10 +0100 Subject: [PATCH] chore: removed realtime shared state tests --- .../tests/shared_state_test.rs | 63 ------------------- 1 file changed, 63 deletions(-) delete mode 100644 services/appflowy-collaborate/tests/shared_state_test.rs diff --git a/services/appflowy-collaborate/tests/shared_state_test.rs b/services/appflowy-collaborate/tests/shared_state_test.rs deleted file mode 100644 index 0485b613..00000000 --- a/services/appflowy-collaborate/tests/shared_state_test.rs +++ /dev/null @@ -1,63 +0,0 @@ -use anyhow::Context; -use appflowy_collaborate::shared_state::RealtimeSharedState; - -async fn redis_client() -> redis::Client { - let redis_uri = "redis://localhost:6379"; - redis::Client::open(redis_uri) - .context("failed to connect to redis") - .unwrap() -} - -#[tokio::test] -async fn connected_user_test() { - let redis_client = redis_client().await; - let shared_state = RealtimeSharedState::new(redis_client.get_connection_manager().await.unwrap()); - - let device_id = uuid::Uuid::new_v4().to_string(); - let is_connected = shared_state - .is_user_connected(&1, &device_id) - .await - .unwrap(); - assert!(!is_connected); - - shared_state - .add_connected_user(1, &device_id) - .await - .unwrap(); - - let is_connected = shared_state - .is_user_connected(&1, &device_id) - .await - .unwrap(); - assert!(is_connected); - - shared_state - .remove_connected_user(1, &device_id) - .await - .unwrap(); - - let is_connected = shared_state - .is_user_connected(&1, &device_id) - .await - .unwrap(); - assert!(!is_connected); -} - -#[tokio::test] -async fn remove_all_connected_user_test() { - let redis_client = redis_client().await; - let shared_state = RealtimeSharedState::new(redis_client.get_connection_manager().await.unwrap()); - - let device_id = uuid::Uuid::new_v4().to_string(); - shared_state - .add_connected_user(1, &device_id) - .await - .unwrap(); - shared_state.remove_all_connected_users().await.unwrap(); - - let is_connected = shared_state - .is_user_connected(&1, &device_id) - .await - .unwrap(); - assert!(!is_connected); -}