chk
/
AppFlowy-Cloud
1
0
Fork 0
Code Issues Pull Requests Packages Projects Releases Wiki Activity

chore: removed realtime shared state tests

This commit is contained in:
Bartosz Sypytkowski 2024-11-04 09:21:10 +01:00
parent 356cf5d132
commit 6aed9609b9
1 changed files with 0 additions and 63 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

63
services/appflowy-collaborate/tests/shared_state_test.rs
View File

@ -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);
}