- function addRequest (id, type, request) {
- logger.debug('Add request to the pool requests.', { id: id, type: type, request: request })
-
- PoolRequestsDB.findOne({ id: id }, function (err, entity) {
- if (err) {
- logger.error('Cannot find one pool request.', { error: err })
- return // Abort
- }
-
- if (entity) {
- if (entity.type === type) {
- logger.error('Cannot insert two same requests.')
- return // Abort
- }
+ function create (id, type, request, callback) {
+ PoolRequestsDB.create({ id: id, type: type, request: request }, callback)
+ }