hex/wstunnel
1
0
Fork 0
Code Issues Pull requests Projects Releases Packages Wiki Activity Actions

fix http2 request

Browse source
This commit is contained in:
Σrebe - Romain GERARD 2024-01-16 22:42:56 +01:00
parent 459a0667b1
commit 81fb524059
No known key found for this signature in database
GPG key ID: 7A42B4B97E0332F4
1 changed files with 3 additions and 5 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

8
src/tunnel/transport/http2.rs
View file

@ -5,7 +5,7 @@ use anyhow::{anyhow, Context};
use bytes::{Bytes, BytesMut};
use http_body_util::{BodyExt, BodyStream, StreamBody};
use hyper::body::{Frame, Incoming};
use hyper::header::{AUTHORIZATION, COOKIE, HOST};
use hyper::header::{AUTHORIZATION, COOKIE};
use hyper::http::response::Parts;
use hyper::Request;
use hyper_util::rt::{TokioExecutor, TokioIo, TokioTimer};
@ -110,13 +110,11 @@ pub async fn connect(
let mut req = Request::builder()
.method("POST")
.uri(format!(
"{}://{}:{}/{}/events",
"{}://{}/{}/events",
client_cfg.remote_addr.scheme(),
client_cfg.remote_addr.host(),
client_cfg.remote_addr.port(),
client_cfg.http_header_host.to_str().unwrap(),
&client_cfg.http_upgrade_path_prefix
))
.header(HOST, &client_cfg.http_header_host)
.header(COOKIE, tunnel_to_jwt_token(request_id, dest_addr))
.version(hyper::Version::HTTP_2);