From c61fca9a5f93a96075235eeb9aafbb6166703248 Mon Sep 17 00:00:00 2001 From: Nikita Kalyanov Date: Thu, 16 Nov 2023 18:52:55 +0100 Subject: [PATCH] fmt --- compute_tools/src/compute.rs | 13 +++++++++++-- compute_tools/src/http/api.rs | 3 ++- 2 files changed, 13 insertions(+), 3 deletions(-) diff --git a/compute_tools/src/compute.rs b/compute_tools/src/compute.rs index e9a3ff0930..04cf672950 100644 --- a/compute_tools/src/compute.rs +++ b/compute_tools/src/compute.rs @@ -1041,7 +1041,10 @@ LIMIT 100", } pub async fn ensure_row_level_sec(&self, params: RowLevelParams) -> Result { - let conn_str = self.connstr.as_str().replace("/postgres", &format!("/{}", params.database_name)); + let conn_str = self + .connstr + .as_str() + .replace("/postgres", &format!("/{}", params.database_name)); let connect_result = tokio_postgres::connect(&conn_str, NoTls).await; let (client, connection) = connect_result.unwrap(); tokio::spawn(async move { @@ -1057,7 +1060,13 @@ CREATE USER $2 WITH PASSWORD $3 IN GROUP $4; CREATE POLICY neon_row_level ON $1 TO $4 USING ($5 = current_user); COMMIT;", -&[¶ms.table_name, ¶ms.user_name, ¶ms.password,¶ms.role, ¶ms.column_name], + &[ + ¶ms.table_name, + ¶ms.user_name, + ¶ms.password, + ¶ms.role, + ¶ms.column_name, + ], ) .await; Ok(result.is_ok()) diff --git a/compute_tools/src/http/api.rs b/compute_tools/src/http/api.rs index ab922c2e0a..f77ee8ed41 100644 --- a/compute_tools/src/http/api.rs +++ b/compute_tools/src/http/api.rs @@ -210,7 +210,8 @@ async fn routes(req: Request, compute: &Arc) -> Response = hyper::body::to_bytes(req.into_body()).await.unwrap().into(); - let params: RowLevelParams = serde_json::from_str(&String::from_utf8(body_bytes).unwrap()).unwrap(); + let params: RowLevelParams = + serde_json::from_str(&String::from_utf8(body_bytes).unwrap()).unwrap(); let res = compute.ensure_row_level_sec(params).await; if !res.is_ok() {