إدارة الجلسات مع Redis

npm install express express-session connect-redis ioredis

const express = require('express');
const session = require('express-session');
const RedisStore = require('connect-redis').default;
const Redis = require('ioredis');

const app = express();
const redisClient = new Redis({
  host: process.env.REDIS_HOST || 'localhost',
  port: process.env.REDIS_PORT || 6379,
  password: process.env.REDIS_PASSWORD
});

// تكوين middleware الجلسة
app.use(session({
  store: new RedisStore({ client: redisClient }),
  secret: process.env.SESSION_SECRET || 'your-secret-key',
  resave: false,
  saveUninitialized: false,
  cookie: {
    secure: process.env.NODE_ENV === 'production', // HTTPS فقط في الإنتاج
    httpOnly: true, // منع XSS
    maxAge: 1000 * 60 * 60 * 24 // 24 ساعة
  }
}));

// نقطة نهاية اختبار
app.get('/', (req, res) => {
  if (req.session.views) {
    req.session.views++;
  } else {
    req.session.views = 1;
  }
  res.json({
    message: 'الجلسة تعمل',
    views: req.session.views,
    sessionID: req.sessionID
  });
});

app.use(session({
  store: new RedisStore({
    client: redisClient,
    prefix: 'sess:', // بادئة المفتاح في Redis
    ttl: 86400 // TTL الجلسة بالثواني (24 ساعة)
  }),
  secret: process.env.SESSION_SECRET,
  name: 'sessionId', // اسم Cookie (افتراضي: connect.sid)
  resave: false, // لا تحفظ الجلسات غير المتغيرة
  saveUninitialized: false, // لا تنشئ جلسات حتى يتم تخزين البيانات
  rolling: true, // إعادة تعيين انتهاء الصلاحية على كل استجابة (جلسات منزلقة)
  cookie: {
    secure: true, // HTTPS فقط
    httpOnly: true, // لا يوجد وصول JavaScript
    sameSite: 'strict', // حماية CSRF
    maxAge: 1000 * 60 * 60 * 24, // 24 ساعة
    domain: '.example.com' // مشاركة عبر النطاقات الفرعية
  }
}));

const bcrypt = require('bcrypt');

// نقطة نهاية تسجيل الدخول
app.post('/login', async (req, res) => {
  const { username, password } = req.body;

  // العثور على المستخدم في قاعدة البيانات
  const user = await db.users.findOne({ username });
  if (!user) {
    return res.status(401).json({ error: 'بيانات اعتماد غير صالحة' });
  }

  // التحقق من كلمة المرور
  const validPassword = await bcrypt.compare(password, user.password);
  if (!validPassword) {
    return res.status(401).json({ error: 'بيانات اعتماد غير صالحة' });
  }

  // تخزين بيانات المستخدم في الجلسة
  req.session.userId = user.id;
  req.session.username = user.username;
  req.session.role = user.role;

  res.json({
    message: 'تسجيل الدخول ناجح',
    user: {
      id: user.id,
      username: user.username,
      role: user.role
    }
  });
});

// نقطة نهاية تسجيل الخروج
app.post('/logout', (req, res) => {
  req.session.destroy((err) => {
    if (err) {
      return res.status(500).json({ error: 'فشل تسجيل الخروج' });
    }
    res.clearCookie('sessionId');
    res.json({ message: 'تسجيل الخروج ناجح' });
  });
});

// middleware المصادقة
function requireAuth(req, res, next) {
  if (!req.session.userId) {
    return res.status(401).json({ error: 'المصادقة مطلوبة' });
  }
  next();
}

// مسار محمي
app.get('/profile', requireAuth, async (req, res) => {
  const user = await db.users.findById(req.session.userId);
  res.json({ user });
});

// 1. إعادة توليد معرف الجلسة بعد تسجيل الدخول (منع تثبيت الجلسة)
app.post('/login', async (req, res) => {
  // ... منطق المصادقة ...

  // إعادة توليد معرف الجلسة
  req.session.regenerate((err) => {
    if (err) {
      return res.status(500).json({ error: 'فشل تسجيل الدخول' });
    }

    // تعيين بيانات الجلسة
    req.session.userId = user.id;
    req.session.username = user.username;

    res.json({ message: 'تسجيل الدخول ناجح' });
  });
});

// 2. تخزين وقت إنشاء الجلسة (كشف اختطاف الجلسة)
app.post('/login', async (req, res) => {
  // ... المصادقة ...

  req.session.userId = user.id;
  req.session.createdAt = Date.now();
  req.session.ipAddress = req.ip;

  res.json({ message: 'تسجيل الدخول ناجح' });
});

// 3. التحقق من الجلسة في كل طلب
function validateSession(req, res, next) {
  if (!req.session.userId) {
    return next();
  }

  // تحقق مما إذا كان عنوان IP قد تغير (اختطاف محتمل)
  if (req.session.ipAddress && req.session.ipAddress !== req.ip) {
    req.session.destroy();
    return res.status(401).json({ error: 'جلسة غير صالحة' });
  }

  // تحقق من عمر الجلسة (إجبار إعادة تسجيل الدخول بعد 7 أيام)
  const maxAge = 1000 * 60 * 60 * 24 * 7; // 7 أيام
  if (Date.now() - req.session.createdAt > maxAge) {
    req.session.destroy();
    return res.status(401).json({ error: 'انتهت صلاحية الجلسة' });
  }

  next();
}

app.use(validateSession);

app.use(session({
  store: new RedisStore({ client: redisClient }),
  secret: process.env.SESSION_SECRET,
  resave: false,
  saveUninitialized: false,
  rolling: true, // إعادة تعيين maxAge على كل طلب
  cookie: {
    maxAge: 1000 * 60 * 30 // 30 دقيقة من عدم النشاط
  }
}));

// أو نفذ منطق انزلاق مخصص
function slidingSession(inactivityMinutes) {
  const maxAge = 1000 * 60 * inactivityMinutes;

  return (req, res, next) => {
    if (!req.session.userId) {
      return next();
    }

    const lastActivity = req.session.lastActivity || Date.now();
    const timeSinceActivity = Date.now() - lastActivity;

    if (timeSinceActivity > maxAge) {
      // انتهت صلاحية الجلسة بسبب عدم النشاط
      req.session.destroy();
      return res.status(401).json({ error: 'انتهت صلاحية الجلسة' });
    }

    // تحديث طابع زمني لآخر نشاط
    req.session.lastActivity = Date.now();
    next();
  };
}

app.use(slidingSession(30)); // مهلة عدم نشاط 30 دقيقة

// الحصول على عدد الجلسات النشطة
async function getActiveSessionCount() {
  const keys = await redisClient.keys('sess:*');
  return keys.length;
}

// الحصول على عدد جلسات المستخدم (كشف تسجيلات دخول متعددة)
async function getUserSessionCount(userId) {
  const keys = await redisClient.keys('sess:*');
  let count = 0;

  for (const key of keys) {
    const sessionData = await redisClient.get(key);
    if (sessionData) {
      const session = JSON.parse(sessionData);
      if (session.userId === userId) {
        count++;
      }
    }
  }

  return count;
}

// تدمير جميع جلسات المستخدم (إجبار تسجيل الخروج)
async function destroyUserSessions(userId) {
  const keys = await redisClient.keys('sess:*');

  for (const key of keys) {
    const sessionData = await redisClient.get(key);
    if (sessionData) {
      const session = JSON.parse(sessionData);
      if (session.userId === userId) {
        await redisClient.del(key);
      }
    }
  }
}

// نقطة نهاية المسؤول لعرض إحصائيات الجلسة
app.get('/admin/sessions', requireAdmin, async (req, res) => {
  const totalSessions = await getActiveSessionCount();
  res.json({ totalSessions });
});

// تنسيق مفتاح الجلسة: sess:<sessionID>
// مثال: sess:abc123def456

// بيانات الجلسة (سلسلة JSON):
{
  "cookie": {
    "originalMaxAge": 86400000,
    "expires": "2025-02-17T12:00:00.000Z",
    "secure": true,
    "httpOnly": true,
    "path": "/"
  },
  "userId": 1001,
  "username": "john_doe",
  "role": "admin",
  "createdAt": 1708171200000,
  "lastActivity": 1708174800000
}

// عرض الجلسة في Redis CLI:
// redis-cli
// KEYS sess:*
// GET sess:abc123def456
// TTL sess:abc123def456