mirror of
https://github.com/EasyTier/EasyTier.git
synced 2026-05-07 02:09:06 +00:00
Update http_connector.rs (#1900)
This commit is contained in:
@@ -12,6 +12,7 @@ use url::Url;
|
|||||||
use crate::{
|
use crate::{
|
||||||
common::{error::Error, global_ctx::ArcGlobalCtx},
|
common::{error::Error, global_ctx::ArcGlobalCtx},
|
||||||
tunnel::{IpVersion, Tunnel, TunnelConnector, TunnelError, ZCPacketSink, ZCPacketStream},
|
tunnel::{IpVersion, Tunnel, TunnelConnector, TunnelError, ZCPacketSink, ZCPacketStream},
|
||||||
|
VERSION,
|
||||||
};
|
};
|
||||||
|
|
||||||
use crate::proto::common::TunnelInfo;
|
use crate::proto::common::TunnelInfo;
|
||||||
@@ -170,6 +171,7 @@ impl HttpTunnelConnector {
|
|||||||
let original_url_clone = original_url.to_string();
|
let original_url_clone = original_url.to_string();
|
||||||
let body_clone = body.clone();
|
let body_clone = body.clone();
|
||||||
let network_name = self.global_ctx.network.network_name.clone();
|
let network_name = self.global_ctx.network.network_name.clone();
|
||||||
|
let user_agent = format!("easytier/{}", VERSION);
|
||||||
let res = tokio::task::spawn_blocking(move || {
|
let res = tokio::task::spawn_blocking(move || {
|
||||||
let uri = http_req::uri::Uri::try_from(original_url_clone.as_ref())
|
let uri = http_req::uri::Uri::try_from(original_url_clone.as_ref())
|
||||||
.with_context(|| format!("parsing url failed. url: {}", original_url_clone))?;
|
.with_context(|| format!("parsing url failed. url: {}", original_url_clone))?;
|
||||||
@@ -181,6 +183,7 @@ impl HttpTunnelConnector {
|
|||||||
);
|
);
|
||||||
|
|
||||||
Request::new(&uri)
|
Request::new(&uri)
|
||||||
|
.header("User-Agent", &user_agent)
|
||||||
.header("X-Network-Name", &network_name)
|
.header("X-Network-Name", &network_name)
|
||||||
.redirect_policy(RedirectPolicy::Limit(0))
|
.redirect_policy(RedirectPolicy::Limit(0))
|
||||||
.timeout(std::time::Duration::from_secs(20))
|
.timeout(std::time::Duration::from_secs(20))
|
||||||
|
|||||||
Reference in New Issue
Block a user