Codeai / backend /models /ChatSession.js
zhlajiex's picture
System Stability Patch: Fix trust proxy, chainable NeDB models, absolute upload paths, and sentinel stack safety
210d827
const { db } = require('../db');
class ChatSession {
static find(query) {
const chain = {
_sort: null,
sort: function(sortQuery) {
this._sort = sortQuery;
return this;
},
then: function(resolve, reject) {
return new Promise((res, rej) => {
let q = db.sessions.find(query);
if (this._sort) q = q.sort(this._sort);
q.exec((err, docs) => {
if (err) rej(err);
else res(docs);
});
}).then(resolve, reject);
},
catch: function(reject) {
return this.then(null, reject);
}
};
return chain;
}
static async findById(id) {
return new Promise((resolve, reject) => {
db.sessions.findOne({ _id: id }, (err, doc) => {
if (err) reject(err);
else resolve(doc);
});
});
}
static async create(sessionData) {
return new Promise((resolve, reject) => {
sessionData.createdAt = sessionData.createdAt || new Date();
sessionData.updatedAt = sessionData.updatedAt || new Date();
db.sessions.insert(sessionData, (err, newDoc) => {
if (err) reject(err);
else resolve(newDoc);
});
});
}
static async deleteMany(query) {
return new Promise((resolve, reject) => {
db.sessions.remove(query, { multi: true }, (err, numRemoved) => {
if (err) reject(err);
else resolve(numRemoved);
});
});
}
}
module.exports = ChatSession;