在Express应用中正确销毁MongoDB中的会话

const session = require('express-session');
const MongoStore = require('connect-mongo');
const express = require('express');
const app = express();

// 获取MongoDB连接URL的辅助函数
function getSessionStoreURL() {
    const env = app.get("env");
    if (env === "development") {
        return process.env.DEV_DB; // 开发环境数据库URL
    }
    return process.env.PROD_DB; // 生产环境数据库URL
}

// 初始化MongoStore实例
const mongoStore = MongoStore.create({ mongoUrl: getSessionStoreURL() });

// 配置express-session中间件
app.use(
    session({
        secret: process.env.SESSIONS_SECRET, // 用于签名会话ID的密钥
        resave: false, // 强制将会话保存回会话存储，即使在请求期间会话从未被修改
        saveUninitialized: false, // 强制将未初始化的会话保存到存储中
        cookie: { 
            secure: app.get("env") === "production", // 生产环境下启用安全cookie
            httpOnly: true, // 防止客户端JavaScript访问cookie
            maxAge: 24 * 60 * 60 * 1000 // cookie有效期为24小时
        },
        store: mongoStore // 指定使用connect-mongo作为会话存储
    })
);

// 示例：创建新用户会话
function createNewUserSession(req, userId, moreUserData) {
    try {
        const session = req.session;
        session.userId = userId;
        session.moreUserData = moreUserData;
        session.save(); // 显式保存会话，确保数据写入存储
        // ...其他异步操作
    } catch (e) {
        console.error('Error creating session:', e);
    }
}

// 假设mongoStore是你在配置express-session时创建的MongoStore实例
// 确保这个实例在destroySession函数中是可访问的
// 例如，可以将其作为参数传入，或者在模块级别定义
// const mongoStore = MongoStore.create({ mongoUrl: getSessionStoreURL() }); // 假设已在文件顶部定义

async function destroySession(req) {
    // 在调用req.session.destroy()之前获取会话ID，
    // 因为destroy()可能会清除req.session对象，导致id不可用
    const sessionId = req.session.id; 

    req.session.destroy((err) => {
        if (err) {
            console.error('Error destroying session:', err);
        } else {
            console.log('Session destroyed on server-side.');

            // 确保mongoStore实例在此处是可访问的
            // 如果mongoStore是全局变量或通过闭包捕获，则可以直接使用
            // 否则，可能需要从app.locals或req.app.get('sessionStore')获取
            if (mongoStore) { // 检查mongoStore是否存在
                // 显式调用mongoStore的destroy方法，从MongoDB中删除会话
                mongoStore.destroy(sessionId, (storeErr) => {
                    if (storeErr) {
                        console.error('Error destroying session in store:', storeErr);
                    } else {
                        console.log(`Session ${sessionId} destroyed in MongoDB store.`);
                    }
                });
            } else {
                console.warn('MongoStore instance not found, unable to destroy session in DB.');
            }
        }
    });
}