Feedback & cleanup

prisma · Oct 9, 2024 · 44fc31a · 44fc31a
1 parent 9818106
commit 44fc31a
Show file tree

Hide file tree

Showing 2 changed files with 4 additions and 8 deletions.
diff --git a/quaint/src/connector/postgres/native/websocket.rs b/quaint/src/connector/postgres/native/websocket.rs
@@ -27,7 +27,6 @@ pub(crate) async fn connect_via_websocket(url: PostgresWebSocketUrl) -> crate::R
 
     let connection_params = require_header_value(response.headers(), CONNECTION_PARAMS_HEADER)?;
     let db_host = require_header_value(response.headers(), HOST_HEADER)?;
-    dbg!(&connection_params);
 
     let config = Config::from_str(connection_params)?;
     let ws_byte_stream = WsStream::new(ws_stream);

diff --git a/schema-engine/connectors/sql-schema-connector/src/flavour/postgres/connection.rs b/schema-engine/connectors/sql-schema-connector/src/flavour/postgres/connection.rs
@@ -22,13 +22,10 @@ impl Connection {
         let url = MigratePostgresUrl::new(url)?;
 
         let quaint = match url.0 {
-            PostgresUrl::Native(ref native_url) => connector::PostgreSql::new(native_url.as_ref().clone())
-                .await
-                .map_err(quaint_err(&url))?,
-            PostgresUrl::WebSocket(ref ws_url) => connector::PostgreSql::new_with_websocket(ws_url.clone())
-                .await
-                .map_err(quaint_err(&url))?,
-        };
+            PostgresUrl::Native(ref native_url) => connector::PostgreSql::new(native_url.as_ref().clone()).await,
+            PostgresUrl::WebSocket(ref ws_url) => connector::PostgreSql::new_with_websocket(ws_url.clone()).await,
+        }
+        .map_err(quaint_err(&url))?;
 
         let version = quaint.version().await.map_err(quaint_err(&url))?;