add acl plugin

config/local.yaml

@@ -21,7 +21,12 @@ mqttserver:
       qos: 2
       plugins:
         - plugin: "register_user"
-          messagePattern: ".*"
+          messagePattern: "register"
+    - topic: 'mqttbot/acl/#'
+      qos: 2
+      plugins:
+        - plugin: "add_user_subscription_acl"
+          messagePattern: "aclpermitsubscription"
 elasticsearch:
   host: "http://localhost:9200"
   sniff: false

plugins/add_user_subscription_acl.lua

@@ -0,0 +1,26 @@
+local redis = require 'redis_module'
+local json = require 'json'
+
+function register_subscriptions(username, subscriptions)
+  for i = 1, #subscriptions do
+    err, ret = redis.execute("set", 2, username.."-"..subscriptions[i], 2)
+    if err ~= nil then
+      return err, 1
+    end
+  end
+  return nil, 0
+end
+
+function run_plugin(topic, payload)
+  local json_message = json.decode(payload)
+  --message: {"payload": {"message": "aclpermitsubscription", "username": "username", subscriptions: ["subs1", "subs2"]}}
+  local username = json_message["payload"]["username"]
+  local subscriptions = json_message["payload"]["subscriptions"]
+  if subscriptions ~= nil then
+    err, ret = register_subscriptions(username, subscriptions)
+    if err ~= nil then
+      return err, 1
+    end
+  end
+  return nil, 0
+end

plugins/register_user.lua

@@ -15,7 +15,6 @@ end
 function run_plugin(topic, payload)
   local json_message = json.decode(payload)
   --message: {"payload": {"message": "register", "username": "username", "password": "userpass", subscriptions: ["subs1", "subs2"]}}
-  print(payload, json_message)
   local username = json_message["payload"]["username"]
   local pass = json_message["payload"]["password"]
   local subscriptions = json_message["payload"]["subscriptions"]