add client_id

authhook/auth_on_publish.js

@@ -33,6 +33,32 @@ module.exports = function (options = {}) {
             checkRealDB(req.body.username, (err, decoded) => {
                 if (err) {
                     // Set Response
+                    var isShadow = require('./utils/getTopic').isShadow
+                    if (isShadow(topic)) {
+                        var _ftopic = require('./utils/getTopic').getTopic(topic, req.body.client_id) // get topic where concat with groupID
+                        var response = {
+                            'result': 'ok',
+                            'modifiers': {
+                                'topic': _ftopic,
+                                'qos': 0,
+                                'retain': false
+                            }
+                        }
+                        console.log(response)
+
+                        if (typeof (authstatus) == 'undefined') {
+                            // cache missed
+                            authCheck(req.body.client_id, req.body.username, topic, function (result) {
+                                cache.set(cachekey, result);
+                                res.send(response);
+                            });
+                        }
+                        else {
+                            res.send(response);
+                        }
+                        next();
+                    }
+                    else {
                         var getGroupID = require('./utils/getGroupID').getGroupID
                         getGroupID(req.body.username, req.body.client_id, (_id) => { // get groupID
                             // console.log(_id)
@@ -60,6 +86,7 @@ module.exports = function (options = {}) {
                             next();
                         })
                     }
+                }
                 else {
                     console.log(decoded)
                     if (decoded.role === 'realtimedb') {

authhook/auth_on_subscribe.js

@@ -38,6 +38,32 @@ module.exports = function (options = {}) {
             checkRealDB(req.body.username, (err, decoded) => {
                 if (err) {
                     // Set Response
+                    var isShadow = require('./utils/getTopic').isShadow
+                    if (isShadow(topic)) {
+                        var _ftopic = require('./utils/getTopic').getTopic(topic, req.body.client_id) // get topic where concat with groupID
+                        var _topic = [{ // setTopic for response
+                            'topic': _ftopic,
+                            'qos': 0
+                        }]
+                        var response = {
+                            'result': 'ok',
+                            'topics': _topic
+                        }
+                        console.log(response)
+
+                        if (typeof (authstatus) == 'undefined') {
+                            // cache missed
+                            authCheck(req.body.client_id, req.body.username, topic, function (result) {
+                                cache.set(cachekey, result);
+                                res.send(response);
+                            });
+                        }
+                        else {
+                            res.send(response);
+                        }
+                        next();
+                    }
+                    else {
                         var getGroupID = require('./utils/getGroupID').getGroupID
                         getGroupID(req.body.username, req.body.client_id, (_id) => { // get groupID
                             // console.log(_id)
@@ -65,6 +91,7 @@ module.exports = function (options = {}) {
                             next();
                         })
                     }
+                }
                 else {
                     console.log(decoded)
                     if (decoded.role === 'realtimedb') {

authhook/utils/getTopic.js

@@ -17,3 +17,11 @@ function classifiedTopic(topic) {
         return '@client'
     }
 }
+
+function isShadow(topic) {
+    if (topic.indexOf('@shadow') !== -1) {
+        return true
+    }
+    else return false
+}
+module.exports.isShadow = isShadow
\ No newline at end of file