Implemented reqwest integration

Signed-off-by: Francesco Guardiani <[email protected]>

Author: slinkydeveloper

Cargo.lock

@@ -33,5 +33,6 @@ name = "cloudevents"
 [workspace]
 members = [
   ".",
-  "cloudevents-sdk-actix-web"
+  "cloudevents-sdk-actix-web",
+  "cloudevents-sdk-reqwest"
 ]

Cargo.toml

@@ -20,6 +20,7 @@ Work in progress SDK for [CloudEvents](https://github.com/cloudevents/spec)
 
 * `cloudevents-sdk`: Provides Event data structure, JSON Event format implementation
 * `cloudevents-sdk-actix-web`: Integration with [Actix Web](https://github.com/actix/actix-web)
+* `cloudevents-sdk-reqwest`: Integration with [reqwest](https://github.com/seanmonstar/reqwest)
 
 ## Development & Contributing
 

README.md

@@ -0,0 +1,19 @@
+[package]
+name = "cloudevents-sdk-reqwest"
+version = "0.1.0"
+authors = ["Francesco Guardiani <[email protected]>"]
+edition = "2018"
+
+# See more keys and their definitions at https://doc.rust-lang.org/cargo/reference/manifest.html
+
+[dependencies]
+cloudevents-sdk = { path = ".." }
+reqwest = { version = "0.10" }
+lazy_static = "1.4.0"
+bytes = "^0.5"
+serde_json = "^1.0"
+url = { version = "^2.1", features = ["serde"] }
+
+[dev-dependencies]
+mockito = "0.25.1"
+tokio = { version = "^0.2", features = ["full"] }

cloudevents-sdk-reqwest/Cargo.toml

@@ -0,0 +1,175 @@
+use super::headers;
+use cloudevents::event::SpecVersion;
+use cloudevents::message::{
+    BinaryDeserializer, BinarySerializer, MessageAttributeValue,
+    Result, StructuredSerializer,
+};
+use cloudevents::Event;
+use reqwest::RequestBuilder;
+use std::str::FromStr;
+
+/// Wrapper for [`RequestBuilder`] that implements [`StructuredSerializer`] & [`BinarySerializer`] traits
+pub struct RequestSerializer {
+    req: RequestBuilder,
+}
+
+impl RequestSerializer {
+    pub fn new(req: RequestBuilder) -> RequestSerializer {
+        RequestSerializer { req }
+    }
+}
+
+impl BinarySerializer<RequestBuilder> for RequestSerializer {
+    fn set_spec_version(mut self, spec_version: SpecVersion) -> Result<Self> {
+        self.req = self
+            .req
+            .header(headers::SPEC_VERSION_HEADER.clone(), spec_version.as_str());
+        Ok(self)
+    }
+
+    fn set_attribute(mut self, name: &str, value: MessageAttributeValue) -> Result<Self> {
+        self.req = self.req.header(
+            headers::ATTRIBUTES_TO_HEADERS.get(name).unwrap().clone(),
+            value.to_string(),
+        );
+        Ok(self)
+    }
+
+    fn set_extension(mut self, name: &str, value: MessageAttributeValue) -> Result<Self> {
+        self.req = self
+            .req
+            .header(attribute_name_to_header!(name)?, value.to_string());
+        Ok(self)
+    }
+
+    fn end_with_data(self, bytes: Vec<u8>) -> Result<RequestBuilder> {
+        Ok(self.req.body(bytes))
+    }
+
+    fn end(self) -> Result<RequestBuilder> {
+        Ok(self.req)
+    }
+}
+
+impl StructuredSerializer<RequestBuilder> for RequestSerializer {
+    fn set_structured_event(self, bytes: Vec<u8>) -> Result<RequestBuilder> {
+        Ok(self
+            .req
+            .header(
+                reqwest::header::CONTENT_TYPE,
+                headers::CLOUDEVENTS_JSON_HEADER.clone(),
+            )
+            .body(bytes))
+    }
+}
+
+/// Method to transform an incoming [`HttpRequest`] to [`Event`]
+pub fn event_to_request(
+    event: Event,
+    request_builder: RequestBuilder,
+) -> Result<RequestBuilder> {
+    BinaryDeserializer::deserialize_binary(event, RequestSerializer::new(request_builder))
+}
+
+#[cfg(test)]
+mod tests {
+    use super::*;
+    use mockito::{mock, Matcher};
+
+    use cloudevents::EventBuilder;
+    use serde_json::json;
+    use url::Url;
+    use cloudevents::message::StructuredDeserializer;
+
+    #[tokio::test]
+    async fn test_request() {
+        let url = mockito::server_url();
+        let m = mock("POST", "/")
+            .match_header("ce-specversion", "1.0")
+            .match_header("ce-id", "0001")
+            .match_header("ce-type", "example.test")
+            .match_header("ce-source", "http://localhost/")
+            .match_header("ce-someint", "10")
+            .match_body(Matcher::Missing)
+            .create();
+
+        let input = EventBuilder::new()
+            .id("0001")
+            .ty("example.test")
+            .source(Url::from_str("http://localhost/").unwrap())
+            .extension("someint", "10")
+            .build();
+
+        let client = reqwest::Client::new();
+        event_to_request(input, client.post(&url))
+            .unwrap()
+            .send()
+            .await
+            .unwrap();
+
+        m.assert();
+    }
+
+    #[tokio::test]
+    async fn test_request_with_full_data() {
+        let j = json!({"hello": "world"});
+
+        let url = mockito::server_url();
+        let m = mock("POST", "/")
+            .match_header("ce-specversion", "1.0")
+            .match_header("ce-id", "0001")
+            .match_header("ce-type", "example.test")
+            .match_header("ce-source", "http://localhost/")
+            .match_header("content-type", "application/json")
+            .match_header("ce-someint", "10")
+            .match_body(Matcher::Exact(j.to_string()))
+            .create();
+
+        let input = EventBuilder::new()
+            .id("0001")
+            .ty("example.test")
+            .source(Url::from_str("http://localhost").unwrap())
+            .data("application/json", j.clone())
+            .extension("someint", "10")
+            .build();
+
+        let client = reqwest::Client::new();
+        event_to_request(input, client.post(&url))
+            .unwrap()
+            .send()
+            .await
+            .unwrap();
+
+        m.assert();
+    }
+
+    #[tokio::test]
+    async fn test_structured_request_with_full_data() {
+        let j = json!({"hello": "world"});
+
+        let input = EventBuilder::new()
+            .id("0001")
+            .ty("example.test")
+            .source(Url::from_str("http://localhost").unwrap())
+            .data("application/json", j.clone())
+            .extension("someint", "10")
+            .build();
+
+        let url = mockito::server_url();
+        let m = mock("POST", "/")
+            .match_header("content-type", "application/cloudevents+json")
+            .match_body(Matcher::Exact(serde_json::to_string(&input).unwrap()))
+            .create();
+
+        let client = reqwest::Client::new();
+        StructuredDeserializer::deserialize_structured(
+            input,
+            RequestSerializer::new(client.post(&url))
+        ).unwrap()
+            .send()
+            .await
+            .unwrap();
+
+        m.assert();
+    }
+}