impl Comment {
pub fn update_ap_id(
- conn: &PgConnection,
+ conn: &mut PgConnection,
comment_id: CommentId,
apub_id: DbUrl,
) -> Result<Self, Error> {
}
pub fn permadelete_for_creator(
- conn: &PgConnection,
+ conn: &mut PgConnection,
for_creator_id: PersonId,
) -> Result<Vec<Self>, Error> {
use crate::schema::comment::dsl::*;
}
pub fn update_deleted(
- conn: &PgConnection,
+ conn: &mut PgConnection,
comment_id: CommentId,
new_deleted: bool,
) -> Result<Self, Error> {
}
pub fn update_removed(
- conn: &PgConnection,
+ conn: &mut PgConnection,
comment_id: CommentId,
new_removed: bool,
) -> Result<Self, Error> {
}
pub fn update_removed_for_creator(
- conn: &PgConnection,
+ conn: &mut PgConnection,
for_creator_id: PersonId,
new_removed: bool,
) -> Result<Vec<Self>, Error> {
.get_results::<Self>(conn)
}
- pub fn update_content(
- conn: &PgConnection,
- comment_id: CommentId,
- new_content: &str,
- ) -> Result<Self, Error> {
- use crate::schema::comment::dsl::*;
- diesel::update(comment.find(comment_id))
- .set((content.eq(new_content), updated.eq(naive_now())))
- .get_result::<Self>(conn)
- }
-
- pub fn update_distinguished(
- conn: &PgConnection,
- comment_id: CommentId,
- new_distinguished: bool,
- ) -> Result<Self, Error> {
- use crate::schema::comment::dsl::*;
- diesel::update(comment.find(comment_id))
- .set((distinguished.eq(new_distinguished), updated.eq(naive_now())))
- .get_result::<Self>(conn)
- }
-
pub fn create(
- conn: &PgConnection,
+ conn: &mut PgConnection,
comment_form: &CommentForm,
parent_path: Option<&Ltree>,
) -> Result<Comment, Error> {
inserted_comment
}
}
- pub fn read_from_apub_id(conn: &PgConnection, object_id: Url) -> Result<Option<Self>, Error> {
+ pub fn read_from_apub_id(conn: &mut PgConnection, object_id: Url) -> Result<Option<Self>, Error> {
use crate::schema::comment::dsl::*;
let object_id: DbUrl = object_id.into();
Ok(
impl Crud for Comment {
type Form = CommentForm;
type IdType = CommentId;
- fn read(conn: &PgConnection, comment_id: CommentId) -> Result<Self, Error> {
+ fn read(conn: &mut PgConnection, comment_id: CommentId) -> Result<Self, Error> {
use crate::schema::comment::dsl::*;
comment.find(comment_id).first::<Self>(conn)
}
- fn delete(conn: &PgConnection, comment_id: CommentId) -> Result<usize, Error> {
+ fn delete(conn: &mut PgConnection, comment_id: CommentId) -> Result<usize, Error> {
use crate::schema::comment::dsl::*;
diesel::delete(comment.find(comment_id)).execute(conn)
}
/// This is unimplemented, use [[Comment::create]]
- fn create(_conn: &PgConnection, _comment_form: &CommentForm) -> Result<Self, Error> {
+ fn create(_conn: &mut PgConnection, _comment_form: &CommentForm) -> Result<Self, Error> {
unimplemented!();
}
fn update(
- conn: &PgConnection,
+ conn: &mut PgConnection,
comment_id: CommentId,
comment_form: &CommentForm,
) -> Result<Self, Error> {
impl Likeable for CommentLike {
type Form = CommentLikeForm;
type IdType = CommentId;
- fn like(conn: &PgConnection, comment_like_form: &CommentLikeForm) -> Result<Self, Error> {
+ fn like(conn: &mut PgConnection, comment_like_form: &CommentLikeForm) -> Result<Self, Error> {
use crate::schema::comment_like::dsl::*;
insert_into(comment_like)
.values(comment_like_form)
.get_result::<Self>(conn)
}
fn remove(
- conn: &PgConnection,
+ conn: &mut PgConnection,
person_id: PersonId,
comment_id: CommentId,
) -> Result<usize, Error> {
impl Saveable for CommentSaved {
type Form = CommentSavedForm;
- fn save(conn: &PgConnection, comment_saved_form: &CommentSavedForm) -> Result<Self, Error> {
+ fn save(conn: &mut PgConnection, comment_saved_form: &CommentSavedForm) -> Result<Self, Error> {
use crate::schema::comment_saved::dsl::*;
insert_into(comment_saved)
.values(comment_saved_form)
.set(comment_saved_form)
.get_result::<Self>(conn)
}
- fn unsave(conn: &PgConnection, comment_saved_form: &CommentSavedForm) -> Result<usize, Error> {
+ fn unsave(
+ conn: &mut PgConnection,
+ comment_saved_form: &CommentSavedForm,
+ ) -> Result<usize, Error> {
use crate::schema::comment_saved::dsl::*;
diesel::delete(
comment_saved
#[test]
#[serial]
fn test_crud() {
- let conn = establish_unpooled_connection();
+ let conn = &mut establish_unpooled_connection();
let new_person = PersonForm {
name: "terry".into(),
..PersonForm::default()
};
- let inserted_person = Person::create(&conn, &new_person).unwrap();
+ let inserted_person = Person::create(conn, &new_person).unwrap();
let new_community = CommunityForm {
name: "test community".to_string(),
..CommunityForm::default()
};
- let inserted_community = Community::create(&conn, &new_community).unwrap();
+ let inserted_community = Community::create(conn, &new_community).unwrap();
let new_post = PostForm {
name: "A test post".into(),
..PostForm::default()
};
- let inserted_post = Post::create(&conn, &new_post).unwrap();
+ let inserted_post = Post::create(conn, &new_post).unwrap();
let comment_form = CommentForm {
content: "A test comment".into(),
..CommentForm::default()
};
- let inserted_comment = Comment::create(&conn, &comment_form, None).unwrap();
+ let inserted_comment = Comment::create(conn, &comment_form, None).unwrap();
let expected_comment = Comment {
id: inserted_comment.id,
};
let inserted_child_comment =
- Comment::create(&conn, &child_comment_form, Some(&inserted_comment.path)).unwrap();
+ Comment::create(conn, &child_comment_form, Some(&inserted_comment.path)).unwrap();
// Comment Like
let comment_like_form = CommentLikeForm {
score: 1,
};
- let inserted_comment_like = CommentLike::like(&conn, &comment_like_form).unwrap();
+ let inserted_comment_like = CommentLike::like(conn, &comment_like_form).unwrap();
let expected_comment_like = CommentLike {
id: inserted_comment_like.id,
person_id: inserted_person.id,
};
- let inserted_comment_saved = CommentSaved::save(&conn, &comment_saved_form).unwrap();
+ let inserted_comment_saved = CommentSaved::save(conn, &comment_saved_form).unwrap();
let expected_comment_saved = CommentSaved {
id: inserted_comment_saved.id,
published: inserted_comment_saved.published,
};
- let read_comment = Comment::read(&conn, inserted_comment.id).unwrap();
- let updated_comment = Comment::update(&conn, inserted_comment.id, &comment_form).unwrap();
- let like_removed = CommentLike::remove(&conn, inserted_person.id, inserted_comment.id).unwrap();
- let saved_removed = CommentSaved::unsave(&conn, &comment_saved_form).unwrap();
- let num_deleted = Comment::delete(&conn, inserted_comment.id).unwrap();
- Comment::delete(&conn, inserted_child_comment.id).unwrap();
- Post::delete(&conn, inserted_post.id).unwrap();
- Community::delete(&conn, inserted_community.id).unwrap();
- Person::delete(&conn, inserted_person.id).unwrap();
+ let read_comment = Comment::read(conn, inserted_comment.id).unwrap();
+ let updated_comment = Comment::update(conn, inserted_comment.id, &comment_form).unwrap();
+ let like_removed = CommentLike::remove(conn, inserted_person.id, inserted_comment.id).unwrap();
+ let saved_removed = CommentSaved::unsave(conn, &comment_saved_form).unwrap();
+ let num_deleted = Comment::delete(conn, inserted_comment.id).unwrap();
+ Comment::delete(conn, inserted_child_comment.id).unwrap();
+ Post::delete(conn, inserted_post.id).unwrap();
+ Community::delete(conn, inserted_community.id).unwrap();
+ Person::delete(conn, inserted_person.id).unwrap();
assert_eq!(expected_comment, read_comment);
assert_eq!(expected_comment, inserted_comment);