diff --git a/lib/connectors/memory.js b/lib/connectors/memory.js index 91c00263..ed7a581b 100644 --- a/lib/connectors/memory.js +++ b/lib/connectors/memory.js @@ -210,6 +210,13 @@ Memory.prototype.create = function create(model, data, callback) { if(!this.collection(model)) { this.collection(model, {}); } + + if (this.collection(model)[id]) { + return process.nextTick(function() { + callback(new Error('Duplicate entry for ' + model + '.' + idName)); + }); + } + this.collection(model)[id] = serialize(data); this.saveToFile(id, callback); }; diff --git a/test/manipulation.test.js b/test/manipulation.test.js index 77311069..875ccf18 100644 --- a/test/manipulation.test.js +++ b/test/manipulation.test.js @@ -291,6 +291,25 @@ describe('manipulation', function () { }); }); + it('should refuse to create object with duplicate id', function(done) { + // NOTE(bajtos) We cannot reuse Person model here, + // `settings.forceId` aborts the CREATE request at the validation step. + var Product = db.define('Product', { name: String }); + db.automigrate(function(err) { + if (err) return done(err); + + Product.create({ name: 'a-name' }, function(err, p) { + if (err) return done(err); + Product.create({ id: p.id, name: 'duplicate' }, function(err) { + if (!err) { + return done(new Error('Create should have rejected duplicate id.')); + } + err.message.should.match(/duplicate/i); + done(); + }); + }); + }); + }); }); describe('save', function () {