]> Untitled Git - lemmy.git/blob - crates/api/src/private_message_report/list.rs
Make functions work with both connection and pool (#3420)
[lemmy.git] / crates / api / src / private_message_report / list.rs
1 use crate::Perform;
2 use actix_web::web::Data;
3 use lemmy_api_common::{
4   context::LemmyContext,
5   private_message::{ListPrivateMessageReports, ListPrivateMessageReportsResponse},
6   utils::{is_admin, local_user_view_from_jwt},
7 };
8 use lemmy_db_views::private_message_report_view::PrivateMessageReportQuery;
9 use lemmy_utils::error::LemmyError;
10
11 #[async_trait::async_trait(?Send)]
12 impl Perform for ListPrivateMessageReports {
13   type Response = ListPrivateMessageReportsResponse;
14
15   #[tracing::instrument(skip(context))]
16   async fn perform(&self, context: &Data<LemmyContext>) -> Result<Self::Response, LemmyError> {
17     let local_user_view = local_user_view_from_jwt(&self.auth, context).await?;
18
19     is_admin(&local_user_view)?;
20
21     let unresolved_only = self.unresolved_only;
22     let page = self.page;
23     let limit = self.limit;
24     let private_message_reports = PrivateMessageReportQuery::builder()
25       .pool(&mut context.pool())
26       .unresolved_only(unresolved_only)
27       .page(page)
28       .limit(limit)
29       .build()
30       .list()
31       .await?;
32
33     Ok(ListPrivateMessageReportsResponse {
34       private_message_reports,
35     })
36   }
37 }