mirror of
https://github.com/fawney19/Aether.git
synced 2026-09-03 01:40:21 +08:00
Expose admin user export counts through gateway state
This commit is contained in:
@@ -1512,6 +1512,16 @@ impl GatewayDataState {
|
|||||||
}
|
}
|
||||||
}
|
}
|
||||||
|
|
||||||
|
pub(crate) async fn count_export_users(
|
||||||
|
&self,
|
||||||
|
query: &aether_data::repository::users::UserExportListQuery,
|
||||||
|
) -> Result<u64, DataLayerError> {
|
||||||
|
match &self.user_reader {
|
||||||
|
Some(repository) => repository.count_export_users(query).await,
|
||||||
|
None => Ok(0),
|
||||||
|
}
|
||||||
|
}
|
||||||
|
|
||||||
pub(crate) async fn summarize_export_users(
|
pub(crate) async fn summarize_export_users(
|
||||||
&self,
|
&self,
|
||||||
) -> Result<aether_data::repository::users::UserExportSummary, DataLayerError> {
|
) -> Result<aether_data::repository::users::UserExportSummary, DataLayerError> {
|
||||||
|
|||||||
@@ -42,6 +42,13 @@ impl<'a> AdminAppState<'a> {
|
|||||||
self.app.list_export_users_page(query).await
|
self.app.list_export_users_page(query).await
|
||||||
}
|
}
|
||||||
|
|
||||||
|
pub(crate) async fn count_export_users(
|
||||||
|
&self,
|
||||||
|
query: &aether_data::repository::users::UserExportListQuery,
|
||||||
|
) -> Result<u64, GatewayError> {
|
||||||
|
self.app.count_export_users(query).await
|
||||||
|
}
|
||||||
|
|
||||||
pub(crate) async fn find_export_user_by_id(
|
pub(crate) async fn find_export_user_by_id(
|
||||||
&self,
|
&self,
|
||||||
user_id: &str,
|
user_id: &str,
|
||||||
|
|||||||
@@ -169,6 +169,16 @@ impl AppState {
|
|||||||
.map_err(|err| GatewayError::Internal(err.to_string()))
|
.map_err(|err| GatewayError::Internal(err.to_string()))
|
||||||
}
|
}
|
||||||
|
|
||||||
|
pub(crate) async fn count_export_users(
|
||||||
|
&self,
|
||||||
|
query: &aether_data::repository::users::UserExportListQuery,
|
||||||
|
) -> Result<u64, GatewayError> {
|
||||||
|
self.data
|
||||||
|
.count_export_users(query)
|
||||||
|
.await
|
||||||
|
.map_err(|err| GatewayError::Internal(err.to_string()))
|
||||||
|
}
|
||||||
|
|
||||||
pub(crate) async fn find_export_user_by_id(
|
pub(crate) async fn find_export_user_by_id(
|
||||||
&self,
|
&self,
|
||||||
user_id: &str,
|
user_id: &str,
|
||||||
|
|||||||
Reference in New Issue
Block a user