Imported-Repos/yandex2mqtt
1
0
Fork 0
mirror of https://github.com/lasthead0/yandex2mqtt.git synced 2025-08-08 01:00:31 +03:00
Code Issues Packages Projects Releases Wiki Activity

const error improvement

Browse Source
This commit is contained in:
Evgenii Abramov
2021-05-17 01:00:15 +03:00
parent d29e9102a5
commit 1ee7e31fa7
1 changed files with 9 additions and 9 deletions
Download Patch File Download Diff File Expand all files Collapse all files

18
db/access_tokens.js
View File

@@ -1,6 +1,6 @@
'use strict'; 'use strict';
const {logger, authl} = global; const {logger} = global;
const loki = require('lokijs'); const loki = require('lokijs');
global.dbl = new loki('./loki.json', { global.dbl = new loki('./loki.json', {
@@ -8,15 +8,15 @@ global.dbl = new loki('./loki.json', {
autosave: true, autosave: true,
autosaveInterval: 5000, autosaveInterval: 5000,
autoloadCallback() { autoloadCallback() {
authl = global.dbl.getCollection('tokens'); global.authl = global.dbl.getCollection('tokens');
if (authl === null) { if (global.authl === null) {
authl = global.dbl.addCollection('tokens'); global.authl = global.dbl.addCollection('tokens');
} }
} }
}); });
module.exports.find = (key, done) => { module.exports.find = (key, done) => {
const ltoken = authl.findOne({'token': key}); const ltoken = global.authl.findOne({'token': key});
if (ltoken){ if (ltoken){
const {userId, clientId} = ltoken; const {userId, clientId} = ltoken;
return done(null, {userId, clientId}) return done(null, {userId, clientId})
@@ -27,7 +27,7 @@ module.exports.find = (key, done) => {
}; };
module.exports.findByUserIdAndClientId = (userId, clientId, done) => { module.exports.findByUserIdAndClientId = (userId, clientId, done) => {
const ltoken = authl.findOne({'userId': userId}); const ltoken = global.authl.findOne({'userId': userId});
if (ltoken){ if (ltoken){
logger.log('info', {message: `Load token by userId (${userId}): User found`}); logger.log('info', {message: `Load token by userId (${userId}): User found`});
const {token, userId: uid, clientId: cid} = ltoken; const {token, userId: uid, clientId: cid} = ltoken;
@@ -45,13 +45,13 @@ module.exports.findByUserIdAndClientId = (userId, clientId, done) => {
module.exports.save = (token, userId, clientId, done) => { module.exports.save = (token, userId, clientId, done) => {
logger.log('info', {message: `Start saving token`}); logger.log('info', {message: `Start saving token`});
const ltoken = authl.findOne({'userId': userId}); const ltoken = global.authl.findOne({'userId': userId});
if (ltoken){ if (ltoken){
logger.log('info', {message: `User Updated`}); logger.log('info', {message: `User Updated`});
authl.update(Object.assign({}, ltoken, {token, userId, clientId})); global.authl.update(Object.assign({}, ltoken, {token, userId, clientId}));
} else { } else {
logger.log('info', {message: `User not Found. Create new...`}); logger.log('info', {message: `User not Found. Create new...`});
authl.insert({'type': 'token', token, userId, clientId}); global.authl.insert({'type': 'token', token, userId, clientId});
} }
done(); done();
}; };