// ---------------------------------------------------------------------------
-const poolRequestsSchema = mongoose.Schema({
+const requestsSchema = mongoose.Schema({
type: String,
id: String, // Special id to find duplicates (video created we want to remove...)
request: mongoose.Schema.Types.Mixed
})
-const PoolRequestsDB = mongoose.model('poolRequests', poolRequestsSchema)
+const RequestsDB = mongoose.model('requests', requestsSchema)
// ---------------------------------------------------------------------------
-const PoolRequests = {
+const Requests = {
create: create,
findById: findById,
list: list,
}
function create (id, type, request, callback) {
- PoolRequestsDB.create({ id: id, type: type, request: request }, callback)
+ RequestsDB.create({ id: id, type: type, request: request }, callback)
}
function findById (id, callback) {
- PoolRequestsDB.findOne({ id: id }, callback)
+ RequestsDB.findOne({ id: id }, callback)
}
function list (callback) {
- PoolRequestsDB.find({}, { _id: 1, type: 1, request: 1 }, callback)
+ RequestsDB.find({}, { _id: 1, type: 1, request: 1 }, callback)
}
function removeRequestById (id, callback) {
- PoolRequestsDB.remove({ id: id }, callback)
+ RequestsDB.remove({ id: id }, callback)
}
function removeRequests (ids) {
- PoolRequestsDB.remove({ _id: { $in: ids } }, function (err) {
+ RequestsDB.remove({ _id: { $in: ids } }, function (err) {
if (err) {
- logger.error('Cannot remove requests from the pool requests database.', { error: err })
+ logger.error('Cannot remove requests from the requests database.', { error: err })
return // Abort
}
// ---------------------------------------------------------------------------
-module.exports = PoolRequests
+module.exports = Requests