yoho-session.js
2.81 KB
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
81
82
83
84
85
86
87
88
89
90
91
92
93
const config = global.yoho.config;
const session = require('yoho-express-session');
const _ = require('lodash');
const uuid = require('uuid');
const cookieSession = require('client-sessions');
const connectRedis = require('connect-redis');
const RedisStore = connectRedis(session);
const monitor = global.yoho.monitorSender;
const monitorType = _.get(monitor, 'type.REDIS');
/**
* 该中间件主要把 express-session 和 client-session 集中起来处理,如果 redis 出错了,使用 cookie session
* @param opts.backSession cookieSession 的键名
* @returns {function(*=, *=, *)}
*/
function yohoSession(opts) {
return (req, res, next) => {
let notUseRedis = _.get(req.app.locals.wap, 'session.removeMemcached', false);
opts.backSession = opts.backSession || 'session2';
if (req.session && !req.session.degrage && !notUseRedis) {
// 如果存在session并且没有被降级,且移除redis开关没开,则继续使用session redis
req.sessionError = false;
} else {
// 重建 session
res.emit('sessionError');
req.sessionError = true;
req.sessionID = req.sessionID || uuid.v4();
req.session = new session.Session(req, req[opts.backSession].sessionBack);
req.session.cookie = new session.Cookie({
domain: 'yohobuy.com',
httpOnly: true
});
}
Object.defineProperty(req.session, 'reset', {
configurable: true,
enumerable: false,
value: function() {
req.session.destroy();
req[opts.backSession].reset();
},
writable: false
});
// 备份数据
req[opts.backSession].sessionBack = req.session;
next();
};
}
module.exports = (app) => {
app.use(session({ // eslint-disable-line
proxy: true,
resave: false,
saveUninitialized: true,
unset: 'destroy',
secret: '82dd7e724f2c6870472c89dfa43cf48d',
name: 'yohobuy_session',
genid() {
return uuid.v4();
},
cookie: {
domain: 'yohobuy.com',
httpOnly: true
},
store: new RedisStore(Object.assign(config.redis.session, {
logErrors: (e) => {
// 上报redis session错误
monitor && monitor.tallyFail(monitorType, e);
}
}))
}));
app.use(cookieSession({ // eslint-disable-line
requestKey: 'session2',
cookieName: 'yohobuy_session_cookie',
secret: '82dd7e724f2c6870472c89dfa43cf48d',
cookie: {
domain: 'yohobuy.com',
ephemeral: true,
httpOnly: true
}
}));
app.use(yohoSession({
backSession: 'session2'
}));
};