list users

backend/src/lib/outbound/metrics_debug_logger.rs

@@ -145,6 +145,13 @@ impl AuthMetrics for MetricsDebugLogger {
         tracing::debug!("[Metrics] User creation failed");
     }
 
+    async fn record_user_list_success(&self) -> () {
+        tracing::debug!("[Metrics] User list succeeded");
+    }
+    async fn record_user_list_failure(&self) -> () {
+        tracing::debug!("[Metrics] User list failed");
+    }
+
     async fn record_auth_session_creation_success(&self) {
         tracing::debug!("[Metrics] Auth session creation succeeded");
     }

backend/src/lib/outbound/notifier_debug_logger.rs

@@ -129,6 +129,14 @@ impl AuthNotifier for NotifierDebugLogger {
         );
     }
 
+    async fn users_listed(&self, user: &User, users: &Vec<User>) {
+        tracing::debug!(
+            "[Notifier] Admin user {} listed {} user(s)",
+            user.name(),
+            users.len()
+        );
+    }
+
     async fn user_logged_in(&self, response: &LoginUserResponse) {
         tracing::debug!("[Notifier] Logged in user {}", response.user().name());
     }

backend/src/lib/outbound/postgres.rs

@@ -25,8 +25,8 @@ use crate::domain::warren::{
             },
         },
         user::{
-            CreateUserError, CreateUserRequest, User, UserEmail, UserName, UserPassword,
-            VerifyUserPasswordError, VerifyUserPasswordRequest,
+            CreateUserError, CreateUserRequest, ListUsersError, ListUsersRequest, User, UserEmail,
+            UserName, UserPassword, VerifyUserPasswordError, VerifyUserPasswordRequest,
         },
         user_warren::{
             UserWarren,
@@ -348,6 +348,21 @@ impl Postgres {
 
         Ok(ids)
     }
+
+    async fn fetch_users(&self, connection: &mut PgConnection) -> Result<Vec<User>, sqlx::Error> {
+        let users: Vec<User> = sqlx::query_as(
+            "
+            SELECT
+                *
+            FROM
+                users
+            ",
+        )
+        .fetch_all(connection)
+        .await?;
+
+        Ok(users)
+    }
 }
 
 impl WarrenRepository for Postgres {
@@ -519,6 +534,21 @@ impl AuthRepository for Postgres {
                 }
             })
     }
+
+    async fn list_users(&self, _request: ListUsersRequest) -> Result<Vec<User>, ListUsersError> {
+        let mut connection = self
+            .pool
+            .acquire()
+            .await
+            .context("Failed to get a PostgreSQL connection")?;
+
+        let users = self
+            .fetch_users(&mut connection)
+            .await
+            .map_err(|e| anyhow!(e))?;
+
+        Ok(users)
+    }
 }
 
 fn is_not_found_error(err: &sqlx::Error) -> bool {