X-Git-Url: http://these/git/?a=blobdiff_plain;f=crates%2Fdb_schema%2Fsrc%2Fimpls%2Fsite.rs;h=fb944f527ada47638b5148d589858fb07eeef74e;hb=c9f140742925d6da20103124b49f2b58a35fc2b8;hp=6c71f076ed1ab6665dc66c6c01f39901081f9da8;hpb=4e6409f325bca5b2727b19c24d77ffa2b59109b1;p=lemmy.git diff --git a/crates/db_schema/src/impls/site.rs b/crates/db_schema/src/impls/site.rs index 6c71f076..fb944f52 100644 --- a/crates/db_schema/src/impls/site.rs +++ b/crates/db_schema/src/impls/site.rs @@ -5,35 +5,35 @@ use url::Url; impl Crud for Site { type Form = SiteForm; type IdType = i32; - fn read(conn: &PgConnection, _site_id: i32) -> Result { + fn read(conn: &mut PgConnection, _site_id: i32) -> Result { use crate::schema::site::dsl::*; site.first::(conn) } - fn create(conn: &PgConnection, new_site: &SiteForm) -> Result { + fn create(conn: &mut PgConnection, new_site: &SiteForm) -> Result { use crate::schema::site::dsl::*; insert_into(site).values(new_site).get_result::(conn) } - fn update(conn: &PgConnection, site_id: i32, new_site: &SiteForm) -> Result { + fn update(conn: &mut PgConnection, site_id: i32, new_site: &SiteForm) -> Result { use crate::schema::site::dsl::*; diesel::update(site.find(site_id)) .set(new_site) .get_result::(conn) } - fn delete(conn: &PgConnection, site_id: i32) -> Result { + fn delete(conn: &mut PgConnection, site_id: i32) -> Result { use crate::schema::site::dsl::*; diesel::delete(site.find(site_id)).execute(conn) } } impl Site { - pub fn read_local_site(conn: &PgConnection) -> Result { + pub fn read_local_site(conn: &mut PgConnection) -> Result { use crate::schema::site::dsl::*; site.order_by(id).first::(conn) } - pub fn upsert(conn: &PgConnection, site_form: &SiteForm) -> Result { + pub fn upsert(conn: &mut PgConnection, site_form: &SiteForm) -> Result { use crate::schema::site::dsl::*; insert_into(site) .values(site_form) @@ -43,7 +43,7 @@ impl Site { .get_result::(conn) } - pub fn read_from_apub_id(conn: &PgConnection, object_id: Url) -> Result, Error> { + pub fn read_from_apub_id(conn: &mut PgConnection, object_id: Url) -> Result, Error> { use crate::schema::site::dsl::*; let object_id: DbUrl = object_id.into(); Ok( @@ -55,7 +55,7 @@ impl Site { ) } - pub fn read_remote_sites(conn: &PgConnection) -> Result, Error> { + pub fn read_remote_sites(conn: &mut PgConnection) -> Result, Error> { use crate::schema::site::dsl::*; site.order_by(id).offset(1).get_results::(conn) }