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
54
55
56
57
58
59
60
61
62
63
64
65
66
67
var async = require('async')
, should = require('should')
module.exports = function(idProperty, getEngine) {
describe('#deleteMany()', function () {
it('should delete the entity if the delete query matches', function (done) {
getEngine(function (error, engine) {
var objectToDelete = { a: 1 }
async.map([ objectToDelete, objectToDelete, { a: 2 }, { b: 1 } ], engine.create, function () {
engine.deleteMany(objectToDelete, function (error) {
should.not.exist(error)
engine.find({}, {}, function (error, objects) {
// Assert items have been deleted
objects.length.should.equal(2)
// Assert items returned arent deleted ones
objects.forEach(function (object) {
object.should.not.equal(objectToDelete)
})
done()
})
})
})
})
})
it('should emit a \'deleteMany\' event', function (done) {
getEngine(function (error, engine) {
engine.create({ a: 1 }, function (error, insertedObject) {
engine.on('deleteMany', function (entity) {
entity.should.eql(insertedObject)
done()
})
engine.deleteMany(insertedObject)
})
})
})
it('should emit a \'afterDeleteMany\' event', function (done) {
getEngine(function (error, engine) {
engine.create({ a: 1 }, function (error, insertedObject) {
engine.on('afterDeleteMany', function (entity) {
entity.should.eql(insertedObject)
done()
})
engine.deleteMany(insertedObject)
})
})
})
it('should not error if there are no objects to delete', function (done) {
getEngine(function (error, engine) {
async.map([ { a: 1 }, { a: 2 }, { a: 3 }, { a: 4 } ], engine.create, function () {
engine.deleteMany({ a: 5 }, function (error) {
should.not.exist(error)
done()
})
})
})
})
})
}