feat(dgw): initial implementation for /jet/fwd/http endpoint (#1084)

Currently behind the unstable flag.
Some details may be adjusted in the future.

For HTTP requests without upgrade, we do not account the
operation as a session: it does not influence DVLS licensing
quota, subscriber events, etc. HTTP requests resulting into a
WebSocket upgrade however will count as a fully-fledged
session as usual.

Issue: DGW-217
Changelog: ignore

crates/devolutions-gateway-generators/src/lib.rs

@@ -234,18 +234,31 @@ pub fn any_scope_claims(now: i64, validity_duration: i64) -> impl Strategy<Value
 #[derive(Debug, Clone, Serialize)]
 pub struct BridgeClaims {
     pub target_host: TargetAddr,
+    pub jet_aid: Uuid,
+    pub jet_ap: ApplicationProtocol,
+    pub jet_rec: RecordingPolicy,
     pub nbf: i64,
     pub exp: i64,
     pub jti: Uuid,
 }
 
 pub fn any_bridge_claims(now: i64, validity_duration: i64) -> impl Strategy<Value = BridgeClaims> {
-    (target_addr(), uuid_typed()).prop_map(move |(target_host, jti)| BridgeClaims {
-        target_host,
-        jti,
-        nbf: now,
-        exp: now + validity_duration,
-    })
+    (
+        target_addr(),
+        uuid_typed(),
+        application_protocol(),
+        recording_policy(),
+        uuid_typed(),
+    )
+        .prop_map(move |(target_host, jet_aid, jet_ap, jet_rec, jti)| BridgeClaims {
+            target_host,
+            jet_aid,
+            jet_ap,
+            jet_rec,
+            nbf: now,
+            exp: now + validity_duration,
+            jti,
+        })
 }
 
 #[derive(Debug, Clone, Serialize)]

devolutions-gateway/Cargo.toml

@@ -65,7 +65,7 @@ tracing = "0.1"
 # Async, futures…
 tokio = { version = "1.41", features = ["signal", "net", "io-util", "time", "rt", "rt-multi-thread", "sync", "macros", "parking_lot", "fs"] }
 tokio-rustls = { version = "0.26", default-features = false, features = ["logging", "tls12", "ring"] }
-reqwest = { version = "0.12", default-features = false, features = ["rustls-tls-native-roots", "json"] }
+reqwest = { version = "0.12", default-features = false, features = ["rustls-tls-native-roots", "json", "stream"] }
 futures = "0.3"
 async-trait = "0.1"
 tower = { version = "0.5", features = ["timeout"] }
@@ -78,6 +78,8 @@ axum = { version = "0.7", default-features = false, features = ["http1", "json",
 axum-extra = { version = "0.9", features = ["query", "async-read-body", "typed-header"] }
 tower-http = { version = "0.5", features = ["cors", "fs"] }
 tungstenite = "0.24" # Should be the same version as `axum` (we perform error downcasting for better error reporting)
+tokio-tungstenite = { version = "0.24", features = ["rustls-tls-native-roots"] } # Should use the same version of tungstenite as `axum`
+http-body-util = "0.1"
 
 # OpenAPI generator
 utoipa = { version = "4.2", default-features = false, features = ["uuid", "time"], optional = true }