use old redis

authhook/auth_on_publish.js

 var config = require('config');
 var config = require('config');
 // https://github.com/isaacs/node-lru-cache
 // https://github.com/isaacs/node-lru-cache
 
 
-var on_message_redis = require('./redis-atomic/on_message').on_message_redis
+var on_message_redis = require('./redis/on_message').on_message_redis
 var LRU = require("lru-cache"),
 var LRU = require("lru-cache"),
     cache = LRU({
     cache = LRU({
         max: 500,
         max: 500,

authhook/auth_on_register.js

@@ -3,7 +3,7 @@ var validator = require('./validator');
 var config = require('config');
 var config = require('config');
 // var seneca = require('seneca')({log: 'silent'}).client({ port: config.get('device_registry_port'), host: config.get('device_registry_host') });
 // var seneca = require('seneca')({log: 'silent'}).client({ port: config.get('device_registry_port'), host: config.get('device_registry_host') });
 var seneca = require('seneca')({ log: 'silent' }).client({ port: config.get('token_registry_port'), host: config.get('token_registry_host') });
 var seneca = require('seneca')({ log: 'silent' }).client({ port: config.get('token_registry_port'), host: config.get('token_registry_host') });
-var on_register_redis = require('./redis-atomic/on_register').on_register_redis
+var on_register_redis = require('./redis/on_register').on_register_redis
 
 
 // https://github.com/isaacs/node-lru-cache
 // https://github.com/isaacs/node-lru-cache
 var LRU = require("lru-cache"),
 var LRU = require("lru-cache"),

authhook/on_offline.js

-var on_offline_redis = require('./redis-atomic/on_offline').on_offline_redis
+var on_offline_redis = require('./redis/on_offline').on_offline_redis
 
 
 module.exports = function (options = {}) {
 module.exports = function (options = {}) {
 
 

authhook/redis-atomic/on_message.lua

@@ -7,8 +7,8 @@ local last_publish = ARGV[3]
 redis.call('HINCRBY', device_keys, 'actual_message_count', 1)
 redis.call('HINCRBY', device_keys, 'actual_message_count', 1)
 redis.call('HINCRBY', device_keys, 'charged_message_count', charged_message_count)
 redis.call('HINCRBY', device_keys, 'charged_message_count', charged_message_count)
 redis.call('HINCRBY', device_keys, 'total_message_size', total_message_size)
 redis.call('HINCRBY', device_keys, 'total_message_size', total_message_size)
+redis.call('HSET', device_keys, 'last_publish', last_publish)
 redis.call('HINCRBY', broker_keys, 'actual_message_count', 1)
 redis.call('HINCRBY', broker_keys, 'actual_message_count', 1)
 redis.call('HINCRBY', broker_keys, 'charged_message_count', charged_message_count)
 redis.call('HINCRBY', broker_keys, 'charged_message_count', charged_message_count)
 redis.call('HINCRBY', broker_keys, 'total_message_size', total_message_size)
 redis.call('HINCRBY', broker_keys, 'total_message_size', total_message_size)
-redis.call('HSET', device_keys, 'last_publish', last_publish)
 return 'true'
 return 'true'
\ No newline at end of file