fix: prod rmqtt acl add connect

ForNetCode · May 21, 2024 · 2b46a0a · 2b46a0a
1 parent 2b80ae7
commit 2b46a0a
Show file tree

Hide file tree

Showing 2 changed files with 7 additions and 3 deletions.
diff --git a/agent/examples/publish_command.rs b/agent/examples/publish_command.rs
@@ -15,10 +15,13 @@ async fn main() -> anyhow::Result<()> {
       "ls -ls".to_string()
     };
 
-    let config_path:PathBuf = "./config.yml".parse().unwrap();
-    let publish_client_id = "test_web";
-    let password:Option<String> = None;
     let username:Option<String> = None;
+    let password:Option<String> = None;
+
+    let config_path:PathBuf = "./config.yml".parse().unwrap();
+    let publish_client_id = "root";
+    //let username:Option<String> = Some("".to_string());
+    //let password:Option<String> = Some("".to_string());
 
     let is_terminal = std::io::stdout().is_terminal();
 

diff --git a/shell/prod/rmqtt/plugin/rmqtt-acl.toml b/shell/prod/rmqtt/plugin/rmqtt-acl.toml
@@ -12,5 +12,6 @@ rules = [
     ["allow", { user = "timzaak", password = "timzaak", superuser = true }],
     # allow nodes to publish/subscribe shell command
     ["allow", { user = "nodes", password ="nodes_password" }, "pubsub", ["cmd/%c", "cmd/%c/resp"]],
+    ["allow", { user = "nodes", password ="nodes_password" }, "connect"],
     ["deny", "all"]
 ]