Skip to content

Commit

Permalink
feat: comment out tenant extraction/checks (#472)
Browse files Browse the repository at this point in the history
Removes `tenant_id` extraction and checks within broker
Updates Changelog and versions for R17
  • Loading branch information
Devdutt Shenoi authored Sep 30, 2022
1 parent 496e310 commit 6436a6f
Show file tree
Hide file tree
Showing 11 changed files with 128 additions and 264 deletions.
9 changes: 4 additions & 5 deletions CHANGELOG.md
Original file line number Diff line number Diff line change
@@ -1,16 +1,15 @@
### Unreleased
### R17
---
rumqttc
rumqttc v0.17.0
-------
- Route `Incoming::ConnAck` onto `Notifier` (#460)
- Reimplement v5 with old `EvenLoop` design (#464)
- Implement `recv`, `try_recv`, `recv_timeout` for `Connection` (#458)
- Export `v5::TryRecvError` (#457)
- Improve filter validation (#453)
- Validate topic before sending a `Publish` (#449)
- Don't create a new runtime in `Iter::drop` (#405)
- Unpin exact version dependency on `tokio-rustls` (#448)

rumqttd
rumqttd v0.12.0-beta.1
-------
- MQTT5 support, StructOpt/Clap based CLI, change in config format (next generation broker) (#442)
- Make dependency on `rustls-pemfile` optional (#439)
Expand Down
163 changes: 5 additions & 158 deletions Cargo.lock

Some generated files are not rendered by default. Learn more about how customized files appear on GitHub.

2 changes: 1 addition & 1 deletion rumqttc/Cargo.toml
Original file line number Diff line number Diff line change
@@ -1,6 +1,6 @@
[package]
name = "rumqttc"
version = "0.16.0"
version = "0.17.0"
description = "An efficient and robust mqtt client for your connected devices"
license = "Apache-2.0"
repository = "https://github.com/bytebeamio/rumqtt"
Expand Down
8 changes: 4 additions & 4 deletions rumqttd/Cargo.toml
Original file line number Diff line number Diff line change
@@ -1,6 +1,6 @@
[package]
name = "rumqttd"
version = "0.12.0-alpha.3"
version = "0.12.0-beta.1"
license = "Apache-2.0"
description = "rumqttd is a high performance MQTT broker written in Rust which is light weight and embeddable"
authors = ["tekjar <[email protected]>"]
Expand All @@ -26,7 +26,7 @@ tokio-tungstenite = { version = "0.15.0", optional = true }
ws_stream_tungstenite = { version = "0.8", optional = true }
websocket-codec = { version = "0.5.1", optional = true }
rouille = "3.1.1"
x509-parser = {version= "0.9.2", optional = true}
# x509-parser = {version= "0.9.2", optional = true}
futures-util = "0.3.16"
parking_lot = "0.11.2"
reqwest = { version = "0.11", features = ["json"] }
Expand All @@ -37,8 +37,8 @@ structopt = "0.3.26"

[features]
default = ["use-rustls"]
use-rustls = ["tokio-rustls", "rustls-pemfile", "x509-parser"]
use-native-tls = ["tokio-native-tls", "x509-parser"]
use-rustls = ["tokio-rustls", "rustls-pemfile"] #, "x509-parser"]
use-native-tls = ["tokio-native-tls"] #, "x509-parser"]
websockets = ["tokio-tungstenite", "ws_stream_tungstenite", "websocket-codec"]

[dev-dependencies]
Expand Down
2 changes: 1 addition & 1 deletion rumqttd/src/link/console.rs
Original file line number Diff line number Diff line change
Expand Up @@ -15,7 +15,7 @@ impl ConsoleLink {
/// Requires the corresponding Router to be running to complete
pub fn new(config: ConsoleSettings, router_tx: Sender<(ConnectionId, Event)>) -> ConsoleLink {
let tx = router_tx.clone();
let (link_tx, link_rx, _ack) = Link::new(None, "console", tx, true, None, true).unwrap();
let (link_tx, link_rx, _ack) = Link::new(/*None,*/ "console", tx, true, None, true).unwrap();
let connection_id = link_tx.connection_id;
ConsoleLink {
config,
Expand Down
Loading

0 comments on commit 6436a6f

Please sign in to comment.