diff --git a/crates/collab/src/api.rs b/crates/collab/src/api.rs
index 6440e8cb3048b0709b5efe64f9b1089ed74930bf..0c91a5a0794020ba548014a242abce4352572175 100644
--- a/crates/collab/src/api.rs
+++ b/crates/collab/src/api.rs
@@ -31,6 +31,7 @@ pub fn routes(rpc_server: &Arc<rpc::Server>, state: Arc<AppState>) -> Router<Bod
         )
         .route("/users/:id/access_tokens", post(create_access_token))
         .route("/bulk_users", post(create_users))
+        .route("/users_with_no_invites", get(get_users_with_no_invites))
         .route("/invite_codes/:code", get(get_user_for_invite_code))
         .route("/panic", post(trace_panic))
         .route("/rpc_server_snapshot", get(get_rpc_server_snapshot))
@@ -228,6 +229,22 @@ async fn create_users(
     Ok(Json(users))
 }
 
+#[derive(Debug, Deserialize)]
+struct GetUsersWithNoInvites {
+    invited_by_another_user: bool,
+}
+
+async fn get_users_with_no_invites(
+    Query(params): Query<GetUsersWithNoInvites>,
+    Extension(app): Extension<Arc<AppState>>,
+) -> Result<Json<Vec<User>>> {
+    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 5e8c45bf87ca435dc439dd16be722bb9479485e6..ce494db59bb6222b90533d0129f86c21e651e697 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<Vec<User>>;
     async fn get_user_by_id(&self, id: UserId) -> Result<Option<User>>;
     async fn get_users_by_ids(&self, ids: Vec<UserId>) -> Result<Vec<User>>;
+    async fn get_users_with_no_invites(&self, invited_by_another_user: bool) -> Result<Vec<User>>;
     async fn get_user_by_github_login(&self, github_login: &str) -> Result<Option<User>>;
     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,20 @@ impl Db for PostgresDb {
             .await?)
     }
 
+    async fn get_users_with_no_invites(&self, invited_by_another_user: bool) -> Result<Vec<User>> {
+        let query = format!(
+            "
+            SELECT users.*
+            FROM users
+            WHERE invite_count = 0
+            AND inviter_id IS{} NULL
+            ",
+            if invited_by_another_user { " NOT" } else { "" }
+        );
+
+        Ok(sqlx::query_as(&query).fetch_all(&self.pool).await?)
+    }
+
     async fn get_user_by_github_login(&self, github_login: &str) -> Result<Option<User>> {
         let query = "SELECT * FROM users WHERE github_login = $1 LIMIT 1";
         Ok(sqlx::query_as(query)
@@ -1363,21 +1378,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();
-
-        assert_eq!(db.get_project_extensions(project).await.unwrap(), [
-            (100, [
-                ("rs".into(), 6),
-                ("md".into(), 5),
-            ].into_iter().collect::<HashMap<_, _>>()),
-            (101, [
-                ("ts".into(), 2),
-                ("md".into(), 1),
-            ].into_iter().collect::<HashMap<_, _>>())
-        ].into_iter().collect());
+        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::<HashMap<_, _>>()
+                ),
+                (
+                    101,
+                    [("ts".into(), 2), ("md".into(), 1),]
+                        .into_iter()
+                        .collect::<HashMap<_, _>>()
+                )
+            ]
+            .into_iter()
+            .collect()
+        );
     }
 
     #[tokio::test(flavor = "multi_thread")]
@@ -2140,6 +2190,10 @@ pub mod tests {
             Ok(ids.iter().filter_map(|id| users.get(id).cloned()).collect())
         }
 
+        async fn get_users_with_no_invites(&self, _: bool) -> Result<Vec<User>> {
+            unimplemented!()
+        }
+
         async fn get_user_by_github_login(&self, github_login: &str) -> Result<Option<User>> {
             Ok(self
                 .users