2 newtypes::{PersonId, PrivateMessageId, PrivateMessageReportId},
3 schema::private_message_report::dsl::{private_message_report, resolved, resolver_id, updated},
4 source::private_message_report::{PrivateMessageReport, PrivateMessageReportForm},
6 utils::{get_conn, naive_now, DbPool},
9 dsl::{insert_into, update},
14 use diesel_async::RunQueryDsl;
17 impl Reportable for PrivateMessageReport {
18 type Form = PrivateMessageReportForm;
19 type IdType = PrivateMessageReportId;
20 type ObjectIdType = PrivateMessageId;
23 pool: &mut DbPool<'_>,
24 pm_report_form: &PrivateMessageReportForm,
25 ) -> Result<Self, Error> {
26 let conn = &mut get_conn(pool).await?;
27 insert_into(private_message_report)
28 .values(pm_report_form)
29 .get_result::<Self>(conn)
34 pool: &mut DbPool<'_>,
35 report_id: Self::IdType,
36 by_resolver_id: PersonId,
37 ) -> Result<usize, Error> {
38 let conn = &mut get_conn(pool).await?;
39 update(private_message_report.find(report_id))
42 resolver_id.eq(by_resolver_id),
43 updated.eq(naive_now()),
49 // TODO: this is unused because private message doesnt have remove handler
50 async fn resolve_all_for_object(
51 _pool: &mut DbPool<'_>,
52 _pm_id_: PrivateMessageId,
53 _by_resolver_id: PersonId,
54 ) -> Result<usize, Error> {
59 pool: &mut DbPool<'_>,
60 report_id: Self::IdType,
61 by_resolver_id: PersonId,
62 ) -> Result<usize, Error> {
63 let conn = &mut get_conn(pool).await?;
64 update(private_message_report.find(report_id))
67 resolver_id.eq(by_resolver_id),
68 updated.eq(naive_now()),