edit msg count

authhook/auth_on_publish.js

@@ -15,11 +15,12 @@ module.exports = function (options = {}) {
                 console.log(req.body);
                 console.log(req.body);
             }
             }
 
 
+            var topic = req.body.topic;
+
             //  save redis
             //  save redis
-            require('./redis/on_message').on_message_redis(req.body.client_id, req.body.payload).then(status => {
+            require('./redis/on_message').on_message_redis(req.body.client_id, req.body.payload, topic).then(status => {
                 if (status) {
                 if (status) {
                     var authstatus;
                     var authstatus;
-                    var topic = req.body.topic;
 
 
                     var cachekey = 'pub:' + req.body.client_id + ':' + req.body.username + ':' + topic;
                     var cachekey = 'pub:' + req.body.client_id + ':' + req.body.username + ':' + topic;
                     var authstatus = cache.get(cachekey);
                     var authstatus = cache.get(cachekey);

authhook/redis/on_message.js

 var Redis = require('ioredis')
 var Redis = require('ioredis')
 var redis = new Redis()
 var redis = new Redis()
 
 
-function on_message_redis(deviceid, payload) { // first time to access on authhook auth_on_register
+function on_message_redis(deviceid, payload, topic) { // first time to access on authhook auth_on_register
     return new Promise((resolve, reject) => {
     return new Promise((resolve, reject) => {
         if (deviceid.indexOf('mqtt') === 0 || deviceid.length !== 36) {
         if (deviceid.indexOf('mqtt') === 0 || deviceid.length !== 36) {
             console.log(deviceid)
             console.log(deviceid)
             resolve(true)
             resolve(true)
         }
         }
         else {
         else {
-            var information = setValue(deviceid, payload)
+            var information = setValue(deviceid, payload, topic)
             redis.hincrby(information.keys, 'actual_message_count', 1)
             redis.hincrby(information.keys, 'actual_message_count', 1)
             redis.hincrby(information.keys, 'charged_message_count', information.charged_message_count)
             redis.hincrby(information.keys, 'charged_message_count', information.charged_message_count)
             redis.hincrby(information.keys, 'total_message_size', information.total_message_size)
             redis.hincrby(information.keys, 'total_message_size', information.total_message_size)
@@ -25,17 +25,17 @@ function on_message_redis(deviceid, payload) { // first time to access on authho
 }
 }
 module.exports.on_message_redis = on_message_redis
 module.exports.on_message_redis = on_message_redis
 
 
-function setValue(deviceid, payload) {
+function setValue(deviceid, payload, topic) {
     var dateNow = Math.floor(Date.now() / 1000)
     var dateNow = Math.floor(Date.now() / 1000)
     var keys = 'deviceid:' + deviceid
     var keys = 'deviceid:' + deviceid
     var last_publish = dateNow
     var last_publish = dateNow
-    var msg_count_size = payload.length * 3 / 4
+    var total_message_size = (payload.length + topic.length) * (3 / 4)
+    var msg_count_size = total_message_size
     var charged_message_count = 1
     var charged_message_count = 1
     while (msg_count_size > 5000) {
     while (msg_count_size > 5000) {
         charged_message_count += 1
         charged_message_count += 1
-        msg_count_size = (payload.length * 3 / 4) - 5000
+        msg_count_size = msg_count_size - 5000
     }
     }
-    var total_message_size = payload.length * 3 / 4
     return {
     return {
         keys: keys,
         keys: keys,
         last_publish: last_publish,
         last_publish: last_publish,

authhook/redis/on_register.js

@@ -10,6 +10,7 @@ function on_register_redis(deviceid) { // first time to access on authhook auth_
             var information = setValue(deviceid)
             var information = setValue(deviceid)
             redis.hdel(information.keys, 'offline_on')
             redis.hdel(information.keys, 'offline_on')
             redis.hset(information.keys, 'status', information.status, 'register_on', information.register_on, 'last_check', information.last_check, function (err, res) {
             redis.hset(information.keys, 'status', information.status, 'register_on', information.register_on, 'last_check', information.last_check, function (err, res) {
+                console.log(res)
                 if (!res) {
                 if (!res) {
                     deviceUsageCount()
                     deviceUsageCount()
                     resolve(!res) // 0 is ok, 1 is no => if ok is 0 then not 0 = 1
                     resolve(!res) // 0 is ok, 1 is no => if ok is 0 then not 0 = 1