update
This commit is contained in:
parent
34d9601d5a
commit
9fced9b8b6
@ -3,25 +3,14 @@
|
|||||||
const crypto = require('crypto');
|
const crypto = require('crypto');
|
||||||
const Redis = require('ioredis');
|
const Redis = require('ioredis');
|
||||||
|
|
||||||
function AuthToken(redisOpt) {
|
function AuthToken(redisdb) {
|
||||||
if (!(this instanceof AuthToken)) {
|
this.tokenDB = redisdb;
|
||||||
return new AuthToken(redisOpt);
|
|
||||||
}
|
|
||||||
|
|
||||||
if (!redisOpt) {
|
|
||||||
throw 'AuthToken: need redis config.';
|
|
||||||
}
|
|
||||||
|
|
||||||
this.tokenDB = new Redis(redisOpt);
|
|
||||||
this.tokenDB.on("connect",function(){
|
|
||||||
console.log("AuthToken: ioredis connected: " + JSON.stringify(redisOpt));
|
|
||||||
});
|
|
||||||
}
|
}
|
||||||
|
|
||||||
AuthToken.prototype.genToken = async function(userData, expiresSeconds) {
|
AuthToken.prototype.genToken = async function(userData, expiresSeconds) {
|
||||||
// 生成系统内部的user token
|
// 生成系统内部的user token
|
||||||
let hash = crypto.createHash('md5');
|
let hash = crypto.createHash('md5');
|
||||||
hash.update(JSON.stringify(userData));
|
hash.update(JSON.stringify(userData) + Date());
|
||||||
let userToken = hash.digest('hex');
|
let userToken = hash.digest('hex');
|
||||||
|
|
||||||
// 缓存到redis
|
// 缓存到redis
|
||||||
@ -109,4 +98,10 @@ AuthToken.prototype.getTokenData = async function (userToken) {
|
|||||||
return tokenData;
|
return tokenData;
|
||||||
};
|
};
|
||||||
|
|
||||||
module.exports = AuthToken;
|
let tokenInstance = null;
|
||||||
|
module.exports = function getTokenInstance(redisPort, redisHost, db) {
|
||||||
|
if (!tokenInstance) {
|
||||||
|
tokenInstance = new AuthToken(redisPort, redisHost, db);
|
||||||
|
}
|
||||||
|
return tokenInstance;
|
||||||
|
};
|
||||||
|
@ -1,6 +1,6 @@
|
|||||||
{
|
{
|
||||||
"name": "@ehason/auth",
|
"name": "@ehason/auth",
|
||||||
"version": "1.0.2",
|
"version": "1.2.2",
|
||||||
"description": "User auth lib",
|
"description": "User auth lib",
|
||||||
"main": "index.js",
|
"main": "index.js",
|
||||||
"scripts": {
|
"scripts": {
|
||||||
|
15
utils/impl/koaresp.js
Normal file
15
utils/impl/koaresp.js
Normal file
@ -0,0 +1,15 @@
|
|||||||
|
'use strict';
|
||||||
|
|
||||||
|
function ctxresp(ctx, data, errno, errmsg) {
|
||||||
|
if (errno === null || errno === undefined) errno = 0;
|
||||||
|
if (errmsg === null || errmsg === undefined) errmsg = '';
|
||||||
|
if (data === null || data === undefined) data = {};
|
||||||
|
|
||||||
|
ctx.body = {
|
||||||
|
result: errno === 0 ? 'ok' : 'fail',
|
||||||
|
error: { code: errno, msg: errmsg },
|
||||||
|
data: data
|
||||||
|
};
|
||||||
|
}
|
||||||
|
|
||||||
|
module.exports = ctxresp;
|
@ -1,4 +1,5 @@
|
|||||||
|
|
||||||
module.exports = {
|
module.exports = {
|
||||||
prxrmq: require('./impl/prxrmq')
|
prxrmq: require('./impl/prxrmq'),
|
||||||
|
ctxresp: require('./impl/koaresp')
|
||||||
};
|
};
|
||||||
|
@ -1,6 +1,6 @@
|
|||||||
{
|
{
|
||||||
"name": "@ehason/utils",
|
"name": "@ehason/utils",
|
||||||
"version": "1.0.1",
|
"version": "1.0.2",
|
||||||
"description": "Utils for ehason develope",
|
"description": "Utils for ehason develope",
|
||||||
"main": "index.js",
|
"main": "index.js",
|
||||||
"scripts": {
|
"scripts": {
|
||||||
|
Loading…
Reference in New Issue
Block a user