mirror of
https://github.com/NodeBB/NodeBB.git
synced 2025-12-24 01:10:31 +01:00
moved connect-redis to the redis.db file, expose the sessionStore from redis.js db file, do the same for mongo db with mongo-connect
This commit is contained in:
@@ -6,6 +6,9 @@
|
|||||||
redis = require('redis'),
|
redis = require('redis'),
|
||||||
winston = require('winston'),
|
winston = require('winston'),
|
||||||
nconf = require('nconf'),
|
nconf = require('nconf'),
|
||||||
|
express = require('express'),
|
||||||
|
connectRedis = require('connect-redis')(express),
|
||||||
|
|
||||||
redis_socket_or_host = nconf.get('redis:host'),
|
redis_socket_or_host = nconf.get('redis:host'),
|
||||||
utils = require('./../../public/src/utils.js');
|
utils = require('./../../public/src/utils.js');
|
||||||
|
|
||||||
@@ -17,6 +20,11 @@
|
|||||||
redisClient = redis.createClient(nconf.get('redis:port'), nconf.get('redis:host'));
|
redisClient = redis.createClient(nconf.get('redis:port'), nconf.get('redis:host'));
|
||||||
}
|
}
|
||||||
|
|
||||||
|
module.sessionStore = new connectRedis({
|
||||||
|
client: redisClient,
|
||||||
|
ttl: 60 * 60 * 24 * 30
|
||||||
|
});
|
||||||
|
|
||||||
module.client = redisClient;
|
module.client = redisClient;
|
||||||
module.type = 'redis';
|
module.type = 'redis';
|
||||||
|
|
||||||
|
|||||||
@@ -43,7 +43,6 @@ var user = require('./user'),
|
|||||||
}
|
}
|
||||||
|
|
||||||
if (res) {
|
if (res) {
|
||||||
console.log('logged in', uid);
|
|
||||||
next(null, {
|
next(null, {
|
||||||
user: {
|
user: {
|
||||||
uid: uid
|
uid: uid
|
||||||
|
|||||||
@@ -15,7 +15,6 @@
|
|||||||
passport.use(new passportLocal(function(user, password, next) {
|
passport.use(new passportLocal(function(user, password, next) {
|
||||||
login_module.loginViaLocal(user, password, function(err, login) {
|
login_module.loginViaLocal(user, password, function(err, login) {
|
||||||
if (!err) {
|
if (!err) {
|
||||||
console.log('LOGGED IN');
|
|
||||||
next(null, login.user);
|
next(null, login.user);
|
||||||
} else {
|
} else {
|
||||||
next(null, false, err);
|
next(null, false, err);
|
||||||
|
|||||||
@@ -5,7 +5,6 @@ var path = require('path'),
|
|||||||
express_namespace = require('express-namespace'),
|
express_namespace = require('express-namespace'),
|
||||||
WebServer = express(),
|
WebServer = express(),
|
||||||
server = require('http').createServer(WebServer),
|
server = require('http').createServer(WebServer),
|
||||||
RedisStore = require('connect-redis')(express),
|
|
||||||
nconf = require('nconf'),
|
nconf = require('nconf'),
|
||||||
winston = require('winston'),
|
winston = require('winston'),
|
||||||
validator = require('validator'),
|
validator = require('validator'),
|
||||||
@@ -142,19 +141,8 @@ var path = require('path'),
|
|||||||
app.use(express.cookieParser()); // If you want to parse cookies (res.cookies)
|
app.use(express.cookieParser()); // If you want to parse cookies (res.cookies)
|
||||||
|
|
||||||
// TODO : this uses redis
|
// TODO : this uses redis
|
||||||
/*app.use(express.session({
|
app.use(express.session({
|
||||||
store: new RedisStore({
|
store: db.sessionStore,
|
||||||
client: RDB,
|
|
||||||
ttl: 60 * 60 * 24 * 30
|
|
||||||
}),
|
|
||||||
secret: nconf.get('secret'),
|
|
||||||
key: 'express.sid',
|
|
||||||
cookie: {
|
|
||||||
maxAge: 60 * 60 * 24 * 30 * 1000 // 30 days
|
|
||||||
}
|
|
||||||
}));*/
|
|
||||||
|
|
||||||
app.use(express.cookieSession({
|
|
||||||
secret: nconf.get('secret'),
|
secret: nconf.get('secret'),
|
||||||
key: 'express.sid',
|
key: 'express.sid',
|
||||||
cookie: {
|
cookie: {
|
||||||
|
|||||||
@@ -12,14 +12,6 @@ var cookie = require('cookie'),
|
|||||||
RedisStoreLib = require('connect-redis')(express),
|
RedisStoreLib = require('connect-redis')(express),
|
||||||
db = require('./database'),
|
db = require('./database'),
|
||||||
|
|
||||||
redis = require('redis'),
|
|
||||||
redisClient = redis.createClient(nconf.get('redis:port'), nconf.get('redis:host')),
|
|
||||||
|
|
||||||
RedisStore = new RedisStoreLib({
|
|
||||||
client: redisClient,
|
|
||||||
ttl: 60 * 60 * 24 * 14
|
|
||||||
}),
|
|
||||||
|
|
||||||
user = require('./user'),
|
user = require('./user'),
|
||||||
Groups = require('./groups'),
|
Groups = require('./groups'),
|
||||||
posts = require('./posts'),
|
posts = require('./posts'),
|
||||||
@@ -74,7 +66,7 @@ websockets.init = function(io) {
|
|||||||
// Validate the session, if present
|
// Validate the session, if present
|
||||||
socketCookieParser(hs, {}, function(err) {
|
socketCookieParser(hs, {}, function(err) {
|
||||||
sessionID = socket.handshake.signedCookies["express.sid"];
|
sessionID = socket.handshake.signedCookies["express.sid"];
|
||||||
RedisStore.get(sessionID, function(err, sessionData) {
|
db.sessionStore.get(sessionID, function(err, sessionData) {
|
||||||
if (!err && sessionData && sessionData.passport && sessionData.passport.user) {
|
if (!err && sessionData && sessionData.passport && sessionData.passport.user) {
|
||||||
uid = users[sessionID] = sessionData.passport.user;
|
uid = users[sessionID] = sessionData.passport.user;
|
||||||
} else {
|
} else {
|
||||||
|
|||||||
Reference in New Issue
Block a user