Update rdkafka, axum, and http.

Cargo.toml

@@ -1,6 +1,6 @@
 [package]
 name = "cloudevents-sdk"
-version = "0.8.0"
+version = "0.9.0"
 authors = ["Francesco Guardiani <[email protected]>"]
 license-file = "LICENSE"
 edition = "2018"
@@ -48,14 +48,14 @@ uuid = { version = "1", features = ["v4"] }
 actix-web = { version = "4", optional = true }
 actix-http = { version = "3", optional = true }
 reqwest-lib = { version = "^0.12", default-features = false, features = ["rustls-tls"], optional = true, package = "reqwest" }
-rdkafka-lib = { version = "^0.36", features = ["cmake-build"], optional = true, package = "rdkafka" }
+rdkafka-lib = { version = "^0.37", features = ["cmake-build"], optional = true, package = "rdkafka" }
 warp-lib = { version = "^0.3", optional = true, package = "warp" }
 async-trait = { version = "^0.1", optional = true }
 bytes = { version = "^1.0", optional = true }
 futures = { version = "^0.3", optional = true, features = ["compat"]}
-http = { version = "1.1", optional = true}
+http = { version = "1.2", optional = true}
 http-0-2 = { version = "0.2", optional = true, package = "http"}
-axum-lib = { version = "^0.7", optional = true, package="axum"}
+axum-lib = { version = "^0.8", optional = true, package="axum"}
 http-body-util = {version = "^0.1", optional = true}
 poem-lib = { version = "^3.1", optional = true, package = "poem" }
 nats-lib = { version = "0.25.0", optional = true, package = "nats" }
@@ -67,15 +67,15 @@ hostname = "^0.4"
 web-sys = { version = "^0.3", features = ["Window", "Location"] }
 
 [target.'cfg(not(target_os = "wasi"))'.dependencies]
-hyper = { version = "^1.4", optional = true, package="hyper" }
+hyper = { version = "^1.5", optional = true, package="hyper" }
 hyper-0-14 = { version = "^0.14", optional = true, package = "hyper"}
 
 [target.'cfg(all(target_arch = "wasm32", target_os = "wasi"))'.dependencies]
 hyper_wasi = { version = "0.15", features = ["full"], optional = true }
 
 [dev-dependencies]
 rstest = "0.23"
-claims = "0.7.1"
+claims = "0.8"
 version-sync = "0.9.2"
 serde_yaml = "^0.9"
 rmp-serde = "1"

README.md

@@ -42,7 +42,7 @@ enabling your Protocol Binding of choice:
 
 ```toml
 [dependencies]
-cloudevents-sdk = { version = "0.8.0" }
+cloudevents-sdk = { version = "0.9.0" }
 ```
 
 Now you can start creating events:

example-projects/axum-example/Cargo.toml

@@ -6,15 +6,15 @@ edition = "2021"
 
 [dependencies]
 cloudevents-sdk = { path = "../..", features = ["axum"] }
-axum = "^0.7"
+axum = "^0.8"
 http = "^1.1"
 tokio = { version = "^1", features = ["full"] }
 tracing = "^0.1"
 tracing-subscriber = "^0.3"
-tower-http = { version = "^0.5", features = ["trace"] }
+tower-http = { version = "^0.6", features = ["trace"] }
 
 [dev-dependencies]
-tower = { version = "^0.4", features = ["util"] }
+tower = { version = "^0.5", features = ["util"] }
 serde = { version = "^1.0", features = ["derive"] }
 serde_json = "^1.0"
 chrono = { version = "^0.4", features = ["serde"] }

example-projects/rdkafka-example/Cargo.toml

@@ -1,6 +1,6 @@
 [package]
 name = "rdkafka-example"
-version = "0.3.0"
+version = "0.4.0"
 authors = ["Pranav Bhatt <[email protected]>"]
 edition = "2018"
 
@@ -16,4 +16,4 @@ serde_json = "^1.0"
 futures = "^0.3"
 tokio = { version = "^1.0", features = ["full"] }
 clap = "2.33.1"
-rdkafka = { version = "^0.36", features = ["cmake-build"] }
+rdkafka = { version = "^0.37", features = ["cmake-build"] }

src/binding/axum/extract.rs

@@ -1,4 +1,3 @@
-use async_trait::async_trait;
 use axum::body::Bytes;
 use axum::extract::{FromRequest, Request};
 use axum::response::Response;
@@ -9,7 +8,6 @@ use http::StatusCode;
 use crate::binding::http::to_event;
 use crate::event::Event;
 
-#[async_trait]
 impl<S> FromRequest<S> for Event
 where
     Bytes: FromRequest<S>,

src/event/attributes.rs

@@ -2,6 +2,7 @@ use super::{
     AttributesIntoIteratorV03, AttributesIntoIteratorV10, AttributesV03, AttributesV10,
     ExtensionValue, SpecVersion, UriReference,
 };
+use base64::prelude::*;
 use chrono::{DateTime, Utc};
 use serde::Serializer;
 use std::fmt;
@@ -37,7 +38,7 @@ impl fmt::Display for AttributeValue<'_> {
             AttributeValue::Boolean(b) => f.serialize_bool(**b),
             AttributeValue::Integer(i) => f.serialize_i64(**i),
             AttributeValue::String(s) => f.write_str(s),
-            AttributeValue::Binary(b) => f.write_str(&base64::encode(b)),
+            AttributeValue::Binary(b) => f.write_str(&BASE64_STANDARD.encode(b)),
             AttributeValue::URI(s) => f.write_str(s.as_str()),
             AttributeValue::URIRef(s) => f.write_str(s.as_str()),
             AttributeValue::Time(s) => f.write_str(&s.to_rfc3339()),

src/lib.rs

@@ -37,24 +37,24 @@
 //! only the module associated with the Protocol Binding you need:
 //!
 //! - `actix`: Enables the [`binding::actix`] protocol binding module. This
 //! extends the [`actix_web::HttpRequest`] with a
 //! [`to_event`](binding::actix::HttpRequestExt::to_event) function, the
 //! [`actix_web::HttpResponseBuilder`] with an
 //! [`event`](binding::actix::HttpResponseBuilderExt::event) function,
 //! and implementations for [`actix_web::FromRequest`] and
 //! [`actix_web::Responder`] in order to take advantage of actix-web's
 //! [Extractors] and [Responders]
 //! - `reqwest`: Enables the [`binding::reqwest`] protocol binding module.
 //! - `warp`: Enables the [`binding::warp`] protocol binding module.
 //! - `axum`: Enables the [`binding::axum`] protocol binding module.
 //! - `rdkafka`: Enables the [`binding::rdkafka`] protocol binding module to
 //! seamlessly consume/produce cloudevents within Kafka messages.
 //!
 //! [feature flags]: https://doc.rust-lang.org/cargo/reference/manifest.html#the-features-section
 //! [Extractors]: https://actix.rs/docs/extractors/
 //! [Responders]: https://actix.rs/docs/handlers/
 
-#![doc(html_root_url = "https://docs.rs/cloudevents-sdk/0.8.0")]
+#![doc(html_root_url = "https://docs.rs/cloudevents-sdk/0.9.0")]
 #![deny(rustdoc::broken_intra_doc_links)]
 #![cfg_attr(docsrs, feature(doc_cfg))] // Show feature gate in doc