X-Git-Url: http://these/git/?a=blobdiff_plain;f=crates%2Fdb_schema%2Fsrc%2Fimpls%2Finstance.rs;h=473ca007e6015d334f6de3e3644c7270ae407b7d;hb=3735c6fabfd85d6c98c2fc126b70e593db532eb8;hp=32d03e3829919bf61cbc699066dc459409bffdaf;hpb=47f4aa3550e7e79736f87673e007f930a9442f1f;p=lemmy.git diff --git a/crates/db_schema/src/impls/instance.rs b/crates/db_schema/src/impls/instance.rs index 32d03e38..473ca007 100644 --- a/crates/db_schema/src/impls/instance.rs +++ b/crates/db_schema/src/impls/instance.rs @@ -31,10 +31,10 @@ impl Instance { Self::create(pool, domain).await } pub async fn create_conn(conn: &mut AsyncPgConnection, domain: &str) -> Result { - let form = InstanceForm { - domain: domain.to_string(), - updated: Some(naive_now()), - }; + let form = InstanceForm::builder() + .domain(domain.to_string()) + .updated(Some(naive_now())) + .build(); Self::create_from_form_conn(conn, &form).await } pub async fn delete(pool: &DbPool, instance_id: InstanceId) -> Result { @@ -47,31 +47,31 @@ impl Instance { let conn = &mut get_conn(pool).await?; diesel::delete(instance::table).execute(conn).await } - pub async fn allowlist(pool: &DbPool) -> Result, Error> { + pub async fn allowlist(pool: &DbPool) -> Result, Error> { let conn = &mut get_conn(pool).await?; instance::table .inner_join(federation_allowlist::table) - .select(instance::domain) - .load::(conn) + .select(instance::all_columns) + .get_results(conn) .await } - pub async fn blocklist(pool: &DbPool) -> Result, Error> { + pub async fn blocklist(pool: &DbPool) -> Result, Error> { let conn = &mut get_conn(pool).await?; instance::table .inner_join(federation_blocklist::table) - .select(instance::domain) - .load::(conn) + .select(instance::all_columns) + .get_results(conn) .await } - pub async fn linked(pool: &DbPool) -> Result, Error> { + pub async fn linked(pool: &DbPool) -> Result, Error> { let conn = &mut get_conn(pool).await?; instance::table .left_join(federation_blocklist::table) .filter(federation_blocklist::id.is_null()) - .select(instance::domain) - .load::(conn) + .select(instance::all_columns) + .get_results(conn) .await } }