Support xhttp

src/config_models/mod.rs

@@ -60,6 +60,15 @@ pub struct KCPSettings {
     pub seed: Option<String>,
 }
 
+#[allow(non_snake_case)]
+#[derive(Serialize, Deserialize)]
+pub struct XHTTPSettings {
+    pub host: Option<String>,
+    pub path: Option<String>,
+    pub mode: Option<String>,
+    pub extra: Option<serde_json::Value>,
+}
+
 #[allow(non_snake_case)]
 #[derive(Serialize, Deserialize)]
 pub struct RealitySettings {
@@ -124,6 +133,7 @@ pub struct StreamSettings {
     pub grpcSettings: Option<GRPCSettings>,
     pub quicSettings: Option<QuicSettings>,
     pub kcpSettings: Option<KCPSettings>,
+    pub xhttpSettings: Option<XHTTPSettings>,
 }
 
 #[allow(non_snake_case)]

src/parser/vless/mod.rs

@@ -31,8 +31,8 @@ pub fn create_outbound_object(data: models::VlessData) -> Outbound {
             },
             wsSettings: if network_type == String::from("ws") {
                 Some(WsSettings {
-                    Host: data.query.host,
+                    Host: data.query.host.clone(),
-                    path: data.query.path,
+                    path: data.query.path.clone(),
                     acceptProxyProtocol: None,
                 })
             } else {
@@ -93,6 +93,16 @@ pub fn create_outbound_object(data: models::VlessData) -> Outbound {
             } else {
                 None
             },
+            xhttpSettings: if network_type == String::from("xhttp") {
+                Some(XHTTPSettings {
+                    host: data.query.host.clone(),
+                    path: data.query.path.clone(),
+                    mode: data.query.mode,
+                    extra: data.query.extra.and_then(|e| parse_raw_json(e.as_str())),
+                })
+            } else {
+                None
+            },
         },
         settings: OutboundSettings::Vless(VlessOutboundSettings {
             vnext: vec![VlessServerObject {
@@ -167,6 +177,7 @@ fn parse_vless_query(raw_query: &str) -> models::VlessQuery {
         service_name: url_decode(get_parameter_value(&query, "serviceName")),
         slpn: get_parameter_value(&query, "slpn"),
         spx: url_decode(get_parameter_value(&query, "spx")),
+        extra: url_decode(get_parameter_value(&query, "extra")),
     };
     return a;
 }
@@ -179,6 +190,15 @@ fn url_decode(value: Option<String>) -> Option<String> {
     });
 }
 
+fn parse_raw_json(input: &str) -> Option<serde_json::Value> {
+    serde_json::from_str::<serde_json::Value>(input)
+        .ok()
+        .and_then(|v| match v {
+            serde_json::Value::Object(_) => Some(v),
+            _ => None,
+        })
+}
+
 fn get_parameter_value(query: &Vec<(&str, &str)>, param: &str) -> Option<String> {
     return query
         .iter()

src/parser/vless/models.rs

@@ -19,6 +19,7 @@ pub struct VlessQuery {
     pub slpn: Option<String>,
     pub spx: Option<String>,
     pub alpn: Option<String>,
+    pub extra: Option<String>,
 }
 
 pub struct VlessAddress {