forked from Juniper/contrail-third-party
-
Notifications
You must be signed in to change notification settings - Fork 0
/
connect-redis_1.4.5.patch
79 lines (70 loc) · 2.47 KB
/
connect-redis_1.4.5.patch
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
--- old/third_party/node_modules/connect-redis/lib/connect-redis.js 2014-04-29 21:12:27.000000000 +0530
+++ new/third_party/node_modules/connect-redis/lib/connect-redis.js 2014-04-29 21:12:47.000000000 +0530
@@ -9,6 +9,7 @@
*/
var redis = require('redis')
+ , eventEmitter = require('events').EventEmitter
, debug = require('debug')('connect:redis');
/**
@@ -16,6 +17,7 @@
*/
var oneDay = 86400;
+var timerEvent = {};
/**
* Return the `RedisStore` extending `connect`'s session Store.
@@ -57,6 +59,8 @@
}
this.ttl = options.ttl;
+ this.eventEmitter = (null == options.eventEmitter)
+ ? null : options.eventEmitter;
if (options.db) {
self.client.select(options.db);
@@ -104,6 +108,24 @@
};
/**
+ * Send event sessionDeleted after maxAge time expires
+ * Note that this event is triggered when maxAge becomes 0, so it may happen
+ * redis has got crashed or got flushed out, so session will get removed from
+ * redis DB. So APP when getting this event, MUST check if the session exists
+ * or not in DB.
+ * @param {eventEmitter} eventEmitter Object passed from client
+ * @param {sid} sessionID created
+ * @param {maxAge} maxAge after which this event should be generated
+ */
+
+ setEventEmitter = function (eventEmitter, sid, maxAge) {
+ var timer = setTimeout(function () {
+ eventEmitter.emit('sessionDeleted', sid);
+ }, maxAge);
+ timerEvent[sid] = timer;
+ }
+
+ /**
* Commit the given `sess` object associated with the given `sid`.
*
* @param {String} sid
@@ -114,6 +136,7 @@
RedisStore.prototype.set = function(sid, sess, fn){
sid = this.prefix + sid;
+ var eEmitter = this.eventEmitter;
try {
var maxAge = sess.cookie.maxAge
, ttl = this.ttl
@@ -124,6 +147,18 @@
: oneDay);
debug('SETEX "%s" ttl:%s %s', sid, ttl, sess);
+ /* NOTE: when request comes from web client, for each url, it sets same
+ * session ID, so even for loading icon, frame gif file, it sets same
+ * session id in redis, so we need to set timeout only one time, if the
+ * session id is not already stored in redis
+ */
+ this.client.get(sid, function (err, data) {
+ if (null == data) {
+ if (eEmitter) {
+ setEventEmitter(eEmitter, sid, maxAge);
+ }
+ }
+ });
this.client.setex(sid, ttl, sess, function(err){
err || debug('SETEX complete');
fn && fn.apply(this, arguments);