merged with delete user query

Author: nguyen-katie

graphql/src/query.rs

@@ -1,13 +1,14 @@
 //! This piece of the project exposes a GraphQL endpoint that allows one to access DAILP data in a federated manner with specific queries.
 
+use aws_sdk_cognitoidentityprovider::Client;
 use dailp::{
     async_graphql::InputType,
     auth::{AuthGuard, GroupGuard, NotGroupGuard, UserGroup, UserInfo},
     collection,
     comment::{CommentParent, CommentUpdate, DeleteCommentInput, PostCommentInput},
     page::{NewPageInput, Page},
     slugify_ltree,
-    user::{User, UserUpdate},
+    user::{User, UserId, UserUpdate},
     AnnotatedForm, AnnotatedSeg, AttachAudioToDocumentInput, AttachAudioToWordInput,
     CollectionChapter, Contributor, ContributorRole, CreateEditedCollectionInput,
     CurateDocumentAudioInput, CurateWordAudioInput, Date, DeleteContributorAttribution,
@@ -643,6 +644,29 @@ impl Mutation {
             .ok_or_else(|| anyhow::format_err!("Failed to load document"))?)
     }
 
+    // Deletes a user
+    #[graphql(guard = "AuthGuard")]
+    async fn delete_user(&self, context: &Context<'_>, user_id: Uuid) -> FieldResult<UserId> {
+        // let cognito = context.data::<aws_sdk_cognitoidentityprovider::Client>()?;
+        // let user_pool_id = std::env::var("DAILP_USER_POOL")
+        //     .map_err(|_| anyhow::format_err!("DAILP_USER_POOL not set"))?;
+
+        // let identity_result = cognito
+        //     .admin_delete_user()
+        //     .user_pool_id(std::env::var("DAILP_USER_POOL"))
+        //     .username(user_id.to_string())
+        //     .send()
+        //     .await
+        //     .map_err(|e| anyhow::format_err!("Failed to delete user: {}", e))?;
+
+        // log::info!("admin_delete_user result: {:?}", identity_result);
+        Ok(context
+            .data::<DataLoader<Database>>()?
+            .loader()
+            .delete_user(&user_id)
+            .await?)
+    }
+
     /// Decide if a piece of word audio should be included in edited collection
     #[graphql(guard = "GroupGuard::new(UserGroup::Editors)")]
     async fn curate_word_audio(

types/.sqlx/query-15e338c47089a2352b2470c60da5784405b2f8de49d56f119d3d98fe8d4dc4db.json

@@ -0,0 +1,3 @@
+DELETE FROM dailp_user
+WHERE id = $1
+RETURNING id

types/queries/remove_user.sql

@@ -921,7 +921,15 @@ impl Database {
             })
             .collect();
 
-        Ok(users) // come back to see if list conversions are needed
+        Ok(users)
+    }
+
+    pub async fn delete_user(&self, user_id: &Uuid) -> Result<UserId> {
+        let row = query_file!("queries/remove_user.sql", user_id)
+            .fetch_one(&self.client)
+            .await?;
+
+        Ok(UserId(row.id.to_string()))
     }
 
     pub async fn bookmarked_documents(&self, user_id: &Uuid) -> Result<Vec<Uuid>> {