Changeset View
Changeset View
Standalone View
Standalone View
services/identity/src/database.rs
| Show First 20 Lines • Show All 242 Lines • ▼ Show 20 Lines | self | ||||
| .set_expression_attribute_values(Some(expression_attribute_values)) | .set_expression_attribute_values(Some(expression_attribute_values)) | ||||
| .send() | .send() | ||||
| .await | .await | ||||
| .map_err(|e| Error::AwsSdk(e.into()))?; | .map_err(|e| Error::AwsSdk(e.into()))?; | ||||
| Ok(()) | Ok(()) | ||||
| } | } | ||||
| pub async fn update_user_password( | |||||
| &self, | |||||
| user_id: String, | |||||
| password_file: Vec<u8>, | |||||
| ) -> Result<(), Error> { | |||||
| let update_expression = | |||||
| format!("SET {} = :p", USERS_TABLE_REGISTRATION_ATTRIBUTE); | |||||
| let expression_attribute_values = HashMap::from([( | |||||
| ":p".to_string(), | |||||
| AttributeValue::B(Blob::new(password_file)), | |||||
| )]); | |||||
| self | |||||
| .client | |||||
| .update_item() | |||||
| .table_name(USERS_TABLE) | |||||
| .key(USERS_TABLE_PARTITION_KEY, AttributeValue::S(user_id)) | |||||
| .update_expression(update_expression) | |||||
| .set_expression_attribute_values(Some(expression_attribute_values)) | |||||
| .send() | |||||
| .await | |||||
| .map_err(|e| Error::AwsSdk(e.into()))?; | |||||
| Ok(()) | |||||
| } | |||||
| pub async fn delete_user( | pub async fn delete_user( | ||||
| &self, | &self, | ||||
| user_id: String, | user_id: String, | ||||
| ) -> Result<DeleteItemOutput, Error> { | ) -> Result<DeleteItemOutput, Error> { | ||||
| debug!("Attempting to delete user: {}", user_id); | debug!("Attempting to delete user: {}", user_id); | ||||
| match self | match self | ||||
| .client | .client | ||||
| ▲ Show 20 Lines • Show All 639 Lines • Show Last 20 Lines | |||||