chore: initial test commit

Author: SharksT

src/config/acl.rs

@@ -2,7 +2,7 @@ use std::{path::Path, str::FromStr};
 
 use tashi_collections::HashMap;
 
-use crate::mqtt::trie::{Filter, TopicName};
+use crate::mqtt::trie::Filter;
 
 #[derive(serde::Deserialize, Default)]
 pub struct AclConfig {

src/mqtt/broker/mod.rs

@@ -171,6 +171,7 @@ pub struct TlsConfig {
 }
 
 impl MqttBroker {
+    #[allow(clippy::too_many_arguments)]
     pub async fn bind(
         listen_addr: SocketAddr,
         tls_config: Option<TlsConfig>,

src/mqtt/trie/mod.rs

@@ -51,7 +51,7 @@ where
 
         // fixme: This iterator is very inefficient (O(n) scans per tree depth) but it probably doesn't matter because this is a Debug impl.
         // it's O(1) memory usage though.
-        impl<'a, T> Iterator for Iter<'a, T> {
+        impl<T> Iterator for Iter<'_, T> {
             type Item = NodeId;
 
             fn next(&mut self) -> Option<Self::Item> {

tests/foxmq.d/cla.toml

@@ -0,0 +1,6 @@
+[permissions.test_user1]
+topic = [{ filter = "topic", allowed = ["publish"] }]
+
+
+[permissions.test_user2]
+topic = [{ filter = "topic", allowed = ["subscribe"] }]

tests/foxmq.d/users.toml

@@ -1,2 +1,8 @@
 [auth]
 allow-anonymous-login = true
+
+[users.test_user1]
+password-hash = "$argon2id$v=19$m=19456,t=2,p=1$TwFLGuZeIBQGjn02H9NpJQ$8s2JrmbxhLfHphYEfmZ4KjJmxS7tTCss06E27kZC6M0"
+
+[users.test_user2]
+password-hash = "$argon2id$v=19$m=19456,t=2,p=1$TwFLGuZeIBQGjn02H9NpJQ$8s2JrmbxhLfHphYEfmZ4KjJmxS7tTCss06E27kZC6M0"

tests/mqtt/distribution.test.js

@@ -113,7 +113,7 @@ describe("publish to node 1, receive from node2", () => {
     test("synchronously, over Websockets", async () => {
         // Test v4 (3.1.1) and v5 (5.0) simultaneously
         const client1 = await mqtt.connectAsync("ws://127.0.0.1:8080", { protocolVersion: 4 });
-        const client2 = await mqtt.connectAsync("ws://127.0.0.1:8081", {protocolVersion: 5});
+        const client2 = await mqtt.connectAsync("ws://127.0.0.1:8081", { protocolVersion: 5 });
 
         await client2.subscribeAsync("weather/los_angeles");
 
@@ -267,5 +267,27 @@ describe("publish to node 1, receive from node2", () => {
 
         await client1.endAsync();
         await client2.endAsync();
-    });
+    }),
+        test("ACL", async () => {
+            // Can publish to test_topic but not subscribe
+            const client1 = await mqtt.connectAsync("mqtt://localhost:1884", { protocolVersion: 5, username: "test_user1", password: "1234" });
+            // Can subscribe to test_topic but not publish
+            const client2 = await mqtt.connectAsync("mqtt://localhost:1884", { protocolVersion: 5, username: "test_user2", password: "1234" });
+            // Can do anything anywhere
+            const client3 = await mqtt.connectAsync("mqtt://localhost:1884", { protocolVersion: 5 });
+
+            await client1.publishAsync("test_topic", "a test message");
+
+            const client_1_res = await client1.subscribe("test_topic");
+            expect(client_1_res.reasonCode).toBe(1);
+
+            await client2.subscribe("test_topic");
+
+            const [topic, message] = await events.once(client2, 'message');
+
+            expect(topic.toString()).toBe("test_topic");
+            expect(message.toString()).toBe("a test message");
+
+        })
+        ;
 });