File size: 1,316 Bytes
9df3c32 1dc8372 9df3c32 3ad0250 9df3c32 3ad0250 210d827 3ad0250 9df3c32 3ad0250 1dc8372 9df3c32 3ad0250 |
1 2 3 4 5 6 7 8 9 10 11 12 13 14 15 16 17 18 19 20 21 22 23 24 25 26 27 28 29 30 31 32 33 34 35 36 37 38 39 40 41 42 43 44 45 46 47 48 49 50 51 52 53 |
const { db } = require('../db');
class Message {
static find(query) {
const chain = {
sort: function(sortQuery) {
this._sort = sortQuery;
return this;
},
limit: function(limitNum) {
this._limit = limitNum;
return this;
},
then: function(resolve, reject) {
return new Promise((res, rej) => {
let q = db.messages.find(query);
if (this._sort) q = q.sort(this._sort);
if (this._limit) q = q.limit(this._limit);
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 create(msgData) {
return new Promise((resolve, reject) => {
msgData.createdAt = msgData.createdAt || new Date();
db.messages.insert(msgData, (err, newDoc) => {
if (err) reject(err);
else resolve(newDoc);
});
});
}
static async deleteMany(query) {
return new Promise((resolve, reject) => {
db.messages.remove(query, { multi: true }, (err, numRemoved) => {
if (err) reject(err);
else resolve(numRemoved);
});
});
}
}
module.exports = Message;
|