/
user_service.js
80 lines (77 loc) · 2.01 KB
/
user_service.js
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
// 依赖
var http = require('http');
var moment = require('moment');
var async = require('async');
var uid = require('uid-safe').sync;
var redis = require('../library/redis').create();
// UserService
var UserService = {
setSession: function (user, req) {
var sid = uid(24);
var expired = moment().unix() + 7 * 24 * 60 * 60;
var session = {
id: sid,
expired: expired,
user: user.get({plain: true}),
user_id: user.id
};
var stringify = JSON.stringify(session);
redis.set(sid, stringify);
req.session = session;
req.user = session.user;
},
destroySession: function (req) {
redis.expire(req.session.id, 0);
},
checkSession: function (req, res, next) {
var self = this;
async.waterfall([
// get session id
function (cb) {
var sid = req.query.sid;
if (!sid) {
cb('please login first');
} else {
cb(null, sid);
}
},
// get session
function (sid, cb) {
redis.get(sid, function (err, session) {
if (session) {
cb(null, session);
} else {
console.log('session empty, sid ' + sid);
cb('please login first');
}
});
},
// check whether session expired or not
function (session, cb) {
var parsed = JSON.parse(session);
if (parsed.expired <= moment().unix()) {
console.log('session expired, sid ' + session.id);
cb('please re-login');
} else {
cb(null, parsed);
}
},
], function (err, session) {
if (err) {
res.status(403);
res.json({msg: err});
} else {
console.log('userid ' + session.user_id + ' session check success');
req.session = session;
req.user = session.user;
next();
}
});
},
isMe: function (req, userId) { // is me
return true;
var me = req.session.user_id;
return parseInt(me) === parseInt(userId);
}
};
module.exports = UserService;