feat: Implement HTTP-over-AMQP

.gitignore

@@ -1,5 +1,6 @@
 **/target
 **/Cargo.lock
+.idea/
 .vscode/
 .DS_Store
 

Cargo.toml

@@ -11,6 +11,7 @@ members = [
     "fe2o3-amqp-ws",
     "fe2o3-amqp-management",
     "fe2o3-amqp-cbs",
+    "fe2o3-amqp-http",
 ]
 
 exclude = [
@@ -67,9 +68,49 @@ log = "0.4"
 tracing = "0.1"
 tokio = { version = "1", default-features = false }
 tokio-util = "0.7"
+tokio-test = "0.4"
 futures-util = "0.3"
 uuid = "1"
 ordered-float = "4"
 pin-project-lite = "0.2"
 rand = "0.8"
-getrandom = { version = "0.2", features = ["js"] }
+getrandom = { version = "0.2", features = ["js"] }
+convert_case = "0.6.0"
+darling = "0.20"
+proc-macro2 = "1"
+quote = "1"
+syn = "2"
+url = "2"
+slab = "0.4"
+parking_lot = { version = "0.12", features = ["send_guard"] }
+sha-1 = "0.10"
+sha2 = "0.10"
+base64 = "0.22"
+stringprep = "0.1"
+hmac = "0.12"
+pbkdf2 = "0.12"
+webpki-roots = "0.26"
+tokio-rustls = "0.26"
+librustls = { package = "rustls", version = "0.23" }
+libnative-tls = { package = "native-tls", version = "0.2" }
+tokio-native-tls = "0.3"
+ring = "0.17"
+tokio-stream = "0.1"
+fluvio-wasm-timer = "0.2"
+testcontainers = "0.15.0"
+indexmap = "2"
+serde_json = "1"
+chrono = "0.4"
+time = "0.3"
+criterion = "0.5"
+http = "1"
+httpdate = "1"
+http-body = "1"
+http-body-util = "0.1"
+tungstenite = "0.24"
+tokio-tungstenite = "0.24"
+js-sys = "0.3"
+wasm-bindgen = "0.2"
+web-sys = "0.3"
+serde_repr = "0.1"
+trait-variant = "0.1.1"

fe2o3-amqp-cbs/Cargo.toml

@@ -13,6 +13,6 @@ readme = "Readme.md"
 # See more keys and their definitions at https://doc.rust-lang.org/cargo/reference/manifest.html
 
 [dependencies]
-fe2o3-amqp = { workspace = true }
-fe2o3-amqp-management = { workspace = true }
-trait-variant = "0.1.1"
+fe2o3-amqp.workspace = true
+fe2o3-amqp-management.workspace = true
+trait-variant.workspace = true

fe2o3-amqp-ext/Cargo.toml

@@ -13,4 +13,4 @@ readme = "Readme.md"
 
 [dependencies]
 serde_amqp = { workspace = true, features = ["derive"] }
-fe2o3-amqp-types = { workspace = true }
+fe2o3-amqp-types.workspace = true

fe2o3-amqp-http/Cargo.toml

@@ -0,0 +1,19 @@
+[package]
+name = "fe2o3-amqp-http"
+version = "0.1.0"
+edition = "2021"
+
+[dependencies]
+fe2o3-amqp.workspace = true
+fe2o3-amqp-types.workspace = true
+serde.workspace = true
+thiserror.workspace = true
+
+http.workspace = true
+httpdate.workspace = true
+http-body.workspace = true
+http-body-util.workspace = true
+
+# Optional dependencies
+log = { workspace = true, optional = true }
+tracing = { workspace = true, optional = true }

fe2o3-amqp-http/src/client.rs

@@ -0,0 +1,9 @@
+use fe2o3_amqp::{Receiver, Sender};
+
+use crate::projected::TryIntoProjected;
+
+#[derive(Debug)]
+pub struct Client {
+    sender: Sender,
+    receiver: Receiver,
+}

fe2o3-amqp-http/src/error.rs

@@ -0,0 +1,58 @@
+use http::{header::{InvalidHeaderValue, ToStrError}, method::InvalidMethod, status::InvalidStatusCode};
+use thiserror::Error;
+
+#[derive(Debug, Error)]
+pub enum TryIntoProjectedError<BE> {
+    #[error(transparent)]
+    ToStrError(#[from] ToStrError),
+
+    #[error(transparent)]
+    Date(#[from] httpdate::Error),
+
+    #[error(transparent)]
+    SystemTime(#[from] std::time::SystemTimeError),
+
+    #[error(transparent)]
+    Body(BE),
+}
+
+#[derive(Debug, Error)]
+pub enum TryFromProjectedError<BE> {
+    #[error("HTTP method not present")]
+    MethodNotPresent,
+
+    #[error(transparent)]
+    InvalidMethod(#[from] InvalidMethod),
+
+    #[error("HTTP status not present")]
+    StatusNotPresent,
+
+    #[error(transparent)]
+    InvalidStatusCode(#[from] InvalidStatusCode),
+
+    #[error("HTTP request target not present")]
+    RequestTargetNotPresent,
+
+    #[error("HTTP version not encoded as a string")]
+    VersionNotString,
+
+    #[error("HTTP version not valid")]
+    InvalidVersion,
+
+    #[error(transparent)]
+    HeaderValue(#[from] InvalidHeaderValue),
+
+    #[error(transparent)]
+    Body(BE),
+
+    #[error(transparent)]
+    Http(#[from] http::Error),
+}
+
+pub(crate) struct InvalidVersion;
+
+impl<T> From<InvalidVersion> for TryFromProjectedError<T> {
+    fn from(_: InvalidVersion) -> Self {
+        TryFromProjectedError::InvalidVersion
+    }
+}

fe2o3-amqp-http/src/lib.rs

@@ -0,0 +1,7 @@
+pub mod client;
+pub mod projected;
+pub mod tunneled;
+pub mod uri;
+pub mod error;
+
+mod util;