Skip to content

V
vernemq
Commit 56021c2a by zCaesar
Options

fix error

parent 045aaf2a
Showing with 25 additions and 23 deletions
authhook/auth_on_publish.js
...@@ -34,7 +34,7 @@ module.exports = function (options = {}) { ...@@ -34,7 +34,7 @@ module.exports = function (options = {}) {
if (decoded) { if (decoded) {
if (decoded.role === 'realtimedb') response = { 'result': 'ok' } if (decoded.role === 'realtimedb') response = { 'result': 'ok' }
else response = { 'result': 'no' } else response = { result: {error: 'not allowed'} }
res.send(response); res.send(response);
next(); next();
} }
...@@ -65,7 +65,7 @@ module.exports = function (options = {}) { ...@@ -65,7 +65,7 @@ module.exports = function (options = {}) {
next(); next();
} }
else { else {
res.send({ "result": "no" }); res.send({ result: {error: 'not allowed'} });
next(); next();
} }
}); });
...@@ -75,7 +75,7 @@ module.exports = function (options = {}) { ...@@ -75,7 +75,7 @@ module.exports = function (options = {}) {
} }
else { else {
res.send({ "result": "no" }); res.send({ result: {error: 'not allowed'} });
next(); next();
} }
} }
......
authhook/auth_on_register.js
...@@ -113,15 +113,15 @@ module.exports = function (options = {}) { ...@@ -113,15 +113,15 @@ module.exports = function (options = {}) {
// "result": "ok" // "result": "ok"
// }); // });
// } else { // } else {
// res.send({ // res.send({
// "result": "no" // result: { error: 'not allowed' }
// }); // });
// } // }
// }) // })
// } else { // } else {
// res.send({ // res.send({
// "result": "no" // result: {error: 'not allowed'}
// }); // });
// } // }
// // const util = require('util') // // const util = require('util')
// // console.log(util.inspect(status, false, null, true)) // // console.log(util.inspect(status, false, null, true))
...@@ -136,18 +136,18 @@ module.exports = function (options = {}) { ...@@ -136,18 +136,18 @@ module.exports = function (options = {}) {
// "result": "ok" // "result": "ok"
// }); // });
// } else { // } else {
// res.send({ // res.send({
// "result": "no" // result: {error: 'not allowed'}
// }); // });
// } // }
// }) // })
// } else { // } else {
// res.send({ // res.send({
// "result": "no" // result: {error: 'not allowed'}
// }); // });
// } // }
// } // }
on_register_redis(req.body.client_id).then(status => { on_register_redis(req.body.client_id).then(status => {
console.log('redis:status: ' + status) console.log('redis:status: ' + status)
if (status) { if (status) {
...@@ -156,7 +156,7 @@ module.exports = function (options = {}) { ...@@ -156,7 +156,7 @@ module.exports = function (options = {}) {
}); });
} else { } else {
res.send({ res.send({
"result": { 'error': "not allowed" } result: { error: 'not allowed' }
}); });
} }
}) })
...@@ -164,7 +164,7 @@ module.exports = function (options = {}) { ...@@ -164,7 +164,7 @@ module.exports = function (options = {}) {
} }
else { else {
res.send({ res.send({
"result": "no" result: { error: 'not allowed' }
}); });
next(); next();
} }
......
authhook/auth_on_subscribe.js
...@@ -29,7 +29,7 @@ module.exports = function (options = {}) { ...@@ -29,7 +29,7 @@ module.exports = function (options = {}) {
if (decoded) { if (decoded) {
if (decoded.role === 'realtimedb') response = { 'result': 'ok' } if (decoded.role === 'realtimedb') response = { 'result': 'ok' }
else response = { 'result': 'no' } else response = { result: {error: 'not allowed'} }
res.send(response); res.send(response);
next(); next();
} }
...@@ -56,14 +56,14 @@ module.exports = function (options = {}) { ...@@ -56,14 +56,14 @@ module.exports = function (options = {}) {
next(); next();
} }
else { else {
res.send({ "result": "no" }); res.send({ result: {error: 'not allowed'} });
next(); next();
} }
}); });
} }
} }
else { else {
res.send({ "result": "no" }); res.send({ result: {error: 'not allowed'} });
next(); next();
} }
} }
......
authhook/on_offline.js
...@@ -5,6 +5,8 @@ module.exports = function (options = {}) { ...@@ -5,6 +5,8 @@ module.exports = function (options = {}) {
return function (req, res, next) { return function (req, res, next) {
console.log('auth_on_offline') console.log('auth_on_offline')
doRedis(req.body.client_id) doRedis(req.body.client_id)
res.status(200);
res.send('');
} }
function doRedis(client_id) { function doRedis(client_id) {
......
authhook/on_unsubscribe.js
...@@ -13,7 +13,7 @@ module.exports = function(options = {}) { ...@@ -13,7 +13,7 @@ module.exports = function(options = {}) {
if (decoded.role === 'realtimedb') { if (decoded.role === 'realtimedb') {
response = { 'result': 'ok' } response = { 'result': 'ok' }
} }
else response = { 'result': 'no' } else response = { result: {error: 'not allowed'} }
res.send(response); res.send(response);
next() next()
} }
...@@ -28,7 +28,7 @@ module.exports = function(options = {}) { ...@@ -28,7 +28,7 @@ module.exports = function(options = {}) {
"topics": [_ftopic] "topics": [_ftopic]
} }
} }
else response = { 'result': 'no' } else response = { result: {error: 'not allowed'} }
if (options.debug) { if (options.debug) {
console.log('on_unsubscribe-------------'); console.log('on_unsubscribe-------------');
......
Markdown is supported
0% or
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment