Express与MongoDB会话管理：正确销毁数据库中存储的会话

const express = require('express');
const session = require('express-session');
const MongoStore = require('connect-mongo');
require('dotenv').config(); // 加载环境变量

const app = express();

// 定义会话存储的URL
function getSessionStoreURL() {
    const env = app.get("env");
    if (env === "development") {
        return process.env.DEV_DB; // 开发环境数据库连接字符串
    }
    return process.env.PROD_DB; // 生产环境数据库连接字符串
}

// 初始化MongoStore实例
const sessionStore = MongoStore.create({
    mongoUrl: getSessionStoreURL(),
    collectionName: 'sessions', // 可选，指定存储会话的集合名称
    ttl: 14 * 24 * 60 * 60 // 会话的默认过期时间，单位秒 (14天)
});

// 配置express-session中间件
app.use(
    session({
        secret: process.env.SESSIONS_SECRET, // 必填，用于签名会话ID的密钥
        resave: false, // 强制将会话保存回会话存储，即使在请求期间没有修改。建议设置为false。
        saveUninitialized: false, // 强制将未初始化的会话保存到存储中。建议设置为false。
        cookie: {
            secure: app.get('env') === 'production', // 生产环境下设置为true，只通过HTTPS发送cookie
            httpOnly: true, // 防止客户端脚本访问cookie
            maxAge: 1000 * 60 * 60 * 24 * 7 // cookie的过期时间，单位毫秒 (7天)
        },
        store: sessionStore // 使用MongoStore作为会话存储
    })
);

// 示例：创建新用户会话
function createNewUserSession(req, userId, moreUserData) {
    try {
        const session = req.session;
        session.userId = userId;
        session.moreUserData = moreUserData;
        session.save(); // 显式保存会话更改
        console.log('Session created for userId:', userId);
    } catch (e) {
        console.error('Error creating session:', e);
    }
}

// 在登录路由中调用示例：
// app.post('/login', (req, res) => {
//     // ... 验证用户凭据
//     createNewUserSession(req, user._id, { username: user.username });
//     res.redirect('/dashboard');
// });

// 确保sessionStore实例在需要时可访问
// 例如，可以从包含sessionStore初始化的模块中导出
// const { sessionStore } = require('./sessionConfig'); // 假设sessionStore在一个单独的文件中导出

async function destroyUserSession(req, res) {
    const sessionId = req.session.id; // 获取当前会话的ID

    req.session.destroy((err) => {
        if (err) {
            console.error('Error destroying session on server:', err);
            // 可以根据错误类型发送不同的响应
            return res.status(500).send('Failed to destroy session.');
        } else {
            console.log('Session destroyed on server.');

            // 显式调用sessionStore的destroy方法，从MongoDB中删除会话
            sessionStore.destroy(sessionId, (storeErr) => {
                if (storeErr) {
                    console.error('Error destroying session in store:', storeErr);
                    // 即使存储销毁失败，服务器端会话也已销毁，可选择性处理
                    return res.status(500).send('Session destroyed on server, but failed to remove from database.');
                } else {
                    console.log('Session destroyed in MongoDB store.');
                    res.status(200).send('Session successfully destroyed.');
                }
            });
        }
    });
}

// 在路由中使用示例：
// app.post('/logout', (req, res) => {
//     destroyUserSession(req, res);
// });

// app.post('/change-password', (req, res) => {
//     // ... 处理密码更改逻辑
//     // 密码更改成功后，销毁当前会话以强制用户重新登录
//     destroyUserSession(req, res);
// });