3 const mongoose = require('mongoose')
5 const logger = require('../helpers/logger')
7 // ---------------------------------------------------------------------------
9 const requestsSchema = mongoose.Schema({
11 id: String, // Special id to find duplicates (video created we want to remove...)
12 request: mongoose.Schema.Types.Mixed
14 const RequestsDB = mongoose.model('requests', requestsSchema)
16 // ---------------------------------------------------------------------------
22 removeRequestById: removeRequestById,
23 removeRequests: removeRequests
26 function create (id, type, request, callback) {
27 RequestsDB.create({ id: id, type: type, request: request }, callback)
30 function findById (id, callback) {
31 RequestsDB.findOne({ id: id }, callback)
34 function list (callback) {
35 RequestsDB.find({}, { _id: 1, type: 1, request: 1 }, callback)
38 function removeRequestById (id, callback) {
39 RequestsDB.remove({ id: id }, callback)
42 function removeRequests (ids) {
43 RequestsDB.remove({ _id: { $in: ids } }, function (err) {
45 logger.error('Cannot remove requests from the requests database.', { error: err })
49 logger.info('Pool requests flushed.')
53 // ---------------------------------------------------------------------------
55 module.exports = Requests