rust/neon
1
0
Fork 0
mirror of https://github.com/neondatabase/neon.git synced 2026-05-21 23:20:40 +00:00
Code Issues Packages Projects Releases Wiki Activity

Fix SQL over HTTP endpoint

Browse Source
This commit is contained in:
Vadim Kharitonov
2023-05-24 14:05:03 +02:00
parent d425f2cb14
commit c82b00110e
1 changed files with 4 additions and 9 deletions
Download Patch File Download Diff File Expand all files Collapse all files

13
proxy/src/http/sql_over_http.rs
View File

@@ -175,14 +175,9 @@ pub async fn handle(
application_name: Some(APP_NAME),
};
let node = creds.wake_compute(&extra).await?.expect("msg");
let conf = node.value.config;
let port = *conf.get_ports().first().expect("no port");
let host = match conf.get_hosts().first().expect("no host") {
tokio_postgres::config::Host::Tcp(host) => host,
tokio_postgres::config::Host::Unix(_) => {
return Err(anyhow::anyhow!("unix socket is not supported"));
}
};
let pg_endpoint = &node.value.address;
let port = pg_endpoint.port;
let host = &pg_endpoint.host;
let request_content_length = match request.body().size_hint().upper() {
Some(v) => v,
@@ -206,7 +201,7 @@ pub async fn handle(
// Connenct to the destination
//
let (client, connection) = tokio_postgres::Config::new()
.host(host)
.host(&host)
.port(port)
.user(&username)
.password(&password)