231cce9350
* Removing a few SuccessResponses for PostHide and MarkPostAsRead. - This also removes the pointless multiple post_ids. These can be done as individual calls on the front end anyway. - Fixes #4755 * Fixing federation tests. * Upgrading lemmy-js-client deps. * Add ability to mark several posts as read. Context: - https://github.com/LemmyNet/lemmy/pull/5043 - https://github.com/LemmyNet/lemmy/issues/4755 - https://github.com/LemmyNet/lemmy/pull/5160 * Simplifying forms. * Fixing forms. * Cleanup post action forms by using derive_new defaults. - Fixes #5195 * Fix ntfy to notify on success builds also. * Removing pointless naive_now function. * Running taplo fmt.
97 lines
2.6 KiB
Rust
97 lines
2.6 KiB
Rust
use crate::{
|
|
newtypes::{CommentId, CommentReportId, PersonId},
|
|
schema::comment_report::{
|
|
comment_id,
|
|
dsl::{comment_report, resolved, resolver_id, updated},
|
|
},
|
|
source::comment_report::{CommentReport, CommentReportForm},
|
|
traits::Reportable,
|
|
utils::{get_conn, DbPool},
|
|
};
|
|
use chrono::Utc;
|
|
use diesel::{
|
|
dsl::{insert_into, update},
|
|
result::Error,
|
|
ExpressionMethods,
|
|
QueryDsl,
|
|
};
|
|
use diesel_async::RunQueryDsl;
|
|
|
|
#[async_trait]
|
|
impl Reportable for CommentReport {
|
|
type Form = CommentReportForm;
|
|
type IdType = CommentReportId;
|
|
type ObjectIdType = CommentId;
|
|
/// creates a comment report and returns it
|
|
///
|
|
/// * `conn` - the postgres connection
|
|
/// * `comment_report_form` - the filled CommentReportForm to insert
|
|
async fn report(
|
|
pool: &mut DbPool<'_>,
|
|
comment_report_form: &CommentReportForm,
|
|
) -> Result<Self, Error> {
|
|
let conn = &mut get_conn(pool).await?;
|
|
insert_into(comment_report)
|
|
.values(comment_report_form)
|
|
.get_result::<Self>(conn)
|
|
.await
|
|
}
|
|
|
|
/// resolve a comment report
|
|
///
|
|
/// * `conn` - the postgres connection
|
|
/// * `report_id` - the id of the report to resolve
|
|
/// * `by_resolver_id` - the id of the user resolving the report
|
|
async fn resolve(
|
|
pool: &mut DbPool<'_>,
|
|
report_id_: Self::IdType,
|
|
by_resolver_id: PersonId,
|
|
) -> Result<usize, Error> {
|
|
let conn = &mut get_conn(pool).await?;
|
|
update(comment_report.find(report_id_))
|
|
.set((
|
|
resolved.eq(true),
|
|
resolver_id.eq(by_resolver_id),
|
|
updated.eq(Utc::now()),
|
|
))
|
|
.execute(conn)
|
|
.await
|
|
}
|
|
|
|
async fn resolve_all_for_object(
|
|
pool: &mut DbPool<'_>,
|
|
comment_id_: CommentId,
|
|
by_resolver_id: PersonId,
|
|
) -> Result<usize, Error> {
|
|
let conn = &mut get_conn(pool).await?;
|
|
update(comment_report.filter(comment_id.eq(comment_id_)))
|
|
.set((
|
|
resolved.eq(true),
|
|
resolver_id.eq(by_resolver_id),
|
|
updated.eq(Utc::now()),
|
|
))
|
|
.execute(conn)
|
|
.await
|
|
}
|
|
|
|
/// unresolve a comment report
|
|
///
|
|
/// * `conn` - the postgres connection
|
|
/// * `report_id` - the id of the report to unresolve
|
|
/// * `by_resolver_id` - the id of the user unresolving the report
|
|
async fn unresolve(
|
|
pool: &mut DbPool<'_>,
|
|
report_id_: Self::IdType,
|
|
by_resolver_id: PersonId,
|
|
) -> Result<usize, Error> {
|
|
let conn = &mut get_conn(pool).await?;
|
|
update(comment_report.find(report_id_))
|
|
.set((
|
|
resolved.eq(false),
|
|
resolver_id.eq(by_resolver_id),
|
|
updated.eq(Utc::now()),
|
|
))
|
|
.execute(conn)
|
|
.await
|
|
}
|
|
}
|