diff --git a/crates/collab/src/api.rs b/crates/collab/src/api.rs index 6440e8cb30..bf35999b7f 100644 --- a/crates/collab/src/api.rs +++ b/crates/collab/src/api.rs @@ -31,6 +31,7 @@ pub fn routes(rpc_server: &Arc, state: Arc) -> Router, + Extension(app): Extension>, +) -> Result>> { + Ok(Json( + app.db + .get_users_with_no_invites(params.invited_by_another_user) + .await?, + )) +} + #[derive(Debug, Deserialize)] struct Panic { version: String, diff --git a/crates/collab/src/db.rs b/crates/collab/src/db.rs index 5e8c45bf87..3224e9dbdb 100644 --- a/crates/collab/src/db.rs +++ b/crates/collab/src/db.rs @@ -25,6 +25,7 @@ pub trait Db: Send + Sync { async fn fuzzy_search_users(&self, query: &str, limit: u32) -> Result>; async fn get_user_by_id(&self, id: UserId) -> Result>; async fn get_users_by_ids(&self, ids: Vec) -> Result>; + async fn get_users_with_no_invites(&self, invited_by_another_user: bool) -> Result>; async fn get_user_by_github_login(&self, github_login: &str) -> Result>; async fn set_user_is_admin(&self, id: UserId, is_admin: bool) -> Result<()>; async fn set_user_connected_once(&self, id: UserId, connected_once: bool) -> Result<()>; @@ -260,6 +261,18 @@ impl Db for PostgresDb { .await?) } + async fn get_users_with_no_invites(&self, invited_by_another_user: bool) -> Result> { + let query = " + SELECT users.* + FROM users + WHERE invite_count = 0 + "; + Ok(sqlx::query_as(query) + .bind(&ids) + .fetch_all(&self.pool) + .await?) + } + async fn get_user_by_github_login(&self, github_login: &str) -> Result> { let query = "SELECT * FROM users WHERE github_login = $1 LIMIT 1"; Ok(sqlx::query_as(query) @@ -1363,21 +1376,56 @@ pub mod tests { let user = db.create_user("user_1", None, false).await.unwrap(); let project = db.register_project(user).await.unwrap(); - db.update_worktree_extensions(project, 100, Default::default()).await.unwrap(); - db.update_worktree_extensions(project, 100, [("rs".to_string(), 5), ("md".to_string(), 3)].into_iter().collect()).await.unwrap(); - db.update_worktree_extensions(project, 100, [("rs".to_string(), 6), ("md".to_string(), 5)].into_iter().collect()).await.unwrap(); - db.update_worktree_extensions(project, 101, [("ts".to_string(), 2), ("md".to_string(), 1)].into_iter().collect()).await.unwrap(); + db.update_worktree_extensions(project, 100, Default::default()) + .await + .unwrap(); + db.update_worktree_extensions( + project, + 100, + [("rs".to_string(), 5), ("md".to_string(), 3)] + .into_iter() + .collect(), + ) + .await + .unwrap(); + db.update_worktree_extensions( + project, + 100, + [("rs".to_string(), 6), ("md".to_string(), 5)] + .into_iter() + .collect(), + ) + .await + .unwrap(); + db.update_worktree_extensions( + project, + 101, + [("ts".to_string(), 2), ("md".to_string(), 1)] + .into_iter() + .collect(), + ) + .await + .unwrap(); - assert_eq!(db.get_project_extensions(project).await.unwrap(), [ - (100, [ - ("rs".into(), 6), - ("md".into(), 5), - ].into_iter().collect::>()), - (101, [ - ("ts".into(), 2), - ("md".into(), 1), - ].into_iter().collect::>()) - ].into_iter().collect()); + assert_eq!( + db.get_project_extensions(project).await.unwrap(), + [ + ( + 100, + [("rs".into(), 6), ("md".into(), 5),] + .into_iter() + .collect::>() + ), + ( + 101, + [("ts".into(), 2), ("md".into(), 1),] + .into_iter() + .collect::>() + ) + ] + .into_iter() + .collect() + ); } #[tokio::test(flavor = "multi_thread")]