feat: add unique index support on create for in-memory connetor

lib/connectors/memory.js

@@ -41,6 +41,7 @@ function Memory(m, settings) {
     this.isTransaction = false;
     this.cache = {};
     this.ids = {};
+    this.indexes = {};
     this.constructor.super_.call(this, 'memory', settings);
   }
 }
@@ -255,6 +256,19 @@ Memory.prototype._createSync = function(model, data, fn) {
     this.collection(model, {});
   }
 
+  for (var p in props) {
+    if (props[p].index && props[p].index.unique === true) {
+      for (var instId in this.cache[model]) {
+        var inst = JSON.parse(this.cache[model][instId]);
+        if (inst[p] === data[p]) {
+          var duplicateIndexError = new Error(g.f('Duplicate entry for %s.%s', model, p));
+          duplicateIndexError.statusCode = duplicateIndexError.status = 409;
+          return fn(duplicateIndexError);
+        }
+      }
+    }
+  }
+
   if (this.collection(model)[id]) {
     var error = new Error(g.f('Duplicate entry for %s.%s', model, idName));
     error.statusCode = error.status = 409;

test/memory.test.js

@@ -677,6 +677,24 @@ describe('Memory connector', function() {
     });
   });
 
+  it('should refuse to create object with duplicate unique index', function(done) {
+    var ds = new DataSource({connector: 'memory'});
+    var Product = ds.define('ProductTest', {name: {type: String, index: {unique: true}}}, {forceId: false});
+    ds.automigrate('ProductTest', function(err) {
+      if (err) return done(err);
+
+      Product.create({name: 'a-name'}, function(err, p) {
+        if (err) return done(err);
+        Product.create({name: 'a-name'}, function(err) {
+          should.exist(err);
+          err.message.should.match(/Duplicate/i);
+          err.statusCode.should.equal(409);
+          done();
+        });
+      });
+    });
+  });
+
   describe('automigrate', function() {
     var ds;
     beforeEach(function() {